python - 在 Windows 上，后台线程接收 zmq 消息失败

Question

我正在尝试通过在后台线程上接收消息，同时使用控制台输入发送消息，在两个对等点之间使用 zmq.PAIR 建立一个 hello world 风格的异步通信示例:

server.py:

import zmq
import threading

context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.bind('tcp://*:5556')

def print_incoming_messages():
    while True:
        msg = socket.recv_string()
        print(f'Message from client: {msg}')

recv_thread = threading.Thread(target=print_incoming_messages)
recv_thread.start()

while True:
    msg = input('Message to send: ')
    socket.send_string(msg)

client.py:

import zmq
import threading

context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.connect('tcp://127.0.0.1:5556')

def print_incoming_messages():
    while True:
        msg = socket.recv_string()
        print(f'Message from server: {msg}')

recv_thread = threading.Thread(target=print_incoming_messages)
recv_thread.start()

while True:
    msg = input('Message to send: ')
    socket.send_string(msg)

这在 Linux 计算机上完全正常工作，但从 Windows 10 命令提示符运行时，socket.send_string 会阻塞任一进程。造成这种差异的原因是什么？

socket 设置正确，刷新所有输出没有什么区别。读数本身也按预期工作，可以通过在浏览器中导航到 127.0.0.1:5556 来验证。查看 Wireshark 中的环回接口(interface)还可以发现连接已正确设置，但没有发送任何消息。

但是，如果我在客户端中注释掉 recv_thread.start() ，则消息将按照可在 Wireshark 中验证的方式发送，这表明以某种方式 socket.recv_string阻止套接字发送，即使它在 Linux 上没有这样做。

我还可以通过使用两组 PUSH/PULL 来实现所需的行为(参见 this answer )，但这并不能完全帮助解释当前示例中发生的情况。

这适用于两个系统上的 Python 3.7.1、pyzmq 18.0.0 和 libzmq 4.3.1。

Answer 1

zmq 套接字不是线程安全的，因此在不同线程中的同一套接字上运行 send 和 receive 不应起作用。不同平台上的不同线程行为可能会导致您所看到的行为差异，但由于 zmq 套接字的线程不安全性，此代码最终也可能导致段错误。使用 Lock可能会解决问题。

顺便说一句，PAIR 是一种很少使用的套接字类型，通常不用于生产或进程间通信。大多数现实世界中的 PAIR 实例都是作为线程间通信的进程内套接字。例如，PAIR 在重新连接时可能会出现奇怪的行为。使用 PUSH-PULL 进行单向通信或使用 DEALER-DEALER 进行双向通信可能会以更预期的方式表现。