6

我正在使用转发器设备（使用 pyzmq）编写 zeromq 演示

以下是代码（参考https://learning-0mq-with-pyzmq.readthedocs.org/en/latest/pyzmq/devices/forwarder.html）：

转发器.py

import zmq

context = zmq.Context()
frontend = context.socket(zmq.SUB)
frontend.bind('tcp://*:5559')
frontend.setsockopt(zmq.SUBSCRIBE, '')

backend = context.socket(zmq.PUB)
backend.bind('tcp://*:5560')

zmq.device(zmq.FORWARDER, frontend, backend)

子.py

import zmq

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect('tcp://localhost:5560')
socket.setsockopt(zmq.SUBSCRIBE, '')

while True:
    print socket.recv()

发布.py

import zmq, time

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.connect('tcp://localhost:5559')
# time.sleep(0.01)
socket.send('9 hahah')

我python forwarder.py在python sub.py终端运行

然后运行python pub.py，订阅者收不到消息。但是，如果我在发送前睡了一点时间（例如 0.01 秒），它就会起作用。

所以我的问题是，为什么我sleep要先发送？谢谢。

4

1 回答 1

11

它被称为慢木匠综合征。阅读指南，有一些方法可以避免使用 pub/sub同步。

于 2013-10-18T13:40:34.300 回答