[發(fā)明專(zhuān)利]一種數(shù)據(jù)庫(kù)雙向同步方法、同步網(wǎng)元及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201911374964.1
• 申請(qǐng)日: 2019-12-27
• 公開(kāi)（公告）號(hào): CN111177264A
• 公開(kāi)（公告）日: 2020-05-19
• 發(fā)明（設(shè)計(jì)）人: 劉寶國(guó);劉先攀
• 申請(qǐng)（專(zhuān)利權(quán)）人: 青島聚看云科技有限公司
• 主分類(lèi)號(hào): G06F16/27
• 分類(lèi)號(hào): G06F16/27
• 代理公司: 北京弘權(quán)知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11363
• 代理人: 逯長(zhǎng)明;許偉群

本申請(qǐng)實(shí)施例示出一種數(shù)據(jù)庫(kù)雙向同步方法、同步網(wǎng)元及系統(tǒng)，本申請(qǐng)實(shí)施例中，當(dāng)需要將第一數(shù)據(jù)庫(kù)中的數(shù)據(jù)同步到第二數(shù)據(jù)庫(kù)中，響應(yīng)于數(shù)據(jù)庫(kù)的數(shù)據(jù)中第二線程ID與同步網(wǎng)元的第一線程ID相同，則不再將第一數(shù)據(jù)庫(kù)中的數(shù)據(jù)同步到第二數(shù)據(jù)庫(kù)中；響應(yīng)于數(shù)據(jù)庫(kù)的數(shù)據(jù)中第二線程ID與同步網(wǎng)元的第一線程ID不同，則同步第一數(shù)據(jù)庫(kù)的數(shù)據(jù)到第二數(shù)據(jù)庫(kù)中，并將第二數(shù)據(jù)庫(kù)中因同步得到的數(shù)據(jù)的第二線程ID設(shè)置為同步網(wǎng)元的第一線程ID。當(dāng)反向同步時(shí)，由于數(shù)據(jù)庫(kù)中存在的因同步生成的數(shù)據(jù)的第二線程ID與同步網(wǎng)元的第一線程ID相同，則不再將因同步生成的數(shù)據(jù)同步。這樣就能避免了相同的數(shù)據(jù)的重復(fù)同步，造成資源浪費(fèi)的問(wèn)題。

技術(shù)領(lǐng)域

本發(fā)明涉及軟件技術(shù)領(lǐng)域，特別涉及一種數(shù)據(jù)庫(kù)雙向同步方法、同步網(wǎng)元及系統(tǒng)。

背景技術(shù)

目前互聯(lián)網(wǎng)迅速發(fā)展，各公司的業(yè)務(wù)也都在逐步擴(kuò)大，業(yè)務(wù)的穩(wěn)定性備受關(guān)注。很多公司都考慮做異地多活，這樣當(dāng)一個(gè)機(jī)房出現(xiàn)故障，業(yè)務(wù)可以迅速切換到另外的機(jī)房正常工作。而異地多活的設(shè)計(jì)中涉及流量的切分、數(shù)據(jù)同步等核心部分。由于跨機(jī)房網(wǎng)絡(luò)波動(dòng)與延遲，兩個(gè)機(jī)房的業(yè)務(wù)都只寫(xiě)本機(jī)房的數(shù)據(jù)庫(kù)，并且數(shù)據(jù)需要雙向同步。

但是，數(shù)據(jù)庫(kù)雙向同步時(shí)經(jīng)常會(huì)出現(xiàn)以下情況：第一數(shù)據(jù)庫(kù)將數(shù)據(jù)庫(kù)中的數(shù)據(jù)同步到第二數(shù)據(jù)庫(kù)，隨后第二數(shù)據(jù)庫(kù)將其內(nèi)部數(shù)據(jù)同步到第一數(shù)據(jù)庫(kù)，但是第二數(shù)據(jù)庫(kù)的數(shù)據(jù)中經(jīng)常存在由第一數(shù)據(jù)庫(kù)同步得到的數(shù)據(jù)，這樣就會(huì)出現(xiàn)，同一數(shù)據(jù)被二次同步，造成數(shù)據(jù)庫(kù)同步的回環(huán)問(wèn)題，最終導(dǎo)致資源浪費(fèi)。

