主页 / 问题 / 707078
Accepted
Senior Pomidor
Asked:2020-08-17 17:28:07 +0000 UTC2020-08-17 17:28:07 +0000 UTC

activemq 代理不断不必要地重新连接到不同的代理

  • 772

有 2 台服务器（amq1、amq2）部署了 ActiveMQ。创建队列的服务位于第三台服务器上。

在我指定的连接设置中spring.activemq.broker-url: failover:(ssl://amq1:61616,ssl://amq1:61616)

两台服务器都正常工作并且不会丢失连接。

问题是该服务首先按优先级连接到amq1，但有时会更改连接到amq2，然后又回到第一个。日志中没有消息表明与 amq1 的连接已丢失。

INFO 24003 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport   : Successfully connected to ssl://amq2:61616  
INFO 24003 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport       : Successfully connected to ssl://amq2:61616  
INFO 24003 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport       : Successfully connected to ssl://amq1:61616 
ERROR 24003 --- [http-nio-127.0.0.1-8080-exec-4] r.o.RestExceptionHandler  : dm.exception.ActiveMQException: Failed get JMS response:  
INFO 24003 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport       : Successfully connected to ssl://amq2:61616  
INFO 24003 --- [ActiveMQ Task-1] o.a.a.t.failover.FailoverTransport       : Successfully connected to ssl://amq1:61616

我怎样才能使与 amq2 的连接仅在 amq1 停止响应时才连接？

ps 如果只指定一台amq server，那么当连接消失时，spring默认尝试重连10次。我想在 10 次后更改与 amq2 的连接

java

1 个回答

  1. Best Answer

    必须添加到连接failover:(ssl://amq1:61616,ssl://amq1:61616)?randomize=false&priorityBackup=true

    简而言之，然后“按顺序使用优先级，如果代理可用，则始终重新连接”

    它来自文档

    优先备份=真

    给定此 URL，客户端将尝试连接并保持与本地代理的连接。如果本地代理失败，它当然会故障转移到远程。但是，由于使用了priorityBackup 参数，客户端会不断尝试重新连接到本地。一旦客户端可以这样做，客户端将重新连接到它，而无需任何手动干预。

    随机化=假

    默认情况下，故障转移传输随机选择一个 URI。这有效地通过多个代理对客户端进行负载平衡。但是，要让客户端首先连接到主代理，并且仅在主代理不可用时连接到辅助备份代理，请设置 randomize=false。

    • 0

相关问题