RabbitMQ 分布式系统实战：从安装部署到 C++ 客户端开发

环境搭建与安装

安装 RabbitMQ

在 Linux 环境下，可以使用以下命令安装：

sudo apt install rabbitmq-server

启动并检查状态：

# 启动服务
sudo systemctl start rabbitmq-server
# 查看状态（确保 active (running)）
sudo systemctl status rabbitmq-server

创建管理员用户

默认 guest 用户权限较低，建议创建管理员用户：

# 添加用户（示例：用户名 root，密码 123456）
sudo rabbitmqctl add_user root 123456
# 设为管理员
sudo rabbitmqctl set_user_tags root administrator
# 赋予权限（对所有虚拟主机）
sudo rabbitmqctl set_permissions -p / root ".*" ".*" ".*"

开启 Web 管理界面

默认端口为 15672，启用插件即可：

sudo rabbitmq-plugins enable rabbitmq_management

访问地址：http://你的服务器 IP:15672。如果无法访问，可能需要修改配置文件 /etc/rabbitmq/rabbitmq.conf 设置监听的 IP 和端口。

如果遇到登录错误，可以尝试重新创建用户并重启服务：

systemctl restart rabbitmq-server

安装 C++ 客户端库

1. 安装 RabbitMQ 官方客户端库（C 语言）

sudo apt-get install librabbitmq-dev

2. 安装 RabbitMQ 的 C++ 客户端库（AMQP-CPP）

AMQP-CPP 是基于 C 接口的 C++ 封装库，更适合用 C++ 编写客户端程序。

(1) 安装依赖库 libev：

sudo apt install libev-dev

(2) 下载 AMQP-CPP 源码：

git clone https://github.com/CopernicaMarketingSoftware/AMQP-CPP.git
cd AMQP-CPP/

(3) 编译并安装：

make
make install

注意：如果编译时出现 SSL 版本错误，需修复系统依赖。可尝试执行 sudo apt --fix-broken install，必要时卸载冲突的 SSL 库。

关于端口，Web 控制台默认是 15672，服务端默认是 5672，集群模式使用 25672。实际部署中可根据需求调整监听配置。

AMQP-CPP 库介绍

AMQP-CPP 是一个 C++ 库，专门用于与 RabbitMQ 通信。它的核心功能是解析/生成数据，完全异步（无阻塞调用），适合对性能要求高的场景，需要 C++17 或更高版本编译。

两种工作模式

模式 1：TCP 模式（自己管网络）

用户需自己实现一个类，继承自 AMQP::TcpHandler。必须重写 monitor 函数，手动管理 IO，把网络套接字交给自己的事件循环（如 select/epoll）。适用于想完全自定义网络层的场景。

模式 2：扩展模式（用现成库省事）

推荐使用此模式。如果使用 libev 库，可以直接使用 AMQP::LibEvHandler 类，库会自动处理 fd 监控和消息处理，无需自己写网络 IO 代码。除了 libev，还支持 libevent、libuv、asio 等异步通信组件。

后续我们将以扩展模式来实现对 RabbitMQ 的访问。

常见接口

• AMQP::Channel（信道类）

  • Channel(Connection *connection)：构造函数
  • bool connected()：检查连接状态
  • Deferred &declareExchange()：声明交换机
  • DeferredQueue &declareQueue()：声明队列
  • Deferred &bindQueue()：绑定交换机与队列
  • bool publish()：发布消息
  • DeferredConsumer &consume()：订阅队列消息
  • bool ack()：消费者确认应答

• class Message（消息类）

  • const char *body()：获取消息正文
  • uint64_t bodySize()：获取消息正文大小

• libev 结构体与接口

  • struct ev_loop *ev_default_loop()：获取 I/O 事件监控句柄
  • int ev_run(struct ev_loop *loop)：运行 I/O 事件监控（阻塞）
  • void ev_break(...)：结束 I/O 监控

简单使用案例

实现思路

分别实现发布客户端与订阅客户端，底层关联事件监控，建立连接、信道，声明交换机、队列、绑定消息，然后进行发布和订阅。

测试效果

首先启动发布客户端，向 MQ 服务端注册信息。可以看到 Publish 客户端建立了连接与信道，交换机、队列以及发送进来的消息都正确显示。

最后启动订阅客户端就能收到对应消息，服务端消息也会清空。

注意：原生 RabbitMQ 无论是先启动订阅还是发布端，最后订阅端都能收到消息。这与我们之前实现的仿 RabbitMQ 项目不同，后者必须先启动订阅端才能接收推送。

参考代码

相关实现代码位于 publish.cc 与 consume.cc，详细步骤见代码注释。

客户端 API 二次封装

封装思想

为了提升开发效率，我们可以对底层 API 进行封装：

1. 将事件监控结构 loop、通信连接 connection 以及信道 channel 封装起来。
2. 提供创建交换机、队列并进行直接绑定的接口。
3. 提供向指定交换机发布消息的接口。
4. 提供订阅指定队列消息的接口。

测试效果

客户端进行订阅队列，底层事件监控交给异步线程，主线程阻塞等待异步线程完成处理后进行异步事件通知来 break 它后进行回收。

打印顺序可能与调用顺序不一致，因为声明完交换机、队列后才回去调用对应回调处理，发布过程的速度可能比处理声明完回调速度快。

成功收到对应消息，此时 publish 与 consume 的顺序谁先谁后也是无关的。

代码汇总

完整的封装头文件及示例代码可以参考以下仓库：

• Rabbitmq.hpp
• publish.cc/consume.cc

小结

RabbitMQ 作为强大的消息队列中间件，通过灵活的交换机和丰富路由规则实现异步通信、解耦等功能。Linux 下安装便捷，AMQP-CPP 库提供了高效的 C++ 交互方式，配合客户端 API 封装能显著提升开发效率，适用于多种分布式场景。