[發明專利]一種任務處理方法及裝置

有效

• 申請號: 202011024978.3
• 申請日: 2020-09-25
• 公開（公告）號: CN112099935B
• 公開（公告）日: 2023-09-01
• 發明（設計）人: 王平;徐婷;柯登科
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/52;G06F11/30
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 沈園園;孫劍鋒

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

接收任務處理請求，所述任務處理請求為同步操作請求；

將所述任務處理請求中的待處理任務分解為多個子任務；

將所述多個子任務分別發送至對應的RMQ隊列，其中每個RMQ隊列對應一個子任務；

通過各個所述RMQ隊列分別執行對應的子任務，并監聽每個RMQ隊列的執行結果，所述執行結果包括成功或者失敗；

當監聽到所述RMQ隊列中的目標RMQ隊列的執行結果為失敗時，通過重試機制對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止，包括：將監聽到所述執行結果為失敗的RMQ隊列作為目標RMQ隊列；確定所述目標RMQ隊列對應的目標處理對象的當前狀態，所述當前狀態為空閑狀態或工作狀態；根據所述當前狀態確定所述目標RMQ隊列的優先級，其中，若當前狀態為工作狀態，則根據獲取的執行進度確定所述目標RMQ隊列執行重試操作的優先級，執行進度越高的優先級越高，若當前狀態為空閑狀態，則所述目標RMQ隊列執行重試操作的優先級最高；根據所述優先級對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止。

2.根據權利要求1所述的方法，其特征在于，所述通過各個所述RMQ隊列分別執行對應的子任務，并監聽每個RMQ隊列的執行結果，包括：

通過所述RMQ隊列將所述子任務發送至對應的處理對象，其中每個RMQ隊列對應一個處理對象；

基于所述RMQ隊列獲取所述處理對象執行所述子任務反饋的執行結果，所述執行結果包括成功或者失敗。

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

確定所述目標RMQ隊列執行重試操作的執行次數；

獲取預設重試時間設置規則；

根據所述執行次數以及所述預設重試時間設置規則，確定下一次執行重試操作與本次執行重試操作之間的時間間隔。

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

當所述執行次數等于預設閾值時，更新所述待處理任務的處理狀態；

將所述處理狀態發送至終端設備；

接收所述終端設備根據所述處理狀態反饋的指示信息；

根據所述指示信息對所述待處理任務執行相應的處理操作。

5.一種任務處理裝置，其特征在于，包括：

獲取模塊，用于接收任務處理請求，所述任務處理請求為同步操作請求；

分解模塊，用于將所述任務處理請求中的待處理任務分解為多個子任務；

分發模塊，用于將所述多個子任務分別發送至對應的RMQ隊列，其中每個RMQ隊列對應一個子任務；

監聽模塊，用于通過各個所述RMQ隊列分別執行對應的子任務，并監聽每個RMQ隊列的執行結果，所述執行結果包括成功或者失敗；

重試模塊，用于當監聽到所述RMQ隊列中的目標RMQ隊列的執行結果為失敗時，通過重試機制對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止，包括：將監聽到所述執行結果為失敗的RMQ隊列作為目標RMQ隊列；確定所述目標RMQ隊列對應的目標處理對象的當前狀態，所述當前狀態為空閑狀態或工作狀態；根據所述當前狀態確定所述目標RMQ隊列的優先級，其中，若當前狀態為工作狀態，則根據獲取的執行進度確定所述目標RMQ隊列執行重試操作的優先級，執行進度越高的優先級越高，若當前狀態為空閑狀態，則所述目標RMQ隊列執行重試操作的優先級最高；根據所述優先級對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止。

6.根據權利要求5所述的裝置，其特征在于，所述監聽模塊，用于通過所述RMQ隊列將所述子任務發送至對應的處理對象，其中每個RMQ隊列對應一個處理對象，基于所述RMQ隊列獲取所述處理對象執行所述子任務反饋的執行結果，所述執行結果包括成功或者失敗。