[發明專利]一種區塊處理任務的控制方法和裝置

有效

• 申請號: 201811069813.0
• 申請日: 2018-09-13
• 公開（公告）號: CN109271245B
• 公開（公告）日: 2021-04-27
• 發明（設計）人: 劉長輝
• 申請（專利權）人: 騰訊科技(深圳)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F16/27;G06F16/23;G06F16/21;H04L29/08;H04L12/819
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 郭潤湘;李娟

1.一種區塊處理任務的控制方法，其特征在于，將區塊處理任務分成連續的多級處理子任務，對應每級處理子任務配置至少一個對應級別的執行模塊，各個執行模塊之間通過任務隊列的方式進行通信；以及所述方法包括：

至少一個非最末一級執行模塊對當前待處理區塊執行本級處理子任務后繼續對下一個待處理區塊執行本級處理子任務；

最末一級執行模塊對當前待處理區塊執行最末一級處理子任務，并將所述各個執行模塊處理當前待處理區塊的各級處理子任務的處理結果同步到數據庫中，所述各級處理子任務之間是并列的關系；

其中，第一級執行模塊對當前待處理區塊執行本級處理子任務之前，還包括：

第一級執行模塊根據當前待處理區塊中數據的級別，為當前待處理區塊申請執行區塊處理任務所需數量的令牌，所述令牌來自于令牌桶，所述令牌桶的令牌總數為配置的執行模塊的總數。

2.如權利要求1所述的方法，其特征在于，還包括：

第一級執行模塊對當前待處理區塊執行本級處理子任務后，將按照先入先出原則提取的任務對應的區塊作為下一個待處理區塊，區塊任務隊列中的任務是根據待處理區塊的接收順序按照先入先出的原則寫入的。

3.如權利要求1所述的方法，其特征在于，

每個非最末一級執行模塊對當前待處理區塊執行本級處理子任務后，還包括：按照先入先出的原則將當前待處理區塊的區塊處理任務添加到與下一級執行模塊之間配置的中間任務隊列中，其中，相鄰執行模塊之間均配置有中間任務隊列；以及

每個非第一級執行模塊對當前待處理區塊執行本級處理子任務后，還包括：將與上一級執行模塊之間配置的中間任務隊列中按照先入先出的原則提取的任務對應的區塊作為下一個待處理區塊。

4.如權利要求1所述的方法，其特征在于，所述第一級執行模塊根據當前待處理區塊中數據的級別，為當前待處理區塊申請執行區塊處理任務所需的令牌，還包括：

第一級執行模塊確定申請的令牌數不大于令牌桶中剩余的令牌數；以及

第一級執行模塊若確定出申請的令牌數大于令牌桶中剩余的令牌數，則掛起本級處理子任務，直至確定出令牌桶中剩余的令牌數滿足申請的令牌數為止。

5.如權利要求4所述的方法，其特征在于，還包括：

最末一級執行模塊對當前待處理區塊執行最末一級處理子任務后，則釋放為當前待處理區塊申請的執行區塊處理任務所需的令牌并補入到令牌桶中。

6.如權利要求1或4所述的方法，其特征在于，所述處理子任務包括賬戶版本驗證子任務；則執行賬戶驗證子任務的執行模塊對當前待處理區塊執行本級處理子任務后繼續對下一個待處理區塊執行本級處理子任務，具體包括：

對當前待處理區塊涉及的交易的賬戶版本驗證通過后，將當前待處理區塊中所述交易中修改的所有數據構成的寫集及其版本號保存到預提交緩存中；以及

處理下一待處理區塊的賬戶版本驗證時，若確定出預提交緩存中存儲有賬戶的版本號，則利用從預提交緩存中讀取的賬戶的版本號對所述下一待處理區塊涉及的交易的賬戶版本進行驗證；否則從數據庫中讀取賬戶的版本號對所述下一待處理區塊涉及的交易的賬戶版本進行驗證。

7.如權利要求6所述的方法，其特征在于，所述處理子任務還包括賬戶更新子任務；以及執行賬戶更新子任務的執行模塊對當前待處理區塊執行本級處理子任務，具體包括：

在將預提交緩存中存儲的當前待處理區塊涉及的所述寫集及其版本號更新至數據庫中之后，清除預提交緩存中存儲的當前待處理區塊涉及的所述寫集及其版本號。

8.如權利要求7所述的方法，其特征在于，所述處理子任務還包括：區塊驗證子任務、區塊提交子任務和同步與收尾子任務，其中處理子任務的順序依次為：區塊驗證子任務、賬戶版本驗證子任務、區塊提交子任務、賬戶更新子任務和同步與收尾子任務。