我想设置一个拓扑,其中工作人员的 IP 地址未知,但只知道中央代理的地址。因此,我试图与经销商绑定(bind),并与代表联系。但销售代表从来没有收到我的消息:
使用Python3。
流程1:
import zmq
context = zmq.Context()
sock = context.socket(zmq.DEALER)
sock.bind("tcp://127.0.0.1:55597")
流程2:
import zmq
context = zmq.Context()
sockrep = context.socket(zmq.REP)
sockrep.connect("tcp://127.0.0.1:55597")
现在,如果我从进程 1 发送一条消息:
sock.send(b"hello")
进程 2 锁定:
sockrep.recv() #..............blocks forever
有什么办法可以让上述模式发挥作用吗?我是否需要其他套接字类型或其他拓扑?我可以让它与 DEALER DEALER 一起正常工作,但是我有两个完全异步的套接字,这不是我想要的。重申一下,只有一个已知的 IP 地址,即发出请求的计算机,而不是填充请求的计算机(这些计算机必须连接到绑定(bind)的请求者)。
最佳答案
从 DEALER
发送到 REP
时,您需要在消息前添加一个空帧作为前缀(因为 REP
支持已发送消息)通过 ROUTER
套接字,因此它会剥离所有帧直到空帧)
关于zeromq - ZMQ : how to bind from the REP side in DEALER/REP or REQ/REP socket,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39295243/