[發(fā)明專(zhuān)利]一種數(shù)據(jù)同步的方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201410533035.1
• 申請(qǐng)日: 2014-10-10
• 公開(kāi)（公告）號(hào): CN104301990B
• 公開(kāi)（公告）日: 2018-01-26
• 發(fā)明（設(shè)計(jì)）人: 張健
• 申請(qǐng)（專(zhuān)利權(quán)）人: 大唐移動(dòng)通信設(shè)備有限公司
• 主分類(lèi)號(hào): H04W56/00
• 分類(lèi)號(hào): H04W56/00
• 代理公司: 北京同達(dá)信恒知識(shí)產(chǎn)權(quán)代理有限公司11291
• 代理人: 劉醒晗

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

本發(fā)明涉及移動(dòng)通信領(lǐng)域，尤其涉及一種數(shù)據(jù)同步的方法及裝置。

背景技術(shù)

大型電信級(jí)裝置通常為分布式網(wǎng)絡(luò)結(jié)構(gòu)，網(wǎng)絡(luò)結(jié)構(gòu)中分布的各個(gè)節(jié)點(diǎn)上儲(chǔ)存有資源運(yùn)行字段，當(dāng)系統(tǒng)運(yùn)行狀況改變時(shí)，資源運(yùn)行字段也隨之更新。網(wǎng)絡(luò)結(jié)構(gòu)中全局節(jié)點(diǎn)與外圍節(jié)點(diǎn)之間、各個(gè)外圍節(jié)點(diǎn)之間相互關(guān)聯(lián)，當(dāng)某個(gè)節(jié)點(diǎn)的資源運(yùn)行字段發(fā)生改變時(shí)，與該節(jié)點(diǎn)相關(guān)聯(lián)的節(jié)點(diǎn)內(nèi)儲(chǔ)存的該資源運(yùn)行字段也需隨之同步更新。

現(xiàn)有技術(shù)中全局節(jié)點(diǎn)將各外圍節(jié)點(diǎn)所需的每個(gè)關(guān)系記錄成一個(gè)表，之后將包含更新數(shù)據(jù)的整個(gè)表發(fā)送給各外圍節(jié)點(diǎn)，從而完成節(jié)點(diǎn)之間數(shù)據(jù)的同步。該方法基于整個(gè)關(guān)系表進(jìn)行數(shù)據(jù)同步，而有時(shí)發(fā)生變化的數(shù)據(jù)可能僅是整個(gè)關(guān)系表中的某一個(gè)字段，此時(shí)同步整個(gè)關(guān)系表則會(huì)同步大量未變化的數(shù)據(jù)，從而影響數(shù)據(jù)同步的效率。

綜上所述，亟需一種數(shù)據(jù)同步方法，用以提高節(jié)點(diǎn)之間數(shù)據(jù)同步的效率。

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

本發(fā)明實(shí)施例提供一種數(shù)據(jù)同步的方法和裝置，用以提高節(jié)點(diǎn)之間數(shù)據(jù)同步的效率。

本發(fā)明實(shí)施例提供一種數(shù)據(jù)同步的方法，包括以下步驟：

全局節(jié)點(diǎn)檢測(cè)到全局節(jié)點(diǎn)的數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生變化時(shí)，根據(jù)發(fā)生變化的數(shù)據(jù)在所在數(shù)據(jù)記錄中的字段位置查詢(xún)得到對(duì)應(yīng)的第一同步號(hào)，同步號(hào)用于唯一標(biāo)識(shí)一條數(shù)據(jù)記錄中的一個(gè)或多個(gè)字段；

全局節(jié)點(diǎn)根據(jù)第一同步號(hào)生成第一同步請(qǐng)求消息，第一同步請(qǐng)求消息中至少包括第一同步號(hào)和第一同步號(hào)所標(biāo)識(shí)的字段的內(nèi)容；

全局節(jié)點(diǎn)將第一同步請(qǐng)求消息發(fā)送給第一外圍節(jié)點(diǎn)，第一同步請(qǐng)求消息用于指示第一外圍節(jié)點(diǎn)依據(jù)第一同步號(hào)和第一同步號(hào)所標(biāo)識(shí)的字段的內(nèi)容更新外圍節(jié)點(diǎn)的數(shù)據(jù)庫(kù)，第一外圍節(jié)點(diǎn)為一個(gè)或多個(gè)。

較佳的，全局節(jié)點(diǎn)檢測(cè)到全局節(jié)點(diǎn)的數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生變化之前，還包括：

全局節(jié)點(diǎn)接收第二外圍節(jié)點(diǎn)發(fā)送的第二同步請(qǐng)求消息；其中，第二同步請(qǐng)求消息為第二外圍節(jié)點(diǎn)在檢測(cè)到第二外圍節(jié)點(diǎn)的數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生變化時(shí)，根據(jù)發(fā)生變化的數(shù)據(jù)在所在數(shù)據(jù)記錄中的字段位置查詢(xún)得到對(duì)應(yīng)的第二同步號(hào)后發(fā)送的，第二同步請(qǐng)求消息中至少包括第二同步號(hào)和第二同步號(hào)所標(biāo)識(shí)的字段的內(nèi)容；

