Qpid客户端连接工厂连接到ArtemisMQ集群

Question

我正在尝试使用Apache Camel和Qpid JMS客户端连接到在两个不同节点（VM）中运行的ActiveMQ Artemis主动-主动集群。我正在使用ActiveMQ Artemis 2.17.0。

Broker1 --- Host1:5672 (active)
Broker2 --- Host2:5672 (active)

我正在试图找出我的组织的远程URI配置应该是什么。阿帕奇。qpid。jms。JmsConnectionFactory实例。使用<代码>ampq://host1:5672,ampq://host2:5672不起作用。我在文档中没有看到任何参考资料。

我希望生产者通过循环或默认方式将消息推送到两个代理，我希望消费者以负载平衡的方式使用来自两个代理的消息。

对于主备份配置，以下操作有效：

<bean id="jmsampqConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
   <property name="remoteURI" value="failover:(ampq://host1:5672,ampq://host2:5672)" />
   <property name="username" value="user"/>
   <property name="password" value="pass"/>
</bean>

对于主从式配置，这是可行的。因此，当主机处于活动状态时，客户端将消息发送给主机，当主机处于关闭状态时，客户端将消息推送到从机。我们在那里没有任何问题。但是，对于active active，这将不起作用。我应该使用什么URL？

作为参考，代理配置与我之前的Stack Overflow问题相同。

Answer 1

Qpid JMS客户端当前没有（将来也不会有）扇出或扇入样式的连接处理程序来自动处理这种情况。客户创建与经纪人和遗嘱的单一连接；如果使用故障切换，请重新连接到另一个提供的代理URI，这就是为什么您描述的主/辅助配置可以工作，而活动/活动配置不能工作的原因。

您可能可以通过其他方式来解决这个问题，例如驼峰路由（camel routes），它可能能够按照这些路线进行操作，或者您可以创建自己的JMS层，创建扇出和扇入样式的连接代理。但是，你如何做到这一点超出了问题的范围。