Android 监听RabbitMQ的断开重连

要监听RabbitMQ的断开和重连，可以在连接断开后尝试重新连接，直到连接成功或达到最大重试次数。可以使用以下代码实现：

private final static int MAX_RETRIES = 10; // 最大重试次数
private final static long RETRY_DELAY = 5000; // 重试延迟时间（毫秒）

private Connection connection;
private Channel channel;
private int retryCount = 0;

private void connectToRabbitMQ() {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("your-rabbitmq-host");
    factory.setUsername("your-username");
    factory.setPassword("your-password");

    try {
        connection = factory.newConnection();
        channel = connection.createChannel();
        setupChannel(); // 设置通道
        retryCount = 0; // 连接成功，重试次数重置为0
    } catch (Exception e) {
        Log.e(TAG, "Failed to connect to RabbitMQ: " + e.getMessage());
        if (retryCount < MAX_RETRIES) {
            retryCount++;
            new Handler().postDelayed(new Runnable() {
                @Override
                public void run() {
                    connectToRabbitMQ(); // 尝试重新连接
                }
            }, RETRY_DELAY);
        } else {
            Log.e(TAG, "Maximum number of retries reached");
        }
    }
}

private void setupChannel() {
    // 设置通道
}

private void closeConnection() {
    try {
        channel.close();
        connection.close();
    } catch (Exception e) {
        Log.e(TAG, "Failed to close RabbitMQ connection: " + e.getMessage());
    }
}

在连接断开时，会尝试重新连接，最多重试10次，每次重试间隔为5秒。当连接成功后，会重置重试次数为0。在关闭连接时，也需要关闭通道和连接。