[發(fā)明專利]消息消費、消息分發(fā)方法、裝置、服務(wù)器及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110296047.7
• 申請日: 2021-03-19
• 公開（公告）號: CN112988423A
• 公開（公告）日: 2021-06-18
• 發(fā)明（設(shè)計）人: 牛旭
• 申請（專利權(quán)）人: 北京京東拓先科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q30/02
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種消息消費方法，其特征在于，應(yīng)用于消費服務(wù)器，所述方法包括：

確定分發(fā)服務(wù)器的各分區(qū)中與所述消費服務(wù)器一一對應(yīng)的目標(biāo)分區(qū)，并從所述目標(biāo)分區(qū)中獲取待消費消息，確定所述待消費消息的消息標(biāo)識，其中所述消息標(biāo)識表示所述待消費消息所屬的消息消費任務(wù)，且所述分發(fā)服務(wù)器是根據(jù)所述消息標(biāo)識將所述待消費消息分發(fā)到所述目標(biāo)分區(qū)上的；

根據(jù)所述消息標(biāo)識從所述消費服務(wù)器的各內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，并將所述待消費消息發(fā)送給所述目標(biāo)內(nèi)存隊列；

確定所述消費服務(wù)器的各線程中與所述目標(biāo)內(nèi)存隊列一一對應(yīng)的目標(biāo)線程，基于所述目標(biāo)線程對所述目標(biāo)內(nèi)存隊列中的所述待消費消息進(jìn)行消費。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述消息標(biāo)識從所述消費服務(wù)器的各內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，包括：

基于預(yù)先設(shè)置的負(fù)載均衡策略對所述消息標(biāo)識進(jìn)行處理，得到處理標(biāo)識；

獲取所述消費服務(wù)器的各內(nèi)存隊列的隊列數(shù)量，根據(jù)所述處理標(biāo)識和所述隊列數(shù)量從各所述內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述基于預(yù)先設(shè)置的負(fù)載均衡策略對所述消息標(biāo)識進(jìn)行處理，得到處理標(biāo)識，包括：

對所述消息標(biāo)識進(jìn)行映射，得到預(yù)設(shè)位數(shù)的數(shù)字類型的映射標(biāo)識；

將所述預(yù)設(shè)位數(shù)的一半更新為所述預(yù)設(shè)位數(shù)，并基于所述預(yù)設(shè)位數(shù)對所述映射標(biāo)識進(jìn)行位移，得到位移標(biāo)識；

將所述映射標(biāo)識和所述位移標(biāo)識進(jìn)行異或處理，得到處理標(biāo)識。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述根據(jù)所述處理標(biāo)識和所述隊列數(shù)量從各所述內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，包括：

對所述隊列數(shù)量進(jìn)行減一操作，得到減一數(shù)量，并將所述減一數(shù)量和所述處理標(biāo)識進(jìn)行與操作，得到隊列編號；或是，將所述隊列數(shù)量和所述處理標(biāo)識進(jìn)行取模操作，得到所述隊列編號；

將各所述內(nèi)存隊列中與所述隊列編號對應(yīng)的內(nèi)存隊列作為目標(biāo)內(nèi)存隊列。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述待消費消息包括物品獲取任務(wù)中的物品獲取狀態(tài)，所述物品獲取狀態(tài)包括創(chuàng)建狀態(tài)、待支付狀態(tài)、已支付狀態(tài)、已發(fā)貨狀態(tài)、配送中狀態(tài)和已收貨狀態(tài)中的至少一個。

6.一種消息分發(fā)方法，其特征在于，應(yīng)用于分發(fā)服務(wù)器，所述方法包括：

接收生產(chǎn)服務(wù)器生產(chǎn)后發(fā)送的待消費消息，并確定所述待消費消息的消息標(biāo)識，其中所述消息標(biāo)識表示所述待消費消息所屬的消息消費任務(wù)；

根據(jù)所述消息標(biāo)識從所述分發(fā)服務(wù)器的各分區(qū)中確定出目標(biāo)分區(qū)，將所述待消費消息分發(fā)到所述目標(biāo)分區(qū)上，以使與所述目標(biāo)分區(qū)一一對應(yīng)的消費服務(wù)器將從所述目標(biāo)分區(qū)中獲取到的所述待消費消息發(fā)送給根據(jù)所述消息標(biāo)識從各內(nèi)存隊列中確定出的目標(biāo)內(nèi)存隊列，并基于各線程中與所述目標(biāo)內(nèi)存隊列一一對應(yīng)的目標(biāo)線程對所述待消費消息進(jìn)行消費。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述根據(jù)所述消息標(biāo)識從所述分發(fā)服務(wù)器的各分區(qū)中確定出目標(biāo)分區(qū)，包括：

基于預(yù)先設(shè)置的負(fù)載均衡策略對所述消息標(biāo)識進(jìn)行處理，得到處理標(biāo)識；

獲取所述分發(fā)服務(wù)器的各分區(qū)的分區(qū)數(shù)量，根據(jù)所述處理標(biāo)識和所述分區(qū)數(shù)量從各所述分區(qū)中確定出目標(biāo)分區(qū)。

8.一種消息消費裝置，其特征在于，配置于消費服務(wù)器，所述裝置包括：

第一消息標(biāo)識確定模塊，用于確定分發(fā)服務(wù)器的各分區(qū)中與所述消費服務(wù)器一一對應(yīng)的目標(biāo)分區(qū)，并從所述目標(biāo)分區(qū)中獲取待消費消息，確定所述待消費消息的消息標(biāo)識，其中，所述消息標(biāo)識表示所述待消費消息所屬的消息消費任務(wù)，且所述分發(fā)服務(wù)器是根據(jù)所述消息標(biāo)識將所述待消費消息分發(fā)到所述目標(biāo)分區(qū)上的；

待消費消息發(fā)送模塊，用于根據(jù)所述消息標(biāo)識從所述消費服務(wù)器的各內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，并將所述待消費消息發(fā)送給所述目標(biāo)內(nèi)存隊列；

待消費消息消費模塊，用于確定所述消費服務(wù)器的各線程中與所述目標(biāo)內(nèi)存隊列一一對應(yīng)的目標(biāo)線程，基于所述目標(biāo)線程對所述目標(biāo)內(nèi)存隊列中的所述待消費消息進(jìn)行消費。