RabbitmqCoect介绍
1、RabbitmqCoect是基于C++11实现的简单易用的rabbitmq客户端。
2、源码只包含一个头文件与一个示例代码，无需编译安装，真正做到零依赖。
3、RabbitmqCoect针对RabbitMQCCliet进行封闭，提供给用户更友好的接口。
4、RabbitmqCoect追求极简易用，只提供了以下方法：
sed发送消息recv接收消息logi身份认证close关闭连接coect连接服务器安装方法1、下载源码
gitcloe https://gitee.com/xuge/rabbitmqcoect.git
2、直接在工程中包含RabbitmqCoect.h头文件
3、利用RabbitmqCoect发送与接收消息示例代码如下
发送消息
RabbitmqCoectco;if(co.coect(host,port)&&co.logi(user,passwd)){cout<<"连接消息队列成功"<<edl;if(co.sed(exchage,queueame,"message")<0){cout<<"发送消息成功"<<edl;}else{cout<<"发送消息失败"<<edl;}}接收消息
while(true){RabbitmqCoectco;if(co.coect(host,port)&&co.logi(user,passwd)){cout<<"开始监听消息队列["<<exchage<<"]["<<queueame<<"]"<<edl;while(true){co.recv(exchage,queueame,[](costchar*data,itle){strigmsg(data,data+le);cout<<"收到消息["<<msg<<"]"<<edl;});//连接异常需要重连if(co.getErrorCode()==AMQP_STATUS_SOCKET_ERROR)break;}cout<<"监听消息队列失败["<<co.getErrorStrig()<<"]"<<edl;}else{cout<<"连接消息队列["<<host<<":"<<port<<"]["<<user<<"]失败"<<edl;}sleep(5);}RabbitMQ官网RabbitMQ客户端RabbitMQCCliet下载
评论