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

在審

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

本發明公開了一種基于Websocket的任務管理系統及方法，包括：任務管理接口模塊，用于向服務器提供RESTful API接口，用于添加、刪除任務，查詢任務執行情況；任務處理模塊，用于根據業務需求，向客戶端添加任務處理邏輯；Websocket接口模塊，用于通過Websocket協議建立服務器與客戶端的連接關系；用于輔助服務器向客戶端發送任務，接收并向服務器發送由客戶端發送的任務執行結果。本發明利用Websocket協議進行網絡任務管理，通過一個連接來發送和接收任務或消息，不需要客戶端重新建立連接，有效提高任務管理效率。

技術領域

本發明涉及網絡任務管理技術領域，具體涉及一種基于Websocket的任務管理系統及方法。

背景技術

在C/S(Client/Server)架構場景中，借助第三方消息隊列產品實現服務器發布任務或消息給客戶端，第三方消息隊列產品包括RabbitMQ、kafka、ZooKeeper等，通過這些軟件，服務器將任務下發給客戶端，客戶端完成任務執行后再和服務器建立新的連接，用來返回任務的執行結果。該過程中常用的任務分發架構包括三種，第一種是推送模式，即當有任務需要發布時，服務器主動發起和客戶端的連接，將任務下發；第二種是拉模式，即客戶端定期連接服務器，查詢是否有需要發給自己的任務，若是則取回任務開始執行，否則等待下一次查詢；第三種是長輪詢，這種方式也是由客戶端向服務器發起連接，和拉模式不同的是，即使沒有需要發給客戶端的任務，連接也不中斷，直到有任務需要發給客戶端時，服務器再返回數據，并關閉連接。

上述三種架構，推送模式需要客戶端主動打開一個端口進行監聽，會增加客戶端的安全風險，同時如果客戶端在NAT等網絡設備后面，則無法進行工作；拉模式雖然避免了推送模式的弱點，但需要客戶端定期去服務器查詢，當客戶端數量很多時，這種頻繁的查詢會增加服務器的壓力；長輪詢在拉模式上進行了改進，減少了很多不必要的查詢請求次數，但同樣需要客戶端在完成任務執行后再發起一個連接向服務器返回執行結果。綜上，現有技術中缺少一種長連接模式的網絡任務管理方法。

發明內容

針對上述現有技術中的缺陷，本發明提供一種基于Websocket的任務管理系統及方法，用于C/S模式下，服務器向指定的一個或多個客戶端發布任務，并等待客戶端完成任務執行后的返回結果。

本發明具體包括：

一種基于Websocket的任務管理系統，包括：

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

任務處理模塊，用于根據業務需求，向客戶端添加任務處理邏輯；例如，對于正在執行任務的客戶端，在當前任務執行結束后才能下發新的任務；

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

所述服務器和客戶端均可以為多個。

進一步地，還包括數據存儲模塊，所述數據存儲模塊與所述任務處理模塊進行數據對接，所述任務處理模塊與所述Websocket接口模塊進行數據對接，具體為：

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

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