Spring-boot集成RabbitMQ踩过的坑

1.java.net.SocketException: socket closed

　　官方文档已经说明，新建user和guest的账户是没有远程登录的权限的需要对登录所用账户授权

　　　解决方法：

rabbitmqctl  set_permissions -p /${user_name}  user_admin '.*' '.*' '.*'

An unexpected connection driver error occured  报错如下

[AMQP Connection 192.168.71.111:5672] WARN com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occured (Exception message: Connection reset)

Exception in thread "main" com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:342)

    at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:62)

    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:99)

    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:900)

    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:859)

    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:817)

    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:954)

　这是因为Rabbit里的queue 没有注解@RabbitListener(queues = "namedQueue") queues的实例

　　　　解决方法：

　　添加监听的queues名称，保存重启。OK

巴特西

Spring-boot集成RabbitMQ踩过的坑

最新文章

热门文章