[發明專利]一種分布式任務處理方法及系統

在審

• 申請號: 202210614760.6
• 申請日: 2022-05-30
• 公開（公告）號: CN114924861A
• 公開（公告）日: 2022-08-19
• 發明（設計）人: 顧晶磊
• 申請（專利權）人: 阿維塔科技（重慶）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54;G06F16/2455;G06F16/28
• 代理公司: 北京金蓄專利代理有限公司 11544
• 代理人: 程引

1.一種分布式任務處理方法，其特征在于，包括：

輪詢緩存數據庫中的延遲任務，得到至少一個到期延遲任務并發送至準備隊列；

從所述準備隊列獲取至少一個所述到期延遲任務；

將至少一個所述到期延遲任務分發至消息隊列以進行處理。

2.根據權利要求1所述的基于延遲隊列的分布式任務處理方法，其特征在于，所述輪詢緩存數據庫中的延遲任務，得到至少一個到期延遲任務并發送至準備隊列之前，所述方法還包括：

接收來自用戶的延遲消息請求；所述延遲消息請求中攜帶有時延信息；

根據所述延遲消息請求生成所述延遲任務；

基于所述時延信息將所述延遲任務寫入所述緩存數據庫。

3.根據權利要求2所述的方法，其特征在于，所述根據所述延遲消息請求生成所述延遲任務之后，所述方法還包括：

將所述延遲任務寫入關系數據庫。

4.根據權利要求3所述的方法，其特征在于，在所述將所述延遲任務寫入所述關系數據庫或所述緩存數據庫之后，所述方法還包括：

輸出所述延遲任務對應的任務標識至所述用戶。

5.根據權利要求3所述的方法，其特征在于，所述從所述準備隊列獲取至少一個所述到期延遲任務并分發至消息隊列以進行處理，具體包括：

從所述準備隊列中獲取待傳送的至少一個所述到期延遲任務至工作隊列；

在所述工作隊列中獲取至少一個所述到期延遲任務并分發至所述消息隊列進行處理。

6.根據權利要求5所述的方法，其特征在于，在所述工作隊列中獲取至少一個所述到期延遲任務并分發至所述消息隊列進行處理之后，還包括：

更改所述緩存數據庫和所述關系數據庫中所述到期延遲任務對應的任務狀態。

7.根據權利要求1所述的方法，其特征在于，在所述從所述準備隊列獲取至少一個所述到期延遲任務并分發至消息隊列以進行處理之前，所述方法還包括：

自注冊至所述緩存數據庫中；

按照預定間隔，與所述緩存數據庫通信，以獲取自身的工作狀態。

8.根據權利要求7所述的的方法，其特征在于，所述自注冊至所述緩存數據庫中，具體包括：

判斷所述緩存數據庫中是否存在宕機節點；

若是，則接管所述宕機節點；

若否，則生成新節點，并將所述新節點注冊至所述緩存數據庫中。

9.根據權利1所述的方法，其特征在于，若輪詢緩存數據庫中的延遲任務時所述緩存數據庫宕機，則所述方法還包括：

從所述關系數據庫中獲取所述緩存數據庫宕機時丟失的所述到期延遲任務；

將丟失的所述到期延遲任務發送至所述準備隊列，并執行所述從所述準備隊列獲取至少一個所述到期延遲任務的步驟。

10.一種基于延遲隊列的分布式任務處理系統，其特征在于，所述系統包括：輪詢器、緩存數據庫和工作節點；

所述輪詢器用于：輪詢所述緩存數據庫中的延遲任務，得到至少一個到期延遲任務并發送至準備隊列；

所述工作節點用于：從所述準備隊列獲取至少一個所述到期延遲任務，將至少一個所述到期延遲任務分發至消息隊列以進行處理。

11.根據權利10所述的系統，其特征在于，所述系統還包括：補償器；

所述補償器用于：從所述關系數據庫中獲取所述緩存數據庫宕機時丟失的所述到期延遲任務，并將丟失的所述到期延遲任務發送至所述準備隊列。