买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉公安部交通管理科学研究所申请的专利一种基于Spark Streaming的快速实时预警方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115168659B 。

龙图腾网通过国家知识产权局官网在2025-10-21发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210845900.0，技术领域涉及：G06F16/901；该发明授权一种基于Spark Streaming的快速实时预警方法是由蔡岗;赵磊;黄淑兵;魏亚宽;孔晨晨;张森;施一珑设计研发完成，并于2022-07-19向国家知识产权局提交的专利申请。

本一种基于Spark Streaming的快速实时预警方法在说明书摘要公布了：本发明提供的一种基于SparkStreaming的快速实时预警方法，将待处理车辆轨迹数据按照车牌号码分别存储到不同的存储分区中，将所有实时监测事件分别建立一个实时比对线程thread，每次将待处理车辆轨迹数据同时送入到所有的实时比对线程thread中并行计算；同时，因为待处理车辆轨迹数据是按照车牌号码存储的，每次计算时，车缓存队列消费线程将数据送入存储分区对应的过车数据缓存队列中，在每个实时比对线程thread中，因为是按照需要比对的待处理车辆轨迹数据对应的车牌范围从基础数据库和嫌疑车辆黑名单中提取对应车牌号码范围的数据，所以数据对比查找的命中率会提高，极大的提高了系统的计算效率，同时每个thread中每次需要计算的数据量有限，进一步的提高了计算速度。

本发明授权一种基于Spark Streaming的快速实时预警方法在权利要求书中公布了：1.一种基于SparkStreaming的快速实时预警方法，其特征在于，其包括以下步骤： S1：确定需要实时处理的车辆轨迹数据，记作待处理车辆轨迹数据； S2：在Kafka系统中，为所述待处理车辆轨迹数据建立一个过车topic， 将所述待处理车辆轨迹数据按照车牌号码分别存储到所述过车topic的不同存储分区中； S3：基于SparkStreaming分布式流式处理框架将预警比对处理程序分配到各个工作节点，单个工作节点启动执行器executor来运行所述预警比对处理程序； 所述工作节点和所述执行器executor的关系为1:n，n为大于等于1的正整数； S4：所述预警比对处理程序确定进行实时计算的所有实时监测事件，以及每个所述实时监测事件中使用到的所有基础数据库数据和嫌疑车辆黑名单数据； 所述基础数据库为在所述实时监测事件中需要比对车辆信息时用到的基础车辆信息所在的数据库； 所述嫌疑车辆黑名单中记载了在所述实时监测事件中需要找到并进行预警的嫌疑车辆； S5：每个所述预警比对处理程序中包括所有并行处理的所述实时监测事件； 每个所述实时监测事件分别对应一个预警规则和一个实时比对线程thread； 每个所述实时监测事件对应一个预警缓存队列作为数据输出，所述实时比对线程thread找到符合条件的所述待处理车辆轨迹数据后，推送到所述预警缓存队列中； S6：构建过车缓存队列消费线程和预警缓存队列消费线程； S7：每个所述预警比对处理程序启动后，并获取本次计算的所述实时计算车辆数据对应的车牌号码范围，记作：车牌提取范围； 按照所述车牌提取范围，在所述基础数据库和所述嫌疑车辆黑名单中提取对应车牌号码范围的数据，分别记作：比对基础数据、比对黑名单数据； S8：所述预警比对处理程序按照预设的数据提取量，从所述过车topic中获取参与本次计算的数据，记作：实时计算车辆数据；将所述实时计算车辆数据封装成离散数据流DStream结构，传递给所述预警比对处理程序中所有的所述实时比对线程thread中进行比对计算； 所述实时比对线程thread按照所述监测事件对应的所述预警规则，将输入的所述待处理车辆数据与所述比对基础数据和所述比对黑名单数据进行碰撞比对，找到符合预警条件的待处理车辆数据推送到预警缓存队列； S9：所述预警缓存队列消费线程从所述预警缓存队列中读取数据发布预警信息。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人公安部交通管理科学研究所，其通讯地址为：214151 江苏省无锡市滨湖区钱荣路88号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。