(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210757324.4 (22)申请日 2022.06.30 (71)申请人 国汽大有时空科技 （安庆） 有限公司 地址 246001 安徽省安庆市经开区胜利路 国汽智慧产业园 申请人 国汽 （北京） 智能网联汽车研究院有 限公司 (72)发明人 张俊伟　李大臣　褚文博　钟薇　 陈雪　 (74)专利代理 机构 南京苏高专利商标事务所 (普通合伙) 32204 专利代理师 冯艳芬 (51)Int.Cl. G06F 16/25(2019.01) G06F 9/54(2006.01)H04L 67/10(2022.01) H04L 67/12(2022.01) (54)发明名称 车辆多源异构数据的接入和处理方法、 模块 及系统 (57)摘要 本发明公开了一种车辆多源异构数据的接 入和处理方法、 模块及系统。 本发明的接入方法 包括： 当有车端、 路侧端或第三方平台发送数据 接入请求时， 判断数据接入请求所采用的协议； 调用所采用的协议对应的协议处理器读取当前 协议数据； 将接收的协议数据进行反序列化； 将 反序列化的消息投递到disruptor消息队列； 批 量将disuptor队列中的数据放入kafka集群的 kafka消息队列， 实现数据接入。 本发明可以以实 现多源异构数据的接入和处理， 满足各类汽车、 交通基础数据的融汇管理。 权利要求书2页 说明书7页 附图3页 CN 115237987 A 2022.10.25 CN 115237987 A 1.一种车辆多源异构数据接入方法， 其特 征在于该 方法包括： 当有车端、 路侧端或第三方平台发送数据接入请求时， 判断数据接入请求所采用的协 议； 调用所采用的协议对应的协议处 理器读取当前协议数据； 将接收的协议数据进行反序列化； 将反序列化的消息投递到disruptor消息队列； 批量将disuptor队列中的数据放入kafka集群的kafka消息队列， 实现数据接入。 2.根据权利 要求1所述的车辆多源异构数据接入方法， 其特征在于： 通过开放的socket 接口实现数据接入请求的监听。 3.根据权利要求1所述的车辆多源异构数据接入方法， 其特征在于： 所述将接收的协议 数据进行反序列化， 具体包括： 读取接收的协议数据的数据体， 通过解析 得到数据体的数据格式、 数据主题； 将解析得到的数据格式、 数据主题和数据体合并， 重新封装成一个消息， 实现反序列 化。 4.根据权利要求1所述的车辆多源异构数据接入方法， 其特征在于： 该方法还包括： 若 由kafka集群向disruptor消息队列返回了消息， 则将disruptor消息队列的消息序列化后， 通过对应的协议处 理器向数据接入请求方返回数据。 5.根据权利要求4所述的车辆多源异构数据接入方法， 其特征在于： 所述将disruptor 消息队列的消息序列化， 具体包括： 解析disruptor消息队列的消息， 得到消息中包 含的数据格式、 数据主题和数据体； 将数据体按照对应协议形成协议数据。 6.一种车辆多源异构数据处理方法， 其特征在于， 该方法对于按照权1 ‑5中任意一项方 法接入的数据进行 数据处理， 该方法具体包括： 接收kafka集群的kafka消息队列发送的消息； 解析接收到的消息， 得到消息中包 含的数据体以及数据体的数据格式、 数据主题； 根据解析得到的数据格式， 调用对应的数据格式解析器对数据体进行解析， 得到统一 格式的数据内容； 将数据内容按照对应数据主题的字段转换配置对应关系， 重新封装成统一预设数据 结 构的数据； 将统一预设数据结构的数据投递到disruptor消息队列。 7.一种车辆多源异构数据接入 模块， 其特 征在于包括： 协议判断单元， 用于当有车端、 路侧端或第三方平台发送数据接入请求 时， 判断数据接 入请求所采用的协议； 协议数据读取 单元， 用于调用所采用的协议对应的协议处 理器读取当前协议数据； 反序列化单 元， 用于将接收的协议数据进行反序列化； disruptor消息队列， 用于暂存反序列化的消息； 批量队列消息投递单元， 用于批量将disuptor队列中的数据放入k afka集群的kafk a消 息队列； 以及kafka集群。权　利　要　求　书 1/2 页 2 CN 115237987 A 28.根据权利要求7 所述的车辆多源异构数据接入 模块， 其特 征在于还 包括： 序列化单元， 用于在kafka集群向disruptor消息队列返 回了消息时， 将disruptor消息 队列的消息序列化， 使得序列化后的通过对应的协议处 理器向数据接入请求方返回数据。 9.一种车辆多源异构数据处 理模块， 其特 征在于包括： 数据解析单元， 用于解析接收到的消息， 得到消息中包含的数据体以及数据体的数据 格式、 数据主题； 数据格式解析单元， 用于根据解析得到的数据格式， 调用对应的数据格式解析器对数 据体进行解析， 得到统一格式的数据内容； 数据封装单元， 用于将数据内容按照对应数据主题的字段转换配置对应关系， 重新封 装成统一预设数据结构的数据； disruptor消息队列， 用于暂存统一预设数据结构的数据。 10.一种车辆多源异构数据的中心云处 理系统， 其特 征在于包括： 如权利要求7或8所述的车辆多源异构数据接入 模块； 如权利要求9所述的车辆多源异构数据处 理模块； 以及 数据存储模块， 包括存储实时数据的memcache和redis数据库， 和存储历史数据的 ClickHouse 数据库。权　利　要　求　书 2/2 页 3 CN 115237987 A 3