(标签-Kafka|关键词-管理软件)

Question

实时监控交通卡口拥堵情况
为交通管理部门开发《智慧交通》交通管理软件；其中的一个重要组成部分就是能够实时的查看每个交通卡口的车流通行情况，从而为交管部门判定交通拥堵提供依据。
‌数据文件‌：
通过MockRealTimeData模块实时产生卡口摄像头抓拍数据，并将数据传输给 Kafka 集群。数据格式如下：
2025-04-28 0003 47045 赣C63307 2025-04-28 12:26:23 44 8 01
2025-04-28 0002 88521 赣C63307 2025-04-28 12:57:06 252 1 06
2025-04-28 0008 36183 赣C63307 2025-04-28 12:32:42 189 22 02
‌任务‌：
‌1.搭建 Kafka 集群‌
搭建 Kafka 集群；
创建 topic；测试是否能接收到模拟数据，并正确消费。
‌2.搭建 Spark streaming 编程框架‌‌
获取车辆信息；
将监控信息变为（speed，1）key-value 对；
每间隔 5 秒，计算近 5 分钟内，通过卡口的车辆速度和总车辆数；
计算卡口平均速度；
依据卡口平均速度对卡口进行由大到小排序，并打印结果。‌
3.材料提交
（1）独立完成的项目源码
（2）项目环境及文件结构截图(包括开发工具中的项目文件结构截图)

Answer 1

阿里嘎多学长整理AIGC生成，因移动端显示问题导致当前答案未能完全显示，请使用PC端查看更加详细的解答过程

问题解答

你想开发一个交通管理软件《智慧交通》，其中需要实时监控交通卡口拥堵情况。为了实现这个功能，你需要设计一个系统来实时收集和存储交通卡口的车流通行情况数据。

考虑到数据量的庞大和实时性要求，你可能会选择使用大数据技术 stack，例如 Hadoop 和 HBase。Hadoop 可以处理大量数据的存储和处理，HBase 可以提供实时的数据存储和查询能力。

在 Java 中，你可以使用 Kafka 作为数据 ingestion 和处理的中间件。Kafka 可以实时地收集和处理数据，然后将其存储到 HBase 中。

下面是一个简单的示例代码，演示如何使用 Kafka 和 HBase 实现实时数据 ingestion 和存储：

// 创建 Kafka  producer
KafkaProducer<String, String> producer = new KafkaProducer<>(props);

// 创建 HBase  table
HBaseTable table = new HBaseTable("traffic_data", "traffic_data");

// 发送数据到 Kafka
producer.send("traffic_data", "key", "value");

// 从 Kafka 中消费数据
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("traffic_data"));
consumer.poll().forEach(record -> {
    // 处理数据
    String value = record.value();
    // 将数据存储到 HBase 中
    table.put(new Put(record.key(), "data", value));
});

这个示例代码只是一个简单的示例，实际实现中你可能需要考虑更多的因素，例如数据的可靠性、数据的实时性、数据的存储和查询能力等。

希望这个示例代码能够帮助你开始你的项目！