[發明專利]一種消息處理的方法、裝置及消息處理服務器

有效

• 申請號: 201811332252.9
• 申請日: 2018-11-09
• 公開（公告）號: CN109614246B
• 公開（公告）日: 2021-01-08
• 發明（設計）人: 鄭巨雙
• 申請（專利權）人: 深圳英飛拓科技股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 深圳中一專利商標事務所 44237
• 代理人: 高星

1.一種消息處理的方法，其特征在于，包括：

從消息隊列中獲取攜帶第一消息ID的待處理消息；

根據歷史處理消息的第二消息ID，確定預期處理消息的第三消息ID；

若所述第一消息ID和所述第三消息ID相同，則對所述待處理消息進行處理；

若所述第一消息ID大于所述第三消息ID，則將所述待處理消息放回所述消息隊列，并記錄放回次數；

判斷所述第一消息ID是否等于預設初始值，若所述第一消息ID等于預設初始值，則獲取所述待處理消息的放回次數；

若所述放回次數等于預設次數，則基于所述預設初始值，對所述消息隊列中位于所述待處理消息之后的消息所對應的消息ID進行對應修改；

其中，所述消息隊列中的每條消息對應一個消息ID，所述消息ID從所述預設初始值開始增加。

2.如權利要求1所述的方法，其特征在于，所述根據歷史處理消息的第二消息ID，確定預期處理消息的第三消息ID之后，包括：

若所述待處理消息為故障消息，則獲取所述待處理消息的第一消息狀態；

根據所述歷史處理消息的第二消息狀態和所述第二消息ID，確定所述預期處理消息的第三消息狀態和所述第三消息ID；

若所述第一消息ID與所述第三消息ID相同，且所述第一消息狀態與所述第三消息狀態相同，則對所述待處理消息進行處理。

3.如權利要求1所述的方法，其特征在于，所述根據歷史處理消息的第二消息ID，確定預期處理消息的第三消息ID之后，包括：

若所述待處理消息為報警消息，則判斷所述第一消息ID與所述第三消息ID是否相同；

若所述第一消息ID與所述第三消息ID相同，則對所述待處理消息進行處理。

4.如權利要求1所述的方法，其特征在于，所述方法還包括：

當所述放回次數達到預設次數時，對所述待處理消息進行處理。

5.如權利要求4所述的方法，其特征在于，所述方法還包括：

獲取所述待處理消息的第一時間戳；

若所述第一時間戳小于或者等于所述歷史處理消息的第二時間戳，則不處理所述待處理消息。

6.一種消息處理的裝置，其特征在于，包括：

消息獲取模塊，用于從消息隊列中獲取攜帶第一消息ID的待處理消息；

第三消息ID確定模塊，用于根據歷史處理消息的第二消息ID，確定預期處理消息的第三消息ID；

消息處理模塊，用于若所述第一消息ID和所述第三消息ID相同，則對所述待處理消息進行處理；

消息放回模塊，用于若所述第一消息ID大于所述第三消息ID，則將所述待處理消息放回所述消息隊列，并記錄放回次數；

第二判斷模塊，用于判斷所述第一消息ID是否等于預設初始值，若所述第一消息ID等于所述預設初始值，則獲取所述待處理消息的放回次數；

消息ID修改模塊，用于若所述放回次數等于預設次數，則基于所述預設初始值，對所述消息隊列中位于所述待處理消息之后的消息所對應的消息ID進行對應修改；

其中，所述消息隊列中的每條消息對應一個消息ID，所述消息ID從所述預設初始值開始增加。

7.一種消息處理服務器，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1至5任一項所述方法的步驟。

8.一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現如權利要求1至5任一項所述方法的步驟。