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

有效

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

本申請涉及一種任務處理方法及裝置，方法包括：接收任務處理請求，任務處理請求為同步操作請求；將任務處理請求中的待處理任務分解為多個子任務；將多個子任務分別發送至對應的RMQ隊列，其中每個RMQ隊列對應一個子任務；通過各個RMQ隊列分別執行對應的子任務，并監聽每個RMQ隊列的執行結果，執行結果包括成功或者失??；當監聽到RMQ隊列中的目標RMQ隊列的執行結果為失敗時，通過重試機制對目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止。本申請根據執行結果確定執行重試操作的RMQ隊列，實現僅對未執行成功的處理對象進行重試，保證了任務最終能夠成功執行的同時，不會造成資源浪費。

技術領域

本申請涉及數據處理領域，尤其涉及一種任務處理方法及裝置。

背景技術

隨著互聯網的發展，很多業務都可以在網上進行，比如電子金融業務、電商業務等。一般地，可以由流程引擎將業務所涉及的一個或多個執行步驟進行編排，構成相應的業務流程，再按照業務流程順序執行業務活動，從而實現業務目標。

對于一些業務場景，需要多個執行步驟同步完成，當每個步驟執行完成后，整個業務才算成功，如果某一個執行步驟失敗，則所有執行步驟重新執行，例如：有同步進行的10個執行步驟，9個執行步驟都成功了，1個執行步驟不成功，這時候需要先回滾到初始狀態，9個成功的步驟都需要重新再執行一次。這樣既造成了資源的浪費，也降低了處理效率。

發明內容

為了解決上述技術問題或者至少部分地解決上述技術問題，本申請提供了一種任務處理方法、裝置、電子設備及存儲介質。

根據本申請實施例的一個方面，提供了一種任務處理方法，包括：

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

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

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

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

當監聽到所述RMQ隊列中的目標RMQ隊列的執行結果為失敗時，通過重試機制對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止。

進一步的，所述通過各個所述RMQ隊列分別執行對應的子任務，并監聽每個RMQ隊列的執行結果，包括：

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

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

進一步的，所述當監測到所述RMQ隊列中的目標RMQ隊列的執行結果為失敗時，通過重試機制對所述目標RMQ隊列中的子任務進行重新執行，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止，包括：

將監聽到所述執行結果為失敗的RMQ隊列作為目標RMQ隊列；

確定所述目標RMQ隊列對應的目標處理對象的當前狀態；

根據所述當前狀態確定所述目標RMQ隊列的優先級；

根據所述優先級對所述目標RMQ隊列中的子任務執行重試操作，直到所有RMQ隊列中分別對應的子任務的執行結果均為成功為止。

進一步的，所述方法還包括：

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

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