[發明專利]消息總線系統及消息傳輸方法、裝置、電子設備

有效

• 申請號: 201911335945.8
• 申請日: 2019-12-23
• 公開（公告）號: CN113098914B
• 公開（公告）日: 2022-09-30
• 發明（設計）人: 李茂桂;王業亮
• 申請（專利權）人: 中國移動通信集團湖南有限公司;中國移動通信集團有限公司
• 主分類號: H04L67/566
• 分類號: H04L67/566;H04L67/567;H04L67/55;H04L12/40
• 代理公司: 北京國昊天誠知識產權代理有限公司 11315
• 代理人: 徐晨影;許振新

1.一種消息總線系統，其特征在于，包括核心層和接入層，所述核心層包括轉發引擎，所述接入層包括多個接入引擎，且所述轉發引擎分別與所述多個接入引擎連接；

所述接入引擎，用于接收來自生產者節點的第一消息并轉發給所述轉發引擎，以使所述轉發引擎將所述第一消息轉發給訂閱所述第一消息主題的消費者節點；以及，接收來自所述轉發引擎的第二消息并將所述第二消息發送給訂閱所述第二消息主題的消費者節點；

所述轉發引擎，用于接收來自所述多個接入引擎中的第一接入引擎的消息，并基于預置的路由表將所述消息轉發給訂閱所述消息主題的消費者節點所對應的第二接入引擎，以使所述第二接入引擎將所述消息發送給訂閱所述消息主題的消費者節點；

所述核心層還包括管理引擎，所述管理引擎分別與所述生產者節點和所述消費者節點連接；

所述管理引擎，用于接收所述生產者節點的注冊信息，并基于所述生產者節點的注冊信息和所述多個接入引擎各自的負荷狀態，從所述多個接入引擎中確定分配給所述生產者節點的接入引擎且將該接入引擎信息返回給所述生產者節點，以供所述生產者節點與該接入引擎建立連接；和/或，接收所述消費者節點的注冊信息，并基于所述消費者節點的注冊信息和所述多個接入引擎各自的負荷狀態，從所述多個接入引擎中確定分配給所述消費者節點的接入引擎且將該接入引擎信息返回給所述生產者節點，以供所述消費者節點與該接入引擎建立連接。

2.根據權利要求1所述的系統，其特征在于，所述管理引擎還與所述轉發引擎連接以及所述多個接入引擎連接；

所述管理引擎，還用于獲取所述轉發引擎的接入負荷，并在所述接入負荷大于或等于預設負荷的情況下，在所述核心層中創建新的轉發引擎；和/或，獲取所述多個接入引擎各自的接入負荷，對于每一所述接入引擎，在該接入引擎的接入負荷大于或等于預設負荷的情況下，創建新的接入引擎。

3.根據權利要求1所述的系統，其特征在于，所述核心層還包括：

備份引擎，分別與所述多個接入引擎和所述轉發引擎連接，用于對所述多個接入引擎和所述轉發引擎各自的運行數據進行備份；

所述管理引擎，還與所述備份引擎連接，還用于在檢測到任一接入引擎宕機的情況下，控制與該接入引擎所對應的生產者節點和消費者節點切換為與所述備份引擎連接，和/或，在檢測到所述轉發引擎宕機的情況下，控制與該轉發引擎所連接的接入引擎切換為與所述備份引擎連接，以通過所述備份引擎進行數據傳輸。

4.一種消息傳輸方法，其特征在于，所述方法應用于如權利要求1所述的消息總線系統，所述消息總線系統包括核心層和接入層，所述核心層轉發引擎，所述接入層包括多個接入引擎，且所述轉發引擎分別與所述多個接入引擎連接，所述方法包括：

所述多個接入引擎中的第一接入引擎接收來自生產者節點的消息并轉發給所述消息總線系統的轉發引擎；

所述轉發引擎基于預置的路由表將所述消息轉發給訂閱所述消息主題的消費者節點所對應的第二接入引擎；

所述第二接入引擎將所述消息發送給訂閱所述消息主題的消費者節點。

5.一種消息傳輸方法，其特征在于，所述方法應用于如權利要求1所述消息總線系統中的轉發引擎，所述轉發引擎分別與所述消息總線系統中的多個接入引擎連接，所述方法包括：

接收所述消息總線系統中的第一接入引擎發送的消息，所述消息是所述第一接入引擎轉發的來自所述第一接入引擎對應的生產者節點的消息；

基于預置的路由表確定訂閱所述消息主題的消費者節點所對應的第二接入引擎；

將所述消息轉發給所述第二接入引擎，以使所述第二接入引擎將所述消息發送給訂閱所述消息主題的消費者節點。