Zeromq使用插座正在使用中



我在此处关注教程。这是重现问题的最小例子。启动生产者流程后,消费者总是抱怨"已经使用的地址"。但是,如果生产者和消费者的端口不同,如何相互交谈?我正在使用Python 3和Pyzmq 16.0.3

生产者

import zmq
context = zmq.Context()
zmq_socket = context.socket(zmq.PUSH)
zmq_socket.bind("tcp://127.0.0.1:5557")
for num in range(2000):
    work_message = { 'num' : num }
    zmq_socket.send_json(work_message)

消费者

import zmq
context = zmq.Context()
zmq_socket = context.socket(zmq.PULL)
zmq_socket.bind("tcp://127.0.0.1:5557")
for _ in range(2000):
    result = zmq_socket.recv_json()
    print(result)

ah,没关系,它应该是消费者中的zmq_socket.connect,而不是bind。我是Zeromq的新手,所以我认为bind是通用的成语。

希望这对任何其他新朋友有所帮助。

最新更新