按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，如果我嘗試推腳本也蟒蛇，它接收到的一切。

所以我的問題是在Java。

我在日誌中看到第一行（「發送」），但我沒有收到腳本中的任何內容。

我應該改變什麼？

Answer 1

從Common mistakes在JeroMQ維基

• 關閉所有的插槽中正確否則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; 

}