rabbitmq cpp 重连

以下是使用AMQP-CPP库在C++中实现RabbitMQ重连的示例代码：

#include <iostream>
#include <amqpcpp.h>
#include <amqpcpp/libboostasio.h>

using namespace std;using namespace AMQP;

int main() {
    // 建立连接
    Address address("localhost", 5672, amqp_default_user, amqp_default_password, "/");
    auto *connection = new TcpConnectionHandler(address);
    auto *channel = new Channel(connection);

    // 设置连接关闭时的回调函数
    connection->onClose([&](const TcpConnectionHandler &connection) {
        cout << "Connection closed" << endl;
        // 重新连接
        connection.connect();
    });

    // 连接到RabbitMQ服务器
    connection->connect();

    // 进入事件循环
    channel->consume("queue_name", [&](const Message &message, uint64_t deliveryTag, bool redelivered) {
        // 处理消息
    });

    return 0;
}

在上面的代码中，我们首先建立了一个连接和一个通道，然后设置了连接关闭时的回调函数。当连接关闭时，回调函数会被调用，我们在回调函数中重新连接到RabbitMQ服务器。最后，我们进入事件循环，等待消息到达。