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

龙图腾网恭喜平安科技(深圳)有限公司申请的专利基于分布式系统的数据处理方法、装置、设备及存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115470205B 。

龙图腾网通过国家知识产权局官网在2025-06-24发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211161771.X，技术领域涉及：G06F16/215；该发明授权基于分布式系统的数据处理方法、装置、设备及存储介质是由易晓博设计研发完成，并于2022-09-23向国家知识产权局提交的专利申请。

本基于分布式系统的数据处理方法、装置、设备及存储介质在说明书摘要公布了：本发明涉及计算机技术领域，公开了一种基于分布式系统的数据处理方法、装置、设备及存储介质。该方法包括：接收生产模块中各第一分布式节点发送的预提交消息数据并将预提交消息数据缓存至中间模块中；获取各第一分布式节点的预设事务ID并实时接收与各预设事务ID对应的第一分布式节点所发送的预设标识；当成功接收到所有预设事务ID对应的第一分布式节点所发送的预设标识时，将预提交消息数据转化为目标消息数据以供消费模块消费，并读取各第一分布式节点的数据偏移量状态，将各第一分布式节点的所述数据偏移量状态存储到状态缓存模块中。通过上述方式，本发明能够实现端到端的数据一致性，提高数据准确性和处理效率。

本发明授权基于分布式系统的数据处理方法、装置、设备及存储介质在权利要求书中公布了：1.一种基于分布式系统的数据处理方法，其特征在于，所述分布式系统包括生产模块、与所述生产模块连接的中间模块、与所述中间模块连接的消费模块以及分别与所述生产模块、所述消费模块连接的状态缓存模块，所述数据处理方法包括： 接收所述生产模块中各第一分布式节点发送的预提交消息数据并将所述预提交消息数据缓存至所述中间模块中； 获取各所述第一分布式节点的预设事务ID并实时接收与各所述预设事务ID对应的第一分布式节点所发送的预设标识； 当成功接收到所有所述预设事务ID对应的第一分布式节点所发送的预设标识时，将所述预提交消息数据转化为目标消息数据以供所述消费模块消费，并读取各所述第一分布式节点的数据偏移量状态，将各所述第一分布式节点的所述数据偏移量状态存储到所述状态缓存模块中； 所述获取各所述第一分布式节点的预设事务ID并实时接收与各所述预设事务ID对应的第一分布式节点所发送的预设标识之后，还包括： 当未成功接收到所有所述预设事务ID对应的第一分布式节点所发送的预设标识时，丢弃所述预提交消息数据，并从所述状态缓存模块中重新读取各所述第一分布式节点的上一次数据偏移量状态，基于所述生产模块根据各所述第一分布式节点的上一次数据偏移量状态对所述预提交消息数据进行重新处理； 所述当成功接收到所有所述预设事务ID对应的第一分布式节点所发送的预设标识时，将所述预提交消息数据转化为目标消息数据以供所述消费模块消费，并读取各所述第一分布式节点的数据偏移量状态，将各所述第一分布式节点的所述数据偏移量状态存储到所述状态缓存模块中之后，还包括： 发送目标数据给所述消费模块并实时获取所述消费模块中各第二分布式节点对所述目标数据的消费及加工成功事件； 基于所述消费及加工成功事件通过预设计算引擎计算各所述第二分布式节点的数据偏移量状态，并将各所述第二分布式节点的数据偏移量状态存储到所述消费模块的内存中。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人平安科技(深圳)有限公司，其通讯地址为：518000 广东省深圳市福田区福田街道福安社区益田路5033号平安金融中心23楼；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。