RabbitMQ 分布式系统实战：从安装部署到 C++ 调用

安装与配置

服务端安装

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

sudo apt install rabbitmq-server

启动并检查状态：

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

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

# 添加用户
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 和端口。

常见问题：Web UI 登录报错通常不是账号密码问题，尝试重新创建用户并重启服务 systemctl restart rabbitmq-server 即可解决。

客户端库安装

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

sudo apt-get install librabbitmq-dev

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

AMQP-CPP 是基于 C 接口的 C++ 封装库，更适合 C++ 项目使用。

(1) 安装依赖库 libev：

sudo apt install libev-dev

(2) 下载源码：

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

(3) 编译并安装：

make
make install

注意：若编译出现 SSL 版本错误，可尝试修复系统依赖或强制卸载冲突库：

sudo apt --fix-broken install
sudo dpkg -P --force-all libevent-openssl-2.1-7
sudo dpkg -P --force-all openssl
sudo dpkg -P --force-all libssl-dev

默认端口说明：Web 控制台通常为 15672，服务端连接端口为 5672，集群模式端口为 25672。

AMQP-CPP 库使用

库介绍

AMQP-CPP 是一个专门用于与 RabbitMQ 通信的 C++ 库。它解析和生成数据，但不直接负责建立网络连接（网络 IO 需用户自己实现），适合对性能要求高的场景。代码需使用 C++17 或更高版本编译。

两种工作模式

模式 1：TCP 模式（自己管网络） 用户需继承 AMQP::TcpHandler 类，重写 monitor 函数，手动管理网络套接字（fd）并将其交给事件循环（如 epoll）。适用于想完全自定义网络层的场景。

模式 2：扩展模式（用现成库省事） 推荐使用此模式。例如使用 libev 库时，直接继承 AMQP::LibEvHandler 类，库会自动处理 fd 监控和消息处理，无需手动编写 monitor 函数。

常用接口

• Channel: declareExchange() 声明交换机，declareQueue() 声明队列，bindQueue() 绑定，publish() 发布消息，consume() 订阅消息。
• Message: body() 获取正文，bodySize() 获取大小。
• libev: ev_default_loop() 获取事件句柄，ev_run() 运行事件循环。

实战案例

基础测试

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

发布端效果：

可以看到客户端成功连接到服务端，建立了连接与信道。

服务端视图：

交换机、队列及消息均正确显示。

订阅端效果：

启动订阅客户端后，能收到发布端发送的消息，服务端消息计数归零。

注意：原生 RabbitMQ 无论先启动发布还是订阅端，消息都能正常流转。这与某些仿制实现不同，后者可能要求必须先启动消费者。

代码参考

相关代码文件包括 publish.cc 和 consume.cc，详细逻辑见注释。

API 二次封装

为了简化开发，可以将事件监控结构 loop、通信连接 connection 以及信道 channel 封装起来，提供统一的接口。

封装思路：

1. 封装底层对象。
2. 提供创建交换机、队列并绑定的便捷接口。
3. 提供向指定交换机发布消息的接口。
4. 提供订阅指定队列消息的接口。

运行表现： 由于声明交换机和队列需要时间，打印顺序可能与调用顺序不一致，这是正常的异步行为。只要发布与订阅顺序无关，最终都能成功收到消息。

完整源码参考：

• Rabbitmq.hpp
• 示例代码目录

小结

RabbitMQ 作为强大的消息队列中间件，通过灵活的路由机制实现了分布式系统的异步通信与解耦。在 Linux 下安装便捷，结合 AMQP-CPP 库可以高效地进行 C++ 客户端开发。通过对客户端 API 的二次封装，能进一步提升开发效率，适用于多种分布式场景。