基于Flink的电影数据实时统计平台(一):项目展示
文章目录
·
一、项目介绍
此项目是一个基于Flink的电影数据实时统计平台。
Github
链接:https://github.com/eurus10/uQiYi- B站视频演示与介绍:https://www.bilibili.com/video/BV1FU4y1h7GX/
项目前后端分离,前端项目为movie-web
,后端项目为movie
:
movie-web
:包含完整的Vue 2
项目,在目录下使用npm run dev
可直接运行movie
:集成了Maven
,Spring Boot
,Flink
,JDBC
,Kafka
等技术的后端。包含三个入口类:MovieApplication.java
:启动Spring Boot
程序,实现如下功能- 前端进行交互
- 从
MySQL
查询数据 - 将数据发送到
Kafka
ServerApplication.java
:Flink
计算程序,用于从Kafka
读取数据进行流计算,并将各项计算结果存储到MySQL
中DataSimulator.java
:评分数据模拟程序,可以完成两种任务:init
:初始化数据库produce
:模拟用户的评分行为,不断地产生大量的评分数据并发送到Kafka
项目的用户接口:
- 前台观影:
- 电影首页:猜你喜欢(推荐系统)、最近热播(流计算)
- 播放电影:播放电影(
HTML video
)、电影评分(Kafka
)
- 数据查询:
- 电影筛选(
JDBC
、MySQL
) - 评分细查(
JDBC
、MySQL
) - 可视化数据(流计算、
JDBC
、MySQL
)
- 电影筛选(
- 用户中心
- 用户信息
由于时间原因,上述用户接口中的推荐系统和用户中心尚未实现,"猜你喜欢"目前使用的是随机伪推荐,用户中心页面则尚未构建。另外,播放电影使用的是HTML
原生的video
标签,性能较差,并且尚未实现后端的连接查询。
二、项目演示
2.1 前端观影/电影首页
原本是个GIF
,结果文件太大传不上来,具体演示还是查看上方的B站视频演示吧,这里只能放几张截图。主要功能是每日推荐以及最近热播的展示,每日推荐涉及推荐系统,由于时间原因尚未完善(课设deadline
要到了。。。),最近热播则是每隔10s
更新一次。
10s
后:
2.2 前端观影/播放电影
此页面包含播放电影和电影评分功能。其中,播放电影由于不是此项目的重点所以做的比较随便,甚至没有连接后端。电影评分功能则需要提供电影ID、用户ID(没有做用户系统,所以无法自动获取)和评分数据。界面如下:
2.3 数据查询/电影筛选
通过电影平均评分和评分次数对电影进行筛选,界面如下:
2.4 数据查询/评分细查
细查每部电影的用户评分记录,界面如下:
2.5 数据查询/可视化数据
提供了流计算多项统计指标结果的实时展示,包括最近10s
内评分次数、历史评分次数变化、评分分布、Top
榜等等。原本也是GIF
,但文件过大无法上传,所以还是只能上截图,视频演示请移步B站。
“信息概览”Tab
:
一段时间后:
“电影数据”Tab
:
一段时间后:
三、相关博客
更多推荐
已为社区贡献1条内容
所有评论(0)