[發(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 | 代理人： | 孟金喆 |
| 地址： | 100176 北京市大興區(qū)北京經(jīng)濟*** | 國省代碼： | 北京;11 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 消息 消費 分發(fā) 方法 裝置 服務(wù)器 存儲 介質(zhì) | ||
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)存隊列中的所述待消費消息進行消費。
2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述消息標(biāo)識從所述消費服務(wù)器的各內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，包括：
基于預(yù)先設(shè)置的負(fù)載均衡策略對所述消息標(biāo)識進行處理，得到處理標(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)識進行處理，得到處理標(biāo)識，包括：
對所述消息標(biāo)識進行映射，得到預(yù)設(shè)位數(shù)的數(shù)字類型的映射標(biāo)識；
將所述預(yù)設(shè)位數(shù)的一半更新為所述預(yù)設(shè)位數(shù)，并基于所述預(yù)設(shè)位數(shù)對所述映射標(biāo)識進行位移，得到位移標(biāo)識；
將所述映射標(biāo)識和所述位移標(biāo)識進行異或處理，得到處理標(biāo)識。
4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述根據(jù)所述處理標(biāo)識和所述隊列數(shù)量從各所述內(nèi)存隊列中確定出目標(biāo)內(nèi)存隊列，包括：
對所述隊列數(shù)量進行減一操作，得到減一數(shù)量，并將所述減一數(shù)量和所述處理標(biāo)識進行與操作，得到隊列編號；或是，將所述隊列數(shù)量和所述處理標(biāo)識進行取模操作，得到所述隊列編號；
將各所述內(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)線程對所述待消費消息進行消費。
7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述根據(jù)所述消息標(biāo)識從所述分發(fā)服務(wù)器的各分區(qū)中確定出目標(biāo)分區(qū)，包括：
基于預(yù)先設(shè)置的負(fù)載均衡策略對所述消息標(biāo)識進行處理，得到處理標(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)存隊列中的所述待消費消息進行消費。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京京東拓先科技有限公司，未經(jīng)北京京東拓先科技有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.17sss.com.cn/pat/books/202110296047.7/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 電子數(shù)據(jù)分發(fā)系統(tǒng)
- 分發(fā)系統(tǒng)、分發(fā)控制設(shè)備和分發(fā)控制方法
- 分發(fā)方法和分發(fā)系統(tǒng)
- 廣播TS分發(fā)系統(tǒng)、分發(fā)裝置及分發(fā)方法
- 分發(fā)裝置、分發(fā)系統(tǒng)以及分發(fā)方法
- 分發(fā)系統(tǒng)以及分發(fā)方法
- 影像分發(fā)裝置、影像分發(fā)系統(tǒng)、影像分發(fā)方法及存儲介質(zhì)
- 分發(fā)梳齒以及分發(fā)梳
- 向用戶分發(fā)問題的方法及裝置
- 數(shù)據(jù)分發(fā)系統(tǒng)及數(shù)據(jù)分發(fā)方法
