Python ZeroMQ REP NOBLOCK

如何解决Python ZeroMQ REP NOBLOCK

我想在 Python ZeroMQ 中使用 NOBLOCK，pyzmq。 服务器代码：

import zmq
import json

context = zmq.Context()
server = context.socket(zmq.REP)
server.bind("tcp://*:8888")

while True:
    try:
        buffer = server.recv(flags=zmq.NOBLOCK)
        print(json.loads(buffer))
        server.send(b'a')
    except zmq.ZMQError as e:
        pass

客户代码：

import zmq
import json
import time

context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:8888")

while True:
    data = {
        "time": time.asctime(time.localtime(time.time()))
    }
    print(data)
    try:
        socket.send_json(json.dumps(data))
        socket.recv(flags=zmq.NOBLOCK)
    except zmq.ZMQError as e:
        pass

我先运行 Server，然后是客户端。我期望的结果是 Server 和 Client 总是 print time，但 Server 只打印一次。

有什么问题？