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

在審

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

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

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

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

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

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

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

2.根據權利要求1所述的方法，其特征在于，所述對所述消息組中的消息進行分包處理，得到第一數據包組的步驟，包括：

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

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

3.根據權利要求1所述的方法，其特征在于，所述網元標識與所述業務服務進程具有一對多的對應關系；所述根據所述第一數據包組對應的網元標識，確定所述第一數據包組對應的業務服務進程的步驟，包括：

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

所述業務服務進程按照所述網元標識，對接收到的不同第一數據包組的數據包進行分組，得到第二數據包組；

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

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

4.根據權利要求3所述的方法，其特征在于，所述消息包括告警消息，所述消息服務進程包括告警服務進程，所述將所述第二數據包組中的數據包發送至對應的消息服務進程進行處理之前，所述方法還包括：

對所述第二數據包組中的數據包進行轉換，得到告警對象；

所述將所述第二數據包組中的數據包發送至對應的消息服務進程進行處理，包括：

將所述第二數據包組中的告警對象發送至對應的告警服務進程進行處理。

5.根據權利要求4所述的方法，其特征在于，所述對所述第二數據包組中的數據包進行轉換，得到告警對象的步驟，包括：

根據所述第二數據包組對應的網元標識，確定所述第二數據包組對應的對象轉換線程；

通過所述對象轉換線程對所述第二數據包組中的數據包進行對象轉換，得到告警對象。

6.根據權利要求4所述的方法，其特征在于，所述將所述第二數據包組中的告警對象發送至對應的告警服務進程進行處理的步驟，包括：

將所述第二數據包組中的告警對象發送至對應的告警服務進程；

所述告警服務進程按照所述網元標識，對接收到的告警對象進行分組，得到告警對象組；

根據所述告警對象組對應的網元標識，確定所述告警對象組對應的處理線程；

將所述告警對象組中的告警對象分發至對應的處理線程進行處理。

7.根據權利要求6所述的方法，其特征在于，所述將所述告警對象組中的告警對象分發至對應的處理線程進行處理的步驟，包括：

根據所述網元標識的次序分發所述告警對象組中的告警對象至對應的處理線程，每次根據每個網元標識分發一個告警對象；

所述處理線程依次對接收到的告警對象進行告警處理。

8.根據權利要求1所述的方法，其特征在于，所述根據所述第一數據包組對應的網元標識，確定所述第一數據包組對應的業務服務進程的步驟包括：

判斷所述業務服務進程是否已接收過與所述第一數據包組對應的網元標識相同的數據包組中的數據包；

若是，則將所述業務服務進程確定為所述第一數據包組對應的業務服務進程；

若否，則獲取所述業務服務進程所在服務器的當前負載，將所述當前負載最低的業務服務進程確定為第一數據包組的對應的業務服務進程。