Android 监听RabbitMQ的连接异常

要监听RabbitMQ的连接异常，你可以使用RabbitMQ Java客户端提供的 ConnectionListener 接口。该接口包含了多个方法，其中 onClosed 和 onDisconnected 可以用来监听连接关闭和连接断开事件。

下面是一个简单的示例代码，演示如何使用 ConnectionListener 监听连接异常：

import com.rabbitmq.client.*;

public class ConnectionListenerExample {
    public static void main(String[] args) throws Exception {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setUsername("guest");
        factory.setPassword("guest");
        factory.setHost("localhost");

        // 创建连接
        Connection connection = factory.newConnection();

        // 添加连接监听器
        connection.addShutdownListener(new ShutdownListener() {
            @Override
            public void shutdownCompleted(ShutdownSignalException e) {
                if (e.isHardError()) {
                    System.err.println("Connection closed with error: " + e.getMessage());
                } else {
                    System.out.println("Connection closed");
                }
            }
        });
        connection.addBlockedListener(new BlockedListener() {
            @Override
            public void handleBlocked(String reason) throws IOException {
                System.err.println("Connection blocked: " + reason);
            }

            @Override
            public void handleUnblocked() throws IOException {
                System.out.println("Connection unblocked");
            }
        });
        connection.addRecoveryListener(new RecoveryListener() {
            @Override
            public void handleRecovery(Recoverable recoverable) {
                System.out.println("Connection recovered");
            }

            @Override
            public void handleRecoveryStarted(Recoverable recoverable) {
                System.out.println("Connection recovery started");
            }
        });

        // 创建一个通道
        Channel channel = connection.createChannel();

        // ... 使用通道进行操作 ...

        // 关闭连接
        connection.close();
    }
}

在上面的代码中，我们添加了三个监听器：ShutdownListener、BlockedListener 和 RecoveryListener。其中，ShutdownListener 监听连接关闭事件，BlockedListener 监听连接被阻塞事件，RecoveryListener 监听连接恢复事件。在每个监听器的回调方法中，我们可以打印一些日志或者执行一些其他操作。

需要注意的是，当连接关闭时，需要检查 ShutdownSignalException 的 isHardError 方法，判断连接是否因为错误而关闭。如果是，则需要打印错误信息。