[發(fā)明專利]一種分布式網(wǎng)絡(luò)中的事務(wù)處理控制方法及裝置

有效

• 申請?zhí)枺?/td>: 201310409201.2
• 申請日: 2013-09-10
• 公開（公告）號: CN103475520B
• 公開（公告）日: 2017-04-26
• 發(fā)明（設(shè)計）人: 劉希偉;王英杰;張樂
• 申請（專利權(quán)）人: 聚好看科技股份有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L12/26;H04L29/08
• 代理公司: 北京同達(dá)信恒知識產(chǎn)權(quán)代理有限公司11291
• 代理人: 黃志華

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

本發(fā)明涉及分布式網(wǎng)絡(luò)技術(shù)領(lǐng)域，尤其涉及一種分布式網(wǎng)絡(luò)中的事務(wù)處理控制方法及裝置。

背景技術(shù)

云平臺通常采取分布式網(wǎng)絡(luò)架構(gòu)，由位于不同服務(wù)器上的網(wǎng)元搭建而成。一個具體的業(yè)務(wù)流程通常需要多個網(wǎng)元協(xié)同完成。

為了保持?jǐn)?shù)據(jù)的完整統(tǒng)一，一種處理方案是保持?jǐn)?shù)據(jù)的傳遞。從參與業(yè)務(wù)處理的起始網(wǎng)元開始，不斷累積各網(wǎng)元的數(shù)據(jù)并將其傳遞給下一網(wǎng)元，直至參與業(yè)務(wù)處理的最后一個網(wǎng)元進(jìn)行數(shù)據(jù)的最終持久化處理。該處理方案雖然保證了數(shù)據(jù)的完整統(tǒng)一，但增加了各個網(wǎng)元的處理復(fù)雜度，且每個網(wǎng)元不僅需要關(guān)心自己的業(yè)務(wù)邏輯，還需要關(guān)注上游傳遞而來的數(shù)據(jù)以及準(zhǔn)備給下游的數(shù)據(jù)，另外，數(shù)據(jù)包的累積增加了網(wǎng)絡(luò)傳輸?shù)呢?fù)擔(dān)，導(dǎo)致處理能力低下。

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

本發(fā)明的目的是提供一種分布式網(wǎng)絡(luò)中的事務(wù)管理方法及裝置，以解決現(xiàn)有實現(xiàn)方案存在的問題。

本發(fā)明的目的是通過以下技術(shù)方案實現(xiàn)的：

一種分布式網(wǎng)絡(luò)中的事務(wù)處理控制方法，包括：

為待處理的事務(wù)分配標(biāo)識信息，并將所述標(biāo)識信息發(fā)送給處理所述事務(wù)的網(wǎng)元，以便處理該事務(wù)的各級網(wǎng)元對該事務(wù)進(jìn)行處理后將本網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與該標(biāo)識信息關(guān)聯(lián)保存；

通過讀取用于保存事務(wù)的狀態(tài)信息的緩存空間對所述事務(wù)的處理狀態(tài)進(jìn)行監(jiān)控；

當(dāng)讀取到所述事務(wù)的標(biāo)識信息對應(yīng)的處理結(jié)束狀態(tài)信息，對處理所述事務(wù)的各級網(wǎng)元保存的所述標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行持久化處理。

本發(fā)明實施例提供的方法，對事務(wù)處理過程進(jìn)行統(tǒng)一管理，以及對處理事務(wù)的網(wǎng)元提交的數(shù)據(jù)進(jìn)行統(tǒng)一的處理，不需要各個網(wǎng)元進(jìn)行數(shù)據(jù)的傳遞即可保證數(shù)據(jù)的完整統(tǒng)一，減少了各個網(wǎng)元的處理復(fù)雜度，提高了處理能力。

下面分別對以上各步驟的優(yōu)選實現(xiàn)方式進(jìn)行描述。應(yīng)當(dāng)指出的是，這些優(yōu)選的實現(xiàn)方式可以單獨應(yīng)用，也可以配合應(yīng)用。

