[發明專利]分布式任務處理系統

有效

• 申請號: 202010322658.X
• 申請日: 2020-04-22
• 公開（公告）號: CN111538604B
• 公開（公告）日: 2023-03-28
• 發明（設計）人: 黃威
• 申請（專利權）人: 北京字節跳動網絡技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京遠智匯知識產權代理有限公司 11659
• 代理人: 范坤坤

本公開實施例公開了一種分布式任務處理系統。該系統包括：任務配置子系統包含至少兩個任務配置設備，每個任務配置設備用于接收任務配置信息，并將任務配置信息發送至任務解析子系統；任務解析子系統用于解析各任務配置信息中的同一個任務配置信息，確定任務周期和任務執行指令，并依據任務周期設置定時器，以及在定時器被觸發時，將任務執行指令寫入任務配置信息對應的消息隊列；下游服務子系統包含至少兩個下游服務處理設備，下游服務處理設備用于依據消息隊列中的任務執行指令處理任務配置信息對應的定時任務。通過上述技術方案，實現了分布式系統中定時任務的合理配置，提高了分布式系統穩定性。

技術領域

本公開實施例涉及計算機技術，尤其涉及一種分布式任務處理系統。

背景技術

隨著互聯網技術發展，諸如支付系統、電商系統、網絡購票系統等均采用分布式系統來提供相應服務，并且這些分布式系統中都會存在一些定時任務，如支付系統中的每天定點清算、電商系統中的整點搶購以及網絡購票系統中定時回收未支付訂單的售票等。

參見圖1，目前分布式系統中的定時任務處理方式為：分布式系統的任務處理總控單機101通過標準輸入設備接收用戶輸入的定時任務對應的crontab命令，并將其存放于“crontab”文件中；之后，該任務處理總控單機101解析“crontab”文件中的定時任務信息，并通過分布式系統的推送機制，將該定時任務信息分發給該分布式系統中的某一個下游服務器102，以便該下游服務器102處理并執行該定時任務。

但是，上述分布式系統中定時任務的處理方式存在如下問題：定時任務的配置和解析均在任務處理總控單機中實現，如果該總控單機故障，則會導致整個分布式系統的定時任務處理中斷。即任務處理總控單機的不穩定性會導致整個分布式系統中定時任務處理流程癱瘓，進而影響整個分布式系統的穩定性。

發明內容

本公開提供一種分布式任務處理系統，以實現分布式系統中定時任務的合理配置，提高定時任務處理的穩定性，進而提高分布式系統穩定性。

本公開實施例提供了一種分布式任務處理系統，該系統包括：任務配置子系統、任務解析子系統和下游服務子系統，其中，

所述任務配置子系統包含至少兩個任務配置設備，每個所述任務配置設備用于接收任務配置信息，并將所述任務配置信息發送至任務解析子系統；

所述任務解析子系統用于解析各所述任務配置信息中的同一個所述任務配置信息，確定任務周期和任務執行指令，并依據所述任務周期設置定時器，以及在所述定時器被觸發時，將所述任務執行指令寫入所述任務配置信息對應的消息隊列；

所述下游服務子系統包含至少兩個下游服務處理設備，所述下游服務處理設備用于依據所述消息隊列中的所述任務執行指令處理所述任務配置信息對應的定時任務。

本公開實施例通過將分布式系統中的定時任務的配置和解析分別拆分至任務配置子系統和任務解析子系統，解決了因任務處理總控單機故障而導致的定時任務的配置和解析均失敗的問題，一定程度上提高了分布式系統中處理定時任務的穩定性。通過將任務配置子系統設置為分布式，即任務配置子系統中至少包含兩個任務配置設備，實現了定時任務配置的備份式處理，確保了定時任務的成功配置，進一步提升了分布式系統中定時任務處理的穩定性。

附圖說明

結合附圖并參考以下具體實施方式，本公開各實施例的上述和其他特征、優點及方面將變得更加明顯。貫穿附圖中，相同或相似的附圖標記表示相同或相似的元素。應當理解附圖是示意性的，原件和元素不一定按照比例繪制。

圖1是現有技術中的分布式系統中定時任務處理的系統結構示意圖；

圖2是本公開實施例一中的一種分布式任務處理系統的結構示意圖；

圖3是本公開實施例二中的一種分布式任務處理系統的結構示意圖；