轻松玩转消息通信:SimpleAmqpClient 和 RabbitMQ 在C++中的终极指南

Rabbmq服务端

安装

这里我使用docker安装rabbitmq服务端,没有安装的就先去看其他的博客安装rabbitmq或者docker

#拉取rabbitmq
docker pull rabbitmq:management
#运行rabbitmq,记得打开防火墙端口
docker run -d --hostname rabbitsrv --name rabbit -p 5672:5672 -p 15672:15672 -p 25672:25672 rabbitmq:management

访问网页后台管理页面

#http示例网址
127.0.0.1:15672

用户名和密码都是guest

image-20240302162600555

  • Direct exchange(直连交换机) 单播
  • Fanout exchange(扇型交换机) 广播
  • Topic exchange(主题交换机) 组播
  • Headers exchange(头交换机) 匹配

添加一个交换机,选择直连模式

image-20240302170420468

image-20240302170632381

添加一个队列

image-20240302170731961

image-20240302170824873

建立绑定规则

填写刚刚创建的my.queue队列,路由key我们输入key1

image-20240302171042610

image-20240302171206276

尝试发送一次消息

  1. 在exchanges界面中点击我们创建的交换机进入

image-20240302172149385

随后进入Queeus界面,点击我们创建的队列

image-20240302172249635

image-20240302172457414

rabbitmq客户端

简介

SimpleAmqpClient是一个C++库,旨在简化处理AMQP消息的过程。AMQP是一种用于消息传递的开放式标准协议,它允许不同应用程序之间的可靠通信。SimpleAmqpClient使得在C++应用程序中轻松实现AMQP消息处理变得简单。

先决条件

确保你的开发环境中已经安装了以下工具:

  • CMake 3.5+ 构建系统
  • Boost 1.47.0 或更新版本
  • 安装 RabbitMQ-C,你可以按照给定的步骤进行安装。
git clone https://github.com/alanxz/rabbitmq-c.git
cd rabbitmq-c
mkdir build && cd build
cmake ..
cmake --build .

安装 SimpleAmqpClient

在安装了 RabbitMQ-C 后,我们将使用 SimpleAmqpClient 进行 C++ 消息通信。请按照以下步骤安装 SimpleAmqpClient:

git clone https://github.com/alanxz/SimpleAmqpClient.git
cd SimpleAmqpClient
mkdir simpleamqpclient-build
cd simpleamqpclient-build
cmake ..
cmake --build .

在编译时,确保将 SimpleAmqpClient 链接到你的项目中。

示例代码

header only

#include <SimpleAmqpClient/SimpleAmqpClient.h>

RabbitMQ 信息结构

rabbitmq.h


#include <string>
struct RabbitMqInfo{std::string RabbitURL = "amqp://guest:guest@127.0.0.1:5672";std::string TransExchangeName = "my.direct";std::string TransQueueName = "my.queue";std::string TransRoutingKey = "key1";
};

生产者

#include "rabbitmq.h"
#include <SimpleAmqpClient/SimpleAmqpClient.h>
int main(){// 指定mq的一些信息RabbitMqInfo MqInfo;// 创建一条和mq的连接AmqpClient::Channel::ptr_t channel = AmqpClient::Channel::Create();// pause();// 创建消息AmqpClient::BasicMessage::ptr_t message = AmqpClient::BasicMessage::Create("Hello");// 发布消息channel->BasicPublish(MqInfo.TransExchangeName,MqInfo.TransRoutingKey,message);
}

消费者

#include "rabbitmq.h"
#include <SimpleAmqpClient/SimpleAmqpClient.h>
int main(){// 指定mq的一些信息RabbitMqInfo MqInfo;// 创建通道AmqpClient::Channel::ptr_t channel = AmqpClient::Channel::Create();// 指定获取一个从某一个队列中的消息channel->BasicConsume(MqInfo.TransQueueName);//信封,用来存储消息AmqpClient::Envelope::ptr_t envelope;//消费消息bool isNotTimeout = channel->BasicConsumeMessage(envelope,5000);if(isNotTimeout == false){fprintf(stderr,"timeout\n");return -1;}fprintf(stderr,"message = %s\n", envelope->Message()->Body().c_str());return 0;
}

