【问题标题】:ZeroMQ XPUB socket dropping packets until subscriptions arriveZeroMQ XPUB 套接字丢弃数据包直到订阅到达
【发布时间】:2015-02-06 20:26:21
【问题描述】:

我了解 XPUB 套接字可以丢弃在其上发送的消息,直到 它会看到一些匹配的转发订阅。有道理。

但是,我的 XPUB 进程已经重新启动,并且其他机器上的订阅者 启动并运行了一段时间,但在几分钟内,我发送的所有消息 在 XPUB 套接字上被静默丢弃,直到 XPUB 套接字接收到 转发的客户端订阅。

我在这里使用 XPUB/XSUB 代理作为中介。这里没什么特别的。

有什么办法可以欺骗 zmq 将订阅转发到新的 XPUB 套接字 哪个更及时地连接到代理?

我考虑过在 XPUB 端排队消息直到订阅 消息到达,或者可能在代理服务器中实现某些东西 缓存最后一次订阅请求,并使用 zmq_monitor_socket() 查找 新连接,然后转发缓存的订阅,但这两者 看起来有点hacky。

【问题讨论】:

    标签: zeromq


    【解决方案1】:

    是只有 xpub 重新启动还是 xpub/xsub 套接字都重新启动,我使用的是 nodejs zmq,根据我的经验,当我的 xpub/xsub 代理重新启动时,我的消息仍然被转发..

    【讨论】:

      猜你喜欢
      • 2015-07-03
      • 2017-07-12
      • 2018-08-08
      • 2013-08-21
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2010-09-17
      • 1970-01-01
      相关资源
      最近更新 更多