1

我正在尝试将推/拉模式与 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 事件。那什么意识?我的拉边代码有问题吗?

4

0 回答 0