Tag: MQ
All the articles with the tag "MQ".
ZMQ DEMO proxy代理模式
Published: at 04:44 PM请求应答直连模式 (https//ningto.com/upload/20210526-ntscreenshot-164326.png) 请求应答代理模式 (https//ningto.com/upload/20210526-ntscreenshot-164400.png) 客户端连接到7733端口，服务端...
ZMQ DEMO send_multipart方法的使用
Published: at 04:41 PM同一个进程内演示了多个包的同时发送和接收 include <iostream> include <zmqaddon.hpp> int main() { zmqcontextt ctx; zmqsockett sock1(ctx, zmqsockettypepush); zmqsoc...
ZMQ DEMO push pull 模式
Published: at 04:36 PM类似如生产者消费者模式，多个消费者可以均衡的消费所有生产出来的东西，比如有100个任务，只有一个消费者它需要消费100次，如果有10个消费者那么每个消费者只需要消费10次，大大提高了效率。 注意：当没有消费者时，生产...
ZMQ DEMO 发布订阅模式
Published: at 04:35 PM发布订阅模式 简介 一端发布，多端接收，如果没有订阅者就直接丢弃。 发布者 推送方，每秒推送一次气象信息： include <iostream> include <zmq.hpp> define randof(num) (int) ((float) (num) rand (...
ZMQ DEMO 分布式处理
Published: at 04:32 PM(https//ningto.com/upload/20210526-ntscreenshot-163324.png) 如图所示：一个工作派发器（dispatcher），多个工作者（worker），一个结果收集器（collector）。 dispatcher不断的派发工作给多个worker处理，worker将...
ZMQ DEMO pull方法的使用
Published: at 04:30 PM多个socket recv 接收多个socket的数据时如果在同一个线程中，其中一个socket阻塞了另外的socket也会受到影响，所以我们需要使用dontwait标志，异步接收消息，如果消息不存在时不阻塞直接返回，如下代码： int main()...
ZMQ DEMO 发布订阅模式-进程内
Published: at 04:24 PMpub sub inproc进程内通信 简介 进程内传输方式意味着在共享ZMQ context的线程间通过内存方式传输数据。 通讯地址必须保证已经被相同context上的一个socket创建了。 文件名必须是在与这个socket关联的ZMQ c...
ZMQ DEMO 请求应答模式
Published: at 04:22 PM请求应答模式 介绍 这是最基本的一个模式，很常用，一个请求一个应答，发送和接收必须配对。 示例说明 客户端发送一个字符串，然后接收服务端的应答； 服务端收到字符串后将其转换为大写返回给客户端； 代...
业界消息总线技术分析-ZeroMQ
Published: at 02:54 PMZeroMQ的设计理念 引用官方的说法： “ZMQ (以下 ZeroMQ 简称 ZMQ)是一个简单好用的传输层，像框架一样的一个 socket library，他使得 Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主...
qpid C++接口简单封装
Published: at 09:57 AMqpid C++接口简单封装 希望简单的封装能满足大部分场景，并且简单易用。 处理队列请求 如果我想处理某个队列的消息我只需要指定一个队列名和回调处理函数就可以了 server.AddQueueServer("pingpong", (const Message &msg, Message &reply) { stdcout...