在我的发布服务器上,我使用下面的命令发送数据。在
context_forward2 = zmq.Context()
forward2_socket = context_forward2.socket(zmq.PUB)
forward2_socket.bind("tcp://127.0.0.1:7002")
transpport = 'orderbook stuff'
forward2_socket.send(transpport)
在我的订阅服务器上。。。在
^{pr2}$但问题是它只是在transport=forward挂起_接收插座()
为什么zeromq不能工作?在
将
time.sleep(5)
添加到发布服务器中的socket.send()
之前。在传输数据之前,您需要在发布服务器和订阅服务器之间建立连接。你的问题是时间问题。在以下程序按我的预期工作:
发布者:
认购人:
^{pr2}$(静态IP地址被127.0.0.1替换,因为我在本地机器上测试)
如果你想让外界联系进来。您需要绑定}(但不是
89.55.55.55
或{127.0.0.1
,它只监听本地tcp包)相关问题 更多 >
编程相关推荐