全局節(jié)點(diǎn)依據(jù)第二同步號(hào)和第二同步號(hào)所標(biāo)識(shí)的字段的內(nèi)容，更新全局節(jié)點(diǎn)的數(shù)據(jù)庫(kù)。

較佳的，全局節(jié)點(diǎn)檢測(cè)到全局節(jié)點(diǎn)的數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生變化時(shí)，根據(jù)發(fā)生變化的數(shù)據(jù)在所在數(shù)據(jù)記錄中的字段位置查詢(xún)得到對(duì)應(yīng)的第一同步號(hào)之后，還包括：

全局節(jié)點(diǎn)檢測(cè)到全局節(jié)點(diǎn)的數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生變化時(shí)，根據(jù)發(fā)生變化的數(shù)據(jù)在所在數(shù)據(jù)記錄中的字段位置查詢(xún)得到第一外圍節(jié)點(diǎn)的地址。

較佳的，全局節(jié)點(diǎn)根據(jù)第一同步號(hào)生成第一同步請(qǐng)求消息之后、全局節(jié)點(diǎn)將第一同步請(qǐng)求消息發(fā)送給第一外圍節(jié)點(diǎn)之前，還包括：

全局節(jié)點(diǎn)將第一同步請(qǐng)求消息緩存至與第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中；

全局節(jié)點(diǎn)將第一同步請(qǐng)求消息發(fā)送給第一外圍節(jié)點(diǎn)之后，還包括：

若全局節(jié)點(diǎn)接收到第一外圍節(jié)點(diǎn)發(fā)送的與第一同步請(qǐng)求消息對(duì)應(yīng)的同步成功響應(yīng)消息，則從第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中釋放第一同步請(qǐng)求消息；

若全局節(jié)點(diǎn)接收到第一外圍節(jié)點(diǎn)發(fā)送的與第一同步請(qǐng)求消息對(duì)應(yīng)的同步失敗響應(yīng)消息，則結(jié)束與第一外圍節(jié)點(diǎn)的數(shù)據(jù)同步過(guò)程，并從第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中釋放第一同步請(qǐng)求消息；

若全局節(jié)點(diǎn)在設(shè)定時(shí)長(zhǎng)內(nèi)未接收到與第一同步請(qǐng)求消息對(duì)應(yīng)的同步響應(yīng)消息，則從第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中獲取第一同步請(qǐng)求消息并重新發(fā)送。

較佳的，全局節(jié)點(diǎn)將第一同步請(qǐng)求消息緩存至與第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中，具體包括：

全局節(jié)點(diǎn)根據(jù)第一列表確定出第一同步號(hào)對(duì)應(yīng)的空閑的第一存儲(chǔ)單元標(biāo)識(shí)；其中，第一列表中用于存儲(chǔ)同步號(hào)和緩存區(qū)內(nèi)的空閑的存儲(chǔ)單元標(biāo)識(shí)的對(duì)應(yīng)關(guān)系；

全局節(jié)點(diǎn)將第一同步請(qǐng)求消息緩存至第一存儲(chǔ)單元標(biāo)識(shí)對(duì)應(yīng)的緩存區(qū)中；根據(jù)第一存儲(chǔ)單元標(biāo)識(shí)，更新第一列表和第二列表；其中，第二列表用于存儲(chǔ)同步號(hào)和緩存區(qū)內(nèi)已占用的存儲(chǔ)單元標(biāo)識(shí)的對(duì)應(yīng)關(guān)系；

從第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中釋放第一同步請(qǐng)求消息，具體包括：

全局節(jié)點(diǎn)從第二列表中確定出的第一同步號(hào)對(duì)應(yīng)的第一存儲(chǔ)單元標(biāo)識(shí)，則從第一存儲(chǔ)單元標(biāo)識(shí)對(duì)應(yīng)的緩存區(qū)中釋放第一同步請(qǐng)求消息；根據(jù)第一存儲(chǔ)單元標(biāo)識(shí)，更新第一列表和第二列表；

從第一同步號(hào)對(duì)應(yīng)的緩存區(qū)中獲取第一同步請(qǐng)求消息并重新發(fā)送，具體包括：

全局節(jié)點(diǎn)從第二列表中確定出的第一同步號(hào)對(duì)應(yīng)的第一存儲(chǔ)單元標(biāo)識(shí)，則從第一存儲(chǔ)單元標(biāo)識(shí)對(duì)應(yīng)的緩存區(qū)中獲取第一同步請(qǐng)求消息，并重新發(fā)送。