ZeroMQ多主题过滤用法中一些丢失的消息

问题描述 投票:0回答:1

我有一个使用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的主题很少,大多数更新消息都丢失了。

我的代码段有问题吗?

java zeromq jeromq
1个回答
0
投票

Q“我的代码段有问题吗?”

不,没有。

[[其余要求保护的观察结果是不可再现的,在没有看到日志,完整的SUB侧设置+算法和PUB侧的广播数据格式(如果不是完整的MCVE / MRE)的情况下,解释的难度就较小。

© www.soinside.com 2019 - 2024. All rights reserved.