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

龙图腾网获悉北京羽乐创新科技有限公司申请的专利一种事务消息的最终一致性处理系统及方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN121300919B 。

龙图腾网通过国家知识产权局官网在2026-04-03发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202511854178.7，技术领域涉及：G06F9/46；该发明授权一种事务消息的最终一致性处理系统及方法是由白云川设计研发完成，并于2025-12-10向国家知识产权局提交的专利申请。

本一种事务消息的最终一致性处理系统及方法在说明书摘要公布了：本申请提供一种事务消息的最终一致性处理系统及方法。该方法包括：获取分布式系统中关于事务消息的事务状态元数据及业务消息体，将业务消息体存储到分布式消息队列中，将事务状态元数据存储到内存数据库中；构建事务状态索引结构；基于业务消息体确定物理偏移量，基于物理偏移量在内存数据库中创建事务状态记录，依据事务状态记录生成待回查事务任务；基于事务创建时间及系统负载因子，确定回查间隔，执行待回查事务任务；在检测到事务状态从待确认状态变更为事务确认状态时，根据物理偏移量拉取业务消息体；对所拉取的业务消息体进行双重确认。本申请解决了事务状态与消息体强耦合导致的性能瓶颈和恢复效率低下的问题。

本发明授权一种事务消息的最终一致性处理系统及方法在权利要求书中公布了：1.一种事务消息的最终一致性处理方法，其特征在于，包括以下步骤： 获取分布式系统中关于事务消息的事务状态元数据及业务消息体，并将所述业务消息体存储到分布式消息队列中，将所述事务状态元数据存储到内存数据库中； 基于所述内存数据库中所存储的事务状态元数据，构建事务状态索引结构，所述事务状态索引结构包含至少一个事务的事务标识及事务数据，所述事务数据包括事务状态以及用于指示需回查所述事务状态的待回查事务数据； 基于所述分布式消息队列中的业务消息体，确定物理偏移量，基于所述物理偏移量在所述内存数据库中创建与所述业务消息体对应的事务状态记录，依据所述事务状态记录生成待回查事务任务以新增到所述事务状态索引结构中，包括：将获取到的业务消息体写入所述分布式消息队列，并将所述业务消息体在所述分布式消息队列中的消息定位标识作为物理偏移量，并记录相应的队列写入结果，所述队列写入结果用于指示所述业务消息体是否成功写入所述分布式消息队列；基于所述物理偏移量和所述事务标识，在所述内存数据库中创建与所述业务消息体对应的事务状态记录，其中，所述事务状态记录中的事务状态设为待确认状态；在由所述事务状态记录的超时时间超过预设的超时阈值时，生成待回查事务任务，并将与所述待回查事务任务对应的事务标识和所述超时时间添加到所述待回查事务索引中；在检测到所述业务消息体成功写入所述分布式消息队列，但检测到数据库操作失败消息时，按照预设的重试策略重新将所述业务消息体写入所述内存数据库，并在重试失败后，生成告警通知，并记录补偿执行日志及补偿失败事务列表，其中，所述数据库操作失败消息包括创建失败消息和任务创建失败消息中的至少一种，所述创建失败消息用于指示在所述内存数据库中对所述事务状态记录的创建操作失败，所述任务创建失败消息用于指示将所述待回查事务任务添加到所述待回查事务索引的操作失败，所述重试策略包括重试次数和重试间隔，所述补偿执行日志用于记录实际重试的操作次数和操作结果；其中，所述物理偏移量用于指示任一业务消息体在所述分布式消息队列中的位置标识，所述事务状态记录包含对应事务的事务标识、所述物理偏移量、所述事务状态、事务创建时间及超时时间，所述事务创建时间用于指示当前创建所述事务状态记录的时间戳； 基于所述事务创建时间以及预先获取的系统负载因子，确定回查间隔，并依据所述回查间隔执行所述待回查事务任务，获得回查处理结果； 在基于所述回查处理结果检测到所述事务状态从待确认状态变更为事务确认状态时，根据对应的事务状态记录中的物理偏移量从所述分布式消息队列中拉取对应的业务消息体； 对所拉取的业务消息体进行双重确认，并在双重确认通过后，生成用于指示消息处理完成的消息处理结果。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人北京羽乐创新科技有限公司，其通讯地址为：102200 北京市昌平区中关村科技园区昌平园超前路5号4幢220B；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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