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

在審

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

1.一種MQ多實例消息發(fā)送方法，其特征在于，包括：

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

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

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

監(jiān)測消息發(fā)送結果，在消息發(fā)送異常時，根據(jù)異常處理機制更換新的MQ隊列管理器重新發(fā)送消息。

2.如權利要求1所述的方法，其特征在于，利用MQ隊列管理器組從緩存中選取MQ隊列管理器，將消息通過選取的MQ隊列管理器發(fā)送至對應的通道，包括：

利用MQ隊列管理器組從緩存中查找可用MQ隊列管理器列表；

在緩存中存在可用MQ隊列管理器列表時，從可用MQ隊列管理器列表中選取一個MQ隊列管理器，將消息通過選取的MQ隊列管理器發(fā)送至對應的通道。

3.如權利要求2所述的方法，其特征在于，還包括：

在緩存中未存在可用MQ隊列管理器列表時，從MQ隊列管理器組中配置好的多個MQ隊列管理器中選取一個MQ隊列管理器，將消息通過選取的MQ隊列管理器發(fā)送至對應的通道；

在消息發(fā)送成功時，將該選取的MQ隊列管理器加入可用MQ隊列管理器列表并緩存。

4.如權利要求2所述的方法，其特征在于，監(jiān)測消息發(fā)送結果，在消息發(fā)送異常時，根據(jù)異常處理機制更換新的MQ隊列管理器重新發(fā)送消息，包括：

監(jiān)測消息發(fā)送結果；

在消息發(fā)送成功時，標記該選取的MQ隊列管理器可用；

在消息發(fā)送異常時，判斷異常消息的類型；

若異常消息的類型為系統(tǒng)類異常，則觸發(fā)異常輪轉機制，更換新的MQ隊列管理器重新發(fā)送消息；

若異常消息的類型為非系統(tǒng)類異常，則根據(jù)消息重發(fā)機制重新發(fā)送消息。

5.如權利要求4所述的方法，其特征在于，若異常消息的類型為系統(tǒng)類異常，則觸發(fā)異常輪轉機制，更換新的MQ隊列管理器重新發(fā)送消息，包括：

若異常消息的類型為包括連接拒絕以及連接超時的系統(tǒng)類異常，則觸發(fā)異常輪轉機制，判斷緩存中是否存在可用MQ隊列管理器；

當緩存中存在可用MQ隊列管理器時，選取一個MQ隊列管理器作為新的MQ隊列管理器，并刪除發(fā)生異常的MQ隊列管理器；

利用新的MQ隊列管理器，重新發(fā)送消息至對應的通道；

當緩存中未存在可用MQ隊列管理器時，從MQ隊列管理器組中配置好的多個MQ隊列管理器中選取一個MQ隊列管理器作為新的MQ隊列管理器，

利用新的MQ隊列管理器，嘗試重新發(fā)送消息至對應的通道，直至消息發(fā)送成功，將該新的MQ隊列管理器加入可用MQ隊列管理器列表并緩存。

6.如權利要求4所述的方法，其特征在于，若異常消息的類型為非系統(tǒng)類異常，則根據(jù)消息重發(fā)機制重新發(fā)送消息，包括：

若異常消息的類型為非系統(tǒng)類異常，則將消息引入消息重發(fā)隊列；

根據(jù)消息重發(fā)機制配置的重發(fā)策略，重新發(fā)送消息至對應的通道。

7.如權利要求6所述的方法，其特征在于，在重發(fā)策略為最大次數(shù)重發(fā)時，

設定消息重發(fā)次數(shù)閾值，每次重發(fā)的間隔按照設定倍率逐漸增加，如消息發(fā)送次數(shù)達到消息重發(fā)次數(shù)閾值且每次都是非系統(tǒng)類異常，則對外拋出異常后處理下一筆消息。

8.如權利要求6所述的方法，其特征在于，在重發(fā)策略為無限重發(fā)時，

重復發(fā)送消息，直至消息成功發(fā)送至對應的通道或出現(xiàn)系統(tǒng)類異常。