(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210286943.X (22)申请日 2022.03.23 (71)申请人 上海东普信息科技有限公司 地址 201707 上海市青浦区外 青松公路 5045号508室U区4 4号 (72)发明人 孙越峰　杨周龙　李杰　 (74)专利代理 机构 上海汉声知识产权代理有限 公司 3123 6 专利代理师 胡晶 (51)Int.Cl. G06Q 10/08(2012.01) G06Q 30/02(2012.01) G06F 9/54(2006.01) G06F 16/23(2019.01) H04L 67/10(2022.01)H04L 67/51(2022.01) H04L 67/53(2022.01) H04L 67/55(2022.01) (54)发明名称 基于kafka技术的订单数据处理方法、 系统、 设备和存 储介质 (57)摘要 本发明公开基于kafka技术的订单数据处理 方法、 系统、 设备和存储介质， 包括： 预先通过 Kafka集群创建订单服务器作为消息生产方， 并 创造一用于存储直接交互订单记录的第一topi   c标题， 直接处理数据交互的处理服务器为第一 topic标题的消息订阅方； 订单服务器通过kafka 消息队列从当前物流订单数据中抓取设置有直 接交互标识的物流订单信息， 将信息发布至第一 topic标题中； 处理服务器消费发布到第一topi   c标题的物流订单信息， 将物流订单信息进行第 二业务处理后， 找到物流订单匹配的终端， 完成 数据传输。 本发明通过kafka队列抓取出有标记 的物流订单， 处理服务器独立处理第二业务， 信 息推送省去中间环节， 节省处理时间， 提高处理 效率， 安全性高。 权利要求书2页 说明书10页 附图3页 CN 114707926 A 2022.07.05 CN 114707926 A 1.一种基于kafka技 术的订单 数据处理方法， 其特 征在于， 包括： 预先通过Kafka集群创建订单服务器作为消息生产方， 并创造一用于存储直接交互订 单记录的第一topic标题， 直接处理数据交互的处理服务器为所述第一topic标题的消息订 阅方； 所述订单服务器通过kafka消息队列从当前物流订单数据中抓取设置有所述直接交互 标识的物流 订单信息， 将所述信息发布至所述第一topic标题中； 所述处理服务器消费所述发布到所述第一topic标题的物流订单信息， 将所述物流订 单信息进行第二 业务处理后， 找到所述物流 订单匹配的终端， 完成数据传输 。 2.如权利要求1所述的基于kafka技术的订单数据处理方法， 其特征在于， 所述处理服 务器消费所述发布到所述第一topic标题的物流 订单信息进一 步包括： 所述处理服务器预先设置并维护偏移量信息， 所述偏移量信息表明所述第一topic标 题消费到的当前物流 订单信息所在的par tition分区的位置信息； 所述处理服务器在空闲状态下， 通过所述偏移量信息去访问适配的所述partition分 区对应的所述物流订单信息， 并将所述物流订单信息依 次放入预置数据库， 后更新所述偏 移量信息 。 3.如权利要求2所述的基于kafka技术的订单数据处理方法， 其特征在于， 将所述物流 订单信息进行第二 业务处理之前还 包括： 读取所述物流 订单信息， 从所述物流 订单信息中解析 出订单标识信息； 通过所述订单标识获得匹配的订单物流轨迹信 息， 其至少包括所述物流订单的签收信 息。 4.如权利要求3所述的基于kafka技术的订单数据处理方法， 其特征在于， 通过所述订 单标识获得匹配的订单物流轨 迹信息进一 步包括： 预先通过Kafka集群创建物流轨迹服务器作为消息生产方， 并创造一用于存储物流轨 迹记录的第二topic标题， 所述处 理服务器为所述第二topic的消息订阅方； 所述物流轨迹服务器通过kafka消息队列从当前物流轨迹数据中抓取符合预设要求的 物流轨迹信息， 将所述物流轨 迹信息发布至所述第二topic标题中； 所述处理服务器消费所述发布到所述第二topic标题的物流轨迹信息， 将所述物流轨 迹信息保存至所述预置数据库所述 订单标识对应的记录中。 5.如权利 要求3或4所述的基于kafka技术的订单数据处理方法， 其特征在于， 将所述物 流订单信息进行第二 业务处理具体为包括： 所述处理服务器按照预先设置的订单派送计费模型， 计算所述预置数据库中派单计费 数据生成付 款信息； 根据所述 付款信息生成付 款账单， 以使将费用支付至所述物流 订单匹配的终端。 6.如权利要求5所述的基于kafka技术的订单数据处理方法， 其特征在于， 计算所述预 置数据库中派单计费数据进一 步包括： 设置所述预置数据库进一 步设置第一数据库、 第二数据库和派单计费数据库； 所述处理服务器通过所述偏移量信息去访问适配的所述partition分区对应的所述物 流订单信息， 将所述物流订单信息放入在所述第一数据库； 并且， 所述处理服务器消费所述 发布到所述第二topic标题的物流轨迹信息， 将所述物流轨迹信息保存至所述第二数据库权　利　要　求　书 1/2 页 2 CN 114707926 A 2中； 定期或触发式将所述第一数据库和和所述第二数据库的同一订单标识数据更新至所 述派单计费数据库； 从所述派单计费数据库中获得所述订单标识下的快递单接收时间， 计算出所述快递单 的送单时间， 以计算出 所述订单的送单费用信息 。 7.如权利要求1所述的基于kafka技术的订单数据处理方法， 其特征在于， 找到所述物 流订单匹配的终端完成数据传输进一 步包括： 找到所述物流 订单匹配的终端； 利用所述处理服务器启动在主线程回调,开启swoole_websocket_server服务， 将所述 第二业务处理后的数据采用sw oole+Redis实现实时数据推送， 其具体为： 预先创建了mana ger进程和创建了w orker进程； 监听定时器； 当监听到所述第二业务处理后的数据被计算后， 所述worker进程使用swoole_server_ task函数投递发送至对应的终端的Task； 当前的Task进程在调用onTask回调函数时会将进程状态切换为忙碌， 这时将不再接收 新的Task， 当o nTask函数返回 时会将进程状态切换为空 闲然后继续接收新的Task； 当所述worker进程投递的任务完成时， 所述task进程会通过$ws ‑>finish()方法将任 务处理的结果 发送给所述worker进程， 以此基于异 步事件驱动和协 程的并行网络通信来完 成所述第二 业务处理后的数据及时传送至对应的终端。 8.一种基于kafka技 术的订单 数据处理系统， 其特 征在于， 包括： Kafka集群： 用于创建订单服务器作为消息生产方， 并创造一用于存储直接交互订单记 录的第一topic标题， 直接处理数据交互的处理服务器为所述第一topic标题的消息订阅 方； 订单服务器： 用于通过kafka消息队列从当前物流订单数据中抓取设置有所述直接交 互标识的物流 订单信息， 将所述信息发布至所述第一topic标题中； 处理服务器： 用于消费所述发布到所述第一topic标题的物流订单信息， 将所述物流订 单信息进行第二 业务处理后， 找到所述物流 订单匹配的终端完成数据传输 。 9.一种基于kafka技 术的订单 数据处理设备， 其特 征在于， Kafka集群交互单元： 用于预先通过Kafka集群创建订单服务器作为消息生产方， 并创 造一用于存储直接交互订单记录的第一topic标题， 直接处理数据交互的处理服务器为所 述第一topic标题的消息订阅方； 发布单元： 用于通过kafka消息队列从当前物流订单数据中抓取设置有所述直接交互 标识的物流 订单信息， 将所述信息发布至所述第一topic标题中； 第二业务处理单元： 用于消费所述发布到所述第一topic标题的物流订单信息， 将所述 物流订单信息进行第二 业务处理后， 找到所述物流 订单匹配的终端完成数据传输 。 10.一种计算机可读存储介质， 所述计算机可读存储介质上存储有计算机程序， 其特征 在于， 所述计算机程序被处理器执行时实现如权利要求 1‑7中任意一项所述的基于kafka技 术的订单 数据处理方法。权　利　要　求　书 2/2 页 3 CN 114707926 A 3