本文主要是介绍某物流公司运输车辆超速实时检测案例(数据源 + Kafka + Flink + Spring MVC + WebSocket + ECharts),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
项目描述
综合运用Flink实时数据处理技术,对Kafka收集到的运输车辆实时监控数据进行分析,运用模式检测及时发现超速车辆,并在服务端通过仪表盘实时告警。
项目架构
项目流程
项目流程说明如下:
- 1. 数据采集:使用Kafka实时收集车速数据(项目中使用数据源程序模拟);
- 2. 超速检测:应用Flink状态API进行模式检测,实时报告超速信息;
- 3. 告警信息实时推送:Spring MVC监控Flink告警信息,并使用WebSocket技术实时推送到Web仪表盘;
- 4. 超速及告警信息实时显示:使用ECharts + WebSocket实时显示超速车辆信息。
适用对象
本项目适合以下人员学习使用:
- 已有Flink基础,需要掌握Flink流处理程序完整开发流程、积累实时大数据处理项目经验;
- 大数据毕业设计项目。
参考来源
这篇关于某物流公司运输车辆超速实时检测案例(数据源 + Kafka + Flink + Spring MVC + WebSocket + ECharts)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!