我已经按如下方式设置我的 spring boot 应用程序:
application.properties:
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
WebSocketConfig.java :
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableStompBrokerRelay("/topic","/queue/");
registry.setApplicationDestinationPrefixes("/app");
}
}
RabbiMQ配置:(安装在Windows 7上)
Protocol Bound to Port
amqp 127.0.0.1 5672
clustering :: 25672
http 0.0.0.0 15672
http :: 15672
当我启动应用程序时,我收到此错误:
Failed to connect to reactor.io.net.impl.netty.tcp.NettyTcpClient
即使我在配置类中设置属性,也会发生这种情况。
有什么想法吗?
谢谢
最佳答案
您需要使用以下方法在 RabbitMQ 上启用 stomp 代理:
rabbitmq-plugins enable rabbitmq_stomp
此外,STOMP 的端口是 61613,而不是 5672。
关于java - Spring 启动和 RabbitMQ : Failed to connect to reactor. io.net.impl.netty.tcp.NettyTcpClient,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43339855/