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