zeromq - ZMQ : how to bind from the REP side in DEALER/REP or REQ/REP socket

标签 zeromq pyzmq

我想设置一个拓扑,其中工作人员的 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/

相关文章:

php - websocket报错413,如何处理?

c++ - ZMQ C++ 从特定工作人员发送和接收

zeromq - pyzmq recv_json 无法解码 send_json 发送的消息

python - pyzmq 非阻塞套接字

python - 通过 KeyboardInterrupt 停止 pyzmq 接收器

python - 绑定(bind) ("tcp://*:6001") 在 python 中的含义

zeromq - 使用 zeromq PUB/SUB 套接字检索订阅者计数

ZeroMQ 管家模式

node.js - 如果仅使用一次 socket.send(),则 zmq 订阅者无法订阅已发布的消息

python - Pyzmq - 将消息发送到 STREAM 套接字