[發(fā)明專利]基于zookeeper任務(wù)處理的方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201911302151.1
• 申請(qǐng)日: 2019-12-17
• 公開(kāi)（公告）號(hào): CN111045807A
• 公開(kāi)（公告）日: 2020-04-21
• 發(fā)明（設(shè)計(jì)）人: 孫朝和;申志彬;李如先
• 申請(qǐng)（專利權(quán)）人: 深圳前海環(huán)融聯(lián)易信息科技服務(wù)有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/54
• 代理公司: 深圳市精英專利事務(wù)所 44242
• 代理人: 羅瑞鋒

1.一種基于zookeeper任務(wù)處理的方法，其特征在于，包括：

接收用戶所提交的任務(wù)請(qǐng)求，根據(jù)所述任務(wù)請(qǐng)求生成對(duì)應(yīng)的任務(wù)；

將所述任務(wù)發(fā)送至預(yù)設(shè)消息隊(duì)列中；

基于zookeeper組件從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)進(jìn)行處理；以及

將處理完成的所述任務(wù)發(fā)送至用戶終端。

2.根據(jù)權(quán)利要求1所述的基于zookeeper任務(wù)處理的方法，其特征在于，所述根據(jù)所述任務(wù)請(qǐng)求生成對(duì)應(yīng)的任務(wù)，包括：

根據(jù)所述任務(wù)請(qǐng)求生成對(duì)應(yīng)的任務(wù)名稱、任務(wù)運(yùn)行參數(shù)以及任務(wù)存儲(chǔ)位置。

3.根據(jù)權(quán)利要求1所述的基于zookeeper任務(wù)處理的方法，其特征在于，所述將所述任務(wù)發(fā)送至預(yù)設(shè)消息隊(duì)列中，包括：

將所述任務(wù)進(jìn)行序列化以生成序列化后的任務(wù)；

將所述序列化后的任務(wù)發(fā)送至所述預(yù)設(shè)消息隊(duì)列中。

4.根據(jù)權(quán)利要求1所述的基于zookeeper任務(wù)處理的方法，其特征在于，所述基于zookeeper組件從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)進(jìn)行處理，包括：

根據(jù)第一預(yù)設(shè)規(guī)則創(chuàng)建預(yù)置的任務(wù)處理模型；

根據(jù)第二預(yù)設(shè)規(guī)則在所述zookeeper組件中創(chuàng)建與所述任務(wù)處理模型相應(yīng)的任務(wù)處理節(jié)點(diǎn)；

根據(jù)所述任務(wù)處理節(jié)點(diǎn)從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)并通過(guò)所述任務(wù)處理模型進(jìn)行任務(wù)處理。

5.根據(jù)權(quán)利要求4所述的基于zookeeper任務(wù)處理的方法，其特征在于，所述根據(jù)所述任務(wù)處理節(jié)點(diǎn)從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)并通過(guò)所述任務(wù)處理模型進(jìn)行任務(wù)處理，包括：

根據(jù)所述任務(wù)處理節(jié)點(diǎn)創(chuàng)建與所述任務(wù)處理模型相應(yīng)的監(jiān)聽(tīng)器；

由所述監(jiān)聽(tīng)器監(jiān)聽(tīng)上一任務(wù)處理模型處理任務(wù)是否完成；

若監(jiān)聽(tīng)到所述上一任務(wù)處理模型處理任務(wù)已完成，通過(guò)所述任務(wù)處理模型從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)并進(jìn)行任務(wù)處理。

6.一種基于zookeeper任務(wù)處理的裝置，其特征在于，包括：

任務(wù)生成單元，用于接收用戶所提交的任務(wù)請(qǐng)求，根據(jù)所述任務(wù)請(qǐng)求生成對(duì)應(yīng)的任務(wù)；

任務(wù)發(fā)送單元，用于將所述任務(wù)發(fā)送至預(yù)設(shè)消息隊(duì)列中；

任務(wù)處理單元，用于基于zookeeper組件從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)進(jìn)行處理；

處理結(jié)果發(fā)送單元，用于將將處理完成的所述任務(wù)發(fā)送至用戶終端。

7.根據(jù)權(quán)利要求6所述的基于zookeeper任務(wù)處理的裝置，其特征在于，所述任務(wù)發(fā)送單元，包括：

任務(wù)序列化單元，用于將所述任務(wù)進(jìn)行序列化以生成序列化后的任務(wù)；

序列化任務(wù)發(fā)送單元，用于將所述序列化后的任務(wù)發(fā)送至所述預(yù)設(shè)消息隊(duì)列中。

8.根據(jù)權(quán)利要求6所述的基于zookeeper任務(wù)處理的裝置，其特征在于，所述任務(wù)處理單元，包括：

處理模型創(chuàng)建單元，用于根據(jù)第一預(yù)設(shè)規(guī)則創(chuàng)建預(yù)置的任務(wù)處理模型；

處理節(jié)點(diǎn)創(chuàng)建單元，用于根據(jù)第二預(yù)設(shè)規(guī)則在所述zookeeper組件中創(chuàng)建與所述任務(wù)處理模型相應(yīng)的任務(wù)處理節(jié)點(diǎn)；

處理單元，用于根據(jù)所述任務(wù)處理節(jié)點(diǎn)從所述預(yù)設(shè)消息隊(duì)列中獲取所述任務(wù)并通過(guò)所述任務(wù)處理模型進(jìn)行任務(wù)處理。

9.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器、處理器及存儲(chǔ)在所述存儲(chǔ)器上并可在所述處理器上運(yùn)行的計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)如權(quán)利要求1至5中任一項(xiàng)所述的基于zookeeper任務(wù)處理的方法。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)存儲(chǔ)有計(jì)算機(jī)程序，所述計(jì)算機(jī)程序當(dāng)被處理器執(zhí)行時(shí)使所述處理器執(zhí)行如權(quán)利要求1至5任一項(xiàng)所述的基于zookeeper任務(wù)處理的方法。