[發明專利]一種基于Websocket的任務管理系統及方法

在審

• 申請號: 201910399088.1
• 申請日: 2019-05-14
• 公開（公告）號: CN110138858A
• 公開（公告）日: 2019-08-16
• 發明（設計）人: 路彬;蔣波
• 申請（專利權）人: 北京杰思安全科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京酷愛智慧知識產權代理有限公司 11514
• 代理人: 向霞

1.一種基于Websocket的任務管理系統，其特征在于，包括：

任務管理接口模塊，用于向服務器提供RESTful API接口，用于添加、刪除任務，查詢任務執行情況；

任務處理模塊，用于根據業務需求，向客戶端添加任務處理邏輯；

Websocket接口模塊，用于通過Websocket協議建立服務器與客戶端的連接關系；用于輔助服務器向客戶端發送任務，接收并向服務器發送由客戶端發送的任務執行結果。

2.如權利要求1所述的系統，其特征在于，還包括數據存儲模塊，所述數據存儲模塊與所述任務處理模塊進行數據對接，所述任務處理模塊與所述Websocket接口模塊進行數據對接，具體為：

在所述Websocket接口模塊向客戶端發送任務前，所述任務處理模塊先將所述任務保存進所述數據存儲模塊，再將所述任務發送給所述Websocket接口模塊；

所述Websocket接口模塊接收并向服務器發送由客戶端發送的任務執行結果的同時，將所述任務執行結果發送給所述任務處理模塊，再由所述任務處理模塊將所述執行結果保存進所述數據存儲模塊。

3.如權利要求2所述的系統，其特征在于，通過所述Websocket接口模塊將任務發送給客戶端時，所述Websocket接口模塊還用于：

判斷所述客戶端與所述服務器連接是否正常，若是則將所述任務直接發送給所述客戶端；

否則當監控到所述客戶端與所述服務器正常連接后，向所述任務處理模塊發送查詢待發送任務的請求，并接收由所述任務處理模塊返回的查詢數據，根據所述查詢數據向所述客戶端發送任務；

所述查詢數據為所述客戶端待執行的任務，由所述任務處理模塊根據所述查詢待發送任務的請求，在所述數據存儲模塊中查詢得到的。

4.如權利要求3所述的系統，其特征在于，還包括執行時間監控模塊，具體用于：

在所述Websocket接口模塊將任務發送給客戶端后，開始計時，判斷所述Websocket接口模塊是否在預設時間內接收到了由所述客戶端發送的任務執行結果，若是則關閉計時；否則視為所述客戶端執行任務超時，并向所述任務處理模塊反饋超時信息。

5.如權利要求4所述的系統，其特征在于，還包括身份驗證模塊，用于接收客戶端發送的注冊請求，并為客戶端分配唯一標識符，所述標識符用于客戶端與服務器連接時的身份驗證；

或用于監控客戶端與服務器的連接狀態，當監控到至少兩個客戶端使用同一標識符與服務器連接時，使用Ping/Pong消息包驗證相應連接是否均有效，若是，則分別向相應客戶端發送重新注冊的消息；否則刪除無效的連接。

6.一種基于Websocket的任務管理方法，其特征在于，包括：

服務器與客戶端通過Websocket協議進行連接；

所述服務器通過RESTful API接口對任務進行管理；

所述服務器通過Websocket接口向所述客戶端發送待執行任務，并根據業務需求，向所述客戶端添加任務處理邏輯；

所述服務器通過所述Websocket接口接收由所述客戶端發送的任務執行結果；

所述通過RESTful API接口對任務進行管理，包括：添加、刪除任務，查詢任務執行情況。

7.如權利要求6所述的方法，其特征在于，所述服務器通過Websocket接口向所述客戶端發送待執行任務前，所述方法還包括：

將所述待執行任務存進數據庫；

所述服務器通過所述Websocket接口接收由所述客戶端發送的任務執行結果的同時，所述方法還包括：

將所述執行結果存進所述數據庫。