我们在不同的 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