[發(fā)明專利]基于限流操作的可重入分布式處理方法及裝置

在審

• 申請?zhí)枺?/td>: 201810864208.6
• 申請日: 2018-08-01
• 公開（公告）號: CN109241106A
• 公開（公告）日: 2019-01-18
• 發(fā)明（設(shè)計）人: 何青松;胡曉喻;李聯(lián)邦;王新盟
• 申請（專利權(quán)）人: 口碑(上海)信息技術(shù)有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/25;G06Q30/02
• 代理公司: 北京市浩天知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11276
• 代理人: 宋菲;劉云貴

1.一種基于限流操作的可重入分布式處理方法，其包括：

從數(shù)據(jù)庫中提取待處理數(shù)據(jù)以及所述待處理數(shù)據(jù)的可重入處理時間；

判斷當(dāng)前時間是否晚于所述待處理數(shù)據(jù)的可重入處理時間；若是，則基于限流控制，對處于待處理狀態(tài)的所述待處理數(shù)據(jù)進行處理；

更新所述待處理數(shù)據(jù)的重入次數(shù)，根據(jù)所述重入次數(shù)更新數(shù)據(jù)庫中記錄的所述待處理數(shù)據(jù)的可重入處理時間；

循環(huán)執(zhí)行上述步驟，直至所述待處理數(shù)據(jù)被成功處理。

2.根據(jù)權(quán)利要求1所述的方法，其中，所述方法還包括：

從數(shù)據(jù)庫提取待處理數(shù)據(jù)后，若所述待處理數(shù)據(jù)未設(shè)置可重入處理時間，則設(shè)置所述待處理數(shù)據(jù)的可重入處理時間。

3.根據(jù)權(quán)利要求1或2所述的方法，其中，所述可重入處理時間＝當(dāng)前時間+所述待處理數(shù)據(jù)的重入次數(shù)*預(yù)設(shè)時間間隔。

4.根據(jù)權(quán)利要求1或2所述的方法，其中，所述基于限流控制，對處于待處理狀態(tài)的所述待處理數(shù)據(jù)進行處理進一步包括：

在確定所述待處理數(shù)據(jù)獲取限流操作的處理權(quán)限后，獲取所述待處理數(shù)據(jù)的處理狀態(tài)；

判斷所述處理狀態(tài)是否為未處理狀態(tài)；

若是，將所述待處理數(shù)據(jù)分配給處理器處理。

5.根據(jù)權(quán)利要求4所述的方法，其中，所述方法還包括：

獲取所述待處理數(shù)據(jù)的處理結(jié)果，并將數(shù)據(jù)庫中的處理狀態(tài)更新為已處理狀態(tài)。

6.根據(jù)權(quán)利要求1所述的方法，其中，在所述基于限流控制，對處于待處理狀態(tài)的所述待處理數(shù)據(jù)進行處理之前，所述方法還包括：

將所述待處理數(shù)據(jù)載入內(nèi)存，以確保所述待處理數(shù)據(jù)被正常處理。

7.一種基于限流操作的可重入分布式處理裝置，其包括：

提取模塊，適于從數(shù)據(jù)庫中提取待處理數(shù)據(jù)以及所述待處理數(shù)據(jù)的可重入處理時間；

判斷模塊，適于判斷當(dāng)前時間是否晚于所述待處理數(shù)據(jù)的可重入處理時間；

處理模塊，適于若所述判斷模塊判斷當(dāng)前時間晚于所述待處理數(shù)據(jù)的可重入處理時間，則基于限流控制，對處于待處理狀態(tài)的所述待處理數(shù)據(jù)進行處理；

可重入更新模塊，適于更新所述待處理數(shù)據(jù)的重入次數(shù)，根據(jù)所述重入次數(shù)更新數(shù)據(jù)庫中記錄的所述待處理數(shù)據(jù)的可重入處理時間；

循環(huán)模塊，適于循環(huán)執(zhí)行所述提取模塊、所述判斷模塊、所述處理模塊和/或所述可重入更新模塊，直至所述待處理數(shù)據(jù)被成功處理。

8.根據(jù)權(quán)利要求7所述的裝置，其中，所述裝置還包括：

設(shè)置模塊，適于從數(shù)據(jù)庫提取待處理數(shù)據(jù)后，若所述待處理數(shù)據(jù)未設(shè)置可重入處理時間，則設(shè)置所述待處理數(shù)據(jù)的可重入處理時間。

9.一種電子設(shè)備，包括：處理器、存儲器、通信接口和通信總線，所述處理器、所述存儲器和所述通信接口通過所述通信總線完成相互間的通信；

所述存儲器用于存放至少一可執(zhí)行指令，所述可執(zhí)行指令使所述處理器執(zhí)行如權(quán)利要求1-6中任一項所述的基于限流操作的可重入分布式處理方法對應(yīng)的操作。

10.一種計算機存儲介質(zhì)，所述存儲介質(zhì)中存儲有至少一可執(zhí)行指令，所述可執(zhí)行指令使處理器執(zhí)行如權(quán)利要求1-6中任一項所述的基于限流操作的可重入分布式處理方法對應(yīng)的操作。