cppzmq发布订阅模式

1. 首先需要下载cppzmq的库

github：https://github.com/zeromq/cppzmq

2. 将zmq.hpp 和 zmq_addon.hpp 两个库文件放入到自己的工程里面

3. 写demo

/*server.cpp*/#include <iostream>
#include <unistd.h>
#include "zmq.hpp"
#include "zmq_addon.hpp"int main()
{zmq::message_t msg;zmq::context_t zmq_context(1);                   //获取zmq上下文zmq::socket_t zmq_socket(zmq_context,ZMQ_PUB);   //创建ZMQ_PUB模式的socketzmq_socket.bind("tcp://*:6666");                 //绑定端口号std::string send_str = "hello world!"; msg.rebuild(send_str.data(), send_str.size());while(1){zmq_socket.send(msg, zmq::send_flags::dontwait);sleep(1);}return 0;
}

/*client.cpp*/#include <iostream>
#include <string>
#include "zmq.hpp"
#include "zmq_addon.hpp"int main()
{zmq::context_t zmq_context(1);                  //获取zmq上下文zmq::socket_t zmq_socket(zmq_context,ZMQ_SUB);  //创建ZMQ_PUB模式的socketzmq_socket.connect("tcp://localhost:6666");     //通过一个socket创建一个对外连接char topic[] = "333";   sock.set(zmq::sockopt::subscribe, zmq::const_buffer(topic, strlen(topic))); //设置过滤条件zmq::message_t msg;while(1){sock.recv(msg, zmq::recv_flags::none);      //接收消息cout << msg.to_string() << endl;}return 0;
}

4. 编译

g++ server.cpp zmq.hpp zmq_addon.hpp -o server -lzmq

g++ client.cpp zmq.hpp zmq_addon.hpp -o client -lzmq

cppzmq发布订阅模式相关推荐

Redis 笔记（10）— 发布订阅模式（发布订阅单个信道、订阅信道后的返回值分类、发布订阅多个信道）
1. 发布-订阅概念发布-订阅模式包含两种角色,分别为发布者和订阅者. 订阅者可以订阅一个或者若干个频道(channel): 而发布者可以向指定的频道发送消息,所有订阅此频道的订阅者都可以收到此消 ...
Redis 高级特性（2）—— 发布订阅模式
Redis 高级特性 -- 发布订阅 1. 发布-订阅介绍 "发布-订阅"模式包含两种角色,分别为发布者和订阅者.订阅者可以订阅一个或者若干个频道(channel),而发布者可以向 ...
【EventBus】发布-订阅模式 ( Android 中使用发布-订阅模式进行通信 )
文章目录一.拷贝发布-订阅模式相关类二.完整代码示例一.拷贝发布-订阅模式相关类将上一篇博客 [EventBus]发布-订阅模式 ( 使用代码实现发布-订阅模式 ) 写的发布-订阅模 ...
【EventBus】发布-订阅模式 ( 使用代码实现发布-订阅模式 )
文章目录一.发布-订阅模式二.代码实现发布-订阅模式 1.订阅者接口 2.订阅者实现类 3.发布者 4.调度中心 5.客户端一.发布-订阅模式发布订阅模式 : 发布者 Publisher : ...
【EventBus】发布-订阅模式 ( EventBus 组成模块 | 观察者模式 )
文章目录一.发布-订阅模式二.EventBus 组成模块三.观察者模式一.发布-订阅模式发布订阅模式 : 发布者 Publisher : 状态改变时 , 向消息中心发送事件 ; 订阅者 ...
JavaScript 设计模式之观察者模式与发布订阅模式
前言在软体工程中,设计模式(design pattern)是对软体设计中普遍存在(反复出现)的各种问题,所提出的解决方案. 设计模式并不直接用来完成程式码的编写,而是描述在各种不同情况下,要怎么解决 ...
点击事件调用匿名函数如何传参_事件发布/订阅模式的简单实现
这是一种广泛应用于异步编程的模式,是回调函数的事件化,常常用来解耦业务逻辑.事件的发布者无需关注订阅的侦听器如何实现业务逻辑,甚至不用关注有多少个侦听器存在.数据通过消息的方式可以灵活的传递. --& ...
利用zookeeper实现发布订阅模式
zookeeper应用发布订阅 zk实现的方式是推拉结合,Client想服务端注册自己需要关注的节点,一旦节点的数据发生变更,那么Server会向对应的客户端发送Watcher事件通知,客户端接收到 ...
设计模式（三）：观察者模式与发布/订阅模式区别
在翻阅资料的时候,有人把观察者(Observer)模式等同于发布(Publish)/订阅(Subscribe)模式,也有人认为这两种模式还是存在差异,而我认为确实是存在差异的,本质上的区别是调度的地方 ...

cppzmq发布订阅模式

1. 首先需要下载cppzmq的库

2. 将zmq.hpp 和 zmq_addon.hpp 两个库文件放入到自己的工程里面

3. 写demo

4. 编译

cppzmq发布订阅模式相关推荐

最新文章

热门文章