[發(fā)明專利]消息處理方法、終端及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011058700.8
• 申請日: 2020-09-30
• 公開（公告）號: CN112350921A
• 公開（公告）日: 2021-02-09
• 發(fā)明（設(shè)計）人: 石鵬;宋磊
• 申請（專利權(quán)）人: 北京大米科技有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08
• 代理公司: 北京恒博知識產(chǎn)權(quán)代理有限公司 11528
• 代理人: 張曉芳

本申請公開了一種消息處理方法、終端及存儲介質(zhì)。該消息處理方法包括接收管理終端發(fā)送的第一指令；響應(yīng)于所述第一指令，讀取第一集群的第一消息的同時，讀取第二集群的第二消息；所述第一消息和所述第二消息在被所述服務(wù)器寫入所述第一集群的同時被寫入所述第二集群。本方案實(shí)現(xiàn)了對兩個集群進(jìn)行雙寫雙消費(fèi)，以此來保證當(dāng)某個集群不可用或消息寫入發(fā)生網(wǎng)絡(luò)抖動時，業(yè)務(wù)不會丟失消息，同時還對消息排重，確保業(yè)務(wù)最終對同一條消息只消費(fèi)一次。

技術(shù)領(lǐng)域

本申請涉及消息處理領(lǐng)域，具體而言，涉及一種消息處理方法、終端及存儲介質(zhì)。

背景技術(shù)

在通信業(yè)務(wù)中，有些業(yè)務(wù)強(qiáng)依賴于kafka消息，且對于有些敏感的業(yè)務(wù)，其不允許經(jīng)過kafka的消息因任何意料之外的原因而導(dǎo)致消息丟失。當(dāng)前現(xiàn)有的解決方案為，當(dāng)因為某些不可預(yù)料的原因?qū)е录翰豢捎脮r，kafka的維護(hù)技術(shù)人員對癥下藥，如kafka磁盤空間不足，則去清理磁盤，如kafka訪問IP及端口被安全組禁用而無法寫入消息時聯(lián)系安全組來開放權(quán)限。該方案存在的問題是，有時kafka維護(hù)人員并不一定能保證百分百及時處理問題，這樣對于一些敏感的業(yè)務(wù)，kafka丟失消息是不可接受的。

發(fā)明內(nèi)容

為了解決上述問題，本申請實(shí)施例提供了一種消息處理方法、終端及存儲介質(zhì)。

第一方面，本申請實(shí)施例提供了一種消息處理方法，所述方法包括：

接收管理終端發(fā)送的第一指令；

響應(yīng)于所述第一指令，讀取第一集群的第一消息，并讀取第二集群的第二消息；所述第一消息和所述第二消息在被所述服務(wù)器寫入所述第一集群的同時被寫入所述第二集群。

可選地，所述響應(yīng)于所述第一指令，讀取第一集群的第一消息，并讀取第二集群的第二消息之后，還包括：

接收緩存終端發(fā)送的第二指令；

響應(yīng)于所述第二指令，刪除目標(biāo)消息；所述目標(biāo)消息為與所述緩存終端的歷史監(jiān)聽記錄中的歷史消息重復(fù)的消息。

可選地，所述監(jiān)聽歷史記錄包含所述歷史消息的識別信息，所述目標(biāo)消息的識別信息與所述歷史消息的識別信息相同。

第二方面，本申請?zhí)峁┝艘环N消息處理方法，所述方法包括：

監(jiān)聽用戶終端接收的消息；所述消息包含第一消息與第二消息中至少一條，所述第一消息由所述用戶終端從第一集群中讀取，所述第二消息由所述用戶終端從第二集群中讀取，所述消息在被所述服務(wù)器寫入所述第一集群的同時被寫入所述第二集群；

根據(jù)歷史監(jiān)聽記錄確定所述消息是否與歷史消息重復(fù)；

在所述消息與所述歷史消息重復(fù)的情況下，向所述用戶終端發(fā)送第二指令，所述第二指令用于指示所述用戶終端刪除所述消息。

可選地，所述歷史監(jiān)聽記錄包含所述歷史消息的識別信息；

所述根據(jù)歷史監(jiān)聽記錄確定所述消息是否與歷史消息重復(fù)，包括：

獲取所述消息的識別信息；

從所述歷史監(jiān)聽記錄中查找是否存在識別信息與所述消息的識別信息相同的所述歷史消息；

所述在所述消息與所述歷史消息重復(fù)的情況下，向所述用戶終端發(fā)送第二指令，包括：

在所述消息的識別信息與所述歷史消息的識別信息重復(fù)的情況下，向所述用戶終端發(fā)送第二指令。

第三方面，本申請實(shí)施例提供了一種用戶終端，所述終端包括：

接收模塊，用于接收所述管理終端發(fā)送的第一指令；