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

RabbitMQ 与相关技术对比

总结

RabbitMQ 是一个轻量级、高可靠的消息队列中间件，通过灵活的路由机制和多种交换机类型，帮助分布式系统实现异步通信、解耦和流量控制，是构建高可用、可扩展服务的核心工具之一。

RabbitMQ 安装教程

RabbitMQ 安装

1. 安装 RabbitMQ

sudo apt install rabbitmq-server

2. 启动 & 检查状态

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

3. 创建管理员用户（默认 guest 权限低）

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

4. 开启 Web 管理界面（默认端口 15672）

sudo rabbitmq-plugins enable rabbitmq_management

访问：http://你的服务器 IP:15672 登录：用户名=root，密码=123456

如果服务器端口未向外开放，需要修改配置文件设置监听的 IP 以及部署的端口。

编辑配置文件：

vim /etc/rabbitmq/rabbitmq.conf

添加对应字段后重启服务即可。

常见问题： 连接 Web UI 时若出现错误，通常不是账号密码问题，而是权限配置问题。重新设置允许登录的新用户并重启服务即可解决。

RabbitMQ 客户端及 C++ 库安装步骤

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

作用：提供基础的 RabbitMQ C 接口，用于消息通信。

sudo apt-get install librabbitmq-dev

2. 安装 RabbitMQ 的 C++ 客户端库（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 版本错误，需重新执行 make 或修复系统依赖。

修复系统依赖：

sudo apt --fix-broken install

卸载冲突的 SSL 库（强制卸载）：

sudo dpkg -P --force-all libevent-openssl-2.1-7
sudo dpkg -P --force-all openssl
sudo dpkg -P --force-all libssl-dev

默认端口介绍

对于 RabbitMQ 的 Web 控制台默认部署的是 15672 端口，服务端默认端口是 5672，集群模式使用的端口是 25672。

AMQP-CPP 库介绍

介绍

1. 是什么？

AMQP-CPP 是一个 C++ 库，专门用于与 RabbitMQ 通信。它的核心功能是解析/生成数据，能处理 RabbitMQ 发来的消息，也能构造要发送的消息。

• 高性能：完全异步（无阻塞调用，不用多线程），适合对性能要求高的场景。
• 依赖 C++17：代码需要用 C++17 或更高版本编译。

2. 怎么用？两种模式

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

• 核心操作：用户需自己实现一个类，继承自 AMQP::TcpHandler（负责 TCP 连接）。
• 关键步骤：重写 monitor 函数，手动管理 IO，把网络套接字交给自己的事件循环。
• 适用场景：想完全自定义网络层。

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

• 以 libev 为例：直接使用 AMQP-CPP 提供的 AMQP::LibEvHandler 类，库会自动处理 fd 监控和消息处理。
• 其他支持：除了 libev，还支持 libevent、libuv、asio 等异步通信组件。
• 适用场景：想快速集成，不想手动写网络 IO 代码（推荐大多数用户用）。

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

模式 2 常见接口介绍

1. AMQP::Channel: 信道类

• Channel(Connection *connection); - 构造函数
• bool connected() - 检查连接状态
• Deferred &declareExchange() - 声明交换机
• DeferredQueue &declareQueue() - 声明队列
• Deferred &bindQueue() - 将交换机与队列进行绑定
• bool publish() - 发布消息
• DeferredConsumer &consume() - 订阅队列消息
• bool ack() - 消费者客户端对收到的消息进行确认应答

2. class Message: 消息类

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

3. libev 使用到的结构体与接口

• struct ev_loop *ev_default_loop (); - 实例化并获取 I/O 事件监控结构句柄。
• int ev_run (struct ev_loop *loop); - 开始运行 I/O 事件监控，这是一个阻塞接口。
• void ev_break (struct ev_loop *loop, int32_t break_type); - 结束 I/O 监控。
• void ev_async_init(ev_async *w, callback cb); - 初始化异步事件结构，并设置回调函数。
• void ev_async_start(struct ev_loop *loop, ev_async *w); - 启动事件监控循环中的异步任务处理。
• void ev_async_send(struct ev_loop *loop, ev_async *w); - 发送当前异步事件到异步线程中执行。

AMQP-CPP 库简单使用

测试效果

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

首先启动发布客户端，进行注册对应信息向 MQ 服务端。 可以看到我们 publish 客户端连对应的连接与信道。 对应的交换机，队列，以及发送进来的消息也都正确。 最后启动订阅客户端就能收到对应消息。

注意： 这个和之前实现的仿 RabbitMQ 实现的消息队列不同，本身的 RabbitMQ 消息队列无论是先启动订阅还是发布端，最后订阅端都能收到发进去的消息；但是之前实现的那个仿照版本的必须先启动订阅端然后再是发布端，因为发布端发布进去消息就去找对应订阅队列的消费者的回调函数给它推送过去，反之则不可能进行推送了。

测试代码

publish.cc 与 consume.cc 对应代码详见项目仓库。

RabbitMQ 客户端 API 二次封装

封装思想

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

测试效果

客户端进行订阅队列，然后对于底层的事件监控交给对应异步线程，主线程阻塞住等待异步线程完成处理后进行异步事件通知来 break 它后进行回收。 这里发现打印的顺序和调用顺序不一样，因为这里声明完对应交换机、队列后才回去调用对应回调处理，也就是进行发布的过程速度比进行处理声明完回调速度快。 成功收到对应消息（这里 publish 与 consume 顺序谁先谁后也是无关的）。

代码汇总

详细代码见注释。

总结

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