[發(fā)明專利]一種保障異步通訊中消息順序性消費(fèi)的方法在審
| 申請?zhí)枺?/td> | 202111144387.4 | 申請日： | 2021-09-28 |
| 公開（公告）號(hào)： | CN113900835A | 公開（公告）日： | 2022-01-07 |
| 發(fā)明（設(shè)計(jì)）人： | 張鶴鳴 | 申請（專利權(quán)）人： | 四川新網(wǎng)銀行股份有限公司 |
| 主分類號(hào)： | G06F9/54 | 分類號(hào)： | G06F9/54 |
| 代理公司： | 成都智言知識(shí)產(chǎn)權(quán)代理有限公司 51282 | 代理人： | 濮云杉 |
| 地址： | 610094 四川省成都高*** | 國省代碼： | 四川;51 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 一種 保障 異步 通訊 消息 順序 消費(fèi) 方法 | ||
1.一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，包括以下步驟:
步驟1：生產(chǎn)端準(zhǔn)備需要發(fā)送的消息內(nèi)容，并且定義該消息類型，將消息類型放入消息屬性中；發(fā)送給消費(fèi)端；
步驟2：消費(fèi)端基于消息類型對(duì)消息進(jìn)行處理。
2.根據(jù)權(quán)利要求1所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，所述消息類型包括無順序要求的異步通訊場景類型、以最近發(fā)送的消息為準(zhǔn)的處理場景類型、按消息發(fā)送順序處理的場景類型。
3.根據(jù)權(quán)利要求2所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，所述步驟1包括：
步驟1.1：生產(chǎn)端準(zhǔn)備需要發(fā)送的消息內(nèi)容、需要投遞的消息隊(duì)列以及當(dāng)前業(yè)務(wù)場景對(duì)應(yīng)的消息類型；
步驟1.2：生產(chǎn)端將步驟1.1中準(zhǔn)備的數(shù)據(jù)作為入?yún)ⅲ⒉襟E1.1中確定的消息類型放入消息內(nèi)容的消息屬性中；
步驟1.3：在消息發(fā)送方法內(nèi)，首先對(duì)入?yún)?shù)據(jù)進(jìn)行校驗(yàn)，將步驟1.1準(zhǔn)備的消息內(nèi)容放入消息體中。
4.根據(jù)權(quán)利要求3所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，當(dāng)步驟1.1中確定的消息類型為無順序要求的異步通訊場景類型時(shí)，所述步驟1還包括以下步驟用于續(xù)接步驟1.3：
步驟1.4：將消息體與消息屬性組裝為完整的消息并發(fā)送到隊(duì)列中；完成消息發(fā)送。
5.根據(jù)權(quán)利要求4所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，所述步驟2包括以下步驟：
步驟2.1：多個(gè)消費(fèi)端接收并消費(fèi)隊(duì)列中的消息內(nèi)容；解析得到消息體、消息屬性；
步驟2.2：消費(fèi)端基于消息屬性確定當(dāng)前消息類型為無順序要求的異步通訊場景類型，則無需管消息的順序問題，直接進(jìn)行接下來的消費(fèi)處理；消費(fèi)端完成消息處理。
6.根據(jù)權(quán)利要求3所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，當(dāng)步驟1.1中確定的消息類型為以最近發(fā)送的消息為準(zhǔn)的處理場景類型時(shí)，所述步驟1包括以下步驟用于續(xù)接步驟1.3：
步驟1.4：隨機(jī)生成一個(gè)唯一不重復(fù)的數(shù)據(jù)A；生產(chǎn)端以固定前綴加上隊(duì)列名稱為key，調(diào)用Redis的set賦值方法，將key的值置為數(shù)據(jù)A；
步驟1.5：生產(chǎn)端重復(fù)步驟1.1到步驟1.3，隨機(jī)生成一個(gè)唯一不重復(fù)的數(shù)據(jù)B，生產(chǎn)端以固定前綴加上隊(duì)列名稱為key，調(diào)用Redis的set賦值方法，將key的值置為數(shù)據(jù)B，將當(dāng)前的消息類型、用來標(biāo)識(shí)業(yè)務(wù)當(dāng)前發(fā)送數(shù)據(jù)的鍵值key、以及標(biāo)識(shí)數(shù)據(jù)B均放入到消息屬性中；將消息體和消息屬性組裝為完整的消息并發(fā)送到隊(duì)列中。
7.根據(jù)權(quán)利要求6所述的一種保障異步通訊中消息順序性消費(fèi)的方法，其特征在于，所述步驟2包括以下步驟：
步驟2.1：消費(fèi)端接收到消費(fèi)隊(duì)列中的消息內(nèi)容，并獲取消息內(nèi)容的消息屬性，基于消息屬性獲取到消息類型為以最近發(fā)送的消息為準(zhǔn)的處理場景類型；根據(jù)key去Redis，通過get方法獲取其中的保存字段，并與消息屬性中的發(fā)來的標(biāo)識(shí)字符串進(jìn)行對(duì)比；
步驟2.2：若Redis中獲取的數(shù)據(jù)B與消息屬性中發(fā)送來的數(shù)據(jù)A對(duì)比不一致，則消費(fèi)端得知該消息不是最新消息，直接終止處理流程，不再執(zhí)行后續(xù)流程；
步驟2.3：若Redis中獲取的數(shù)據(jù)B與消息屬性中發(fā)送來的數(shù)據(jù)B對(duì)比一致，則消費(fèi)者得知該條消息為最新發(fā)送的消息，進(jìn)行后續(xù)的處理流程。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于四川新網(wǎng)銀行股份有限公司，未經(jīng)四川新網(wǎng)銀行股份有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/202111144387.4/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 上一篇：換流變壓器潛油泵更換裝置
- 下一篇：鋰電手持式套絲機(jī)及套絲方法
