一种基于MQTT协议消息的数据同步方法及系统

摘要

一种基于MQTT协议消息的数据同步方法及系统，方法包括：搭建基于MQTT的ActiveMQ消息中间件平台，在ActiveMQ消息中间件平台为不同目标数据库配置用于存储消息的指定队列；当业务系统有相关业务操作时，将对应的业务操作数据转化成指令数据，往对应指定队列中推送一条包括请求业务数据接口的消息；当目标数据库收到消息后，基于所述消息获取请求业务数据接口，基于所述请求业务数据接口获取经过转化后的指令数据，基于所述指令数据进行数据同步。本发明通过架设ActiveMQ中间件构建消息中间件，源数据库数据一旦发生变化，发送者将消息发送给消息中间件平台，并将消息转发给目标数据库数据服务，实现不同局域网网络环境下信息互通，并且能实时监测到源数据变化。