ZeroMQ 多主题过滤使用中缺少一些消息



我有一个使用 JeroMQ 0.5.2 用 Java 编写的 ZeroMQ 订阅者应用程序。
在代码中,我订阅了多个主题,如下所示:

Socket subscriber = context.createSocket(SocketType.SUB);
subscriber.connect("tcp://127.0.0.1:2770");
subscriber.subscribe("DAX");
subscriber.subscribe("AD");

当我运行订阅者时,我看到以 DAX 和 AD 开头的消息,但似乎在多个过滤器情况下缺少一些消息,因为当我只订阅 DAX 或仅订阅 AD 时,我看到大量更新消息。当我订阅这两个主题时,我很少看到 DAX 的更新消息,大多数更新消息都丢失了。

我的代码段有问题吗?

:">我的片段有问题吗?

不,没有。

其余声称的观察结果是不可重现的,在没有看到日志的情况下更难解释,完整的 SUB 端设置 + 算法化和 PUB 端广播数据格式(如果不是完整的 MCVE/MRE (。

最新更新