一種利用消息總線(xiàn)進(jìn)行數(shù)據(jù)庫(kù)實(shí)時(shí)同步的方法及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201811130748.8 申請(qǐng)日 -
公開(kāi)（公告）號(hào) CN109522361A 公開(kāi)（公告）日 2019-03-26
申請(qǐng)公布號(hào) CN109522361A 申請(qǐng)公布日 2019-03-26
分類(lèi)號(hào) G06F16/27（2019.01）I 分類(lèi) 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 曹海旺 申請(qǐng)（專(zhuān)利權(quán)）人 中國(guó)經(jīng)濟(jì)信息社有限公司
代理機(jī)構(gòu) 北京思海天達(dá)知識(shí)產(chǎn)權(quán)代理有限公司 代理人 中國(guó)經(jīng)濟(jì)信息社有限公司
地址 100052 北京市西城區(qū)宣武門(mén)西大街57號(hào)
法律狀態(tài) -

摘要

摘要 本發(fā)明公開(kāi)了一種利用消息總線(xiàn)進(jìn)行數(shù)據(jù)庫(kù)實(shí)時(shí)同步的方法及系統(tǒng)，包括：監(jiān)聽(tīng)需要同步的數(shù)據(jù)庫(kù)，實(shí)時(shí)獲取數(shù)據(jù)庫(kù)的寫(xiě)操作消息，解析或者獲得寫(xiě)操作的DML,DDL,DCL語(yǔ)句，將語(yǔ)句封裝為消息，發(fā)送到消息總線(xiàn)上，目標(biāo)數(shù)據(jù)庫(kù)消費(fèi)系統(tǒng)從消息總線(xiàn)上獲取到消息，解析出DML，DDL，DCL語(yǔ)句，轉(zhuǎn)換為目標(biāo)數(shù)據(jù)庫(kù)SQL，連接目標(biāo)數(shù)據(jù)然后執(zhí)行語(yǔ)句，完成數(shù)據(jù)的寫(xiě)操作，從而達(dá)到數(shù)據(jù)庫(kù)數(shù)據(jù)實(shí)時(shí)同步的效果。本發(fā)明可實(shí)時(shí)的進(jìn)行數(shù)據(jù)庫(kù)的同步，可用于分布式服務(wù)場(chǎng)景或者災(zāi)備等需要數(shù)據(jù)實(shí)時(shí)同步的應(yīng)用場(chǎng)景中。