[發明專利]一種消息處理方法和消息處理裝置

在審

• 申請號: 201911056601.3
• 申請日: 2019-10-31
• 公開（公告）號: CN112749018A
• 公開（公告）日: 2021-05-04
• 發明（設計）人: 李爽
• 申請（專利權）人: 大唐移動通信設備有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52;H04L12/24
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 莎日娜

本發明實施例提供了一種消息處理方法和消息處理裝置，其中的方法包括：通過網關服務接收攜帶有網元標識的消息；按照所述網元標識，對所述網關服務接收到的消息進行分組，獲得所述網元標識對應的消息組；其中，同一個消息組中的消息具有相同的網元標識；對所述消息組中的消息進行分包處理，得到第一數據包組；根據所述第一數據包組對應的網元標識，確定所述第一數據包組對應的業務服務進程；將所述第一數據包組中的數據包發送至對應的業務服務進程進行處理。本發明實施例可以提高消息處理的效率，以及提高消息處理的穩定性。

技術領域

本發明涉及通信技術領域，尤其涉及一種消息處理方法和消息處理裝置。

背景技術

在分布式網管系統中，存在多個業務微服務，服務間采取不同的通信協議與方式，且每個服務都是由多個進程組成的集群服務，因此，對消息在分布式網管系統間的傳輸提出了更高的要求。

現有的分布式網管系統中，當OMC(Operation and Maintenance Center，操作維護中心)通過南向網關收到基站上報的告警消息時，需要將告警消息經過南向業務服務、告警服務等多個服務處理后，才能將告警數據呈現給用戶，但是，當同一網元按次序生成多個告警消息時，可能出現無法保證告警消息按照接收的順序處理，后接收到的告警消息先處理的情況，造成告警亂序或告警無法清除的問題。

為了解決這一問題，當前的告警系統采用分布式鎖來控制消息處理，以保證告警消息處理的有序性，具體的，將生成告警消息的網元唯一標識DN(Distinguished Name，可識別名)作為分布式鎖，服務在收到告警消息后，申請分布式鎖，當獲取到分布式鎖后，才開始處理告警消息。告警消息處理結束后，將處理后的告警消息發送給下游服務，并釋放分布式鎖。由此，先收到告警消息先處理，后收到告警消息后處理，從而保證了告警消息處理的有序性。

但是，由于分布式鎖一般基于分布式網管系統外的第三方系統實現，因此，在告警消息處理過程中，對分布式鎖的獲取和釋放都是系統間的交互，極大增加了告警消息處理過程中的耗時，影響了處理效率，另外，由于分布式鎖通過第三方系統實現，在第三方系統出現故障時，會導致告警消息無法處理，加強了分布式網管系統對第三方系統的依賴，影響了分布式網管系統處理告警消息的穩定性。

發明內容

本發明實施例提供一種消息處理方法和裝置，可以提高消息處理的效率，以及提高消息處理的穩定性。

本發明實施例提供了一種消息處理方法，該方法可以包括：

通過網關服務接收攜帶有網元標識的消息；

按照所述網元標識，對所述網關服務接收到的消息進行分組，獲得所述網元標識對應的消息組；其中，同一個消息組中的消息具有相同的網元標識；

對所述消息組中的消息進行分包處理，得到第一數據包組；

根據所述第一數據包組對應的網元標識，確定所述第一數據包組對應的業務服務進程；

將所述第一數據包組中的數據包發送至對應的業務服務進程進行處理。

可選地，所述對所述消息組中的消息進行分包處理，得到第一數據包組的步驟，包括：

將所述消息組中順序接收到的預設數量的消息進行分包處理，得到第一數據包組；和/或，

將所述消息組中預設時間內順序接收到的消息進行分包處理，得到第一數據包組。

可選地，所述網元標識與所述業務服務進程具有一對多的對應關系；所述根據所述第一數據包組對應的網元標識，確定所述第一數據包組對應的業務服務進程的步驟，包括：

將至少兩個網元標識對應的第一數據包組中的數據包發送至相同的業務服務進程；