结论

SimpleAmqpClient提供了一个简单而强大的方式来在C++应用程序中处理AMQP消息。通过这个库,你可以轻松地实现可靠的消息通信,使你的应用程序更加灵活和可扩展。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/748570.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

前端和后端权限控制【笔记】

前端权限设置【笔记】 前言版权推荐前端权限设置需求效果实现资源 后端权限控制1.给所有前端请求都携带token2.添加拦截器3.配置到WebMvcConfiguration4.更多的权限验证 最后 前言 2024-3-15 18:27:26 以下内容源自《【笔记】》 仅供学习交流使用 版权 禁止其他平台发布时删…

Seata 2.x 系列【11】多数据源分布式事务

有道无术&#xff0c;术尚可求&#xff0c;有术无道&#xff0c;止于术。 本系列Seata 版本 2.0.0 本系列Spring Boot 版本 3.2.0 本系列Spring Cloud 版本 2023.0.0 源码地址&#xff1a;https://gitee.com/pearl-organization/study-seata-demo 文章目录 1. 概述2. 多数据…

SQLiteC/C++接口简介

快速跳转文章列表&#xff1a;SQLite—系列文章目录 上一篇&#xff1a;SQLite——世界上部署最广泛的开源数据库&#xff08;简介&#xff09; 下一篇&#xff1a;SQLiteC/C接口详细介绍&#xff08;一&#xff09; 引言&#xff1a; 作为一种轻量级、嵌入式关系型数据库…

MAC M芯片 Anaconda安装

Anaconda安装 1.M芯片下载AnaConda 1.M芯片下载AnaConda https://www.anaconda.com/download 安装完成 conda的版本是24.1.2

Go语言中的make和new:内存分配与对象创建的巧妙之道

Go语言中的make和new&#xff1a;内存分配与对象创建的巧妙之道 Go语言作为一门简洁而强大的编程语言&#xff0c;提供了多种用于动态内存分配和对象创建的关键词。其中&#xff0c;make和new是两个常见且常被混淆的关键词。本文将深入讲解Go语言中make和new的区别&#xff0c;…

python来判断密码强弱-类

设计者&#xff1a;ISDF 版本&#xff1a;v1.0 日期&#xff1a;2019/4/3设计者&#xff1a;ISDF 版本&#xff1a;v2.0 日期&#xff1a;2024/4/3 class PasswordTool:密码工具类def __init__(self,password):#类的属性self.password passwordself.stregth_level 0def check…

考研C语言复习进阶(5)

目录 1. 为什么使用文件 2. 什么是文件 2.1 程序文件 2.2 数据文件 2.3 文件名 3. 文件的打开和关闭 3.1 文件指针 3.2 文件的打开和关闭 4. 文件的顺序读写 ​编辑 ​编辑 4.1 对比一组函数&#xff1a; ​编辑 5. 文件的随机读写 5.1 fseek 5.2 ftell 5.3 rewind…

【C语言】linux内核pci_save_state

一、中文注释 //include\linux\pci.h /* 电源管理相关的例程 */ int pci_save_state(struct pci_dev *dev);//drivers\pci\pci.c /*** pci_save_state - 在挂起前保存PCI设备的配置空间* dev: - 我们正在处理的PCI设备*/ int pci_save_state(struct pci_dev *dev) {int i;/* X…

谷歌网络营销方案有几种?​

谷歌作为海外的头部工具&#xff0c;本身其实就有多种工具可以供你使用&#xff0c;在这里说说谷歌那些工具 Google My Business&#xff0c;对于小企业或者本地服务来说&#xff0c;把自己的业务信息优化并完善在Google My Business上是个不错的选择。这样当人们在附近搜索相…

微信小程序云开发教程——墨刀原型工具入门(表单组件)

引言 作为一个小白&#xff0c;小北要怎么在短时间内快速学会微信小程序原型设计&#xff1f; “时间紧&#xff0c;任务重”&#xff0c;这意味着学习时必须把握微信小程序原型设计中的重点、难点&#xff0c;而非面面俱到。 要在短时间内理解、掌握一个工具的使用&#xf…

【NC223888】红色和紫色

