1

尽管

ConnectionFactory.newConnection(Address[] addrs)

因此

ConnectionFactory.newConnection(
  Address.parseAddresses("somehost.com:5672,otherhost.com:5672")) 

工作,我想知道是否有一种方法可以传递多个 URI,例如:

ConectionFactory.newConnection("amqps://somehost.com:5671,amqps://otherhost.com:5671")

或者要允许每个 URI 可能有不同的客户端证书,首先创建多个 ConnectionFactories,每个都有一个 URI,然后创建一个 ConnectionFactory,将这些连接工厂作为输入。

4

1 回答 1

0

很确定这是不可能的。 http://www.rabbitmq.com/uri-spec.html

如果您尝试实现故障转移,您可能会考虑类似心跳:https ://wiki.archlinux.org/index.php/Simple_IP_Failover_with_Heartbeat

如果您尝试从多个位置读取消息,您可以使用 shovel (http://www.rabbitmq.com/shovel.html) 将这些消息从多个位置放入一个队列并从中读取。

于 2012-12-31T18:34:42.480 回答