python - ZeroMQ ROUTER 套接字无法向 REP 套接字发送消息

Question

我通过使用 ZeroMQ 的路由器实现了一个简单的请求-回复架构。这适用于 PyZMQ 版本 2.1.11。不幸的是，当我在 PyZMQ 版本 14.0.0 上测试它时，发送方 (REQ) 可以发送到路由器，然后路由器接收到它的消息并发送到接收方 (REP)，但接收方没有收到消息! 我在将 PyZMQ 从 2.1.11 版本升级到 14.0.0 时遇到了这个问题。

REQ <-> ROUTER <-> REP

这是我的代码:

sender.py

import zmq
import time

if __name__=='__main__':
    context = zmq.Context()
    socket = context.socket(zmq.REQ)
    socket.setsockopt(zmq.IDENTITY, "S")
    socket.connect("tcp://127.0.0.1:6660")
    i = 0
    while True:
        i += 1
        socket.send("R", zmq.SNDMORE)
        socket.send("", zmq.SNDMORE)
        socket.send("Message: %d" % i)
        print("Message : %d sent" % i)
        fromAddr = socket.recv()
        empty = socket.recv()
        resp = socket.recv()
        print("%s received!" % str(resp))
        time.sleep(1)

router.py

import zmq
import time

if __name__=='__main__':
    context = zmq.Context()
    frontend = context.socket(zmq.ROUTER)
    frontend.bind("tcp://*:6660")

    poll = zmq.Poller()
    poll.register(frontend, zmq.POLLIN)

    while True:
        sockets = dict(poll.poll(100))
        if frontend in sockets:
            if sockets[frontend] == zmq.POLLIN:
                fromAddr = frontend.recv()
                empty = frontend.recv()
                toAddr = frontend.recv()
                empty = frontend.recv()
                msg = frontend.recv()
                print("Message received from %s must be send to %s [%s]" % (str$
                frontend.send(toAddr, zmq.SNDMORE)
                frontend.send("", zmq.SNDMORE)
                frontend.send(fromAddr, zmq.SNDMORE)
                frontend.send("", zmq.SNDMORE)
                frontend.send(msg)
                print("Message has been send to %s!" % str(toAddr))

receiver.py

import zmq
import time

if __name__=='__main__':
    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.setsockopt(zmq.IDENTITY, "R")
    socket.connect("tcp://127.0.0.1:6660")
    while True:
        print("Wating for request...")
        toAddr = socket.recv()
        empty = socket.recv()
        req = socket.recv()
        print("%s received!" % str(req))
        socket.send(toAddr, zmq.SNDMORE)
        socket.send(empty, zmq.SNDMORE)
        socket.send("Reply to %s" % str(req))

当我使用这个架构时:

DEALER 不会路由到多个接收者。 DEALER 仅使用循环法向接收者发送消息。如果可以使用 ROUTER 而不是 DEALER，则消息可以路由到特定的接收者，并在这些接收者之间进行循环。

Answer 1

ROUTER 到 REP 套接字是无效组合，如下所述:http://zguide.zeromq.org/page:all#Request-Reply-Combinations