题目 红色和紫色 博弈论&#xff0c;想得出来思路就简单&#xff0c;想不出来就难。一般使用猜测法。 思路 如果小红随意取一个格子涂色&#xff0c;那么小紫怎么涂色才是她的最优选择呢&#xff1f; 假设小紫只能选择小红涂色的格子的相邻格子或者是最近斜对角的一个格子涂色…

LeetCode 2684.矩阵中移动的最大次数:一列一列处理,只记能到哪行(BFS)

【LetMeFly】2684.矩阵中移动的最大次数&#xff1a;一列一列处理&#xff0c;只记能到哪行(BFS) 力扣题目链接&#xff1a;https://leetcode.cn/problems/maximum-number-of-moves-in-a-grid/ 给你一个下标从 0 开始、大小为 m x n 的矩阵 grid &#xff0c;矩阵由若干 正 整…

【漏洞复现】大华智慧园区综合管理平台SQL注入漏洞

Nx01 产品简介 大华智慧园区综合管理平台是一款综合管理平台&#xff0c;具备园区运营、资源调配和智能服务等功能。该平台旨在协助优化园区资源分配&#xff0c;满足多元化的管理需求&#xff0c;同时通过提供智能服务&#xff0c;增强使用体验。 Nx02 漏洞描述 大华智慧园区…

Halcon图像预处理、阈值分割

1、blob&#xff08;Binary Large Object&#xff09;是指二值图像中连通区域。 预处理通常包括一系列步骤&#xff0c;例如去噪、形态学操作、特征提取等。 read_image(Image,claudia) get_image_size(Image,Width,Height) dev_open_window_fit_size (0, 0, Width, Width, -1,…

如何在iPhone上恢复已删除的微信聊天记录?

你好&#xff0c;我前几天删除了微信聊天记录。有什么办法可以恢复iPhone上已删除的微信聊天记录吗&#xff1f; 有些人每次使用设备时都会遇到在 iPhone 上丢失消息的风险。特别是&#xff0c;由于多种因素&#xff0c;可能会丢失第三方数据&#xff0c;微信消息也是如此。微…

2024Vue高频面试题

前言: Vue 在前端开发领域拥有强劲的发展势头,以下是一些 Vue 的发展趋势: 1.持续增长的用户数量: Vue 作为一款轻量级、易学易用的前端框架,吸引了越来越多的开发者和企业选择使用。其活跃的社区和丰富的资源也促进了用户数量的不断增长。 2.生态系统不断丰富: 随着 V…

远超预期,特效吹爆!《武庚纪》:建议漫改都按这个标准来!

作为《武庚纪》动画党&#xff0c;听闻要改编成真人电视剧时&#xff0c;最害怕的无非五毛钱特效&#xff0c;流水线仙侠&#xff0c;无脑古偶。但在看过《烈焰》&#xff08;原名&#xff1a;武庚纪&#xff09;之后&#xff0c;不得不感叹一句&#xff1a;“倒也不用这么还原…

【计算机网络篇】计算机网络的性能指标

文章目录 &#x1f354;计算机网络的性能指标&#x1f5c3;️常见的计算机网络性能指标⭐速率⭐带宽⭐吞吐量⭐时延⭐时延带宽积⭐往返时间⭐利用率⭐丢包率 &#x1f50e;总结 &#x1f354;计算机网络的性能指标 计算机网络的性能指标被用来从不同方面度量计算机网络的性能 …

算法的渐进时间复杂度

T(n) = O(F(n)) T(n):Time 渐进时间复杂度 O:正比例关系 F(n):代码执行次数 只要代码执行的次数越来越多 所耗费的时间也就越来越高 常见的5种: O(n^2) O(n logn) O(n) O(logn) O(1):不管重复多少次1次也是这个时间,10次也是这个时间。 时间复杂度排序:由小到…

JAVA22 FFM实战之HelloWorld

前言 JDK22即将发布&#xff0c;Java Foreign Function & Memory API将会退出预览&#xff0c;是时候开始学习一波了。 FFM API介绍 FFM API由两大部分组成&#xff0c;一个是Foreign Function Interface&#xff0c;另一个是Memory API。前者是外部函数接口&#xff0c…