(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111656898.4 (22)申请日 2021.12.3 0 (71)申请人 中国电信股份有限公司 地址 100033 北京市西城区金融街31号 (72)发明人 黄梓鹏　段俊　叶亿　罗思扬　 黄佳祺　刘泳安　邵壮丰　曾绍汉　 邱贤奕　 (74)专利代理 机构 北京同达信恒知识产权代理 有限公司 1 1291 代理人 郭润湘 (51)Int.Cl. H04L 9/40(2022.01) H04L 45/50(2022.01) (54)发明名称 一种基于ZeroMQ的数据包传输方法、 装置及 设备 (57)摘要 本发明实施例提供了一种基于ZeroMQ的数 据包传输方法、 装置及设备， 基于ZeroMQ， 通过抓 包模块将其采集到的数据包的头部封装队列标 签， 并发送至通道 接收模块； 基于ZeroMQ， 通过通 道接收模块对接收到的数据包进行解封装， 得到 每个数据包的队列标签； 通过通道接收模块根据 每个数据包的队列标签对数据完整性进行校验。 由于抓包模块和通道接收模块都是基于ZeroMQ 实现数据传输的， 从而通道接收模块可以根据传 输的每个数据包的队列标签的数据完整性进行 校验， 因此可以提高数据传输的可靠性。 权利要求书2页 说明书8页 附图2页 CN 114401127 A 2022.04.26 CN 114401127 A 1.一种基于ZeroMQ的数据包传输方法， 其特 征在于， 应用于服 务器， 该方法包括： 基于ZeroMQ， 通过抓包模块将其采集到的数据包的头部封装队列标签， 并发送至通道 接收模块； 基于ZeroMQ， 通过所述通道接收模块对接收到的数据包进行解封装， 得到每个数据包 的队列标签； 通过所述通道接收模块 根据每个数据包的队列标签对数据完整性进行 校验。 2.如权利要求1所述的方法， 其特征在于， 所述通过所述通道接收模块根据每个数据包 的队列标签对数据完整性进行 校验， 包括： 若多个数据包的队列标签符合预设顺序， 则通过所述通道接收模块确定数据完整， 否 则确定数据不完整。 3.如权利要求2所述的方法， 其特 征在于， 若确定数据不完整， 则： 通过所述通道接收模块 等待接收所述 抓包模块发送的封装后的数据包。 4.如权利要求1所述的方法， 其特 征在于， 该 方法还包括： 针对所述通道接收模块中的每个消息队列， 确定所述消息队列中存储的数据包的数量 大于等于预设值， 通过所述通道接 收模块向所述抓包模块发送控制指令， 以控制所述抓包 模块停止发送数据包。 5.如权利要求1所述的方法， 其特征在于， 所述基于ZeroMQ， 通过抓包模块将其采集到 的数据包的头 部封装队列标签， 并发送至通道接收模块之后， 还 包括： 通过所述抓包模块为采集到的数据包注入时间戳。 6.如权利要求1所述的方法， 其特 征在于， 该 方法还包括： 根据多协议标签交换技术， 通过所述通道接收模块将接收到的具有相同转发处理方式 的数据包设置业 务标签， 并将设置有相同的业 务标签的数据包发送至终端。 7.一种基于ZeroMQ的数据包传输装置， 其特征在于， 应用于服务器， 包括抓包模块和通 道接收模块； 所述抓包模块， 用于基于ZeroMQ， 将其采集到的数据包的头部封装队列标签， 并发送至 通道接收模块； 所述通道接收模块， 用于基于ZeroMQ， 对接收到的数据包进行解封装， 得到每个数据包 的队列标签； 根据每 个数据包的队列标签对数据完整性进行 校验。 8.如权利要求7 所述的装置， 其特 征在于， 所述 通道接收模块具体用于： 若多个数据包的队列标签符合预设顺序， 则确定数据完整， 否则确定数据不完整。 9.如权利要求8所述的装置， 其特征在于， 若确定数据不完整， 则： 所述通道接收模块具 体用于： 等待接收所述 抓包模块发送的封装后的数据包。 10.如权利要求7 所述的装置， 其特 征在于， 所述 通道接收模块还用于： 针对所述通道接收模块中的每个消息队列， 确定所述消息队列中存储的数据包的数量 大于等于预设值， 向所述 抓包模块发送控制指令， 以控制所述 抓包模块停止发送数据包。 11.如权利 要求7所述的装置， 其特征在于， 所述抓包模块基于ZeroMQ， 将其采集到的数 据包的头 部封装队列标签， 并发送至通道接收模块之后， 还用于： 为采集到的数据包注入时间戳。权　利　要　求　书 1/2 页 2 CN 114401127 A 212.如权利要求7 所述的装置， 其特 征在于， 所述 通道接收模块还用于： 根据多协议标签交换技术， 将接收到的具有相同转发处理方式的数据包设置业务标 签， 并将设置有相同的业 务标签的数据包发送至终端。 13.一种基于ZeroMQ的数据包传输设备， 其特征在于， 包括至少一个处理器； 以及与所 述至少一个处理器通信连接的存储器； 其中， 所述存储器存储有可被所述至少一个处理器 执行的指令， 所述指令被所述至少一个处理器执行， 以使所述至少一个处理器能够执行权 利要求1‑6中任何一项所述的方法。 14.一种计算机存储介质， 其特征在于， 所述计算机存储介质存储有计算机程序， 所述 计算机程序用于使计算机执 行权利要求1 ‑6任何一项所述的方法。 15.一种计算机程序产品， 包括计算机程序， 其特征在于， 所述计算机程序被处理器执 行时实现权利要求1 ‑6中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114401127 A 3