Spring boot 和 RabbitMQ:无法连接到 reactor.io.net.impl.netty.tcp.N

Question

我已经按如下方式设置了我的 Spring 启动应用程序：

应用程序属性：

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

即使我在配置类中设置属性，也会发生这种情况。

有什么想法吗？

谢谢

Answer 1

您需要

使用以下方法在 RabbitMQ 上启用 stomp 代理：

rabbitmq-plugins enable rabbitmq_stomp

此外，STOMP 的端口是 61613，而不是 5672。