發(fā)明內(nèi)容

基于上述技術(shù)問(wèn)題，本發(fā)明的發(fā)明目的在于提供一種數(shù)據(jù)庫(kù)雙向同步方法、同步網(wǎng)元及系統(tǒng)。

本申請(qǐng)實(shí)施例第一方面示出一種數(shù)據(jù)庫(kù)雙向同步系統(tǒng)，包括：第一數(shù)據(jù)庫(kù)、第二數(shù)據(jù)庫(kù)、第一同步網(wǎng)元、第二同步網(wǎng)元和同步管理器，所述第一同步網(wǎng)元、第二同步網(wǎng)元分別與所述同步管理器連接，所述第一數(shù)據(jù)庫(kù)和所述第二數(shù)據(jù)庫(kù)通過(guò)所述第一同步網(wǎng)元和所述第二同步網(wǎng)元連接；

所述同步管理器，被配置為分配第一線程ID給所述第一同步網(wǎng)元和所述第二同步網(wǎng)元，其中，第一同步網(wǎng)元的第一線程ID和第二同步網(wǎng)元的第一線程ID相同；

所述第一數(shù)據(jù)庫(kù)，被配置為響應(yīng)于第一數(shù)據(jù)庫(kù)的變化，生成第一同步文件，發(fā)送第一同步文件到所述第一同步網(wǎng)元，所述第一同步文件包括事務(wù)，所述第一同步文件中的事務(wù)包括第二線程ID，所述第二線程ID表征第一數(shù)據(jù)庫(kù)的變化對(duì)應(yīng)的事務(wù)的來(lái)源，所述事務(wù)的來(lái)源包括第二同步網(wǎng)元或其他網(wǎng)元；

所述第一同步網(wǎng)元，被配置為響應(yīng)于所述第二線程ID和所述第一線程ID不同，根據(jù)所述事務(wù)，生成可執(zhí)行文件，所述可以執(zhí)行文件用于發(fā)送給所述第二數(shù)據(jù)庫(kù)，所述第二數(shù)據(jù)庫(kù)被配置為根據(jù)所述可執(zhí)行文件，改變第二數(shù)據(jù)庫(kù)，并根據(jù)可執(zhí)行文件對(duì)第二數(shù)據(jù)庫(kù)的改變結(jié)果，生成第二同步文件，所述第二同步文件包括事務(wù)，所述第二同步文件中的事務(wù)包括第一線程ID；

所述第一同步網(wǎng)元，還被配置為響應(yīng)于所述第二線程ID和所述第一線程ID相同，忽略所述事務(wù)。

本申請(qǐng)實(shí)施例第二方面示出一種同步網(wǎng)元，第一同步網(wǎng)元和第二網(wǎng)元同樣為所述第一數(shù)據(jù)庫(kù)和第二數(shù)據(jù)庫(kù)之間的同步網(wǎng)元，所述第二同步網(wǎng)元和所述第一網(wǎng)元具有相同的第一線程ID；

所述第一同步網(wǎng)元被配置為：接收第一同步文件，所述第一同步文件是第一數(shù)據(jù)庫(kù)響應(yīng)于第一數(shù)據(jù)庫(kù)的變化生成的，所述第一同步文件包括事務(wù)，所述第一同步文件的事務(wù)包括第二線程ID，所述第二線程ID被配置為表征第一數(shù)據(jù)庫(kù)的變化對(duì)應(yīng)的可執(zhí)行文件的來(lái)源，所述可執(zhí)行文件的來(lái)源包括所述第二同步網(wǎng)元或其他網(wǎng)元；

響應(yīng)于所述第二線程ID和所述第一線程ID不同，根據(jù)所述事務(wù)，生成可執(zhí)行文件，所述可以執(zhí)行文件用于發(fā)送給所述第二數(shù)據(jù)庫(kù)；

響應(yīng)于所述第二線程ID和所述第一線程ID相同，忽略所述事務(wù)

本申請(qǐng)實(shí)施例第三方面示出一種數(shù)據(jù)庫(kù)雙向同步方法，應(yīng)用于同步網(wǎng)元，包括：