草庐IT

java - jeromq:关闭上下文失败

编辑:自己解决了,见下文(虽然我不确定我是否在这里偶然发现了一个错误)使用下面这个简单的hello-world请求-回复示例,在程序结束时关闭上下文失败:它要么简单地卡在ctx.close()处,要么抛出以下异常:Exceptioninthread"reaper-1"java.lang.NullPointerExceptionatzmq.Ctx.destroy_socket(Ctx.java:327)atzmq.ZObject.destroy_socket(ZObject.java:144)atzmq.SocketBase.check_destroy(SocketBase.java:9

java - 如何在 JeroMQ 中实现主备队列作业处理系统?

使用ZeroMQ.Context和.Socket实例,我能够推送/拉取消息例如,在我的代码下面,用于类似设置的队列:ZMQ.Contextcontext=ZMQ.context(1);//SockettosendmessagesonZMQ.Socketsender=context.socket(ZMQ.PUSH);sender.bind("tcp://*:5557");//Sendmessagessender.send("0",0);ZMQ.Socketreceiver=context.socket(ZMQ.PULL);receiver.connect("tcp://localhost

java - 通过 TCP 使用 JeroMQ,有没有办法获取发件人的 IP?

我们的应用程序使用JeroMQ0.4.3在客户端应用程序和API之间发送消息。(使用ZAuth的曲线加密)。我们正在从代理中的ROUTER套接字获取客户端消息(MDP模式)。在代理中接收消息时查找发件人IP的最佳方法是什么?在ZeroMQ中,似乎可以使用ZMQ_SRCFD消息选项和getpeername()但我还没有找到将其转换为JeroMQ的方法。 最佳答案 最近的ZeroMQAPI确实定义了消息可能携带的ZMQ_SRCFD属性。事实A)人们基本上无法确定,远程系统使用什么ZeroMQAPI版本(2.x~3.x~4.2.2~?截至