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

有效

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

本發明適用于信息處理技術領域，提供了一種消息處理的方法、裝置及消息處理服務器，包括：從消息隊列中獲取攜帶第一消息ID的待處理消息；根據歷史處理消息的第二消息ID，確定預期處理消息的第三消息ID；若所述第一消息ID和所述第三消息ID相同，則對所述待處理消息進行處理。本發明實施例通過將所述待處理消息對應的第一消息ID與預期處理消息所對應的第三消息ID進行對比，當二者相同時，才對所述待處理消息進行處理，保證了所述待處理消息是消息處理服務器當前預期要處理的消息，從而避免了消息處理過程中的消息亂序問題。

技術領域

本發明屬于信息處理技術領域，尤其涉及一種消息處理的方法、裝置及消息處理服務器。

背景技術

隨著物聯網技術的迅速發展，越來越多的設備通過網絡接入到物聯網平臺中，大量的設備產生了海量的消息。目前，設備產生的消息經過設備管理服務器、消息轉發服務器的轉發之后，由于不能確定每條消息是由哪一個消息轉發服務器進行轉發的，因此在轉發之后得到的消息隊列中，可能會出現消息順序錯亂和消息重復的問題。例如原始的消息順序是1、2、3、4，但是在消息隊列中，消息順序變成了1、3、4、2，這就是消息順序錯亂，如果消息隊列中的消息順序變為1、3、4、4、2，這就是消息順序錯亂和消息重復。

發明內容

有鑒于此，本發明實施例提供了一種消息處理的方法、裝置及消息處理服務器，以解決現有技術中消息處理時發生的消息順序錯亂的問題。

本發明實施例的第一方面提供了一種消息處理的方法，包括：

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

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

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

本發明實施例的第二方面提供了一種消息處理的裝置，包括：

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

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

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

本發明實施例的第三方面提供了一種消息處理服務器，包括處理器、輸入設備、輸出設備和存儲器，所述處理器、輸入設備、輸出設備和存儲器相互連接，其中，所述存儲器用于存儲計算機程序，所述計算機程序包括程序指令，所述處理器被配置用于調用所述程序指令，執行上述第一方面所述的方法。

本發明實施例的第四方面提供了一種計算機可讀存儲介質，所述計算機存儲介質存儲有計算機程序，所述計算機程序包括程序指令，所述程序指令當被處理器執行時使所述處理器執行上述第一方面所述的方法。

本發明實施例通過將所述待處理消息對應的第一消息ID與預期處理消息所對應的第三消息ID進行對比，當二者相同時，才對所述待處理消息進行處理，保證了所述待處理消息是消息處理服務器當前預期要處理的消息，從而避免了消息處理過程中的消息亂序問題。

附圖說明

為了更清楚地說明本發明實施例中的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動性的前提下，還可以根據這些附圖獲得其他的附圖。

圖1是本發明實施例提供的一種消息處理的方法的實現流程示意圖；

圖2是本發明實施例提供的另一種消息處理的方法的實現流程示意圖；

圖2a是本發明實施例提供的一種對故障消息的處理日志表；