【发布时间】:2018-08-08 04:41:11
【问题描述】:
我已经实现了一个基于 ZeroMQ 的基础架构,在 c++ 中使用 XPUB/XSUB-proxy 将消息从多个 PUB-s 传递到多个 SUB-s。
多个PUB(s) --> XSUB/XPUB 代理--> 多个SUB(s)
如果我启动所有SUB(s) 然后启动PUB(s) 那么它按照设计工作,但是如果我先启动PUB(s) 然后我启动@ 987654330@(s),则在此期间来自PUB(s) 的所有消息都将被丢弃。
有解决办法吗?
由于在应用程序中可能会发生SUB 关闭或崩溃的情况,因此不应丢弃来自任何PUB 的针对该SUB 的消息。
【问题讨论】:
标签: c++ message-queue zeromq