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

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114116791A(43)申请公布日2022.03.01(21)申请号202111160305.5(22)申请日2021.09.30(71)申请人武汉武钢绿色城市技术发展有限公司地址430000湖北省武汉市青山区厂前一号门(72)发明人叶婷李雪强陶强(74)专利代理机构北京汇泽知识产权代理有限公司11228代理人郑飞(51)Int.Cl.G06F16/2455(2019.01)G06F16/23(2019.01)G06F16/27(2019.01)G06F16/28(2019.01)权利要求书2页说明书4页附图1页(54)发明名称一种基于MQTT协议消息的数据同步方法及系统(57)摘要一种基于MQTT协议消息的数据同步方法及系统，方法包括：搭建基于MQTT的ActiveMQ消息中间件平台，在ActiveMQ消息中间件平台为不同目标数据库配置用于存储消息的指定队列；当业务系统有相关业务操作时，将对应的业务操作数据转化成指令数据，往对应指定队列中推送一条包括请求业务数据接口的消息；当目标数据库收到消息后，基于所述消息获取请求业务数据接口，基于所述请求业务数据接口获取经过转化后的指令数据，基于所述指令数据进行数据同步。本发明通过架设ActiveMQ中间件构建消息中间件，源数据库数据一旦发生变化，发送者将消息发送给消息中间件平台，并将消息转发给目标数据库数据服务，实现不同局域网网络环境下信息互通，并且能实时监测到源数据变化。CN114116791ACN114116791A权利要求书1/2页1.一种基于MQTT协议消息的数据同步方法，其特征在于，所述方法包括：步骤1，搭建基于MQTT的ActiveMQ消息中间件平台，在ActiveMQ消息中间件平台为不同目标数据库配置用于存储消息的指定队列；步骤2，当业务系统有相关业务操作时，将对应的业务操作数据转化成指令数据，往对应指定队列中推送一条包括请求业务数据接口的消息；步骤3，当目标数据库收到消息后，基于所述消息获取请求业务数据接口，基于所述请求业务数据接口获取经过转化后的指令数据，基于所述指令数据进行数据同步。2.根据权利要求1所述的基于MQTT协议消息的数据同步方法，其特征在于，步骤2还包括：当业务系统有相关业务操作时，根据不同业务类型将业务操作数据存入Mqsql关系型数据库中，对Mqsql关系型数据库中的业务操作数据进行指令标识。3.根据权利要求2所述的基于MQTT协议消息的数据同步方法，其特征在于，所述指令标识包括指令码字段，所述指令码字段包括新增、修改和删除指令。4.根据权利要求1所述的基于MQTT协议消息的数据同步方法，其特征在于，步骤3还包括：当目标数据库收到消息后，新建线程池，并指定线程池维护的最大线程个数，将新开启的多线程任务放入线程池里进行统一管理，通过异步多线程任务分别请求各自的源数据库数据，即所述指令数据，将获取到的指令数据存入目标数据库表TARGET_DATA_TEMP中，并在线程任务结束后销毁所述线程池，避免内存耗尽。5.根据权利要求1所述的基于MQTT协议消息的数据同步方法，其特征在于，所述方法包括，在目标数据库基于所述指令数据进行数据同步完毕后，调用设备接口将指令数据下发至设备，同时调用业务接口上传本地状态数据至源数据库表进行状态回写。6.一种基于MQTT协议消息的数据同步系统，其特征在于，所述系统包括：配置单元、消息发送单元以及消息接收单元；所述配置单元用于搭建基于MQTT的ActiveMQ消息中间件平台，在ActiveMQ消息中间件平台为不同目标数据库配置用于存储消息的指定队列；所述消息发送单元用于当业务系统有相关业务操作时，将对应的业务操作数据转化成指令数据，往对应指定队列中推送一条包括请求业务数据接口的消息；所述消息接收单元用于当目标数据库收到消息后，基于所述消息获取请求业务数据接口，基于所述请求业务数据接口获取经过转化后的指令数据，基于所述指令数据进行数据同步。7.根据权利要求6所述的基于MQTT协议消息的数据同步系统，其特征在于，所述消息发送单元还用于：当业务系统有相关业务操作时，根据不同业务类型将业务操作数据存入Mqsql关系型数据库中，对Mqsql关系型数据库中的业务操作数据进行指令标识。8.根据权利要求7所述的基于MQTT协议消息的数据同步系统，其特征在于，所述指令标识包括指令码字段，所述指令码字段包括新增、修改和删除指令。9.根据权利要求6所述的基于MQTT协议消息的数据同步系统，其特征在于，所述消息接收单元还用于：当目标数据库收到消息后，新建线程池，并指定线程池维护的最大线程个数，将新开启的多线程任务放入线程池里进行统一管理，通过异步多线程任务分别请求各自的源数