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

基本信息

申请号 CN202111160305.5 申请日 -
公开(公告)号 CN114116791A 公开(公告)日 2022-03-01
申请公布号 CN114116791A 申请公布日 2022-03-01
分类号 G06F16/2455(2019.01)I;G06F16/23(2019.01)I;G06F16/27(2019.01)I;G06F16/28(2019.01)I 分类 计算;推算;计数;
发明人 叶婷;李雪强;陶强 申请(专利权)人 武汉武钢绿色城市技术发展有限公司
代理机构 北京汇泽知识产权代理有限公司 代理人 郑飞
地址 430000湖北省武汉市青山区厂前一号门
法律状态 -

摘要

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