时间戳

首页 > 解决方案 > ZeroMQ 多主题过滤使用中的一些缺失消息

java - ZeroMQ 多主题过滤使用中的一些缺失消息

问题描述

我有一个使用 JeroMQ 0.5.2 用 Ja​​va 编写的 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 的主题，大多数更新消息都丢失了。

我的片段有问题吗？

标签： javazeromqjeromq

解决方案

问：“我的代码片段有问题吗？”

不，那里没有。

其余声称的观察结果是不可重现的，如果没有看到日志、完整的 SUB 端设置 + 算法和 PUB 端广播数据格式（如果不是完整的 MCVE / MRE），则难以解释。

推荐阅读