qpid C++接口简单封装

       阅读(118)  2019-04-12 17:57:21

qpid C++接口简单封装

希望简单的封装能满足大部分场景,并且简单易用。

处理队列请求

如果我想处理某个队列的消息我只需要指定一个队列名和回调处理函数就可以了

server.AddQueueServer("pingpong", [](const Message &msg, Message &reply) {
    std::cout << std::this_thread::get_id() << " msgid:" << msg.getMessageId() << ",reply:" << msg.getContent() << std::endl;
    reply = msg;
});

如果一个处理不过来可以循环调用上面函数多次,每个新增都是在一个单独的线程上处理,相当于多个线程在消费qpid上的消息

接收订阅消息

跟处理队列类似,订阅没有应答

server.AddTopicServer("ningtotopic", [](const Message &msg) {
    std::cout << std::this_thread::get_id() << " msgid:" << msg.getMessageId() << ",reply:" << msg.getContent() << std::endl;
});

发送同步消息

参数依次是:队列名、请求消息、应答消息、超时时间

bool SendMsg(const std::string &name, const Message &requestMsg, Message &responseMsg, int milliseconds = 1000);

发送异步消息

参数依次是:队列名、请求消息、超时时间秒、应答回调

bool PostMsg(const std::string &name, const QMsgPtr &msg, int second, const ResponseCallback &cb);

推送消息

参数依次是:topic、发送的消息

bool PublishMsg(const std::string &topic, const Message &msg);

源码

github源码

文章评论

Keep it simple,stupid
文章数
283
总访问量
260271
今日访问
601
最近评论

ningto : 请到next.ningto.com里发表评论。
tujiaw : 抱歉csdn code服务关闭了,这个代码我也找不到了
于淞 : 你好,这个文章的源码能分享一下吗,songsong9181@163.com,谢谢了 上面的写错了
于淞 : 你好,这个文章的源码能分享一下吗,838106303@163.com,谢谢了 上面的链接不能用了
tujiaw : 多谢多谢
essaypinglun college-paper.org : 很好的博客,赞赞
Folly : 这个实现有点奇怪,Qt为什么没有统一的比对方法。
过多s : alert("hello, world!")
tujiaw : 还不错哦
回到顶部