[發明專利]一種基于客戶端、服務器系統的分布式定時任務調度系統

有效

• 申請號: 201410689980.0
• 申請日: 2014-11-26
• 公開（公告）號: CN104536809B
• 公開（公告）日: 2018-01-19
• 發明（設計）人: 徐東;曹奎
• 申請（專利權）人: 上海瀚之友信息技術服務有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 上海正旦專利代理有限公司31200
• 代理人: 陸飛,盛志范

技術領域

本發明屬于客戶端、服務器系統的任務管理技術領域，具體涉及一種基于客戶端、服務器系統的分布式定時任務調度系統。

背景技術

目前，大多數項目工程需要有一套定時任務執行功能，即配置一個任務的啟動規則（例如：開始時間，間隔執行N次，某些情況下不執行等規則），再加上任務執行的主體（具體什么任務）。對于一個大公司來說，往往有很多業務，從而產生很多項目。每個項目又有多個定時任務。對于開發人員和運維人員來說，想要知道自己應用中定時任務的運行情況是什么樣的，就需要去運維那邊登陸遠程正式服務器進行日志查看；想要修改一些定時任務的規則，就需要修改代碼或者配置文件，重啟生效。運維人員維護全部項目的時候，對于任務執行情況缺乏一個完整的監控手段。

發明內容

本發明的目的在于提供一種能夠實時監控任務執行、動態修改執行規則的基于客戶端、服務器系統的分布式定時任務調度系統。

本發明提供的分布式定時任務調度系統，其構成如圖1所示，主要包括：應用服務器、核心調度服務器、WEB監控服務器、消息服務器和數據庫；其中：

所述應用服務器有若干個，采用分布式的集群服務器，主要是提供電子商務、充值、游戲、頁面等對外業務的服務，此類服務有定時任務的功能需求，例如在每天半夜進行數據的更新操作；該應用服務器給出多個任務執行地址到核心調度服務器，每個地址就是一個任務執行入口；

所述核心調度服務器有若干個，是一種統籌服務器，可以控制應用服務器在什么時間執行任務，并且可以收集應用服務器執行任務的結果；由于任務有很多個，每個核心調度服務器中都維護了一個任務池，任務池是一個存放所有任務的地方。

所述WEB監控服務器，用于對任務的執行時間和執行邏輯進行配置，并且至少提供任務的暫停、刪除、新增、查看、手動觸發等功能中的任意一種，同時提供對歷史任務的執行記錄查看；

所述消息服務器，作為一個代理，在WEB監控服務器配置完相關信息后，WEB監控服務器發送同步信息給消息服務器，由消息服務器把同步信息轉發到核心調度服務器；同步信息是指服務器之間通信的內容。

所述數據庫，用于存儲任務配置的信息、任務執行結束后的信息等。

本發明系統的執行流程如下（圖2）：

（1）WEB監控服務器負責進行任務信息的配置，配置完成后把信息數據保存進數據庫中，同時至少提供任務信息的查看、新增、修改、暫停、刪除等操作中的任意一種，操作后也會把對應的任務信息保存入數據庫；數據庫中保存的任務信息同時提供給WEB監控服務器進行查看等功能；

（2）當WEB監控服務器中的任務信息有新增、修改、暫停、刪除操作中的任意一種的時候，發送一個同步信息給消息服務器；

（3）消息服務器找到所有核心調度服務器，對每個核心調度服務器發送同步信息；由于核心調度服務器在啟動的時候會自動的到消息服務器上面進行注冊，所以消息服務器能找到在自己這里注冊的所有核心調度服務器；

（4）核心調度服務器收到通知后去數據庫中取出任務，放入任務池中進行監聽；

（5）當任務時間到達的時候，核心調度服務器通知應用服務器進行任務的執行，在通知應用服務器的同時，核心調度服務器在數據庫中記錄任務開始執行的信息；

（6）當應用服務器執行結束后，返回信息給核心調度服務器，核心調度服務器又把返回信息記錄進數據庫；此時WEB監控服務器可以通過數據庫查看任務的執行歷史。

下面對流程的各部分作進一步具體描述。

應用服務器啟動的時候，首先任務執行主體初始化，生成一個唯一地址；在WEB監控服務器中配置相對應的任務信息（包含以上所說的任務主體的地址，任務執行的時間規則，以及其他一些相關附帶屬性）；當配置完信息后，通知核心調度服務器，核心調度服務器根據通知過來的信息把需要新增或修改的任務加載（從數據庫中取出對應的任務）進來，并加入任務池中，當監聽發現有任務觸發的時候找到對應的任務主體地址進行遠程通知調用；當應用服務器執行結束后，應用服務器把執行結果發送回核心調度服務器。