我有一个使用 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 主题,大多数更新消息都丢失了。
我的代码片段有问题吗?
最佳答案
Q : "Is there something wrong with my snippet?"
不,没有。
其余的观察结果是不可重现的,如果没有看到日志、完整的 SUB 端设置 + 算法和 PUB 端广播数据格式(如果不是完整的 MCVE/MRE ),则更难以解释。
block 引用>
关于java - ZeroMQ 多主题过滤使用中一些丢失的消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61874204/