基于消息队列高可用性的数据同步方法

摘要

本发明涉及数据同步技术领域，具体为基于消息队列高可用性的数据同步方法，包括以下内容：S100：消息发布端向消息队列服务器发送一阶段准备消息；S200：消息队列服务接收一阶段准备消息；S300：消息发布端执行本地数据事务；S400：消息发布端根据本地数据事务执行结果向消息队列服务器发送二阶段消息；S500：消息队列服务器接收消息发布端发布的二阶段消息，若二阶段消息为二阶段提交消息，则将消息下发给消息消费端；若二阶段消息为二阶段撤回消息，则清除一阶段准备消息。本申请的基于消息队列高可用性的数据同步方法，能够提供高可用性的消息队列服务，确保生产端发送的数据同步到消费端。