[發(fā)明專利]消息處理方法、裝置、電子設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011027584.3
• 申請日: 2020-09-25
• 公開（公告）號(hào): CN112181737A
• 公開（公告）日: 2021-01-05
• 發(fā)明（設(shè)計(jì)）人: 黃啟成;翁世清;賴海濱
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司
• 主分類號(hào): G06F11/20
• 分類號(hào): G06F11/20;G06F9/54
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種消息處理方法，其特征在于，由服務(wù)端執(zhí)行，所述方法包括：

讀取未處理列表中的未處理消息；其中，所述未處理消息為未被第一消費(fèi)客戶端成功處理的消息；

將所述未處理消息的處理對象變更為第二消費(fèi)客戶端；

控制所述第二消費(fèi)客戶端根據(jù)所述未處理消息從消息隊(duì)列中被讀取的次數(shù)，以及再處理時(shí)間，對所述未處理消息進(jìn)行處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端之前，所述方法還包括：

針對消費(fèi)客戶端組，記錄消費(fèi)客戶端組中的第一消費(fèi)客戶端從消息隊(duì)列中讀取的目標(biāo)消息，生成未處理列表；

若接收到所述第一消費(fèi)客戶端發(fā)送的針對任一目標(biāo)消息的成功處理確認(rèn)通知，則將該目標(biāo)消息從所述未處理列表中刪除。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端，包括：

根據(jù)所述未處理消息從消息隊(duì)列中被讀取時(shí)刻到當(dāng)前時(shí)刻的持續(xù)時(shí)長，或第一消費(fèi)客戶端針對所述未處理消息發(fā)送的通知消息，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)所述未處理消息從消息隊(duì)列中被讀取時(shí)刻到當(dāng)前時(shí)刻的持續(xù)時(shí)長，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端，包括：

若所述未處理消息從消息隊(duì)列中被讀取時(shí)刻到當(dāng)前時(shí)刻的持續(xù)時(shí)長達(dá)到預(yù)設(shè)時(shí)長，則將所述未處理消息的處理對象變更為第二消費(fèi)客戶端。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)第一消費(fèi)客戶端針對所述未處理消息發(fā)送的通知消息，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端，包括：

若接收到第一消費(fèi)客戶端發(fā)送的針對未處理消息的消息錯(cuò)誤通知，則將所述未處理消息的被讀取的次數(shù)設(shè)置為預(yù)設(shè)限制次數(shù)；

將所述未處理消息的處理對象變更為第二消費(fèi)客戶端。

6.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)第一消費(fèi)客戶端針對所述未處理消息發(fā)送的通知消息，將所述未處理消息的處理對象變更為第二消費(fèi)客戶端，包括：

若接收到第一消費(fèi)客戶端發(fā)送的針對未處理消息的處理失敗通知，則將所述未處理消息的被讀取的次數(shù)進(jìn)行累加；

將所述未處理消息的處理對象變更為第二消費(fèi)客戶端。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

對消息隊(duì)列中的消息存儲(chǔ)于存儲(chǔ)器中，進(jìn)行持久化存儲(chǔ)。

8.一種消息處理方法，其特征在于，由第二消費(fèi)客戶端執(zhí)行，所述方法包括：

從未處理列表中讀取處理對象為第二消費(fèi)客戶端的未處理消息；

根據(jù)所述未處理消息從消息隊(duì)列中被讀取的次數(shù)，以及再處理時(shí)間，對所述未處理消息進(jìn)行處理。

9.根據(jù)權(quán)利要求8所述的方法，其特征在于，根據(jù)所述未處理消息從消息隊(duì)列中被讀取的次數(shù)，對所述未處理消息進(jìn)行處理，包括：

若所述未處理消息從消息隊(duì)列中被讀取的次數(shù)超過預(yù)設(shè)限制次數(shù)，則將該未處理消息從消息隊(duì)列中刪除，并置于黑名單隊(duì)列。

10.根據(jù)權(quán)利要求8所述的方法，其特征在于，根據(jù)所述未處理消息從消息隊(duì)列中被讀取的次數(shù)，以及再處理時(shí)間，對所述未處理消息進(jìn)行處理，包括：

若所述未處理消息從消息隊(duì)列中被讀取的次數(shù)未超過預(yù)設(shè)限制次數(shù)，則確定再處理時(shí)間是否達(dá)到預(yù)設(shè)再處理時(shí)間；

若是，則將所述未處理消息從消息隊(duì)列中刪除，并將所述未處理消息重新插入消息隊(duì)列，以被第一消費(fèi)客戶端重新讀取。

11.根據(jù)權(quán)利要求10所述的方法，其特征在于，將所述未處理消息重新插入消息隊(duì)列，包括：

為所述未處理消息定義新標(biāo)識(shí)；

將存儲(chǔ)被讀取的次數(shù)的哈希表中的未處理消息對應(yīng)的原標(biāo)識(shí)，替換為新標(biāo)識(shí)；

將具有新標(biāo)識(shí)的未處理消息重新插入消息隊(duì)列。