主备部署ActiveMQ连接错误规避及直连主节点方案咨询

问题1：直接识别并仅连接主节点的实现方案 #

• 方案1：通过ZooKeeper读取当前主节点地址（适用于基于ZK选举的主备集群）
  如果你的ActiveMQ主备集群采用ZooKeeper做选举协调，当前活跃的主节点地址会自动注册到ZK的指定节点（默认路径为/activemq/masters下的子节点）。你可以在创建连接前先调用ZK客户端API读取该节点的数据，解析出当前主节点的TCP连接地址，直接用这个单个地址创建ActiveMQConnectionFactory，就不会遍历其他备用节点，自然不会产生连接失败的报错。
  注意需要额外处理主节点切换场景：当连接断开时重新去ZK拉取最新的主节点地址再重建连接。
• 方案2：调整failover连接顺序（适用于主节点地址固定的场景）
  首先修正你现有URL的语法错误：多个broker地址之间需要用逗号分隔，而不是冒号，正确的基础URL格式为：

  String furl = "failover:(tcp://aa.myamq-01:61616,tcp://aa.myamq-02:61616,tcp://aa.myamq-03:61616)";
  

  在此基础上添加randomize=false参数，强制failover按照你填写的地址顺序尝试连接。如果主节点固定为列表第一个地址，只要主节点正常，只会尝试第一个地址，不会触发后续备用节点的连接尝试：

  String furl = "failover:(tcp://aa.myamq-01:61616,tcp://aa.myamq-02:61616,tcp://aa.myamq-03:61616)?randomize=false";
  

问题2：屏蔽连接失败错误日志的方案 #

如果不需要修改连接逻辑，只想屏蔽报错日志，有两种实现方式：

• 方式1：调整failover传输的日志级别
  在failover URL中添加日志级别参数，将连接失败的日志优先级从ERROR调整为WARN或更低：

  String furl = "failover:(tcp://aa.myamq-01:61616,tcp://aa.myamq-02:61616,tcp://aa.myamq-03:61616)?transport.logWriterPriority=WARN";
  

• 方式2：调整日志框架的输出规则
  直接在你项目的日志配置文件（logback.xml、log4j2.xml等）中，将org.apache.activemq.transport.failover.FailoverTransport类的日志级别设置为WARN，该类输出的连接失败ERROR日志就会被过滤，不会打印到控制台。

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