草庐IT

java - 如何检查 JZMQ 套接字是否已连接

有没有办法检查JZMQ(zmq的java绑定(bind))套接字是否已连接?ZContextzmqContext=newZContext();ZMQ.SocketworkerSocket=zmqContext.createSocket(ZMQ.DEALER);workerSocket.setIdentity("ID".getBytes());workerSocket.connect("tcp://localhost:5556");在上面的代码之后,我想检查workerSocket是否已连接。检查连接状态会很好。 最佳答案 不,API

Hadoop 和 JZMQ - java.library.path 中没有 jzmq

我正在尝试让JZMQ代码在Hadoop集群上的一个节点上运行。我在该节点上的-/usr/local/lib目录下安装了必要的nativejmzq库文件。这是列表-libjzmq.alibjzmq.lalibjzmq.solibjzmq.so.0libjzmq.so.0.0.0libzmq.alibzmq.lalibzmq.solibzmq.so.3libzmq.so.3.0.0pkgconfig在我的shell脚本中,如果我运行下面的Java命令,它绝对可以正常工作-java-Djava.library.path=/usr/local/lib-classpathclass/:lib/:

android - 如何在 ZeroMQ(jzmq) 3.xx 中使用 XPUB 和 XSUB 实现带有代理的发布-订阅网络

我正在尝试使用下图中提供的XPUB和XSUB来实现。我已经完成了他们提供的示例,但无法获得Java中的XPUB和XSUB。Here他们在C中给出了一个示例,这个示例有点复杂,因为我是ZeroMQ的新手。我正在尝试使用jniwrappedversion在android中使用它.请帮我找一个例子,如何使用java在ZeroMQ中实现这个带有代理的Pub-Sub网络。目前我指的是http://zguide.zeromq.org/page:all我试过如下移植它。订阅者.javapublicclassSubscriberextendsThreadimplementsRunnable{priva

java - 0MQ - JZMQ 不满意链接错误

我已经在运行CentOS的VM上安装了0MQ,并且我有一个基于C的应用程序可以愉快地使用它。但是,我无法让Java应用程序通过JZMQ绑定(bind)工作。这是我得到的错误:java-Djava.library.path=/usr/local/lib-jarAidApps.jarreceivelocalhost:9007Startingthereceiverapplication.Exceptioninthread"main"java.lang.UnsatisfiedLinkError:/usr/local/lib/libjzmq.so.0.0.0:libzmq.so.1:cannot

java - 0MQ - JZMQ 不满意链接错误

我已经在运行CentOS的VM上安装了0MQ,并且我有一个基于C的应用程序可以愉快地使用它。但是,我无法让Java应用程序通过JZMQ绑定(bind)工作。这是我得到的错误:java-Djava.library.path=/usr/local/lib-jarAidApps.jarreceivelocalhost:9007Startingthereceiverapplication.Exceptioninthread"main"java.lang.UnsatisfiedLinkError:/usr/local/lib/libjzmq.so.0.0.0:libzmq.so.1:cannot

java - 使用 Maven 安装 Java ZeroMQ 绑定(bind) (jzmq),缺少 native 代码库

我正在尝试从Maven存储库(http://search.maven.org/#search|ga|1|a%3A%22jzmq%22)安装jzmq,即JavaZeroMQ绑定(bind)。当作为依赖项添加到我的pom.xml[1]时,Maven会下载主jar,它会按预期提供Java库。除了主库之外,jzmq还需要一个Maven似乎没有下载的native代码库。在运行时,由于缺少native代码库,Java库会引发异常。native库在存储库中提供,jzmq的pom.xml[2]文件似乎指定应下载native库(libjzmq.so)。如果我下载该库并手动设置native库位置,一切正常