Android监听RabbitMQ的断开和重连

要监听RabbitMQ的断开和重连，你可以使用RabbitMQ自带的ConnectionListener接口。

首先，你需要创建一个ConnectionListener的实现类：

public class RabbitMQConnectionListener implements ConnectionListener {

    @Override
    public void onConnectionClosed(Connection connection) {
        // 当RabbitMQ连接关闭时，会调用此方法
        // 在此处处理连接关闭的逻辑
    }

    @Override
    public void onConnectionBlocked(Connection connection, String reason) {
        // 当RabbitMQ连接被阻塞时，会调用此方法
        // 在此处处理连接被阻塞的逻辑
    }

    @Override
    public void onConnectionUnblocked(Connection connection) {
        // 当RabbitMQ连接被解除阻塞时，会调用此方法
        // 在此处处理连接解除阻塞的逻辑
    }
}

然后，在创建RabbitMQ连接的时候，将上面的ConnectionListener实现类添加到连接中：

ConnectionFactory factory = new ConnectionFactory();
// 设置RabbitMQ的连接参数
factory.setHost("localhost");
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");

// 创建RabbitMQ的连接
Connection connection = factory.newConnection();
// 将ConnectionListener添加到连接中
RabbitMQConnectionListener connectionListener = new RabbitMQConnectionListener();
connection.addShutdownListener(connectionListener);

这样，当RabbitMQ的连接关闭、被阻塞或被解除阻塞时，ConnectionListener的相应方法就会被调用，你就可以在这些方法中处理相应的逻辑了。