本發明的實施例提供了一種有序任務的執行方法、執行裝置和執行系統。其中，有序任務的執行方法包括：接收任務信息；對任務信息進行分組排序存儲；獲取任務執行器組的工作狀態；基于任務執行器組的空閑狀態，發送待執行任務組至任務執行器組；將任務執行器組執行完成的任務信息分組排序存儲至完成任務集。通過對接收的任務信息按照組號和序號進行分組排序存儲，以及將任務執行器組執行完成的任務信息分組排序存儲至完成任務集，解決了分布式系統中多個有序的任務進行異步按序執行的問題，從而確保了任務組中的任務信息的一致性。

技術領域

本發明涉及計算機領域，具體而言，涉及一種有序任務的執行方法、有序任務的執行裝置、有序任務的執行系統和可讀存儲介質。

背景技術

由于分布式系統的特性，不同的任務可能在多個應用服務器中執行。但存在一些業務場景，需要保證一組任務的有序執行，并且需要保證這樣一組有相關性和順序性的任務的一致性。

相關技術中，大多是在業務代碼中判斷是否執行冪等邏輯。然而，代碼復雜度高、可讀性差、維護成本高，并且不具有一般性，使得業務代碼中判斷邏輯的復雜性高、重復性高，并且可用性差，以致無法保證有序任務的執行以及任務失敗后冪等業務邏輯的統一調用。

發明內容

本發明旨在至少解決現有技術或相關技術中存在的技術問題之一。

為此，本發明的實施例的第一個方面在于提出了一種有序任務的執行方法。

本發明的實施例的第二個方面在于提出了一種有序任務的執行裝置。

本發明的實施例的第三個方面在于提出了一種有序任務的執行系統。

本發明的實施例的第四個方面在于提出了一種可讀存儲介質。

有鑒于此，根據本發明的實施例的第一個方面，提出了一種有序任務的執行方法，包括：接收任務信息，其中，任務信息攜帶有組號和序號；根據組號和序號，對任務信息進行分組排序存儲，以生成待執行任務組；獲取任務執行器組的工作狀態；基于任務執行器組的空閑狀態，發送待執行任務組至任務執行器組，以供任務執行器組執行待執行任務組；將任務執行器組執行完成的任務信息分組排序存儲至完成任務集。

本發明實施例提供的有序任務的執行方法，通過接收攜帶有組號和序號的任務信息，以便對接收的任務信息按照組號和序號進行分組排序存儲，并生成待執行任務組，使得任務執行器組在執行待執行任務組時，能夠按照任務信息在待執行任務組中的排序進行執行，從而實現所有的任務信息能夠按照既定的順序執行，保證一組內有相關性和順序性的任務信息執行順序的一致性。具體地，在進行分組排序存儲時，將任務信息按照組號進行分組，并按照序號確定任務信息在組內的順序。進一步地，通過將任務執行器組執行完成的任務信息分組排序存儲至完成任務集，以便在完成任務集中判斷是否執行冪等邏輯，從而不必在業務代碼中判斷是否執行冪等邏輯，降低了判斷冪等邏輯的復雜性、重復性問題，從而保證了任務執行失敗后冪等業務邏輯的統一調用能夠實現。更進一步的，通過對接收的任務信息按照組號和序號進行分組排序存儲，以及將任務執行器組執行完成的任務信息分組排序存儲至完成任務集，解決了分布式系統中多個有序的任務進行異步按序執行的問題，以及當其他任務執行出現異常后，進行冪等回滾其他已經執行完成的任務，從而確保任務組中的任務信息的一致性，進而同時實現了確保有序任務組中的任務的有序執行和任務失敗后的統一冪等回滾邏輯調用。

另外，根據本發明提供的上述技術方案中的有序任務的執行方法，還可以具有如下附加技術特征：

在上述技術方案中，任務執行器組執行待執行任務組的步驟，具體包括：獲取待執行任務組中的任務信息；根據任務信息的序號，判斷當前任務信息的前一任務信息是否存在于完成任務集；基于前一任務信息存在于完成任務集的判斷結果，執行當前任務信息。