[發(fā)明專利]任務(wù)分發(fā)方法、服務(wù)器、客戶端和系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201910006736.2
• 申請日: 2019-01-04
• 公開（公告）號: CN109766201A
• 公開（公告）日: 2019-05-17
• 發(fā)明（設(shè)計）人: 高肇捷;叢新法;王曉明;張輝;李光明;顧傳兵;王文華;宋魯鵬;崔忠輝;趙風(fēng)飛
• 申請（專利權(quán)）人: 中國聯(lián)合網(wǎng)絡(luò)通信集團有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/48
• 代理公司: 北京同立鈞成知識產(chǎn)權(quán)代理有限公司 11205
• 代理人: 胡艾青;劉芳

本發(fā)明提供一種任務(wù)分發(fā)方法、服務(wù)器、客戶端和系統(tǒng)，通過在定時時刻到達時，確定與所述定時時刻匹配的至少一個定時任務(wù)；根據(jù)所述至少一個定時任務(wù)，分別生成指令消息并將所述指令消息均存入第一消息隊列，每個所述指令消息對應(yīng)一個所述定時任務(wù)，實現(xiàn)指令消息生成與分發(fā)之間的異步，提高了任務(wù)分發(fā)的靈活性和效率，在從所述第一消息隊列逐個接收到所述指令消息時，將所述指令消息分發(fā)給目標(biāo)客戶端，所述目標(biāo)客戶端與所述指令消息對應(yīng)的定時任務(wù)相匹配，由此形成的非阻塞模式提高了任務(wù)分發(fā)的速度和效率。

技術(shù)領(lǐng)域

本發(fā)明涉及信號處理技術(shù)，尤其涉及一種任務(wù)分發(fā)方法、服務(wù)器、客戶端和系統(tǒng)。

背景技術(shù)

在各類計算機的日常運維工作中，通常需要以不同的時間間隔執(zhí)行各種定時任務(wù)，以對計算機中的軟件或硬件進行周期性維護和配置。計算機需要對這些任務(wù)進行周期性且合理的任務(wù)分發(fā)。

常用的任務(wù)分發(fā)方法一般需要依賴于計算機本地的crontab服務(wù)進行任務(wù)配置、管理和執(zhí)行。通過在計算機中完成一次crontab服務(wù)的初始配置，計算機就能自動維護該crontab服務(wù)，對本地的定時任務(wù)周期性執(zhí)行。

但隨著分布式架構(gòu)的推廣，運維操作不再局限于少量的幾臺服務(wù)器。對成百上千臺計算機使用crontab服務(wù)進行日常的運維操作，需要人工登錄到每臺計算機進行手工修改，增加了巨大工作量。現(xiàn)有的任務(wù)分發(fā)方法中，crontab服務(wù)不能跨網(wǎng)絡(luò)，只能針對本地服務(wù)，難以用于多臺計算機定時任務(wù)的分發(fā)管控。

發(fā)明內(nèi)容

本發(fā)明提供一種任務(wù)分發(fā)方法、服務(wù)器、客戶端和系統(tǒng)，通過服務(wù)器以消息隊列進行統(tǒng)一任務(wù)分發(fā)，實現(xiàn)對多臺客戶端的定時任務(wù)執(zhí)行的管控。

根據(jù)本發(fā)明的第一方面，提供一種任務(wù)分發(fā)方法，包括：

在定時時刻到達時，確定與所述定時時刻匹配的至少一個定時任務(wù)；

根據(jù)所述至少一個定時任務(wù)，分別生成指令消息并將所述指令消息均存入第一消息隊列，每個所述指令消息對應(yīng)一個所述定時任務(wù)；

在從所述第一消息隊列逐個接收到所述指令消息時，將所述指令消息分發(fā)給目標(biāo)客戶端，所述目標(biāo)客戶端與所述指令消息對應(yīng)的定時任務(wù)相匹配。

可選地，所述在從所述第一消息隊列逐個接收到所述指令消息時，將所述指令消息分發(fā)給目標(biāo)客戶端，所述目標(biāo)客戶端與所述指令消息對應(yīng)的定時任務(wù)相匹配，包括：

在從所述第一消息隊列逐個接收到所述指令消息時，從每個所述指令消息中解析得到至少一個目標(biāo)主機標(biāo)識，所述目標(biāo)主機標(biāo)識指示了所述指令消息對應(yīng)的定時任務(wù)預(yù)設(shè)的執(zhí)行主機；

根據(jù)每個所述目標(biāo)主機標(biāo)識，在備選客戶端中確定與所述指令消息對應(yīng)的定時任務(wù)相匹配的目標(biāo)客戶端，所述目標(biāo)客戶端的主機標(biāo)識與所述目標(biāo)主機標(biāo)識一致；

將所述指令消息分發(fā)給所述目標(biāo)客戶端。

可選地，所述在定時時刻到達時，確定與所述定時時刻匹配的至少一個定時任務(wù)，包括：

根據(jù)預(yù)存儲的每個備選任務(wù)的第一發(fā)布時刻和預(yù)設(shè)的執(zhí)行頻率，獲得每個備選任務(wù)的第二發(fā)布時刻；

在獲取到指示定時時刻到達的信息時，從所有所述備選任務(wù)中，獲取第二發(fā)布時刻與所述定時時刻一致的至少一個備選任務(wù)；

將所述至少一個備選任務(wù)，確定為與所述定時時刻匹配的定時任務(wù)，并將所述第二發(fā)布時刻重新確定為所述至少一個備選任務(wù)的第一發(fā)布時刻。

可選地，所述根據(jù)所述至少一個定時任務(wù)，分別生成指令消息，包括：

獲取每個定時任務(wù)預(yù)設(shè)的目標(biāo)主機標(biāo)識、目標(biāo)運行目錄、目標(biāo)用戶標(biāo)識、調(diào)用命令；

將每個定時任務(wù)的所述目標(biāo)主機標(biāo)識、目標(biāo)運行目錄、目標(biāo)用戶標(biāo)識、調(diào)用命令生成一個指令消息。