请求Open Liberty应用连接MQ统一集群为可重连客户端的配置建议

问题背景 #

我们需要在Open Liberty（22.x）中部署的应用，通过MQ Adapter 9.2.x连接MQ队列管理器（9.3.x）组成的统一集群，以可重连客户端身份接入并实现应用负载均衡（Application Rebalancing）。此前尝试结合CCDT、连接名称列表与clientReconnectOptions配置，但未达到预期效果。

当前CCDT配置 #

{
    "channel": [{
        "name": "UNIFORM.SVRCONN",
        "clientConnection": {
          "connection": [{
            "host": "Host1",
            "port": 51000
           },{
            "host": "Host2",
            "port": 51000
           },{
            "host": "Host3",
            "port": 51000
            }],
          "queueManager": "ANY_QM"
        },
       "transmissionSecurity":
      {
        "cipherSpecification": "TLS_RSA_WITH_AES_256_CBC_SHA256"
      },
        "type": "clientConnection"
        },
        {
            "name": "UNIFORM.SVRCONN",
            "clientConnection":
            {
                "connection":
                [
                    {
                        "host": "Host1",
                        "port": 51000
                    }
                ],
                "queueManager": "QM1"
            },
      "transmissionSecurity":
      {
        "cipherSpecification": "TLS_RSA_WITH_AES_256_CBC_SHA256"
      },
            "type": "clientConnection"
        },
        {
            "name": "UNIFORM.SVRCONN",
            "clientConnection":
            {
                "connection":
                [
                    {
                        "host": "Host2",
                        "port": 51000
                    }
                ],
                "queueManager": "QM2"
            },
      "transmissionSecurity":
      {
        "cipherSpecification": "TLS_RSA_WITH_AES_256_CBC_SHA256"
      },
            "type": "clientConnection"
        },
        {
            "name": "UNIFORM.SVRCONN",
            "clientConnection":
            {
                "connection":
                [
                    {
                        "host": "Host3",
                        "port": 51000
                    }
                ],
                "queueManager": "QM3"
            },
     "transmissionSecurity":
      {
        "cipherSpecification": "TLS_RSA_WITH_AES_256_CBC_SHA256"
      },
            "type": "clientConnection"
        }
   ]
}

配置修正与优化建议 #

1. CCDT配置调整 #

当前CCDT的多条目设计会让客户端优先匹配精确队列管理器名称的条目，直接绕过统一集群的负载均衡逻辑。建议简化为如下配置：

{
    "channel": [{
        "name": "UNIFORM.SVRCONN",
        "clientConnection": {
          "connection": [
            {"host": "Host1", "port": 51000},
            {"host": "Host2", "port": 51000},
            {"host": "Host3", "port": 51000}
          ],
          "queueManager": "*"
        },
        "transmissionSecurity": {
          "cipherSpecification": "TLS_RSA_WITH_AES_256_CBC_SHA256"
        },
        "type": "clientConnection"
    }]
}

• 使用queueManager": "*"替代ANY_QM，让客户端自动发现集群内所有队列管理器。
• 移除单个QM的专属条目，避免客户端固定连接到特定节点，确保负载均衡逻辑触发。

2. JMS连接工厂核心配置 #

在Open Liberty的server.xml中配置JMS连接工厂时，需添加以下关键属性：

<jmsConnectionFactory jndiName="jms/MyConnectionFactory">
  <properties.wmqJms
    queueManager="*"
    channel="UNIFORM.SVRCONN"
    ccdtUrl="file:/path/to/your/ccdt.json"
    clientReconnectOptions="RECONNECT_Q_MGR,RECONNECT"
    clientReconnectTimeout="300"
    clientIDPrefix="MyApp-"
    connectionNameList="Host1(51000),Host2(51000),Host3(51000)"
    loadBalancingPolicy="ROUND_ROBIN"
    maxPoolSize="20"
    minPoolSize="5"
  />
</jmsConnectionFactory>

• clientReconnectOptions: 设置为RECONNECT_Q_MGR,RECONNECT，允许连接断开时重连到集群内任意可用QM，同时触发负载均衡。
• loadBalancingPolicy: 指定ROUND_ROBIN，让新连接在集群节点间循环分配，实现负载均衡。
• clientReconnectTimeout: 设置重连超时（单位：秒），定义客户端尝试重连的最长时长。
• connectionNameList: 与CCDT主机列表保持一致，作为CCDT的 fallback 补充配置。
• queueManager="*": 配合CCDT的*配置，确保客户端接入统一集群而非单个QM。

3. Open Liberty MQ Adapter配置 #

确保server.xml中启用正确的MQ Adapter特性，并配置集群相关参数：

<featureManager>
  <feature>wmqJmsClient-2.0</feature>
  <feature>jms-2.0</feature>
</featureManager>

<wmqJmsClient id="mqClient">
  <properties.wmq
    java.naming.provider.url="file:/path/to/ccdt.json"
    java.naming.factory.initial="com.ibm.mq.jms.context.WMQInitialContextFactory"
    enableClientReconnect="true"
    enableClientReconnectMQ="true"
  />
</wmqJmsClient>

• enableClientReconnect与enableClientReconnectMQ: 显式启用客户端重连功能，与连接工厂的重连配置协同生效。
• 使用wmqJmsClient-2.0特性，适配MQ Adapter 9.2.x与Open Liberty 22.x的兼容性。

4. 应用代码配合要点 #

• 避免硬编码队列管理器名称，通过JNDI获取连接工厂。
• 确保JMS连接/会话使用后正确关闭，让连接池正常回收连接，便于负载均衡重新分配。
• 消息消费者使用CLIENT_ACKNOWLEDGE或DUPS_OK_ACKNOWLEDGE模式，结合MQ事务或持久化消息特性，避免重连后消息重复消费。

验证要点 #

• 重启Open Liberty后，查看日志确认客户端是否连接到集群内多个QM。
• 手动停止一个QM，检查应用是否自动重连到其他可用节点，且新连接分配到剩余节点。
• 监控MQ集群连接数，确认各节点连接分布符合负载均衡策略。

内容的提问来源于stack exchange，提问作者Raju