simpleamqpclient 已不推荐用于新项目，因其底层 librabbitmq-c 停更、无异步i/o、无自动重连、易fd泄漏；amqp-cpp 成主流替代，支持自动资源管理、回调重试、免轮询消费及publisher confirms。
直接用 SimpleAmqpClient 库连接 RabbitMQ 是可行的，但 2025 年底它已**不再推荐用于新项目**——底层依赖的 librabbitmq-c 停更多年，不支持 AMQP 1.0、无异步 I/O、在高并发或断网重连场景下极易崩溃（比如 amqp_login 返回 AMQP_STATUS_SOCKET_ERROR 后未清理 socket 导致 fd 泄露）。
为什么 SimpleAmqpClient 在 C++ 项目中越来越难用
它本质是 rabbitmq-c 的薄封装，没解决核心痛点：
- 连接失败后
amqp_new_connection()+amqp_tcp_socket_new()需手动配对释放，漏一步就内存泄漏 - 没有内置重连逻辑：网络抖动时
amqp_basic_publish()可能静默失败，返回AMQP_STATUS_CONNECTION_CLOSED却不抛异常 - 消费者端用
amqp_basic_consume()后，必须自己轮询amqp_simple_wait_frame_noblock()，阻塞模式下线程卡死风险高 - 不支持消息确认（
ack）的自动重发补偿，basic.nack语义需手写状态机
替代方案：AMQP-CPP（轻量 + 异步 + 线程安全）
2025 年主流 C++ 项目已转向 AMQP-CPP，它用纯 C++11 实现，头文件即用，且天然适配现代构建系统。关键差异：
- 连接对象
AMQP::TcpConnection析构时自动关闭 socket 和 channel - 提供
AMQP::Channel::publish()的回调式重试（通过onError捕获AMQP::error_t::connection_error） - 消费用
channel.consume("queue", [](const AMQP::Message &msg, uint64_t deliveryTag) { ... })，消息到达即触发，无需轮询 - 默认启用 publisher confirms，
publish()返回bool表示是否进服务端队列，比SimpleAmqpClient::Channel::BasicPublish()更可靠
安装只需：
立即学习“C++免费学习笔记（深入）”；
git clone https://github.com/CopernicaMarketingSoftware/AMQP-CPP.git cd AMQP-CPP && make && sudo make install
CMakeLists.txt 中加一行：target_link_libraries(your_app AMQP-CPP)
生产者代码精简示例（AMQP-CPP）
对比 SimpleAmqpClient 动辄 50 行的连接+声明+发布流程，AMQP-CPP 15 行搞定且自带错误兜底：
#include <AMQP-CPP.h>
#include <iostream>
int main() {
AMQP::TcpConnection connection("amqp://guest:guest@localhost:5672/");
AMQP::TcpChannel channel(connection);
channel.declareQueue("task_queue", AMQP::durable);
auto ok = channel.publish("", "task_queue", "Hello World!", AMQP::confirmable);
if (!ok) std::cerr << "publish failed" << std::endl;
connection.close(); // 自动 wait for close ack
return 0;
}
注意："" 作 exchange 名表示使用默认 direct exchange；AMQP::confirmable 开启发布确认，避免消息丢失。
消费者要小心“公平分发”陷阱
很多人照搬 Java 教程设 channel.qos(1) 就以为能实现“能者多劳”，但在 C++ 里：
-
AMQP::Channel::setQos()必须在consume()之前调用，否则无效 - 若用
channel.consume(..., AMQP::noack)，则qos完全失效（RabbitMQ 不做 unack 计数） - 真正生效的写法是：
channel.consume("queue", callback, AMQP::manual)，然后在 callback 里显式调用channel.ack(deliveryTag)
否则两个消费者启动后，RabbitMQ 会把所有消息预取给第一个连上的 consumer，第二个 consumer 一直空转。
最常被忽略的一点：RabbitMQ 的 C++ 客户端不是“连上就能发”，而是“连上→开 channel →声明 queue/exchange →设置 qos（如需）→再 publish/consume”。少任何一环，错误码都藏在 AMQP::error_t 或 amqp_status_enum 里，不打印日志根本看不出哪步挂了。
