小编Kar*_*ert的帖子

Spring boot - 如何使用故障转移 URL 连接到外部 ActiveMQ 主/从集群

我们在不同的 VM 上有 2 个 ActiveMQ 节点(例如主机:amq1、amq2)。它们作为主/从集群链接。

我们想使用故障转移协议连接到这个集群。如何才能做到这一点?春季启动配置:

@Configuration
@EnableWebSocketMessageBroker
public class WebsocketConfiguration extends AbstractWebSocketMessageBrokerConfigurer {

  @Override
  public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableStompBrokerRelay("/topic")
        .setRelayHost(activeMQProperties.getRelayHost())
        .setRelayPort(activeMQProperties.getRelayPort());
  }
}
Run Code Online (Sandbox Code Playgroud)

不幸的是,这里我们只能设置一台主机和一个端口。我们怎么能设置这样的东西:

failover:(stomp://amq1:61613,stomp://amq2:61613)
Run Code Online (Sandbox Code Playgroud)

更新:目前使用的是 Spring Boot 2.3.5

activemq-classic stomp message-queue cluster-computing spring-boot

6
推荐指数
1
解决办法
686
查看次数