[發明專利]一種MQ多實例消息發送方法和裝置

在審

• 申請號: 202111247686.0
• 申請日: 2021-10-26
• 公開（公告）號: CN113961372A
• 公開（公告）日: 2022-01-21
• 發明（設計）人: 錢峰
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 薛平;周曉飛

本發明提供了一種MQ多實例消息發送方法和裝置，屬于大數據，該方法包括：配置多個MQ隊列管理器加入MQ隊列管理器組；在應用系統發來消息時，通過MQ隊列管理器組選取MQ隊列管理器，確定可用MQ隊列管理器列表并緩存；通過MQ隊列接收應用系統發來的消息，利用MQ隊列管理器組從緩存中選取MQ隊列管理器，將消息通過選取的MQ隊列管理器發送至對應的通道；監測消息發送結果，在消息發送異常時，根據異常處理機制更換新的MQ隊列管理器重新發送消息。本發明從應用角度對多個MQ實例進行統一管理，給出了一個MQ多實例的高可用解決方案，應用實現了多MQ隊列管理器的配置和消息發送。

技術領域

本發明涉及計算機數據處理技術領域，尤其涉及一種MQ多實例消息發送方法和裝置。

背景技術

本部分旨在為權利要求書中陳述的本發明的實施方式提供背景或上下文。此處的描述不因為包括在本部分中就承認是現有技術。

MQ(IBM Message Queue)是現有的一款商業消息中間產品，適用于分布式計算環境或異構系統之中。消息隊列技術是分布式應用間交換信息的一種技術。消息隊列可駐留在內存或磁盤上,隊列存儲消息直到它們被應用程序讀走。通過消息隊列，應用程序可獨立地執行--它們不需要知道彼此的位置、或在繼續執行前不需要等待接收程序接收此消息。

在傳統的應用架構中MQ采用單點部署，如圖2現有技術中MQ單實例架構圖所示，應用系統在發送消息時，需要通過隊列進行，隊列根據配置的單個隊列管理器發送消息到指定的通道，存在故障后不可用的風險。

因此，如何提供一種新的方案，其能夠解決上述技術問題是本領域亟待解決的技術難題。

發明內容

本發明實施例提供一種MQ多實例消息發送方法，本發明從應用角度對多個MQ實例進行統一管理，給出了一個MQ多實例的高可用解決方案，應用實現了多MQ隊列管理器的配置和消息發送，該方法包括：

配置多個MQ隊列管理器加入MQ隊列管理器組；

在應用系統發來消息時，通過MQ隊列管理器組選取MQ隊列管理器，確定可用MQ隊列管理器列表并緩存；

通過MQ隊列接收應用系統發來的消息，利用MQ隊列管理器組從緩存中選取MQ隊列管理器，將消息通過選取的MQ隊列管理器發送至對應的通道；

監測消息發送結果，在消息發送異常時，根據異常處理機制更換新的MQ隊列管理器重新發送消息。

本發明實施例還提供一種MQ多實例消息發送裝置，包括：

MQ隊列管理器配置模塊，用于配置多個MQ隊列管理器加入MQ隊列管理器組；

可用MQ隊列管理器列表確定模塊，用于在應用系統發來消息時，通過MQ隊列管理器組選取MQ隊列管理器，確定可用MQ隊列管理器列表并緩存；

MQ多實例調度模塊，用于通過MQ隊列接收應用系統發來的消息，利用MQ隊列管理器組從緩存中選取MQ隊列管理器，將消息通過選取的MQ隊列管理器發送至對應的通道；

異常消息處理重發模塊，用于監測消息發送結果，在消息發送異常時，根據異常處理機制更換新的MQ隊列管理器重新發送消息。

本發明實施例還提供一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述一種MQ多實例消息發送方法。

本發明實施例還提供一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有執行上述一種MQ多實例消息發送方法的計算機程序。