[發明專利]分布式任務調度系統及方法

有效

• 申請號: 201710146536.8
• 申請日: 2017-03-13
• 公開（公告）號: CN108572863B
• 公開（公告）日: 2022-07-12
• 發明（設計）人: 余英;趙予汐;王欣剛;張越月;張謙;張若純;張新強
• 申請（專利權）人: 國家新聞出版廣電總局廣播電視衛星直播管理中心
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;H04N17/00;H04N21/442
• 代理公司: 北京德恒律治知識產權代理有限公司 11409
• 代理人: 章社杲;盧軍峰

1.一種分布式任務調度系統，其特征在于，包括：

調度模塊以及與所述調度模塊通信連接的多個任務執行模塊；

所述調度模塊用于獲取任務請求，并根據所述任務請求向相應的任務執行模塊分發任務以完成所述任務請求；

多個任務請求模塊，與所述調度模塊均通信連接，用于根據需求生成所述任務請求；

其中，所述調度模塊還用于將多個任務執行模塊的任務執行結果返回至相應的任務請求模塊，以使所述任務請求模塊對返回的任務執行結果進行分析，從而實現對各個控制機頂盒的測試結果進行自動分析和判斷，

存儲模塊，通信連接于所述任務請求模塊和所述多個任務執行模塊，

其中，所述多個任務執行模塊中各個任務執行模塊將任務結果存至所述存儲模塊，以及所述任務請求模塊通過所述存儲模塊獲取所述任務結果，

其中通過所述存儲模塊采集機頂盒的日志文件，進一步經所述任務請求模塊對所述日志文件進行自動分析生成測試結果，從而對各個機頂盒進行自動測試。

2.根據權利要求1所述的分布式任務調度系統，其特征在于，

所述任務的數量為多個；

其中，所述多個任務的處理時序均與所述任務請求相符合。

3.根據權利要求2所述的分布式任務調度系統，其特征在于，

所述調度模塊根據所述任務請求對所述任務請求進行封裝，還用于將封裝后的任務請求分解為所述多個任務。

4.根據權利要求1所述的分布式任務調度系統，其特征在于，還包括：

消息中間件，通信連接于所述調度模塊和所述多個任務執行模塊之間；

其中，所述調度模塊通過所述消息中間件將所述多個任務分發至所述相應的任務執行模塊，且所述相應的任務執行模塊通過所述消息中間件向所述調度模塊返回任務執行結果。

5.根據權利要求1所述的分布式任務調度系統，其特征在于，還包括監測模塊，用于獲取所述多個任務執行模塊中各個任務執行模塊的任務狀態。

6.根據權利要求5所述的分布式任務調度系統，其特征在于，所述監測模塊還用于根據所述任務狀態注銷任務模塊或創建任務模塊。

7.一種任務調度方法，其特征在于，包括：

獲取任務請求；以及

根據所述任務請求向相應的任務執行模塊分發任務以完成所述任務請求；

多個任務請求模塊根據需求生成所述任務請求；

其中，將多個任務執行模塊的任務執行結果返回至相應的任務請求模塊，以使所述任務請求模塊對返回的任務執行結果進行分析，從而實現對各個控制機頂盒的測試結果進行自動分析和判斷，

存儲模塊通信連接于所述任務請求模塊和所述多個任務執行模塊，

其中，所述多個任務執行模塊中各個任務執行模塊將任務結果存至所述存儲模塊，以及所述任務請求模塊通過所述存儲模塊獲取所述任務結果，

其中通過所述存儲模塊采集機頂盒的日志文件，進一步經所述任務請求模塊對所述日志文件進行自動分析生成測試結果，從而對各個機頂盒進行自動測試。

8.根據權利要求7所述的任務調度方法，其特征在于，根據所述任務請求向相應的任務執行模塊分發任務，包括：

根據所述任務請求對所述任務請求進行封裝；以及

將封裝后的任務請求分解為多個任務。