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

龙图腾网获悉上海中通吉网络技术有限公司申请的专利一种实现低延迟的数据处理方法、装置和设备获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116501769B 。

龙图腾网通过国家知识产权局官网在2026-02-10发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310530970.1，技术领域涉及：G06F16/2455；该发明授权一种实现低延迟的数据处理方法、装置和设备是由王永春设计研发完成，并于2023-05-11向国家知识产权局提交的专利申请。

本一种实现低延迟的数据处理方法、装置和设备在说明书摘要公布了：本发明涉及一种实现低延迟的数据处理方法、装置和设备，属于数据处理技术领域。本发明通过获取运单消息，运单消息包括运单号、运单路由段和运单扫描日期；将多个运单消息进行数据聚合，并给运单消息标记消息类型和版本，得到标记运单消息，将标记运单消息发送至Kafka消息队列；对标记运单消息进行数据分组计算，生成对应的汇总结果数据，并对汇总结果数据注册一个对应的定时器；当所述定时器触发，将汇总结果数据发送至任务下游算子进行存储。通过对运单消息进行消息类型和版本标记，进行分组计算并设定定时器，对数据进行实时计算，从而解决现有的物流业务数据中存在着通过被动的数据查询无法满足对数据计算的实时性要求的问题。

本发明授权一种实现低延迟的数据处理方法、装置和设备在权利要求书中公布了：1.一种实现低延迟的数据处理方法，其特征在于，包括： 获取运单消息；其中，所述运单消息包括运单号、运单路由段和运单扫描日期； 将多个所述运单消息进行数据聚合，并给所述运单消息标记消息类型和版本，得到标记运单消息，将所述标记运单消息发送至Kafka消息队列；其中，给所述运单消息标记消息类型和版本，得到标记运单消息，包括： 若第N次接收运单消息，将此运单消息的消息类型设置为CALCULATE，版本设置为N，则确定当前运单消息为第N计算标记运单消息；以及 将所述第N计算标记运单消息的消息类型设置为ROLLBACK，得到第N回滚标记运单消息，并将所述第N回滚标记运单消息进行存储； 若第N+1次接收运单消息，将所述第N回滚标记运单消息发送到所述Kafka消息队列，通过与第N+1次接收的运单消息进行计算，得到第N+1计算标记运单消息，且将所述第N+1计算标记运单消息的消息类型设置为CALCULATE，版本设置为N+1；以及 将所述所述第N+1计算标记运单消息的消息类型设置为ROLLBACK，得到第N+1回滚标记运单消息，并将所述第N+1回滚标记运单消息进行存储； 其中，所述标记运单消息包括运单号、运单路由段、运单扫描日期、消息类型和版本；所述第N计算标记运单消息与所述第N回滚标记运单消息的消息类型不同，且其他数据内容完全相同；所述第N计算标记运单消息与所述第N+1计算标记运单消息的运单号相同，且所述第N计算标记运单消息的运单路由段ID为N，所述第N+1计算标记运单消息的运单路由段ID为N+1； 对所述Kafka消息队列中的所述标记运单消息进行数据分组计算，生成对应的汇总结果数据，并对所述汇总结果数据注册一个对应的定时器； 当所述定时器触发，将所述汇总结果数据发送至任务下游算子进行存储。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人上海中通吉网络技术有限公司，其通讯地址为：201799 上海市青浦区华志路1685号5幢；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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