问题标签 [jeromq]

我有一个使用 JeroMQ 0.5.2 用 Ja​​va 编写的 ZeroMQ 订阅者应用程序。
在代码中，我订阅了多个这样的主题：

当我运行订阅者时，我看到以 DAX 和 AD 开头的消息，但在多个过滤器情况下似乎缺少一些消息，因为当我仅订阅 DAX 或仅 AD 时，我看到大量更新消息。当我订阅这两个主题时，我几乎看不到 DAX 的主题，大多数更新消息都丢失了。

我的片段有问题吗？

就像这个操作看起来一样简单，我找不到任何关于如何使用 ZMQ (Jeromq) 接收多部分消息的文档。我检查了指南，但它只包含带有此信息的 C 代码，而且无论我收到什么类型的消息，我似乎都应该以相同的方式接收消息。

实际上，我使用以下代码在两条消息中收到多部分消息：

如果我发送这样的多部分消息，“已接收”部分将被打印两次：

我究竟做错了什么？

编辑：C我知道示例下方有一个语言选择器，但是在任何仅与代码内联解释的示例中都不存在此特定问题。

编辑

我试图探索 API 并找到了hasReceiveMore()方法。我尝试使用它，但它没有用，我最终使用以下代码进行了无限循环：

我正在评估 ZeroMQ 作为低延迟项目的候选者。但是我找不到一种方法来停止纯 java 实现 recv 调用引起的 GC 周期。有没有办法告诉 ZeroMQ 使用相同的字节缓冲区进行同步读取？

}

一个 ZFrame() 可以写入多少数据。（没有在 ZMsg 中添加多个 Zframes()）。

我正在尝试从使用 JeroMQ 的 Android Java 客户端向使用 ZeroMQ 的 Python 服务器发送消息。我在同一台机器上运行打扰服务器和客户端。服务器在 Jupyter 笔记本中运行，而客户端在 Android Studio 上的 Android 设备模拟器中运行。代码如下。Python服务器：

这是 Python 客户端（有效）：

这是我在 Java 客户端中做同样事情的尝试：

但是，服务器似乎没有收到任何东西。知道我哪里出错了吗？

我们正在努力实现一个 PUB-SUB 模型，用于在不同 VM 上的两个应用程序之间交换消息。

我们的解决方案是；

Server-1-App-1 -----> Server-2-App-2

Server-2-App-1 -----> Server-2-App-2

当我们只有 1 个 PUB-SUB 时，我们就能够获取所有消息。当我们有 1 个 PUB 和 MULTIPLE SUB 时，消息会被丢弃，并且不会在任何 SUBS 处收到。

对此行为有任何意见吗？我们正在使用 Java 库。

我将一些本机代码编译到共享库中，并在 Android 应用程序和纯 JVM 代码（Kotlin）中使用。我想避免使用 JNI 样板。本机端的 ZeroMQ + JVM 端的JeroMQ可以相互通信吗？似乎不可行，但只想仔细检查：

ipc:// 协议与 zeromq。Java 不支持 UNIX 域套接字。

任何解决方法/替代基于 zeromq 的解决方案？TCP套接字可能？

我正在尝试将 JeroMQ 发布者连接到 PyZMQ 订阅者。它运行良好，但我不知道如何解码/反序列化我在 Python 端获得的数据。

例如，这是我从 Java 发送的一个字节数组：[10, 10, 7, 55, 79]。我的目标是在 Python 中恢复相同的整数数组。在实践中，我b"\n\n\xf97O"在 Python 端得到了这个。我希望 abytes.decode("utf-8")可能会让我得到类似的东西101075579，但显然 utf-8 是错误的编解码器。你知道是什么样的物体b"\n\n\xf97O"吗？

这是我正在使用的代码：

Java端

Python端

你知道如何解决这个问题吗？请注意，ZMQ.Socket.sendMore(String)发送的对象确实被 Python 识别为字节字符串，但我不确定如何正确解析它们。

提前致谢。

我遇到了 PUB/SUB 模式的问题，其中 SUB 有时会随机（一天左右一次）停止接收数据。我想每秒添加一些从 PUB 到 SUB 的自定义心跳消息，但我必须从同一个线程发送它，因为 PUB 不是线程安全的。为此，我可以使用一些 java Timer/Scheduler 每秒执行一次，但问题是 Timer/Scheduler 创建了一个新线程。我正在从 PUB 中的外部 websocket 接收数据，但我看不到每个人都在谈论的发送心跳的方法。唯一的方法是使用 XPUB-XSUB 添加代理...

知道怎么做吗？