我正在尝试使用 ZeroMQ 设置“倒置”PUB/SUB。
这意味着订阅(SUB)套接字属于几个长期存在的服务器,做zmq_bind()
; 和发布(PUB)套接字是一个短暂的客户端,并且zmq_connect()
.
我使用单个ipc://
套接字。
我希望来自发布者的消息会到达每个订阅者。
问题:只有一个订阅者进程接收到消息。如果该过程终止,发布者将陷入zmq_term()
.
zmq是否支持这种操作模式?如果是,那我做错了什么?如果没有,那么如何实现我需要的?
带有一些额外细节的最小示例(在 Lua 中,但这不重要):https ://gist.github.com/938429