一種基于MQTT協(xié)議消息的數(shù)據(jù)同步方法及系統(tǒng)

基本信息

申請?zhí)?/td> 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 分類 計算；推算；計數(shù);
發(fā)明人 葉婷;李雪強;陶強 申請（專利權(quán)）人 武漢武鋼綠色城市技術(shù)發(fā)展有限公司
代理機構(gòu) 北京匯澤知識產(chǎn)權(quán)代理有限公司 代理人 鄭飛
地址 430000湖北省武漢市青山區(qū)廠前一號門
法律狀態(tài) -

摘要

摘要 一種基于MQTT協(xié)議消息的數(shù)據(jù)同步方法及系統(tǒng)，方法包括：搭建基于MQTT的ActiveMQ消息中間件平臺，在ActiveMQ消息中間件平臺為不同目標數(shù)據(jù)庫配置用于存儲消息的指定隊列；當業(yè)務(wù)系統(tǒng)有相關(guān)業(yè)務(wù)操作時，將對應(yīng)的業(yè)務(wù)操作數(shù)據(jù)轉(zhuǎn)化成指令數(shù)據(jù)，往對應(yīng)指定隊列中推送一條包括請求業(yè)務(wù)數(shù)據(jù)接口的消息；當目標數(shù)據(jù)庫收到消息后，基于所述消息獲取請求業(yè)務(wù)數(shù)據(jù)接口，基于所述請求業(yè)務(wù)數(shù)據(jù)接口獲取經(jīng)過轉(zhuǎn)化后的指令數(shù)據(jù)，基于所述指令數(shù)據(jù)進行數(shù)據(jù)同步。本發(fā)明通過架設(shè)ActiveMQ中間件構(gòu)建消息中間件，源數(shù)據(jù)庫數(shù)據(jù)一旦發(fā)生變化，發(fā)送者將消息發(fā)送給消息中間件平臺，并將消息轉(zhuǎn)發(fā)給目標數(shù)據(jù)庫數(shù)據(jù)服務(wù)，實現(xiàn)不同局域網(wǎng)網(wǎng)絡(luò)環(huán)境下信息互通，并且能實時監(jiān)測到源數(shù)據(jù)變化。