网站建设图片大小,打电话叫人做网站,扬州房产网,wordpress商城汉化主题#x1f60f;★,:.☆(#xffe3;▽#xffe3;)/$:.★ #x1f60f; 这篇文章主要介绍。 无专精则不能成#xff0c;无涉猎则不能通。——梁启超 欢迎来到我的博客#xff0c;一起学习#xff0c;共同进步。 喜欢的朋友可以关注一下#xff0c;下次更新不迷路#x1… ★,°:.☆(▽)/$:.°★ 这篇文章主要介绍。 无专精则不能成无涉猎则不能通。——梁启超 欢迎来到我的博客一起学习共同进步。 喜欢的朋友可以关注一下下次更新不迷路 文章目录 :smirk:1. 项目介绍:blush:2. 环境配置:satisfied:3. 使用说明 1. 项目介绍
官网https://www.rabbitmq.com/
参考链接http://t.csdnimg.cn/z8UOG
RabbitMQ 是一个开源的消息中间件最初由 Rabbit Technologies 公司开发并在后来成为 Pivotal Software现为 VMware 子公司的一部分。它实现了高级消息队列协议AMQP标准提供了可靠的、灵活的、可扩展的消息传递机制被广泛应用于构建分布式系统中的消息通信架构。
以下是 RabbitMQ 的一些关键特点和功能 1.消息队列 RabbitMQ 提供了一个消息队列系统用于在生产者和消费者之间传递消息。它支持多种消息传递模式包括点对点、发布/订阅等。 2.可靠性 RabbitMQ 提供了持久化消息、消息确认机制、错误处理等功能确保消息能够可靠地发送和接收同时能够处理网络故障和系统崩溃等情况。 3.灵活性 RabbitMQ 支持多种消息格式、消息路由规则、交换机类型和队列绑定使其能够适应各种复杂的消息传递场景。 4.可扩展性 RabbitMQ 提供了集群和分区机制可以方便地进行水平扩展以处理大量的消息流量和提高系统的容错能力。 5.管理界面 RabbitMQ 提供了用户友好的管理界面用于监控队列、交换机、连接、通道等状态并进行配置管理和性能调优。 6.插件系统 RabbitMQ 提供了丰富的插件系统可以扩展其功能例如支持 STOMP、MQTT、Web STOMP、LDAP 等插件。 RabbitMQ 被广泛应用于微服务架构、分布式系统、消息驱动的架构、日志收集和分析等场景中成为构建可靠、高效消息传递系统的重要工具之一。通过使用 RabbitMQ开发人员可以轻松地构建分布式系统实现异步通信、解耦组件、提高系统的可靠性和可扩展性。
常用的RabbitMQC代理平台有AMQP-CPP和SimpleAmqpClient。AMQP-CPP有基于asio、libev等多个示例是基于c17的没跑通这里就介绍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-chttps://github.com/alanxz/rabbitmq-c Github-SimpleAmqpClienthttps://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 ldconfigg编译示例g -o main main.cpp -lSimpleAmqpClient -lrabbitmq
3. 使用说明
发布/生产者示例
#include SimpleAmqpClient/SimpleAmqpClient.h
#include iostreamint 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 iostreamint 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 CTRLC 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;
}效果如下 以上。
