[發明專利]分布式消息服務系統、方法、設備及計算機可讀存儲介質

有效

• 申請號: 201910342370.6
• 申請日: 2019-04-26
• 公開（公告）號: CN110138753B
• 公開（公告）日: 2021-07-23
• 發明（設計）人: 黃涌銘;黃錚;賴林光;劉爽
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08;H04L12/24
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王天堯

1.一種分布式消息服務系統，其特征在于，包括：接口裝置、路由裝置、數據存儲裝置、消息引擎裝置以及管理裝置，其中，

所述消息引擎裝置包括：

消息引擎集群單元，所述消息引擎集群單元包括不同類型的開源消息引擎的服務器；

所述數據存儲裝置，用于存儲業務應用系統的驗證信息以及消息引擎的配置信息；

所述接口裝置，用于對所述消息引擎集群單元中所有開源消息引擎的原生接口進行統一封裝，生成統一的訪問入口，所述訪問入口供各業務應用系統訪問，接收訪問的業務應用系統的請求；

所述路由裝置，與所述接口裝置、所述數據存儲裝置和所述消息引擎裝置連接，用于從所述接口裝置接收所述請求，從所述請求中獲取業務應用系統的驗證數據和消息服務的場景信息，根據獲取的驗證數據和所述數據存儲裝置已存的業務應用系統的驗證信息對訪問的業務應用系統進行驗證，根據獲取的消息服務的場景信息和所述數據存儲裝置已存的消息引擎的配置信息確定滿足所述請求的消息引擎，在驗證成功時，將所述請求轉發給所述消息引擎集群單元中確定出的消息引擎的服務器；

所述消息引擎集群單元，用于通過確定出的消息引擎的服務器與訪問的業務應用系統建立連接，并根據所述請求提供消息服務；

所述消息引擎裝置，還包括：監控采集單元，與所述消息引擎集群單元和所述數據存儲裝置連接，用于采集所述消息引擎集群單元中各開源消息引擎的服務器的運行數據，并將所述運行數據發送給所述數據存儲裝置進行存儲；其中，

所述管理裝置，包括：

監控數據處理單元，與所述監控采集單元和所述數據存儲裝置連接，用于將所述運行數據轉發給所述數據存儲裝置進行存儲；

自動安裝單元，與所述監控數據處理單元、所述接口裝置和所述數據存儲裝置連接，用于從所述監控數據處理單元的所述運行數據中獲取或通過所述接口裝置接收消息引擎安裝需求，根據所述消息引擎安裝需求從所述數據存儲裝置中獲取未安裝的消息引擎的環境信息，并將獲取的未安裝的消息引擎的環境信息安裝在當前有空閑環境的消息引擎的服務器上。

2.如權利要求1所述的分布式消息服務系統，其特征在于，所述管理裝置，還包括：配置中心單元和故障應急處理單元，其中，

所述監控數據處理單元，還用于從所述數據存儲裝置中獲取運行數據的數據閾值，當所述運行數據不滿足數據閾值時，通過所述接口裝置將所述運行數據發送給業務應用系統，并調用所述自動安裝單元、所述配置中心單元和所述故障應急處理單元；

所述自動安裝單元，還用于對性能容量不足的消息引擎進行自動擴容或者對故障消息引擎節點進行重裝；

所述配置中心單元，用于對故障的消息引擎節點實例進行配置；

所述故障應急處理單元，用于對故障的消息引擎節點實例進行故障分析和故障處理。

3.一種分布式消息服務方法，其特征在于，包括：

對不同類型的開源消息引擎的原生接口進行統一封裝，生成統一的訪問入口，所述訪問入口供各業務應用系統訪問，接收訪問的業務應用系統的請求；

從所述請求中獲取業務應用系統的驗證數據和消息服務的場景信息，根據獲取的驗證數據和已存的業務應用系統的驗證信息對訪問的業務應用系統進行驗證，根據獲取的消息服務的場景信息和已存的消息引擎的配置信息確定滿足所述請求的消息引擎，在驗證成功時，將所述請求轉發給確定出的消息引擎的服務器；

通過確定出的消息引擎的服務器與訪問的業務應用系統建立連接，通過確定出的消息引擎的服務器根據所述請求提供消息服務；

所述方法還包括：采集各開源消息引擎的服務器的運行數據，并存儲所述運行數據；

從所述運行數據中獲取或接收業務應用系統輸入的消息引擎安裝需求，根據所述消息引擎安裝需求獲取未安裝的消息引擎的環境信息，并將獲取的未安裝的消息引擎的環境信息安裝在當前有空閑環境的消息引擎的服務器上。

4.如權利要求3所述的分布式消息服務方法，其特征在于，還包括：

獲取已存的運行數據的數據閾值，當所述運行數據不滿足數據閾值時，將所述運行數據發送給業務應用系統；

對性能容量不足的消息引擎進行自動擴容或者對故障消息引擎節點進行重裝；

對故障的消息引擎節點實例進行配置；

對故障的消息引擎節點實例進行故障分析和故障處理。