如何在Twisted中实现自定义协议?

2024-03-29 14:41:57 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试将一个简单的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

但老实说,我不明白。我应该把安装代码和接收数据的代码放在哪里?在


Tags: 代码服务器协议bindsetupcontexttwistedsocket