ActiveMQ 5.15.5下Camel配置brokerURL连接双独立Broker报无效URI异常解决

你之前配置的brokerURL格式不符合ActiveMQ的URI解析规范，核心缺失了最外层的传输协议前缀——ActiveMQ识别多Broker地址列表的逻辑必须依托failover传输层实现，没有这个前缀的话，解析器会直接把以左括号开头的字符串判定为非法URI，直接抛出无效Broker地址的运行时异常。

核心调整内容 #

只需要在多地址列表的最外层补充failover:协议前缀，不需要改动原有参数的位置，修正后可完全兼容现有项目依赖与5.15.5版本Broker的连接要求：

<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
  <!-- 修正：补充failover传输协议前缀 -->
  <property name="brokerURL" value="failover:(tcp://host1:61616,tcp://host2:61616)?wireFormat.maxInactivityDuration=500000" />
</bean>

除brokerURL的配置修正外，你之前编写的jmsPooledConnectionFactory、jmsConfig、Camel ActiveMQ组件的其他配置均不需要调整，替换原来的brokerURL值即可正常启动上下文。

配置兼容说明 #

• 当前项目使用的activemq-camel、activemq-broker 5.12.1 与5.15.5版本Broker完全兼容，不需要强制升级客户端依赖，可适配现有spring-core 4.2.4、spring-boot 1.3.1的版本栈。
• 该格式下，wireFormat.maxInactivityDuration参数会由failover层自动透传给底层每个TCP连接，不需要在每个Broker地址后面重复配置。
• failover传输层默认的实现逻辑是：同一时间只会与两个Broker中状态正常的一个建立长连接，另一个作为故障备用节点，当前节点宕机后会自动重连切换到备用节点，不会同时和两个独立Broker保持连接消费消息。

因为你部署的是两个独立运行的Broker节点，需要根据实际架构确认是否匹配上面的配置逻辑：

• 如果两个节点是做了主备同步、共享存储的高可用集群（同一时间只有一个节点对外提供服务），上面的修正配置直接可用。
• 如果两个节点是完全独立、没有数据同步、各自接收不同来源消息的孤立Broker，单靠单个brokerURL无法实现同时连接两个节点消费的需求，需要为每个Broker单独配置独立的ConnectionFactory、PooledConnectionFactory与对应的Camel ActiveMQ组件，分别绑定对应的消费路由。

如果需要自定义连接重试行为，可以在现有参数后追加failover层的配置，比如开启节点随机选择、限制重连次数：

<property name="brokerURL" value="failover:(tcp://host1:61616,tcp://host2:61616)?wireFormat.maxInactivityDuration=500000&randomize=true&startupMaxReconnectAttempts=5&maxReconnectAttempts=10" />

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