用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中尝试一个push脚本，它会接收所有的东西。

所以我的问题是在java。

我在日志中看到了第一行(“发送”)，但在脚本中没有收到任何信息。

我该换什么？

Answer 1

来自常见错误 at JeroMQ Wiki

• 正确关闭所有套接字，否则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;

}