Docker部署RabbitMQ修改端口后Java客户端连接被拒绝问题

问题场景 #

正常运行情况 #

使用以下命令启动RabbitMQ容器，端口映射保持默认：

docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management

此时Java代码可正常连接：

ConnectionFactory factory = new ConnectionFactory();
factory.setUsername("guest");
factory.setPassword("guest");
Connection connection = factory.newConnection("http://localhost:5672");

修改端口后的异常情况 #

修改端口映射后启动容器：

docker run --rm -it --hostname my-rabbit -p 15673:15672 -p 5673:5672 rabbitmq:3-management

管理控制台http://localhost:15673可正常访问，但Java连接代码抛出连接拒绝异常：

ConnectionFactory factory = new ConnectionFactory();
factory.setUsername("guest");
factory.setPassword("guest");
Connection connection = factory.newConnection("http://localhost:5673");

异常信息：

Exception in thread "main" java.net.ConnectException: Connection refused: connect
    at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:81)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:162)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)
    at java.net.Socket.connect(Socket.java:606)
    at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:59)
    at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:63)
    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:1310)
    at com.project.Main.main(Main.java:14)

补充说明：使用默认端口5672时可正常连接。

问题原因 #

RabbitMQ的Java客户端使用AMQP协议而非HTTP协议，连接字符串中使用http://前缀属于格式错误。默认端口下看似正常，是因为客户端会忽略错误的协议前缀，自动使用默认的AMQP协议和5672端口，刚好与容器映射端口匹配。修改端口后，错误的协议前缀导致客户端无法正确解析目标端口，最终连接失败。

解决方案 #

方案1：显式设置主机和端口 #

通过setHost和setPort方法明确指定连接参数：

ConnectionFactory factory = new ConnectionFactory();
factory.setUsername("guest");
factory.setPassword("guest");
factory.setHost("localhost");
factory.setPort(5673); // 对应容器映射的5673端口
Connection connection = factory.newConnection();

方案2：使用AMQP协议格式的连接字符串 #

连接字符串使用amqp://前缀，客户端可正确解析端口：

ConnectionFactory factory = new ConnectionFactory();
factory.setUsername("guest");
factory.setPassword("guest");
Connection connection = factory.newConnection("amqp://localhost:5673");

内容的提问来源于stack exchange，提问作者Pavel Petrashov