[發(fā)明專利]數(shù)據(jù)處理方法、裝置和服務(wù)器

在審

• 申請?zhí)枺?/td>: 202010903226.8
• 申請日: 2020-09-01
• 公開（公告）號: CN113297233A
• 公開（公告）日: 2021-08-24
• 發(fā)明（設(shè)計(jì)）人: 鞠進(jìn)濤;朱云鋒;安凱歌;羅劍明;程霖
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F16/18;G06Q20/06;G06Q20/10
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 周達(dá);闞傳猛

本說明書提供了數(shù)據(jù)處理方法、裝置和服務(wù)器。在一個實(shí)施例中，基于上述數(shù)據(jù)處理方法，在分布式系統(tǒng)中，前端服務(wù)器在接收到來自終端設(shè)備發(fā)起的包含有操作的數(shù)據(jù)處理請求時，不會立即響應(yīng)數(shù)據(jù)處理請求執(zhí)行該操作，而是先將該數(shù)據(jù)處理請求發(fā)送到全局服務(wù)器；全局服務(wù)器在接收到該數(shù)據(jù)處理請求后，不會執(zhí)行該操作，而是按照順序?qū)碜圆煌岸朔?wù)器的數(shù)據(jù)處理請求中的操作記錄在全局日志中；前端服務(wù)器再通過全局服務(wù)器獲取增量日志，并根據(jù)增量日志，按順序來執(zhí)行增量日志中所包含的操作。從而使得日志鏡像分離的分布式系統(tǒng)中的數(shù)據(jù)處理操作高效、有序。

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

本說明書屬于互聯(lián)網(wǎng)技術(shù)領(lǐng)域，尤其涉及數(shù)據(jù)處理方法、裝置和服務(wù)器。

背景技術(shù)

在日志鏡像分離的分布式數(shù)據(jù)系統(tǒng)中，當(dāng)某一個前端服務(wù)器接收到當(dāng)前終端設(shè)備發(fā)起的數(shù)據(jù)處理請求時，往往需要獲取與該數(shù)據(jù)處理請求相關(guān)的當(dāng)前最新數(shù)據(jù)才能進(jìn)行相應(yīng)的操作處理。但是，由于系統(tǒng)中日志與鏡像是分離的，這部分當(dāng)前最新數(shù)據(jù)可能已經(jīng)存儲在了本地的鏡像數(shù)據(jù)中，也可能還存儲在遠(yuǎn)端的全局服務(wù)器的全局日志中。這時前端服務(wù)器勢必還是需要先從遠(yuǎn)端的全局服務(wù)器處拉取上述當(dāng)前最新數(shù)據(jù)。但是，在該前端服務(wù)器拉取上述當(dāng)前最新數(shù)據(jù)的過程中，可能其他區(qū)域的前端服務(wù)器訪問過全局服務(wù)器，并對上述數(shù)據(jù)作了修改，進(jìn)而又會對該前端服務(wù)器的數(shù)據(jù)處理產(chǎn)生影響，導(dǎo)致該分布式系統(tǒng)中的數(shù)據(jù)處理操作出現(xiàn)混亂、不一致等問題。

因此，亟需一種能夠使得日志鏡像分離的分布式系統(tǒng)中的數(shù)據(jù)處理操作高效、有序的數(shù)據(jù)處理方法。

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

本說明書提供了一種數(shù)據(jù)處理方法、裝置和服務(wù)器，以使得日志鏡像分離的分布式系統(tǒng)中的數(shù)據(jù)處理操作高效、有序。

本說明書提供的一種數(shù)據(jù)處理方法、裝置和服務(wù)器是這樣實(shí)現(xiàn)的：

一種數(shù)據(jù)處理方法，包括：接收終端設(shè)備發(fā)送的數(shù)據(jù)處理請求；其中，所述數(shù)據(jù)處理請求包含有操作；將所述數(shù)據(jù)處理請求發(fā)送至全局服務(wù)器；其中，所述全局服務(wù)器用于接收前端服務(wù)器發(fā)送的數(shù)據(jù)處理請求，并將所述數(shù)據(jù)處理請求中包含的操作按照順序記錄在全局日志中；通過全局服務(wù)器獲取增量日志；根據(jù)所述增量日志，和本地的鏡像數(shù)據(jù)，按順序執(zhí)行所述增量日志中所包含的操作。

一種數(shù)據(jù)處理方法，包括：獲取數(shù)據(jù)處理請求；將數(shù)據(jù)處理請求中包含的操作按照順序記錄在全局日志中。

一種數(shù)據(jù)處理方法，包括：獲取提議數(shù)據(jù)；根據(jù)一致性協(xié)議，在多個全局服務(wù)器中發(fā)起針對所述提議數(shù)據(jù)的表決；在確定超過預(yù)設(shè)數(shù)量的全局服務(wù)器針對所述提議數(shù)據(jù)表決通過的情況下，將所述提議數(shù)據(jù)中包含的操作按照順序記錄在全局日志中。

一種數(shù)據(jù)處理系統(tǒng)，包括多個前端服務(wù)器、多個全局服務(wù)器，其中：所述前端服務(wù)器接收終端設(shè)備發(fā)送的數(shù)據(jù)處理請求；其中，所述數(shù)據(jù)處理請求包含有操作；所述前端服務(wù)器將所述數(shù)據(jù)處理請求封裝成基于一致性協(xié)議的提議數(shù)據(jù)，并將所述提議數(shù)據(jù)發(fā)送至全局服務(wù)器；所述全局服務(wù)器獲取提議數(shù)據(jù)；根據(jù)一致性協(xié)議，在多個全局服務(wù)器中發(fā)起針對所述提議數(shù)據(jù)的表決；在確定超過預(yù)設(shè)數(shù)量的全局服務(wù)器針對所述提議數(shù)據(jù)表決通過的情況下，將所述提議數(shù)據(jù)中包含的操作按照順序記錄在全局日志中；所述前端服務(wù)器還通過全局服務(wù)器獲取增量日志；并根據(jù)所述增量日志，和本地的鏡像數(shù)據(jù)，按順序執(zhí)行所述增量日志中所包含的操作。

一種數(shù)據(jù)處理裝置，包括：接收模塊，用于接收終端設(shè)備發(fā)送的數(shù)據(jù)處理請求；其中，所述數(shù)據(jù)處理請求包含有操作；發(fā)送模塊，用于將所述數(shù)據(jù)處理請求發(fā)送至全局服務(wù)器；其中，所述全局服務(wù)器用于接收前端服務(wù)器發(fā)送的數(shù)據(jù)處理請求，并將所述數(shù)據(jù)處理請求中包含的操作按照順序記錄在全局日志中；第一獲取模塊，用于通過全局服務(wù)器獲取增量日志；執(zhí)行模塊，用于根據(jù)所述增量日志，和本地的鏡像數(shù)據(jù)，按順序執(zhí)行所述增量日志中所包含的操作。