生产者客户端

生产者客户端

代码如下：

#include "mq_connection.hpp"int main()
{//1. 实例化异步工作线程对象xypmq::AsyncWorker::ptr awp=std::make_shared<xypmq::AsyncWorker>();//2. 实例化连接对象xypmq::Connection::ptr conn=std::make_shared<xypmq::Connection>("127.0.0.1",8085,awp);//3. 通过连接创建信道xypmq::Channel::ptr channel=conn->openChannel();//4. 通过信道提供的服务完成所需//  1. 声明一个交换机exchange1, 交换机类型为广播模式google::protobuf::Map<std::string,std::string> tmp_map;channel->declareExchange("exchange1",xypmq::ExchangeType::FANOUT,true,false,tmp_map);//  2. 声明一个队列queue1channel->declareQueue("queue1", true, false, false, tmp_map);//  3. 声明一个队列queue2channel->declareQueue("queue2", true, false, false, tmp_map);//  4. 绑定queue1-exchange1，且binding_key设置为queue1channel->queueBind("exchange1", "queue1", "queue1");//  5. 绑定queue2-exchange1，且binding_key设置为news.music.#channel->queueBind("exchange1", "queue2", "news.music.#");//5. 循环向交换机发布消息for (int i = 0; i < 10; i++) {xypmq::BasicProperties bp;bp.set_id(xypmq::UUIDHelper::uuid());bp.set_delivery_mode(xypmq::DeliveryMode::DURABLE);bp.set_routing_key("news.music.pop");channel->basicPublish("exchange1", &bp, "Hello World-" + std::to_string(i));}xypmq::BasicProperties bp;bp.set_id(xypmq::UUIDHelper::uuid());bp.set_delivery_mode(xypmq::DeliveryMode::DURABLE);bp.set_routing_key("news.music.sport");channel->basicPublish("exchange1", &bp, "Hello Bite");bp.set_routing_key("news.sport");channel->basicPublish("exchange1", &bp, "Hello chileme?");return 0;
}