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

标签 java zeromq jeromq

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

我的代码片段有问题吗?

最佳答案

Q : "Is there something wrong with my snippet?"

不,没有。

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

关于java - ZeroMQ 多主题过滤使用中一些丢失的消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61874204/

相关文章:

java - 了解 equals 方法的模式和帮助

java - 使用参数和 SVN 构建 Jenkins 作业

java - 没有 Maven 的 Spring MyBatis

sockets - 创建多个 ZeroMQ 套接字的开销是多少?

php - 您的要求无法解析为一组可安装的软件包

c++ - c++中面向性能的消息回调解决方案

java - Neo4j 节点之间的方向

android - 在 jeromq 中使用轮询

java - 子服务器套接字关闭时如何制作ZMQ pub客户端套接字缓冲区消息

json - 如何将 float 组(无需序列化/反序列化)从 Scala (JeroMQ) 传输到 C (ZMQ)?