我正在尝试一个简单的zmq脚本,但不知何故响应者没有收到第一条消息。
响应者看起来像这样:
def main():
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.connect("tcp://localhost:{}".format(5560))
print("connected ...")
while True:
# Wait for next request from client
message = socket.recv_pyobj()
#print (message)
print(message)
if __name__ == '__main__':
main()
Run Code Online (Sandbox Code Playgroud)
我正在从另一个进程发送带有以下代码的请求:
def main():
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:{}".format(5560))
print("sending object")
socket.send_pyobj("ok")
print("done")
if __name__ == '__main__':
main()
Run Code Online (Sandbox Code Playgroud)
有人知道为什么它没有到达吗?