[發(fā)明專利]一種避免消息隊(duì)列中消息丟失的處理方法及相關(guān)設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202111032842.1
• 申請(qǐng)日: 2021-09-03
• 公開（公告）號(hào): CN113742107A
• 公開（公告）日: 2021-12-03
• 發(fā)明（設(shè)計(jì)）人: 洪志權(quán);盧山;崔偉成;邱含;張志浩
• 申請(qǐng)（專利權(quán)）人: 廣州新絲路信息科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F16/2455
• 代理公司: 廣東翰銳律師事務(wù)所 44442
• 代理人: 胡厚財(cái)

1.一種避免消息隊(duì)列中消息丟失的處理方法，其特征在于，包括：

S101、應(yīng)用系統(tǒng)將業(yè)務(wù)數(shù)據(jù)構(gòu)成的業(yè)務(wù)消息存入redis緩存中；

S102、所述應(yīng)用系統(tǒng)向消息隊(duì)列發(fā)送所述業(yè)務(wù)消息；

S103、所述應(yīng)用系統(tǒng)按照預(yù)設(shè)時(shí)間間隔掃描所述redis緩存中的所有業(yè)務(wù)消息；

S104、若所述redis緩存的所有業(yè)務(wù)消息中存在第一消息生成時(shí)間大于預(yù)設(shè)時(shí)間的業(yè)務(wù)消息，則觸發(fā)消息重發(fā)補(bǔ)償機(jī)制，且更新所述第一消息生成時(shí)間。

2.根據(jù)權(quán)利要求1所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，還包括：

S105、所述應(yīng)用系統(tǒng)監(jiān)聽所述業(yè)務(wù)消息在所述消息隊(duì)列中的消費(fèi)狀態(tài)，所述消費(fèi)狀態(tài)包括消費(fèi)成功以及消費(fèi)失敗；

S106、若所述業(yè)務(wù)消息的消費(fèi)狀態(tài)更新為消費(fèi)失敗，則刪除所述消息隊(duì)列以及所述redis緩存中的所述業(yè)務(wù)消息，并將所述業(yè)務(wù)消息存入數(shù)據(jù)庫中，使得所述數(shù)據(jù)庫按照以預(yù)設(shè)時(shí)間間隔為定時(shí)任務(wù)，觸發(fā)消費(fèi)失敗補(bǔ)償機(jī)制；

S107、若所述業(yè)務(wù)消息的消費(fèi)狀態(tài)更新為消費(fèi)成功，則刪除所述消息隊(duì)列以及所述redis緩存中的所述業(yè)務(wù)消息。

3.根據(jù)權(quán)利要求2所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，所述步驟S101具體包括：

應(yīng)用系統(tǒng)向redis緩存中發(fā)送業(yè)務(wù)數(shù)據(jù)構(gòu)成的業(yè)務(wù)消息以及第一消息生成時(shí)間；

所述應(yīng)用系統(tǒng)接收到所述redis緩存返回的備份成功回執(zhí)后，執(zhí)行向數(shù)據(jù)庫發(fā)送所述業(yè)務(wù)消息以及第二消息生成時(shí)間的數(shù)據(jù)庫事務(wù)；

所述應(yīng)用系統(tǒng)接收Spring返回的所述數(shù)據(jù)庫事務(wù)的執(zhí)行成功回執(zhí)。

4.根據(jù)權(quán)利要求3所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，所述消息重發(fā)補(bǔ)償機(jī)制具體包括：

所述應(yīng)用系統(tǒng)將所述redis緩存中的所述業(yè)務(wù)消息重新發(fā)送至所述消息隊(duì)列中。

5.根據(jù)權(quán)利要求4所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，所述步驟S106具體包括：

若所述業(yè)務(wù)消息的消費(fèi)狀態(tài)更新為消費(fèi)失敗，則判斷所述業(yè)務(wù)消息是否包含預(yù)設(shè)標(biāo)記；

若所述業(yè)務(wù)消息不包含所述預(yù)設(shè)標(biāo)記，則刪除所述消息隊(duì)列以及所述redis緩存中所述業(yè)務(wù)消息，并將所述業(yè)務(wù)消息存入數(shù)據(jù)庫中，在所述數(shù)據(jù)庫中將所述業(yè)務(wù)消息添加所述預(yù)設(shè)標(biāo)記，記錄所述業(yè)務(wù)消息的重試次數(shù)為0；

若所述業(yè)務(wù)消息包含所述預(yù)設(shè)標(biāo)記，則以預(yù)設(shè)時(shí)間間隔為定時(shí)任務(wù)，將所述數(shù)據(jù)庫中的所述業(yè)務(wù)消息發(fā)送至所述消息隊(duì)列中，并將所述業(yè)務(wù)消息的重試次數(shù)加一。

6.根據(jù)權(quán)利要求5所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，所述步驟S106中若所述業(yè)務(wù)消息包含所述預(yù)設(shè)標(biāo)記，則將所述數(shù)據(jù)庫中的所述業(yè)務(wù)消息發(fā)送至所述消息隊(duì)列中，并將所述業(yè)務(wù)消息的重試次數(shù)加一具體包括：

若所述業(yè)務(wù)消息包含所述預(yù)設(shè)標(biāo)記，且所述業(yè)務(wù)消息的重試次數(shù)達(dá)到預(yù)設(shè)閾值，則觸發(fā)郵件預(yù)警機(jī)制；

若所述業(yè)務(wù)消息包含所述預(yù)設(shè)標(biāo)記，但所述業(yè)務(wù)消息的重試次數(shù)未達(dá)到所述預(yù)設(shè)閾值，則將所述數(shù)據(jù)庫中的所述業(yè)務(wù)消息發(fā)送至所述消息隊(duì)列中，并將所述業(yè)務(wù)消息的重試次數(shù)加一。

7.根據(jù)權(quán)利要求2所述的避免消息隊(duì)列中消息丟失的處理方法，其特征在于，所述步驟S102具體包括：

若所述業(yè)務(wù)消息的消費(fèi)狀態(tài)更新為消費(fèi)成功，則分別刪除所述消息隊(duì)列以及所述redis緩存中的所述業(yè)務(wù)消息。

8.一種避免消息隊(duì)列中消息丟失的處理系統(tǒng)，其特征在于，包括應(yīng)用系統(tǒng)、消息隊(duì)列以及redis緩存，其中：

所述應(yīng)用系統(tǒng)將業(yè)務(wù)數(shù)據(jù)構(gòu)成的業(yè)務(wù)消息存入所述redis緩存中；

所述應(yīng)用系統(tǒng)向消息隊(duì)列發(fā)送所述業(yè)務(wù)消息；

所述應(yīng)用系統(tǒng)按照預(yù)設(shè)時(shí)間間隔掃描所述redis緩存中的所有業(yè)務(wù)消息；

若所述redis緩存的所有業(yè)務(wù)消息中存在第一消息生成時(shí)間大于預(yù)設(shè)時(shí)間的業(yè)務(wù)消息，則觸發(fā)消息重發(fā)補(bǔ)償機(jī)制，且更新所述第一消息生成時(shí)間。