删除文章

确定要删除这篇文章吗?

取消
确定

qpid C++接口简单封装

     阅读(595)  2019-04-12 09: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
文章数
326
总访问量
314857
今日访问
258
最近评论

liangzi: 不错 谢谢分享
tujiaw: registerThreadInactive:如果当前没有激活的线程,就去激活线程,让等待的线程去执行任务。
hgzzx: 佩服佩服。 请教:registerThreadInactive的作用是什么?
xuehaoyun: 很不错,来围观一下
tujiaw: 抱歉csdn code服务关闭了,这个代码我也找不到了
于淞: 你好,这个文章的源码能分享一下吗,songsong9181@163.com,谢谢了 上面的写错了
回到顶部