我正在尝试将一个简单的ZeroMQ套接字服务器实现为twisted协议,我的代码目前是:
# Setup
context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.bind("tcp://127.0.0.1:5558")
poller = zmq.Poller()
poller.register(socket, zmq.POLLIN)
# Respond to incoming messages.
while True:
if poller.poll(1000):
msg = self.socket.recv()
print "Received a message ..."
else:
time.sleep(0.05)
我发现:
http://twistedmatrix.com/documents/11.0.0/api/twisted.internet.interfaces.IProtocol.html
但老实说,我不明白。我应该把安装代码和接收数据的代码放在哪里?在
目前没有回答
相关问题 更多 >
编程相关推荐