问题标签 [jzmq]

我使用 OpenPGM 5.2.122 在 Windows 7 上的 MULTICAST 通道上为 ZeroMQ PUB 套接字发布数据在 java (JDK 7) 中编写了一个简单的测试。我在 ZeroMQ 3.2.3 之上尝试了 JZMQ 版本 2.2.0、2.1.3 和 2.1.0。测试文件如下。

我注意到进程的内存占用不断增加，直到计算机内存不足。它不会崩溃（我确信 malloc() 失败是在内部处理的）。我还在我们的 linux 服务器上尝试过它，在我停止进程之前它一直消耗 22 GB 的内存。用于多播的 JZMQ 包装器中是否存在内存泄漏？

如果我将上面的代码更改为绑定到 TCP 地址（注释掉的行），内存占用保持稳定并且几乎没有增加。

我还编写了上述代码的 C 版本。这个版本在下面给出，它没有相同的多播内存占用问题。

有谁知道为什么会发生这种情况？

谢谢。

我正在尝试嵌入zeroMQ我的应用程序，我按照这个指南安装ZMQ，所以直到这里一切正常。我的应用程序中有这行代码：

但上面的代码行引发以下异常：

错误正是指向这一行。

PS：完全解释这个问题有点困难..如果你有任何问题请告诉我。谢谢。

我检查了 ZMQ 指南中给出的几个示例，但由于某种原因，订阅者没有收到任何消息。这是我要测试的代码，但徒劳无功。请为此提出解决方案 -

请帮我解决这个问题。谢谢！！！

我试图让 JZMQ 代码在 Hadoop 集群上的一个节点上运行。我在该节点的 /usr/local/lib 目录下安装了必要的本机 jmzq 库文件。

这是列表 - libjzmq.a libjzmq.la libjzmq.so libjzmq.so.0 libjzmq.so.0.0.0 libzmq.a libzmq.la libzmq.so libzmq.so.3 libzmq.so.3.0.0 pkgconfig

在我的 shell 脚本中，如果我运行下面的 Java 命令，它绝对可以正常工作 -

但是当我运行下面的命令时，它会在线程“main”中抛出异常

我使用 Export 命令在 Hadoop Classpath、Opts 等中明确设置了必要的文件/Jars

源代码 JAR 和 jzmq-2.1.3.jar 文件位于 Hadoop 节点上的 /home/txtUser/analytics/lib/ 文件夹下。此外，/usr/local/lib 被添加到系统 ld.conf

任何人都可以建议，给出我在这里可能做错的输入吗？

使用 jzmq 包装器：

scala> 导入 o​​rg.zeromq.ZMQ 导入 o​​rg.zeromq.ZMQ

这似乎在版本 3 中已被弃用：

https://github.com/zeromq/jzmq/blob/750f2eecaa4c71adf86c156fab5840a2f614d4ea/src/org/zeromq/ZMQ.java#L895-900

有谁知道为什么？使用 jzqm + zmq3 设置 HWM 的替代方法是什么？

所以我正在使用 jzmq GIT master 分支和 ZeroMQ 3.2.3 编写自己的东西。

安装后，我尝试测试以下简单PUB/SUB程序，其中发布者和订阅者在一个进程中交谈。由于测试是在windows下，所以我使用了TCP。

现在如您所见，在订阅者中，如果我使用一种简单的.recv(ZMQ.DONTWAIT)方法，它就可以完美运行。但是，如果我使用的是直接字节缓冲区，我什么也没有返回 - 我得到了以下异常，似乎在程序退出时：

我还尝试使用一个简单的ByteBuffer（不是直接缓冲区），它不会抛出上面的异常；但也没有回报我。

有人知道如何解决上述问题吗？

我不想byte[]到处创建对象，因为我正在做一些高性能系统。如果这无法解决，我可能会简单地使用 Unsafe 代替。但我真的很想以“假定的方式”工作。

提前致谢。

亚历克斯

简单的问题。为什么在 java 上“移植”zmq 并将其称为 JeroMQ 是个好主意？

我使用 zeromq 和 C 编程语言编写了一个请求-回复代理。代理将客户端请求路由到适当的服务，然后将回复路由回客户端。这些服务是用 JAVA 编写的。

有人可以解释一下如何让服务与经纪人沟通。我确信这一定是一个常见的场景，但我没有太多经验，所以有人可以帮助我使我的代码可互操作。

请假设服务不会被 zeromq 感知。在这种情况下是否要使用 node.js？我必须写一个http前端吗？

我是新手，ZMQ试图弄清楚如何将它集成到我的项目中。我需要实现最基本的请求-回复模型，server is Java其中client is C++. 我正在Windows使用VS2013 and Eclipse (STS). 我发现 0MQ 上的材料令人费解且令人困惑。我正在寻找的是一个简单的步骤列表：

1. 下载 0MQ Java - 我究竟应该下载什么以及从哪个 URL 下载最新的稳定版本。

2. 我需要什么（位置和文件）进入我的 Eclipse 项目，以便我可以开始在我的代码中使用 0MQ。

3. 下载 0MQ C++ - 我究竟应该下载什么以及从哪个 URL 下载最新的稳定版本。

4. 我需要什么（位置和文件）进入我的 VS 项目，以便我可以开始在我的代码中使用 0MQ。

谢谢。

My Nimbus host and supervisor run properly. When I submit a wordcount topology to the Nimbus host it successfully upload. After uploading topology supervisor giving error

When I check the worker-6001.log and 6002.log I found a following error:

my configuration is

storm.yaml

java version

I used this blog as a example.