RabbitMQ调用setPort设为15672后连接拒绝、超时的原因是什么

示例代码 #

private Channel channel;
private ConnectionFactory connectionFactory;

@Autowired
public RabbitMqManager() {
    connectionFactory = new ConnectionFactory();
    connectionFactory.setHost("localhost");
    //connectionFactory.setPort(15672); // 报错：该行代码会导致RabbitMQ连接失败
    try {
        Connection connection = connectionFactory.newConnection();
        channel = connection.createChannel();

核心错误原因 #

问题本质是RabbitMQ不同功能模块监听的端口完全独立，你混淆了客户端通信端口和管理后台端口：

• 15672是RabbitMQ管理后台的HTTP服务端口，仅支持浏览器访问、HTTP API调用，不支持AMQP协议的客户端连接请求
• Java RabbitMQ客户端默认使用AMQP协议与服务端通信，对应的默认服务端口是5672，你注释掉setPort代码时，ConnectionFactory会自动使用5672作为默认端口，所以连接正常

当你强制指定端口为15672时，客户端会尝试用AMQP协议与15672端口的HTTP服务通信，服务端无法识别请求格式，所以会出现两类报错：

• 如果服务端15672端口直接拒绝非HTTP请求，就会抛出ConnectionRefused
• 如果服务端没直接拒绝，而是等待符合格式的请求超时，就会抛出TimeoutException

疑问解答 #

1. 为什么设置端口会连接失败？

因为你指定的15672是Web UI端口，不是AMQP协议的服务端口，客户端和服务端协议不匹配无法建立连接。如果要显式指定端口，改成connectionFactory.setPort(5672);即可正常连接。

2. RabbitMQ会不会扫描所有端口查找可用服务？

不会，RabbitMQ客户端只会连接你代码中显式指定的端口，没有指定的情况下会直接使用对应协议的默认端口，不会主动扫描其他端口。

3. 默认使用的端口是不是15672？

不是，不同场景的默认端口完全不同，RabbitMQ常用默认端口如下：

• 5672：未加密AMQP协议客户端连接默认端口
• 5671：加密TLS AMQP协议客户端连接默认端口
• 15672：未加密管理后台Web UI/HTTP API默认端口
• 15671：加密TLS管理后台Web UI/HTTP API默认端口

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