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

基本信息

申請(qǐng)?zhí)?/td> CN202111160305.5 申請(qǐng)日 -
公開(kāi)（公告）號(hào) CN114116791A 公開(kāi)（公告）日 2022-03-01
申請(qǐng)公布號(hào) CN114116791A 申請(qǐng)公布日 2022-03-01
分類號(hào) G06F16/2455（2019.01）I;G06F16/23（2019.01）I;G06F16/27（2019.01）I;G06F16/28（2019.01）I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 葉婷;李雪強(qiáng);陶強(qiáng) 申請(qǐng)（專利權(quán)）人 武漢武鋼綠色城市技術(shù)發(fā)展有限公司
代理機(jī)構(gòu) 北京匯澤知識(shí)產(chǎn)權(quán)代理有限公司 代理人 鄭飛
地址 430000湖北省武漢市青山區(qū)廠前一號(hào)門(mén)
法律狀態(tài) -

摘要

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