[發明專利]分布式任務調度方法及其系統、存儲介質、電子設備

在審

• 申請號: 201810094656.2
• 申請日: 2018-01-31
• 公開（公告）號: CN108287764A
• 公開（公告）日: 2018-07-17
• 發明（設計）人: 孫傲林;蔣一新
• 申請（專利權）人: 上海攜程商務有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 上海隆天律師事務所 31282
• 代理人: 臧云霄;周駿

1.一種分布式任務調度方法，其特征在于，所述分布式任務調度方法用于分布式任務調度系統的任務調度，所述分布式任務調度系統包括至少一任務生產者、至少一任務消費者、注冊中心以及管理中心，所述分布式任務調度方法包括如下步驟：

S10：所述任務生產者和所述任務消費者分別向所述注冊中心進行注冊；

S20：所述注冊中心將所有所述任務生產者和所述任務消費者的注冊信息發送至所述管理中心，所述管理中心緩存所述任務生產者和所述任務消費者的信息；

S30：由一所述任務生產者生成任務列表，并將所述任務列表推送至所述管理中心；

S40：所述管理中心接收并落地所述任務列表；

S50：所述管理中心設置任務分配規則，并實時根據所述任務分配規則分配各項任務；

S60：所述任務消費者接收所述管理中心分配的任務；

S70：所述任務消費者處理任務后，反饋任務處理的結果至所述管理中心。

2.如權利要求1所述的分布式任務調度方法，其特征在于，多個所述任務生產者之間才用主—備方式進行切換，同一時刻僅有一個所述任務生產者在工作。

3.如權利要求1所述的分布式任務調度方法，其特征在于，所述步驟S30還包括如下步驟：

S301：所述任務生產者生成至少一待處理任務；

S302：將所述待處理任務拆分為多個子任務，多個所述子任務形成一任務列表；

S303：將所述任務列表推送至所述管理中心；

S304：向所述注冊中心發出取消注冊的消息。

4.如權利要求3所述的分布式任務調度方法，其特征在于，所述注冊中心接收所述任務生產者或所述任務消費者發出的取消注冊的消息后，將該取消注冊的消息轉發至所述管理中心，所述管理中心接收到該取消注冊的消息后等待一秒后，選擇另一個所述任務生產者接收任務列表或選擇另一個所述任務消費者分配任務。

5.如權利要求1所述的分布式任務調度方法，其特征在于，所述管理中心包括Rest接口，所述管理中心通過所述Rest接口接收所述任務生產者發出的任務列表、接收所述任務生產者反饋的任務處理的結果，并且發出啟動或者停止的指令。

6.如權利要求1所述的分布式任務調度方法，其特征在于，在所述步驟S70中，任務消費者通過ACK控制字符反饋任務處理的結果發送至所述注冊中心，并且通過所述注冊中心修改所述管理中心的當前任務狀態信息。

7.如權利要求1至6中任一項所述的分布式任務調度方法，其特征在于，所述注冊中心為Zookeeper。

8.一種分布式任務調度系統，其特征在于，所述分布式任務調度系統包括至少一任務生產者、至少一任務消費者、注冊中心以及管理中心；

其中，所述任務生產者用于生成任務并拆分任務后形成任務列表，并將所述任務列表推送至所述管理中心；

所述任務消費者用于接收所述管理中心分配的任務，并且處理任務后，反饋任務處理的結果至所述管理中心；

所述注冊中心用于將所有所述任務生產者和所述任務消費者的注冊信息發送至所述管理中心、對所述任務生產者和所述任務消費者進行注冊；

所述管理中心用于緩存所述任務生產者和所述任務消費者的信息、接收并落地所述任務列表、設置任務分配規則、實時根據所述任務分配規則分配各項任務、啟動或停止更改作業的調度周期，監控任務的進度。

9.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現權利要求1至7中任一項所述的分布式任務調度方法的步驟。

10.一種電子設備，其特征在于，包括：

處理器；以及

存儲器，用于存儲所述處理器的可執行指令；

其中，所述處理器配置為經由執行所述可執行指令來執行權利要求1至7中任一項所述的分布式任務調度方法的步驟。