首先创建上下文并初始化套接字,然后根据通信需求选择REQ/REP或PUB/SUB等模式;在REQ/REP中客户端发送请求后必须等待响应,服务端需及时回复;在PUB/SUB中发布者广播消息,订阅者需设置主题过滤并只能接收连接后的消息;消息支持多部分结构,通过ZMQ_SNDMORE标记分段,zmq_send和zmq_recv用于传输二进制安全数据。

在C++中使用ZeroMQ进行消息传递,核心是理解其通信模式并调用对应的API。它不像传统Socket那样需要处理复杂的连接管理,而是通过“套接字(Socket)”抽象来实现不同模式的通信。下面介绍几个常用步骤和模式。
初始化上下文与创建套接字
每个ZeroMQ程序开始前都需要创建一个上下文(Context),它是线程安全的,通常一个进程只需要一个。所有套接字都从这个上下文中创建。
- 调用 zmq_ctx_new() 创建上下文。- 使用 zmq_socket() 并指定套接字类型,如 ZMQ_REQ、ZMQ_REP、ZMQ_PUB 等。
- 服务端用 zmq_bind() 绑定地址,客户端用 zmq_connect() 连接。比如 "tcp://*:5555" 表示监听所有IP的5555端口。
请求-响应模式(REQ/REP)
这是最基础的同步通信方式,常用于客户端向服务器发起请求并等待回复。
- 客户端创建 ZMQ_REQ 套接字,发送请求后必须等待响应,顺序不能错。- 服务端创建 ZMQ_REP 套接字,接收请求后必须回复,否则客户端会一直阻塞。
- 发送用 zmq_send(),接收用 zmq_recv()。默认是阻塞操作,可通过 ZMQ_DONTWAIT 标志改为非阻塞。
发布-订阅模式(PUB/SUB)
适用于一对多的消息广播,比如实时行情推送。
立即学习“C++免费学习笔记(深入)”;
- 发布者(Publisher)创建 ZMQ_PUB 套接字并绑定,用 zmq_send() 发送消息。- 订阅者(Subscriber)创建 ZMQ_SUB 套接字并连接,需先用 zmq_setsockopt() 设置感兴趣的“主题”(topic),然后调用 zmq_recv() 接收。
- 一个特点是:订阅者只能收到在其连接之后发布的消息,早期消息不会被缓存。
消息发送与接收细节
ZeroMQ的消息可以是单部分或多部分(multi-part),用于构建复杂的消息结构。
- 发送多部分消息时,在前几部分的 zmq_send() 中加入 ZMQ_SNDMORE 标志,表示还有后续部分。最后一部分不加此标志。- 接收时,通过检查 zmq_msg_more() 判断是否还有后续部分。
- 消息内容是二进制安全的,可以传输任意数据,包括字符串、结构体或序列化对象。
基本上就这些。掌握好上下文、套接字类型和通信模式,再结合具体的业务场景选择合适的方式,就能在C++项目中顺利集成ZeroMQ实现高效的消息传递。











