[發(fā)明專利]一種分布式任務(wù)處理方法、裝置、系統(tǒng)及設(shè)備

有效

• 申請(qǐng)?zhí)枺?/td>: 201710615914.2
• 申請(qǐng)日: 2017-07-26
• 公開(kāi)（公告）號(hào): CN107688500B
• 公開(kāi)（公告）日: 2021-12-24
• 發(fā)明（設(shè)計(jì)）人: 甘劍峰
• 申請(qǐng)（專利權(quán)）人: 創(chuàng)新先進(jìn)技術(shù)有限公司
• 主分類號(hào): G06F9/52
• 分類號(hào): G06F9/52
• 代理公司: 北京晉德允升知識(shí)產(chǎn)權(quán)代理有限公司 11623
• 代理人: 周莉娜

1.一種分布式的任務(wù)處理方法，所述方法包括：任務(wù)分發(fā)設(shè)備向分布式的各任務(wù)處理設(shè)備分發(fā)任務(wù)消息；其中，所述任務(wù)消息包括任務(wù)調(diào)度消息及任務(wù)處理消息，所述任務(wù)調(diào)度消息包括任務(wù)掃描消息；

所述任務(wù)處理設(shè)備接收所述任務(wù)分發(fā)設(shè)備分發(fā)的任務(wù)消息；

根據(jù)所述任務(wù)消息中的任務(wù)掃描消息掃描任務(wù)數(shù)據(jù)庫(kù)中相應(yīng)的任務(wù)表，以查找所述任務(wù)表中需要進(jìn)行處理的任務(wù)；若發(fā)現(xiàn)需要處理的任務(wù)，則生成任務(wù)處理消息，并向所述任務(wù)分發(fā)設(shè)備所包含的消息設(shè)備發(fā)送任務(wù)處理消息，以使所述消息設(shè)備將所述任務(wù)處理消息發(fā)送給各任務(wù)處理設(shè)備；

優(yōu)先接收到所述任務(wù)處理消息的任務(wù)處理設(shè)備處理所述任務(wù)處理消息；

獲取匹配于所述任務(wù)消息的任務(wù)鎖；

當(dāng)獲取到所述任務(wù)鎖時(shí)，對(duì)所述任務(wù)消息進(jìn)行處理。

2.如權(quán)利要求1所述的方法，獲取匹配于所述任務(wù)消息的任務(wù)鎖，具體包括：

確定所述任務(wù)消息對(duì)應(yīng)的待處理任務(wù)的任務(wù)數(shù)據(jù)；

根據(jù)所述任務(wù)數(shù)據(jù)生成取鎖字符串；

在任務(wù)鎖表中獲取匹配于所述取鎖字符串的任務(wù)鎖；

其中，所述任務(wù)數(shù)據(jù)至少包括：待處理任務(wù)的任務(wù)狀態(tài)數(shù)據(jù)、任務(wù)標(biāo)識(shí)數(shù)據(jù)。

3.如權(quán)利要求2所述的方法，在獲取任務(wù)鎖之前，所述方法還包括：

在所述任務(wù)鎖表中，確定所述取鎖字符串可用。

4.如權(quán)利要求3所述的方法，確定所述取鎖字符串可用，具體包括：

確定所述取鎖字符串未記錄在所述任務(wù)鎖表中。

5.如權(quán)利要求3所述的方法，確定所述取鎖字符串可用，具體包括：

確定與已記錄在所述任務(wù)鎖表中的取鎖字符串的使用者信息相同。

6.如權(quán)利要求3所述的方法，確定所述取鎖字符串可用，具體包括：

確定已記錄在所述任務(wù)鎖表中、與所述取鎖字符串的使用者信息相同的任務(wù)鎖未超時(shí)。

7.如權(quán)利要求1所述的方法，所述方法還包括：

當(dāng)對(duì)所述任務(wù)消息的處理完成時(shí)，生成解鎖字符串，解除所述任務(wù)鎖。

8.如權(quán)利要求1所述的方法，對(duì)所述任務(wù)消息進(jìn)行處理，具體包括：

確定所述任務(wù)消息所對(duì)應(yīng)的待處理任務(wù)；

調(diào)用預(yù)先定義的、與該待處理任務(wù)對(duì)應(yīng)的任務(wù)執(zhí)行邏輯，對(duì)所述待處理任務(wù)進(jìn)行處理；

所述待處理任務(wù)包括：可拆分任務(wù)以及根據(jù)所述可拆分任務(wù)得到的子任務(wù)。

9.如權(quán)利要求8所述的方法，所述任務(wù)調(diào)度消息還包括任務(wù)創(chuàng)建消息；

調(diào)用預(yù)先定義的、與該待處理任務(wù)對(duì)應(yīng)的任務(wù)執(zhí)行邏輯，對(duì)所述待處理任務(wù)進(jìn)行處理，具體包括：

當(dāng)所述任務(wù)調(diào)度消息為任務(wù)創(chuàng)建消息時(shí)，調(diào)用任務(wù)創(chuàng)建邏輯創(chuàng)建可拆分任務(wù)，并寫(xiě)入任務(wù)表；

當(dāng)所述任務(wù)調(diào)度消息為任務(wù)掃描消息時(shí)，調(diào)用任務(wù)掃描邏輯在所述任務(wù)表中掃描未處理的可拆分任務(wù)以及子任務(wù)。

10.如權(quán)利要求8所述的方法，所述任務(wù)處理消息包括：可拆分任務(wù)處理消息及子任務(wù)處理消息；

調(diào)用預(yù)先定義的、與該待處理任務(wù)對(duì)應(yīng)的任務(wù)執(zhí)行邏輯，對(duì)所述待處理任務(wù)進(jìn)行處理，具體包括：

當(dāng)所述任務(wù)處理消息為可拆分任務(wù)處理消息時(shí)，調(diào)用可拆分任務(wù)的處理邏輯對(duì)所述可拆分任務(wù)進(jìn)行處理；

當(dāng)所述任務(wù)處理消息為子任務(wù)處理消息時(shí)，調(diào)用子任務(wù)的處理邏輯對(duì)所述子任務(wù)進(jìn)行處理；

其中，可拆分任務(wù)的處理邏輯至少包括：對(duì)可拆分任務(wù)進(jìn)行拆分、對(duì)合并后的可拆分任務(wù)完成處理；

子任務(wù)的處理邏輯至少包括：查找未處理的子任務(wù)、按照子任務(wù)的業(yè)務(wù)邏輯處理該子任務(wù)、對(duì)處理完成后的多個(gè)子任務(wù)進(jìn)行合并。

11.如權(quán)利要求9所述的方法，所述方法還包括：

根據(jù)查找到的各未處理的子任務(wù)，生成子任務(wù)執(zhí)行消息發(fā)送給所述任務(wù)分發(fā)設(shè)備。