pyzmq对套接字卡住

Question

我遵循pyzmq文档中的双向对套接字示例。我用下面的代码创建了两个文件socket1.py

import zmq
import random
import sys
import time

port = "5556"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.connect("tcp://localhost:{}".format(port))
print("Socket created")

i = 0
while True:
    msg = socket.recv()
    print("socket: msg recved")
    print(msg)
    socket.send_string("hello from 1")
    time.sleep(1)
    print(i)

和socket2.py，代码如下：

import zmq
import random
import sys
import time

port = "5556"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.connect("tcp://localhost:{}".format(port))
print("Socket created")

i = 0
while True:
    socket.send_string("hello from 2")
    print("socket2: msg sent")
    msg = socket.recv()
    print(msg)
    time.sleep(1)
    print(i)

我在两个不同的终端上运行这两个文件，但它分别在terminal1和terminal2中输出以下消息：

Socket created

Socket created
socket2: msg sent

我不能理解为什么socket1没有收到socket2发送的消息，而被困在socket.recv()上。我真的很感谢任何人的帮助。蒂娅。

Answer 1

你已经很接近了。第一个示例中，socket1.py需要绑定到端口。zeromq会将其转换为客户端要连接的侦听。

import zmq
import random
import sys
import time

port = "5556"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
socket.bind("tcp://localhost:{}".format(port))
print("Socket created")

i = 0
while True:
    msg = socket.recv()
    print("socket: msg recved")
    print(msg)
    socket.send_string("hello from 1")
    time.sleep(1)
    print(i)