[發明專利]一種消息處理方法及系統、存儲介質

在審

• 申請號: 202011026589.4
• 申請日: 2020-09-25
• 公開（公告）號: CN112099975A
• 公開（公告）日: 2020-12-18
• 發明（設計）人: 劉君
• 申請（專利權）人: OPPO廣東移動通信有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50;G06F9/48
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 王軍紅;張穎玲

1.一種消息處理系統，其特征在于，所述系統包括：面向消息的中間件服務和多個消息隊列；所述多個消息隊列中的每一個消息隊列對應一個隊列優先級，所述每一個消息隊列中存儲與其隊列優先級匹配的消息，所述中間件服務中存儲至少一個消息處理對象，所述至少一個消息處理對象中的每一個消息處理對象對應所述多個消息隊列中的至少一個消息隊列，所述至少一個消息隊列屬于同一類別；

所述中間件服務，用于按照所述隊列優先級，依次將所述多個消息隊列中的待處理消息傳輸至所述多個消息隊列對應的目標消息處理對象中；以利用所述目標消息處理對象對所述待處理消息進行消息處理。

2.根據權利要求1所述的系統，其特征在于，所述消息處理系統還包括至少一個處理器；

所述中間件服務，還用于基于所述至少一個處理器的至少一個空閑內核，將所述多個消息隊列分配至所述至少一個處理器中，以在至少一個處理器上實現所述目標消息處理對象對所述待處理消息的消息處理過程。

3.根據權利要求1所述的系統，其特征在于，所述中間件服務中存儲服務上下文，所述服務上下文中包括所述至少一個消息處理對象、所述多個消息隊列和任務處理對象之間的關聯關系，其中，

所述任務處理對象用于管理所述中間件服務創建的多優先級任務，所述多個消息隊列的隊列個數與所述多優先級任務的任務個數一一對應；所述消息隊列通過所述服務上下文繼承對應的所述多優先級任務的優先級。

4.根據權利要求1所述的系統，其特征在于，所述至少一個消息處理對象中的每一個消息處理對象包括一組處理函數，所述一組處理函數用于處理所述每一個消息處理對象對應的至少一個消息隊列中的消息；

所述中間件服務，用于從所述待處理消息中解析消息標識和消息體；根據所述消息標識從所述目標消息處理對象中確定第一處理函數，并將所述消息體傳輸至所述第一處理函數中，以利用所述第一處理函數對所述消息體進行處理。

5.根據權利要求1所述的系統，其特征在于，所述系統還基于待存儲消息的消息優先級，調整所述待存儲消息在所述至少一個消息隊列中的存儲消息隊列。

6.一種消息處理方法，其特征在于，應用于消息處理系統，所述消息處理系統包括面向消息的中間件服務和多個消息隊列，所述多個消息隊列中的每一個消息隊列對應一個隊列優先級，所述每一個消息隊列中存儲與其隊列優先級匹配的消息，所述中間件服務存儲至少一個消息處理對象；所述方法包括：

通過所述中間件服務按照所述消息隊列的隊列優先級，依次調度多個消息隊列中的待處理消息，并依次查找所述多個消息隊列對應的目標消息處理對象；

利用所述目標消息處理對象對所述待處理消息進行消息處理。

7.根據權利要求6所述的方法，其特征在于，所述消息處理系統還包括至少一個處理器；所述利用所述目標消息處理對象對所述待處理消息進行消息處理，包括：

獲取所述至少一個處理器的至少一個空閑內核；

通過所述中間件服務，基于所述至少一個空閑內核將所述多個消息隊列分配至所述至少一個處理器中；

在所述至少一個處理器上實現所述目標消息處理對象對所述待處理消息的消息處理過程。

8.根據權利要求6或7所述的方法，其特征在于，所述利用所述目標消息處理對象對所述待處理消息進行消息處理，包括：

通過所述中間件服務從所述待處理消息中解析消息標識和消息體；

通過所述中間件服務根據所述消息標識，從所述目標消息處理對象中確定第一處理函數；

通過所述中間件服務將所述消息體傳輸至所述第一處理函數中，并利用所述第一處理函數對所述待處理消息進行消息處理。