2

我希望这个程序中的线程在锁步中工作。但是，发送者在等待接收者赶上之前发送了大约 60000 条消息。我对 HWM 有什么误解？

如果我不启动接收者线程，则发送者在尝试发送第二条消息时会阻塞。

public static void main(String[] args) throws Exception {
    new Thread() {
        @Override
        public void run() {
            ZMQ.Context context = ZMQ.context(1);
            ZMQ.Socket socket = context.socket(ZMQ.XREP);
            socket.setHWM(1);
            socket.bind("tcp://127.0.0.1:8080");
            while (true) {
                try {
                    socket.recv(0);
                    byte[] msg = socket.recv(0);
                    System.out.println("Received: " + new String(msg, "UTF-8"));
                    Thread.sleep(1000);
                } catch (Exception ex) {
                    Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
    }.start();

    new Thread() {
        @Override
        public void run() {
            ZMQ.Context context = ZMQ.context(1);
            ZMQ.Socket socket = context.socket(ZMQ.XREQ);
            socket.setHWM(1);
            socket.connect("tcp://127.0.0.1:8080");
            Integer i = 1;
            while (true) {
                System.out.println("Sending: " + i);
                socket.send(i.toString().getBytes(), 0);
                i++;
            }
        }
    }.start();
}
4

1 回答 1

2

乍一看，我的想法和你一样，并对这种行为感到惊讶。但我做了一些研究，我想我找到了答案。

系统中还有其他缓冲区在这里起作用。设置高水位线只会影响其中之一。

http://www.aosabook.org/en/zeromq.html#fig.zeromq.arch

调用 send 只是推送到管道，而不是等待它通过线路。相关的 I/O 线程将消息从管道中读取到网络上。因为您处于发送小消息的如此紧密的循环中，所以您似乎在发送第一条消息之前就已经填满了管道。

于 2013-02-12T12:59:43.980 回答