¹⁸

连接线上 RabbitMQ 报错、服务器 Docker 安装 RabbitMQ

leikooo

2023-11-16 20:10

阅读2203

leikooo

2023-11-16 20:10

阅读 2203

后面有 docker 上安装 RabbitMQ 的教程

连接报错

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

import java.nio.charset.StandardCharsets;

/**

* @author <a href="https://github.com/lieeew">leikooo</a>

* 生产者

public class SingleProducer {

private final static String QUEUE_NAME = "hello";

public static void main(String[] argv) throws Exception {

ConnectionFactory factory = new ConnectionFactory();

// 不需要加 http:// 或者 https://

factory.setHost("服务器 IP");

factory.setUsername("lieeew");

factory.setPassword("密码如果有的话");

try (Connection connection = factory.newConnection();

Channel channel = connection.createChannel()) {

channel.queueDeclare(QUEUE_NAME, false, false, false, null);

String message = "Hello World!";

channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));

System.out.println(" [x] Sent '" + message + "'");

}

报错信息

19:09:11.432 [main] DEBUG com.rabbitmq.client.impl.ConsumerWorkService - Creating executor service with 12 thread(s) for consumer work service

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:385)

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

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

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

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

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

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

at com.leikooo.yubi.mq.SingleProducer.main(SingleProducer.java:22)

19:09:11.706 [AMQP Connection 1.117.228.86:5672] ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occurred

java.net.SocketException: Socket Closed

at java.net.SocketInputStream.socketRead0(Native Method)

at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)

at java.net.SocketInputStream.read(SocketInputStream.java:171)

at java.net.SocketInputStream.read(SocketInputStream.java:141)

at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)

at java.io.BufferedInputStream.read(BufferedInputStream.java:265)

at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)

at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:90)

at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:184)

at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:669)

at java.lang.Thread.run(Thread.java:750)

排查一下，首先我访问 http://ip:15672 没有问题，看一眼日志也没有报错，看服务器防火墙对应的端口（15672，5672）也都开了。而且我服务器上面没有安装宝塔面板，也不存在宝塔拦截了对应的端口。经过了一系列排查问题，我发现了一处异常 No access这有点奇怪了。

经过操作之后发现，我的问题是因为创建的用户默认不能被外部连接，上图黄色的就表示没有办法被远程连接，就是这个的问题！

在 Docker 上安装 RabbitMQ

我自己先是按照文章 https://learnku.com/articles/37157 ，完成在服务器上的 Docker 安装 RabbitMQ

mkdir -p ~/data/rabbitmq

docker run -d --hostname rabbit-svr --name rabbit -p 5672:5672 -p 15672:15672 -p 25672:25672 -v /data/rabbitmq:/var/lib/rabbitmq rabbitmq:management

对应参数的解释：

● - d 表示程序在后台静默运行；

● --hostname 指定 RabbitMQ 的主机名称；

● --name 指定启动的容器名称；

● -p 指定端口映射

● -v 将本地目录挂载到 Docker 容器中以实现数据持久化

● rabbitmq:management 指的是构建容器需要用到的镜像以及标签。

正常情况下，之后可以查看运行状态和日志

docker ps|grep rabbit

结果：

d6a2bd41361d rabbitmq:management "docker-entrypoint.s…" 30 minutes ago Up 30 minutes 4369/tcp, 5671/tcp, 0.0.0.0:5672->5672/tcp, 0.0.0.0:15672->15672/tcp, 15671/tcp, 0.0.0.0:25672-

第一个就是 [CONTAINER ID]

docker logs [CONTAINER ID]