一种基于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中间件构建消息中间件,源数据库数据一旦发生变化,发送者将消息发送给消息中间件平台,并将消息转发给目标数据库数据服务,实现不同局域网网络环境下信息互通,并且能实时监测到源数据变化。 |
