为什么我的模拟代理实现在另一个 Socket 创建时崩溃？

Question

我遇到了 PyZMQ 代理的问题，我不太明白。当我取消注释看似不相关的代码行时，代理似乎可以工作。这是一个 MWE：

minimal_proxy.py：

    from multiprocessing import Process
    import zmq
    
    
    def pubsubproxy(ctx: zmq.Context):
        receiver = ctx.socket(zmq.SUB)
        receiver.connect("tcp://localhost:51121")
        receiver.setsockopt_string(zmq.SUBSCRIBE, "")
    
        sender = ctx.socket(zmq.PUB)
        sender.bind("tcp://*:51131")
    
        # Pub/sub  Proxy
        zmq.proxy(receiver, sender)
    
    def main():
        ctx = zmq.Context.instance()
    
        # capture = ctx.socket(zmq.PUSH) # when uncommented, proxy fails
        p = Process(target=pubsubproxy, args=(ctx,))
        p.start()
        p.join()
    
    if __name__ == '__main__':
        main()

proxy_tester.py：

import zmq
from multiprocessing import Process
import time

def receive(ctx: zmq.Context):
    receiver = ctx.socket(zmq.SUB)
    receiver.connect("tcp://localhost:51131")
    receiver.setsockopt_string(zmq.SUBSCRIBE, "")

    while True:
        msg = receiver.recv() # wait for timestamp messages relayed via proxy
        print(msg) # print message to stdout when received

def send(ctx: zmq.Context):
    sender = ctx.socket(zmq.PUB)
    sender.bind("tcp://*:51121")

    while True:
        sender.send_string(f"timestamp: {time.time()}")
        time.sleep(1)


def main():
    ctx = zmq.Context.instance()

    p1 = Process(target=receive, args=(ctx,))
    p2 = Process(target=send, args=(ctx,))
    p1.start()
    p2.start()

    p1.join()
    p2.join()

if __name__ == '__main__':
    main()

如您所见，proxy_tester 在端口 51121 上打开一个发布者，在端口 51131 上打开一个接收者，并期望minimal_proxy 连接这两个端口。不幸的是，当我尝试创建一个新的套接字捕获（据我所知与代理完全无关）时，我停止从 proxy_tester 中的接收器接收时间戳消息。 zmq.VERSION 返回 40203。这是怎么回事？