(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111506207.2 (22)申请日 2021.12.10 (71)申请人 广东联合电子服 务股份有限公司 地址 510000 广东省广州市天河区体 育西 路189号15楼 (72)发明人 汤成　冯炳辉　王文涛　 (74)专利代理 机构 广州市越秀区哲力专利商标 事务所(普通 合伙) 44288 代理人 陶洁雯 (51)Int.Cl. H04L 67/025(2022.01) H04L 67/06(2022.01) H04L 67/12(2022.01) H04L 67/565(2022.01) H04L 67/568(2022.01)H04L 69/04(2022.01) G06F 9/54(2006.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) G08G 1/01(2006.01) H04L 9/40(2022.01) (54)发明名称 海量交通数据处 理系统和方法 (57)摘要 本申请公开了一种海量交通数据处理系统 和方法， 涉及交通数据处理技术， 系统包括： 数据 接收子系统， 用于获取路段数据， 并对路段数据 进行鉴权和校对， 以及将路段数据进行拆分， 将 分拆后得到的数据包缓存到对应的消息队列之 中， 并响应上传数据的客户端； 所述消息队列有 多个， 一个消息队列用于存放一类数据包； 数据 处理及分发子系统， 用于各所述消息列队中读取 数据包， 并将读取的数据包进行打包后分发到各 业务系统。 本实施例可以增加系统灵活性， 增加 响应速度。 权利要求书1页 说明书5页 附图1页 CN 114422496 A 2022.04.29 CN 114422496 A 1.一种海量交通数据处 理系统， 其特 征在于， 包括： 数据接收子系统， 用于获取路段数据， 并对路段数据进行鉴权和校对， 以及将路段数据 进行拆分， 将分拆后得到的数据包缓存到对应的消息队列之中， 并响应上传数据的客户端； 所述消息队列有 多个， 一个消息队列用于存放 一类数据包； 数据处理及分发子系统， 用于各所述消息列队中读取数据包， 并将读取的数据包进行 打包后分发到各业 务系统。 2.根据权利要求1所述的一种 海量交通数据处理系统， 其特征在于， 所述数据处理及分 发子系统中包括多个中间件 模块； 每个中间件模块从若干个所述消息列队中获取数据包， 并将 获取的数据包进行预设处 理和打包后发送到对应的业 务系统。 3.根据权利要求2所述的一种 海量交通数据处理系统， 其特征在于， 所述数据处理及分 发子系统中的线程按照预设周期进行动态分配。 4.根据权利要求3所述的一种 海量交通数据处理系统， 其特征在于， 所述数据处理及分 发子系统中的线程按照当前各所述中间件模块的待处理数据量进行分配； 其中， 待处理数 据量较多的中间件模块所分配到的线程相对于待处理数据量较少的中间件模块所分配到 的线程多。 5.根据权利 要求2所述的一种海量交通数据处理系统， 其特征在于， 还包括redis缓存， 所述redis缓存中配置有各消息队列需要分发到的业 务系统； 所述数据处理及分发子系统从消息列队中拉取数据接收子系统推送的数据包， 从 redis缓存中读取各消息队列需要分发到的业务系统， 从而将各消息列队的数据包送入对 应的中间件 模块。 6.根据权利要求1所述的一种海量交通数据处理系统， 其特征在于， 还包括数据库， 所 述数据库用于存 储数据接收子系统经 过鉴权和校对后的数据包。 7.根据权利要求1所述的一种 海量交通数据处理系统， 其特征在于， 所述消息列队采用 kafka队列。 8.根据权利要求1所述的一种海量交通数据处理系统， 其特征在于， 所述获取路段数 据， 并对路段 数据进行鉴权和校对， 具体包括： 接收收费站的HT TPS请求， 对请求进行鉴权； 鉴权通过后， 对压缩文件进行解压得到jso n文件； 根据数据类型对jso n文件进行解析入库 与校验。 9.根据权利要求2所述的一种 海量交通数据处理系统， 其特征在于， 各所述中间件模块 根据从redis缓存中读取的配置信息确定向业 务系统推送的数据包格式。 10.一种海量交通数据处 理方法， 其特 征在于， 包括以下步骤： 获取路段 数据， 并对路段 数据进行鉴权和校对； 将路段数据进行拆分， 将分拆后得到的数据包缓存到对应的消息队列之中， 所述消息 队列有多个， 一个消息队列用于存放 一类数据包； 响应上传数据的客户端； 从各所述消息列队中读取 数据包， 并将 读取的数据包进行打包后分发到各业 务系统。权　利　要　求　书 1/1 页 2 CN 114422496 A 2海量交通数据处理系统和方 法 技术领域 [0001]本申请涉及交通数据处 理技术， 特别是一种海量交通数据处 理系统和方法。 背景技术 [0002]交通道路的管控系统为了实现计费和交通管控等功能， 需要分析海量的道路数 据。 现有的系统中， 为了确保数据幂等性， 通常是由业务系统对数据进行处理， 并将数据已 经处理的消息反馈 至收费站系统(路段系统)。 [0003]但是这一方式需要业务端对数据进行实际处理后才将处理完毕的信息返回收费 站系统， 会导 致收费站系统接收反馈的时间较长， 导 致影响收费站系统对本地数据的处 理。 发明内容 [0004]本发明旨在至少解决现有技术中存在的技术问题之一。 为此， 本发明提出一种海 量交通数据处 理系统和方法， 以提高对收费站系统响应的及时性。 [0005]一方面， 本实施例公开了一种海量交通数据处 理系统， 包括： [0006]数据接收子系统， 用于获取路段数据， 并对路段数据进行鉴权和校对， 以及将路段 数据进行拆分， 将分拆后得到的数据包缓存到对应的消息队列之中， 并响应上传数据的客 户端； 所述消息队列有 多个， 一个消息队列用于存放 一类数据包； [0007]数据处理及分发子系统， 用于各所述消息列队中读取数据包， 并将读取的数据包 进行打包后分发到各业 务系统。 [0008]在一些实施例中， 所述数据处 理及分发子系统中包括多个中间件 模块； [0009]每个中间件模块从若干个所述消息列队中获取数据包， 并将获取的数据包进行预 设处理和打包后发送到对应的业 务系统。 [0010]在一些实施例中， 所述数据处理及分发子系统中的线程按照预设周期进行动 态分 配。 [0011]在一些实施例中， 所述数据处理及分发子系统中的线程按照当前各所述中间件模 块的待处理数据量进行分配； 其中， 待处理数据量较多的中间件模块所分配到的线程相对 于待处理数据量较少的中间件 模块所分配到的线程多。 [0012]在一些实施例中， 还包括redis缓存， 所述redis缓存中配置有各消息队列需要分 发到的业 务系统； [0013]所述数据处理及分发子系统从消息列队中拉取数据 接收子系统推送的数据包， 从 redis缓存中读取各消息队列需要分发到的业务系统， 从而将各消息列队的数据包送入对 应的中间件 模块。 [0014]在一些实施例中， 还包括数据库， 所述数据库用于存储数据接收子系统经过鉴权 和校对后的数据包。 [0015]在一些实施例中， 所述消息列队采用kafka队列。 [0016]在一些实施例中， 所述获取路段 数据， 并对路段 数据进行鉴权和校对， 具体包括：说　明　书 1/5 页 3 CN 114422496 A 3