我正在尝试将推/拉模式与 jeromq(0.3.2) 一起使用。在开始时,它运作良好。但经过一段时间。推送方不发送消息并在那里被阻止。我不知道为什么。我设置了 sendTimeout 参数,并打印了 zmq 套接字错误号。它是 35。有什么我没有注意到的吗?或其他建议?
谢谢!
推送端代码:
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket push4Topic = context.socket(ZMQ.PUSH);
private void init() {
push4Topic.setTCPKeepAlive(1);
push4Topic.setSendTimeOut(30000);
push4Topic.bind(bindUrl);
}
public boolean send(String msg) {
return push4Topic.send(msg);
}
private void destroy() {
if (push4Topic != null) {
push4Topic.close();
}
if (context != null) {
context.term();
}
logger.info("destroy() socket destroied");
}
====
我添加了一个监控推送端的监控线程。然后,我发现了 ZMQ_EVENT_DISCONNECTED 事件。那什么意识?我的拉边代码有问题吗?