连接异常处理

RabbitMQ 连接过程中可能遇到多种异常，下面梳理常见异常类型及处理策略。

常见异常类型

TimeoutException 连接超时

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import java.util.concurrent.TimeoutException;
import java.io.IOException;

public class ConnectionTimeoutExample {
    public static void main(String[] args) {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setConnectionTimeout(5000);
        
        try {
            Connection connection = factory.newConnection();
            System.out.println("连接成功");
            connection.close();
        } catch (TimeoutException e) {
            System.err.println("连接超时: " + e.getMessage());
        } catch (IOException e) {
            System.err.println("IO异常: " + e.getMessage());
        }
    }
}

AuthenticationFailureException 认证失败

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ShutdownSignalException;

public class AuthFailureExample {
    public static void main(String[] args) {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("wrong_user");
        factory.setPassword("wrong_pass");
        
        try {
            factory.newConnection();
        } catch (Exception e) {
            if (e.getCause() instanceof ShutdownSignalException) {
                ShutdownSignalException sig = (ShutdownSignalException) e.getCause();
                System.err.println("认证失败: " + sig.getMessage());
            } else {
                System.err.println("连接异常: " + e.getMessage());
            }
        }
    }
}

异常分类与处理

安全资源释放

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class SafeResourceReleaseExample {
    public static void main(String[] args) {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        Connection connection = null;
        Channel channel = null;
        
        try {
            connection = factory.newConnection();
            channel = connection.createChannel();
            System.out.println("资源创建成功");
            
            // 执行业务逻辑
            // channel.basicPublish(...);
            
        } catch (IOException | TimeoutException e) {
            System.err.println("连接异常: " + e.getMessage());
        } finally {
            // 按顺序关闭资源
            try {
                if (channel != null && channel.isOpen()) {
                    channel.close();
                }
            } catch (IOException | TimeoutException e) {
                System.err.println("关闭Channel异常: " + e.getMessage());
            }
            try {
                if (connection != null && connection.isOpen()) {
                    connection.close();
                }
            } catch (IOException e) {
                System.err.println("关闭Connection异常: " + e.getMessage());
            }
        }
    }
}

注意事项

捕获异常时应区分 TimeoutException 和 IOException，两者处理策略不同。

资源释放必须按 Channel -> Connection 顺序关闭，避免依赖资源报错。

生产环境建议实现 Connection 的自动重连机制或使用客户端库提供的重连策略。

频繁出现认证失败时检查 RabbitMQ 用户权限配置，而非盲目重试。

要点总结

• 连接异常主要分为超时、IO、认证、已关闭四类，需分类处理。
• TimeoutException 通常由网络或服务未启动引起，需检查基础配置。
• 认证失败通过 ShutdownSignalException 捕获，需验证账号密码。
• 资源释放必须在 finally 块中按顺序关闭，先 Channel 后 Connection。
• 生产环境应配合重连策略，避免单次失败导致业务中断。