使用 jeroMQ 推送

Question

我认为我的 zmq.jar 有问题，所以我尝试使用 jeroMQ 但我遇到了同样的问题。

这是我的方法：

private boolean submitEvent(String ioMessage) {
    log.info("SEND");

    ZMQ.Context context = ZMQ.context();

    ZMQ.Socket sender = context.socket(ZMQ.PUSH);

    sender.connect("tcp://localhost:8086");

    sender.send("MESSAGE");

    return true;

}

我在 python 中有一个 PULL 脚本，如果我也在 python 中尝试推送脚本，它会接收所有内容。

所以我的问题出在 java 中。

我在日志中看到第一行（“发送”），但我没有收到脚本中的任何内容。

我应该改变什么？

Answer 1

来自 JeroMQ Wiki 上的 Common mistakes

• 正确关闭所有套接字，否则Context.term() 将永远等待

所以你的最终代码应该是

private boolean submitEvent(String ioMessage) {

    log.info("SEND");

    ZMQ.Context context = ZMQ.context();

    ZMQ.Socket sender = context.socket(ZMQ.PUSH);

    sender.connect("tcp://localhost:8086");

    sender.send("MESSAGE");

    sender.close();

    context.term(); 

    return true;

}