[發(fā)明專利]一種分布式調(diào)度方法、系統(tǒng)、存儲介質(zhì)和設(shè)備

有效

• 申請?zhí)枺?/td>: 202010418887.1
• 申請日: 2020-05-18
• 公開（公告）號: CN111597056B
• 公開（公告）日: 2023-06-30
• 發(fā)明（設(shè)計）人: 閆永濤
• 申請（專利權(quán)）人: 北京思特奇信息技術(shù)股份有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52;G06F9/50
• 代理公司: 北京輕創(chuàng)知識產(chǎn)權(quán)代理有限公司 11212
• 代理人: 厲洋洋

1.一種分布式調(diào)度方法，其特征在于，包括以下步驟：

以輪詢的方式向應(yīng)用服務(wù)器列表中的每一個應(yīng)用服務(wù)器發(fā)送探測報文；

若不存在zookeeper臨時節(jié)點且接收到被輪詢到的所述應(yīng)用服務(wù)器發(fā)出的應(yīng)答報文，則創(chuàng)建所述zookeeper臨時節(jié)點，以便被輪詢到的所述應(yīng)用服務(wù)器獲得分布式鎖，使得僅被輪詢到的所述應(yīng)用服務(wù)器能夠執(zhí)行任務(wù)；

所述方法還包括：

若存在所述zookeeper臨時節(jié)點且接收到被輪詢到的所述應(yīng)用服務(wù)器發(fā)出的應(yīng)答報文，則將被輪詢到的所述應(yīng)用服務(wù)器加入等待隊列中；

按照預(yù)設(shè)時間周期探測是否存在所述zookeeper臨時節(jié)點，若否，則從所述等待隊列中提取所述應(yīng)用服務(wù)器，并向所述應(yīng)用服務(wù)器發(fā)送所述探測報文，若接收到所述應(yīng)用服務(wù)器的應(yīng)答報文，則創(chuàng)建所述zookeeper臨時節(jié)點；

所述等待隊列包括高優(yōu)先級等待隊列和低優(yōu)先級等待隊列，所述從所述等待隊列中提取所述應(yīng)用服務(wù)器，具體包括：

當(dāng)所述高優(yōu)先級等待隊列不為空時，提取所述高優(yōu)先級等待隊列中的應(yīng)用服務(wù)器；

否則，提取所述低優(yōu)先級等待隊列中的應(yīng)用服務(wù)器。

2.根據(jù)權(quán)利要求1所述的分布式調(diào)度方法，其特征在于，所述應(yīng)用服務(wù)器包括高優(yōu)先級應(yīng)用服務(wù)器和低優(yōu)先級應(yīng)用服務(wù)器，所述將被輪詢到的所述應(yīng)用服務(wù)器加入等待隊列中，具體包括：

將所述高優(yōu)先級應(yīng)用服務(wù)器加入所述高優(yōu)先級等待隊列中；

將所述低優(yōu)先級所述應(yīng)用服務(wù)器加入所述低優(yōu)先級等待隊列中。

3.根據(jù)權(quán)利要求1或2所述的分布式調(diào)度方法，其特征在于，所述以輪詢的方式向應(yīng)用服務(wù)器列表中的每一個應(yīng)用服務(wù)器發(fā)送探測報文之前，還包括：

創(chuàng)建公共存儲區(qū)，并將所述應(yīng)用服務(wù)器列表存儲至所述公共存儲區(qū)內(nèi)。

4.一種分布式調(diào)度系統(tǒng)，其特征在于，所述分布式調(diào)度系統(tǒng)包括zookeeper服務(wù)器和多個應(yīng)用服務(wù)器；

所述zookeeper服務(wù)器向應(yīng)用服務(wù)器列表中的每一個應(yīng)用服務(wù)器輪詢發(fā)送探測報文；

若所述zookeeper服務(wù)器不存在zookeeper臨時節(jié)點且被輪詢到的所述應(yīng)用服務(wù)器發(fā)出應(yīng)答報文，則在所述zookeeper服務(wù)器上創(chuàng)建所述zookeeper臨時節(jié)點，被輪詢到的所述應(yīng)用服務(wù)器獲得分布式鎖，僅被輪詢到的所述應(yīng)用服務(wù)器能夠執(zhí)行任務(wù)；

若所述zookeeper服務(wù)器上存在所述zookeeper臨時節(jié)點且接收到被輪詢到的所述應(yīng)用服務(wù)器發(fā)出的應(yīng)答報文，則將所述被輪詢到的所述應(yīng)用服務(wù)器加入等待隊列中；

所述zookeeper服務(wù)器按照預(yù)設(shè)時間周期探測是否存在所述zookeeper臨時節(jié)點，若否，則從所述等待隊列中提取所述應(yīng)用服務(wù)器，并向所述應(yīng)用服務(wù)器發(fā)送所述探測報文，若接收到所述應(yīng)用服務(wù)器的應(yīng)答報文，則創(chuàng)建所述zookeeper臨時節(jié)點；

所述等待隊列包括高優(yōu)先級等待隊列和低優(yōu)先級等待隊列；

當(dāng)所述高優(yōu)先級等待隊列不為空時，所述zookeeper服務(wù)器提取所述高優(yōu)先級等待隊列中的應(yīng)用服務(wù)器；

否則，所述zookeeper服務(wù)器提取所述低優(yōu)先級等待隊列中的應(yīng)用服務(wù)器。

5.一種計算機(jī)可讀存儲介質(zhì)，包括指令，其特征在于，當(dāng)所述指令在計算機(jī)上運(yùn)行時，使所述計算機(jī)執(zhí)行根據(jù)權(quán)利要求1-3中任一項所述的分布式調(diào)度方法的步驟。

6.一種計算機(jī)設(shè)備，包括存儲器、處理器及存儲在所述存儲器上的并可在所述處理器上運(yùn)行的計算機(jī)程序，其特征在于，所述處理器執(zhí)行所述程序時實現(xiàn)如權(quán)利要求1-3中任一項所述的分布式調(diào)度方法的步驟。