將上述標(biāo)識信息發(fā)送給處理上述事務(wù)的網(wǎng)元，其具體實現(xiàn)方式既可以是將標(biāo)識信息發(fā)送給處理上述事務(wù)的起始網(wǎng)元，在事務(wù)處理過程中，該標(biāo)識信息在處理該事務(wù)的各級網(wǎng)元之間逐級傳遞。也可以是將標(biāo)識信息發(fā)送給處理上述事務(wù)的各級網(wǎng)元。

對上述事務(wù)的處理狀態(tài)進(jìn)行監(jiān)控的具體實現(xiàn)方式與上述事務(wù)的狀態(tài)信息存儲位置有關(guān)。如果處理上述事務(wù)的網(wǎng)元將該事務(wù)的狀態(tài)信息與上述標(biāo)識信息關(guān)聯(lián)保存在共享緩存空間，則通過讀取該共享緩存空間對該事務(wù)的狀態(tài)進(jìn)行監(jiān)控。如果處理上述事務(wù)的各級網(wǎng)元將該事務(wù)的狀態(tài)信息與上述標(biāo)識信息分別保存在對應(yīng)的緩存空間中，則通過讀取上述各級網(wǎng)元對應(yīng)的緩存空間對該事務(wù)的處理狀態(tài)進(jìn)行監(jiān)控。

對處理上述事務(wù)的各級網(wǎng)元保存的上述標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行持久化處理的具體實現(xiàn)方式與數(shù)據(jù)存儲的位置有關(guān)。如果上述各級網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與該標(biāo)識信息關(guān)聯(lián)保存在上述共享緩存空間，則對處理該事務(wù)的各級網(wǎng)元保存的該標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行持久化處理的具體實現(xiàn)方式可以是：從該共享緩存空間中獲取該標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)；將獲取的數(shù)據(jù)進(jìn)行持久化處理。如果上述各級網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與該標(biāo)識信息分別關(guān)聯(lián)保存在對應(yīng)的緩存空間，則對處理該事務(wù)的各級網(wǎng)元保存的該標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行持久化處理的具體實現(xiàn)方式可以是：分別從上述各級網(wǎng)元對應(yīng)的緩存空間中獲取該標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)；將獲取的數(shù)據(jù)進(jìn)行持久化處理。

較佳地，上述共享緩存空間包括棧內(nèi)存和堆內(nèi)存。如果處理上述事務(wù)的網(wǎng)元將該事務(wù)的狀態(tài)信息與上述標(biāo)識信息關(guān)聯(lián)保存在共享緩存空間，那么，該事務(wù)的狀態(tài)信息與上述標(biāo)識信息關(guān)聯(lián)保存在該共享緩存空間的棧內(nèi)存中。如果上述各級網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與該標(biāo)識信息關(guān)聯(lián)保存在上述共享緩存空間，那么，處理該事務(wù)得到的數(shù)據(jù)保存在該共享緩存空間的棧內(nèi)存中，指示該數(shù)據(jù)存儲位置的指針與該標(biāo)識信息關(guān)聯(lián)保存在棧內(nèi)存中。

當(dāng)處理上述事務(wù)的網(wǎng)元出現(xiàn)異常時，需要對數(shù)據(jù)進(jìn)行回滾處理。本發(fā)明實施例中，出現(xiàn)異常的網(wǎng)元會保存處理異常狀態(tài)信息。那么，基于上述任意實施例，如果上述各級網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與上述標(biāo)識信息關(guān)聯(lián)保存在共享緩存空間，且在讀取到該事務(wù)的標(biāo)識信息對應(yīng)的處理結(jié)束狀態(tài)信息之前，讀取到該事務(wù)的標(biāo)識信息對應(yīng)的處理異常狀態(tài)信息，還對上述共享緩存空間中保存的該標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行回滾處理；如果上述各級網(wǎng)元處理該事務(wù)得到的數(shù)據(jù)與該標(biāo)識信息分別關(guān)聯(lián)保存在對應(yīng)的緩存空間，且在讀取到該事務(wù)的標(biāo)識信息對應(yīng)的處理結(jié)束狀態(tài)信息之前，讀取到該事務(wù)的標(biāo)識信息對應(yīng)的處理異常狀態(tài)信息，還對上述各級網(wǎng)元對應(yīng)的緩存空間中保存的上述標(biāo)識信息關(guān)聯(lián)的數(shù)據(jù)進(jìn)行回滾處理。