如何获取ZMQ每个PUSH连接发送的最新消息？

核心结论 #

ZeroMQ 原生没有针对单个连接生效的类似ZMQ_CONFLATE的选项。官方的ZMQ_CONFLATE是作用于整个PULL套接字的全局队列，只会保留所有连接发来的最后一条消息，无法区分不同连接来源。

可行解决方案 #

方案1：为每个PUSH连接分配独立PULL套接字

• 让每个PUSH客户端连接到服务端的不同端点（比如不同端口），服务端为每个端点创建单独的PULL套接字，并给每个套接字设置ZMQ_CONFLATE=true
• 利用zmq_poll工具轮询所有PULL套接字，每个套接字只会返回对应PUSH连接的最新消息
• 优势：逻辑直观，直接复用原生CONFLATE特性，无需额外状态维护
• 劣势：若PUSH连接数量动态变化，需要额外的套接字动态管理逻辑，复杂度较高

方案2：客户端加标识，服务端维护单连接最新消息

• 每个PUSH客户端在发送消息时，附加唯一的客户端标识（如自定义ID、IP+端口等）
• 服务端使用普通PULL套接字（不设置ZMQ_CONFLATE），内部维护一个键值对结构（比如字典），键为客户端标识，值为该客户端的最新消息
• 收到新消息时，直接用新消息覆盖对应标识的旧消息；需要获取各连接最新消息时，遍历键值对即可
• 注意：若消息量极大，可配合ZMQ_RCVHWM设置合理高水位线，或在处理前先清空队列中旧消息（仅保留每个客户端的最后一条），避免队列积压
• 优势：无需修改套接字拓扑，适配动态增减的PUSH连接
• 劣势：需要额外的客户端标识逻辑，服务端需维护状态

内容的提问来源于stack exchange，提问作者Adam Polak Moetsi