[發明專利]基于zookeeper任務處理的方法、裝置、計算機設備及存儲介質

在審

• 申請號: 201911302151.1
• 申請日: 2019-12-17
• 公開（公告）號: CN111045807A
• 公開（公告）日: 2020-04-21
• 發明（設計）人: 孫朝和;申志彬;李如先
• 申請（專利權）人: 深圳前海環融聯易信息科技服務有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 羅瑞鋒

本發明實施例提供了一種基于zookeeper任務處理的方法、裝置、計算機設備及存儲介質，該方法為：接收用戶所提交的任務請求，根據所述任務請求生成對應的任務；將所述任務發送至預設消息隊列中；基于zookeeper組件從所述預設消息隊列中獲取所述任務進行處理；以及將將處理完成的所述任務發送至用戶終端。通過上述方法，緩解了現有分布式任務調度系統中調度器的壓力，提高任務處理效率和運行穩定性。

技術領域

本發明涉及計算機技術領域，尤其涉及一種基于zookeeper任務處理的方法、裝置、計算機設備及存儲介質。

背景技術

在現有的分布式任務調度系統中，任務的生成、依賴管理、任務的分配、編排都是由調度器節點來完成的，為了更好地實現任務的調度、調度器需要與執行器保持通信連接、定時獲取執行器的健康情況，當執行器節點比較多的時候，調度器需要維護多個執行器的信息等情況，保持連接，將會耗費調度器的資源，導致調度器在調度過程會偶爾出現資源不足導致調度的失敗和性能不佳，需要一種新的任務調度策略來解決上面的問題。

發明內容

本發明實施例提供了一種基于zookeeper任務處理的方法、裝置、計算機設備及存儲介質，旨在解決現有分布式任務調度系統中穩定性較差的問題。

第一方面，本發明實施例提供了一種基于zookeeper任務處理的方法，其包括：

接收用戶所提交的任務請求，根據所述任務請求生成對應的任務；

將所述任務發送至預設消息隊列中；

基于zookeeper組件從所述預設消息隊列中獲取所述任務進行處理；以及

將將處理完成的所述任務發送至用戶終端。

第二方面，本發明實施例提供了一種基于zookeeper任務處理的裝置，其包括：

任務生成單元，用于接收用戶所提交的任務請求，根據所述任務請求生成對應的任務；

任務發送單元，用于將所述任務發送至預設消息隊列中；

任務處理單元，用于基于zookeeper組件從所述預設消息隊列中獲取所述任務進行處理；

處理結果發送單元，用于將將處理完成的所述任務發送至用戶終端。

第三方面，本發明實施例又提供了一種計算機設備，其包括存儲器、處理器及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述第一方面所述的基于zookeeper任務處理的方法。

第四方面，本發明實施例還提供了一種計算機可讀存儲介質，其中所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序當被處理器執行時使所述處理器執行上述第一方面所述的基于zookeeper任務處理的方法。

本發明實施例提供了一種基于zookeeper任務處理的方法、裝置、計算機設備及存儲介質，該方法為：接收用戶所提交的任務請求，根據所述任務請求生成對應的任務；將所述任務發送至預設消息隊列中；基于zookeeper組件從所述預設消息隊列中獲取所述任務進行處理；以及將將處理完成的所述任務發送至用戶終端。通過上述方法，緩解了現有分布式任務調度系統中調度器的壓力，提高任務處理效率和運行穩定性。

附圖說明

為了更清楚地說明本發明實施例技術方案，下面將對實施例描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1為本發明實施例提供的基于zookeeper任務處理的方法的流程示意圖；