RabbitMQ C++ 客户端开发与 AMQP 协议解析

首先安装底层事件循环库 libev，用于网络 I/O 监控：

sudo apt install libev-dev

接着克隆并编译 AMQP-CPP：

git clone https://gitee.com/iOceanPlus_Forked/AMQP-CPP.git
cd AMQP-CPP
make
sudo make install

AMQP-CPP 库的使用方式

AMQP-CPP 负责解析和生成 AMQP 数据包，但不负责建立网络连接。网络 I/O 由用户完成，或者使用其提供的可选网络层接口（如 TCP、libevent、libuv、asio 等）。

模式选择

1. TCP 模式：使用默认的 TCP 模块，需自行实现事件循环。
2. 扩展模式：集成 libevent、libev 等异步组件，性能更高。

TCP 模式实现示例

在 TCP 模式下，你需要继承 AMQP::TcpHandler 类来处理连接生命周期。必须重写 monitor 函数，将文件描述符放入事件循环（如 epoll/select）中监控。

以下是一个基础的处理类骨架，展示了如何响应连接状态变化：

#include <amqpcpp.h>
#include <amqpcpp/linux_tcp.h>

class MyTcpHandler : public AMQP::TcpHandler {
    /**
     * 当 AMQP 库创建新连接时调用
     */
    virtual void onAttached(AMQP::TcpConnection *connection) override {
        // 此处可初始化事务或配置
    }

    /**
     * TCP 连接建立后调用
     */
    virtual void onConnected(AMQP::TcpConnection *connection) override {
        // 准备建立 AMQP 握手
    }

    /**
     * TLS 安全连接建立后调用（仅 amqps://）
     */
    virtual bool onSecured(AMQP::TcpConnection *connection, const SSL *ssl) override {
        // 验证证书逻辑
        return true;
    }

    /**
     * 登录成功后调用，此时连接已就绪
     */
    virtual void onReady(AMQP::TcpConnection *connection) override {
        // 创建通道，开始发布或订阅
    }

    /**
     * 协商心跳间隔
     */
    virtual uint16_t onNegotiate(AMQP::TcpConnection *connection, uint16_t interval) {
        if (interval < 60) interval = 60;
        return interval;
    }

    /**
     * 发生致命错误时调用
     */
    virtual void onError(AMQP::TcpConnection *connection, const char *message) override {
        // 记录日志或通知用户
    }

    /**
     * AMQP 协议结束时调用
     */
    virtual void onClosed(AMQP::TcpConnection *connection) override {
        // 清理资源
    }

    /**
     * TCP 连接关闭或丢失时调用
     */
    virtual void onLost(AMQP::TcpConnection *connection) override {
        // 重连逻辑
    }

    /**
     * 最终分离方法
     */
    virtual void onDetached(AMQP::TcpConnection *connection) override {
        // 释放句柄
    }
};

在实际工程中，记得在 main 函数中实例化该类，并将其传递给 AMQP::TcpConnection 对象，随后启动事件循环即可。