python - 具有 NOBLOCK 标志行为的 pyzmq socket.recv()

Question

我使用pyzmq创建了简单的客户端/服务器。

我不确定的一件事是 .recv() 没有收到消息，即使它是从服务器发送的。它只是忽略它并抛出一个我觉得很奇怪的错误。

Client.py

try:
    socket = context.socket(zmq.REQ)
    socket.connect("tcp://localhost:2222")
    print("Sending request")
    socket.send(b"send the message")
    message = socket.recv(flags=zmq.NOBLOCK)
    print("Received reply %s " % message)
except Exception as e:
    print(str(e))

服务器.py

 context = zmq.Context()
 socket = context.socket(zmq.REP)
 socket.bind("tcp://*:2222")
 while True:
     message = socket.recv()
     socket.send(b"Ack")

我认为客户端应该接收Ack并打印它，而不是抛出异常。

文件说，

With flags=NOBLOCK, this raises ZMQError if no messages have arrived

显然，服务器在收到消息后立即响应“Ack”。

错误消息是，

Resource temporarily unavailable

Answer 1

请记住，在并发环境中，无法保证独立进程的执行顺序。即使您立即响应 server.py 中的消息，在调用 socket.recv 之前响应也可能无法到达接收套接字。当您调用 socket.send 时，消息需要通过网络发送到您的服务器，服务器需要创建消息并做出响应，然后消息需要通过网络返回到您的客户端代码。通过网络发送消息的时间会很长，并且您在 socket.send 之后立即调用 socket.recv。

因此，事实上，当您调用 message = socket.recv(flags=zmq.NOBLOCK) 时，客户端 socket 将不会收到 Ack 尚未从服务器接收到，并且由于您使用的是 NOBLOCK，因此会引发错误，因为 socket 上尚未收到任何消息。

NOBLOCK 可能不适合这种情况。您可以通过在 send 和 recv 之间添加 sleep 调用来进行实验，以显示等待服务器响应的时间延迟确实是问题所在，但从长远来看，这对于您的客户端代码来说并不是一个好的解决方案。

如果您想在等待一定时间后退出，您应该使用socket.poll。

event = socket.poll(timeout=3000)  # wait 3 seconds
if event == 0:
    # timeout reached before any events were queued
    pass
else:
    # events queued within our time limit
    msg = socket.recv()

Pyzmq Doc for socket.poll()