问题标签 [jzmq]

我想使用 ZeroMQ（java 绑定，jzmq）将客户端连接到服务器，但我非常需要 TCP 信息，例如客户端请求的 TCP/IP 地址！问题是，为了能够在网络中宣布服务，我需要获取请求的 TCP 地址才能将客户端重定向到该服务。在这种情况下，代理是一个中央“服务注册中心”。但是，在双方都有 ZeroMQ 服务时，我看不到检索该信息的选项。

我现在要做的是使用标准套接字与代理建立一个虚拟连接，在建立连接后，我获取用于此连接的 IP 地址并再次关闭连接。检索到的 IP 地址现在正用于使用随机端口上的 ZeroMQ 套接字对其进行绑定。

我认为这个解决方案是有史以来最丑陋的解决方案，所以：这个问题的更好解决方案是什么？

问候。

我希望这个程序中的线程在锁步中工作。但是，发送者在等待接收者赶上之前发送了大约 60000 条消息。我对 HWM 有什么误解？

如果我不启动接收者线程，则发送者在尝试发送第二条消息时会阻塞。

有没有办法检查JZMQ（zmq的java绑定）套接字是否连接？

在上面的代码之后，我想检查是否连接了 workerSocket。检查连接状态会很好。

我正在尝试使用以下配置/要求运行ZeroMQ http://www.zeromq.org/ ：

• 内置 Java SDK 7 的 OS X 10.8
• ZMQ 的 Java 绑定
• 需要使用 SDK 6

显然jzmq是用Java SDK 7的头文件编译的，但我真的需要用SDK 6的头文件编译它们。那是因为我想使用目前只支持SDK 6的http://jmonkeyengine.org/ 。

所以我的一般问题是，如何让它工作，或者只是提示在哪里获取 SDK 6 头文件以及如何用它们编译 jzmq。

我正在尝试使用 Java 示例在 Ubuntu 上使用 ZeroMQ 进行编程。我已经成功构建了 ZeroMq 核心和 Java 绑定，但是尝试运行简单的示例，它只是无限期地挂起。

这是我到目前为止所做的，顺便说一句，我正在使用JDK/JRE 1.7,ZeroMQ 3.2.2和Ubuntu 12.10 64-bit

构建 ZeroMQ 核心库

我从这里下载了核心 ZeroMQ 3.2.2 POSIX tarball ，根据这里的说明提取和构建。配置、制作和安装一切顺利，没有错误，我还运行ldconfig以下make更新系统库缓存。快速浏览一下，/usr/local/lib核心库似乎已经正确构建......

构建 JZMQ Java 绑定

从这里下载 Java 绑定源，配置，运行 make；一切看起来都不错。这会创建zmq.jar和zmq-perf.jar; 再次运行ldconfig以更新库缓存；将罐子移到/usr/local/share/java...

运行示例local_lat

我为我的环境使用以下设置运行了此处local_lat详述的示例...

得到UnsatisfiedLinkError；只需登录和退出即可解决此问题。再次运行，它只是挂起，没有错误，nata，zilch。我从上面删除了参数100并从中获取了使用消息local_lat，所以我知道它正在查找 zmq jar 文件，因为local_lat类驻留在zmq-perf.jar. 使用上述命令再次运行，它只是挂起；没有错误，什么都没有。有点失望，因为要完成所有的工作需要做很多工作。

更新

见下文，原来这是我测试方式的问题

尝试构建 jzmq https://github.com/nathanmarz/jzmq时出现以下错误

知道我在这里缺少什么吗？

我成功创建了发布者，但未能使用以下内容创建订阅者：

收到此错误：线程 [System-akka.zeromq.socket-dispatcher-7] 未捕获的错误正在关闭 JVM，因为 ActorSystem [System] java.lang.NoSuchMethodError 启用了“akka.jvm-exit-on-fatal-error” : org.zeromq.ZMQ$Poller.poll(J)J at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala:180) at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala: 179) 在akka.zeromq.ConcurrentSocketActor$$anonfun$receive$1.applyOrElse(ConcurrentSocketActor.scala:46) 在akka.actor.akka.zeromq.ConcurrentSocketActor.akka$zeromq$ConcurrentSocketActor$$doPoll(ConcurrentSocketActor.scala:197)。 ActorCell.receiveMessage(ActorCell.scala:425) at akka.actor.ActorCell.invoke(ActorCell.scala:386) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230) at akka.dispatch.Mailbox。在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 在 java.lang.Thread 的 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 运行(Mailbox.scala:212) .run(Thread.java:722)

这是什么意思？

我有很久以前别人构建的 zmq.jar 。如何找出它对应的版本？

清单中没有太多：

这是内容。有人能分辨它是 2.x 还是 3.x 吗？

运行以下命令安装 jzmq

我是 zeroMQ 的新手，在运行 CentOS 5.9 版的服务器上绑定 ØMQ 和 java 时遇到了困难。

不幸的是，我在服务器上没有超级用户/ root权限，我正在尝试以具有受限权限的普通用户身份安装 ØMQ。我已经按照http://www.zeromq.org/area:download上的说明安装了 ØMQ

显然无法运行以下

然后我尝试安装jzmq。

1. 克隆[git clone https://github.com/zeromq/jzmq.git]
2. 冉自动生成.sh
3. 然配置

此时我收到以下错误

由于上述错误，我无法运行 java 测试并收到错误“java.library.path 中没有 jzmq”。

当您没有 root 权限来安装它时，任何人都可以帮助/指导我如何获得用于 zeromq 工作的 java 绑定吗？很难让 IT 部门在服务器上安装新软件。

感谢你的帮助。

注意：我没有对 /usr 目录的写权限

谢谢英镑