文章目录
😏1. 项目介绍
官网:https://www.rabbitmq.com/
参考链接:http://t.csdnimg.cn/z8UOG
RabbitMQ 是一个开源的消息中间件,最初由 Rabbit Technologies 公司开发,并在后来成为 Pivotal Software(现为 VMware 子公司)的一部分。它实现了高级消息队列协议(AMQP
)标准,提供了可靠的、灵活的、可扩展的消息传递机制,被广泛应用于构建分布式系统中的消息通信架构。
以下是 RabbitMQ 的一些关键特点和功能:
RabbitMQ 被广泛应用于微服务架构、分布式系统、消息驱动的架构、日志收集和分析等场景中,成为构建可靠、高效消息传递系统的重要工具之一。通过使用 RabbitMQ,开发人员可以轻松地构建分布式系统,实现异步通信、解耦组件、提高系统的可靠性和可扩展性。
常用的RabbitMQ(C++)代理平台有:AMQP-CPP
和SimpleAmqpClient
。AMQP-CPP有基于asio、libev等多个示例,是基于c++17的,没跑通;这里就介绍SimpleAmqpClient,是在rabbitmq-c基础上的C++接口库。
😊2. 环境配置
首先,要有一个rabbitmq服务,可以在Linux上安装:
# 安装rabbitmq-server
sudo apt-get install --no-install-recommends rabbitmq-server
# 启动和启用 RabbitMQ Server,查看服务状态
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server
sudo systemctl status rabbitmq-server
# 安装管理插件并重启服务
sudo rabbitmq-plugins enable rabbitmq_management
sudo systemctl restart rabbitmq-server
# 可访问 http://localhost:15672 使用默认用户名和密码(guest/guest)登录来管理交换机、队列等
Github-rabbitmq-c:https://github.com/alanxz/rabbitmq-c
Github-SimpleAmqpClient:https://github.com/alanxz/SimpleAmqpClient
然后安装C++的客户端代理库:
# rabbitmq-c依赖
sudo apt-get install librabbitmq-dev
# SimpleAmqpClient
git clone https://github.com/alanxz/SimpleAmqpClient.git
cd SimpleAmqpClient
mkdir build
cd build
cmake ..
make
sudo make install
# 更新库
sudo ldconfig
g++编译示例:g++ -o main main.cpp -lSimpleAmqpClient -lrabbitmq
😆3. 使用说明
发布/生产者示例:
#include <SimpleAmqpClient/SimpleAmqpClient.h>
#include <iostream>
int main() {
try {
// 创建连接
AmqpClient::Channel::ptr_t channel = AmqpClient::Channel::Create("localhost");
// 声明队列
std::string queue_name = "hello";
channel->DeclareQueue(queue_name, false, true, false, false);
// 创建生产者消息
std::string message = "Hello World!";
AmqpClient::BasicMessage::ptr_t msg = AmqpClient::BasicMessage::Create(message);
std::cout << "=== produce message: " << message << std::endl;
// 发送消息
while (true) {
channel->BasicPublish("", queue_name, msg);
std::cout << "=== Sent " << message << std::endl;
usleep(200 * 1000);
}
} catch (const std::exception &e) {
std::cerr << e.what() << std::endl;
return 1;
}
return 0;
}
订阅/消费者示例:
#include <SimpleAmqpClient/SimpleAmqpClient.h>
#include <iostream>
int main() {
try {
// 创建连接
AmqpClient::Channel::ptr_t channel = AmqpClient::Channel::Create("localhost");
// 声明队列
std::string queue_name = "hello";
channel->DeclareQueue(queue_name, false, true, false, false);
// 消费者标记
std::string consumer_tag = channel->BasicConsume(queue_name, "");
std::cout << " [*] Waiting for messages. To exit press CTRL+C" << std::endl;
while (true) {
AmqpClient::Envelope::ptr_t envelope = channel->BasicConsumeMessage(consumer_tag);
std::string message_body = envelope->Message()->Body();
std::cout << "=== Received " << message_body << std::endl;
usleep(10 * 1000);
}
} catch (const std::exception &e) {
std::cerr << "Error: " << e.what() << std::endl;
return 1;
}
return 0;
}
效果如下:
以上。