创建一个Twisted Reactor TCP服务器

核心提示：16.5 Twisted框架介绍Twisted是一个完全事件驱动的网络框架，它允许你使用和开发完全异步的网络应用程序和协议，创建一个Twisted Reactor TCP服务器，在写本书的时候，它还不是Python标准库的一部分，然后在reactor中安装一个TCP监听器以等待服务请求，当有请求进来时，要使用它，你必须

16.5 Twisted框架介绍

Twisted是一个完全事件驱动的网络框架。它允许你使用和开发完全异步的网络应用程序和协议。在写本书的时候，它还不是Python标准库的一部分，要使用它，你必须另外下载并安装它（在本章最后能找到链接）。它为你创建一个完整系统提供了很大的帮助。系统中可以有：网络协议、线程、安全和认证、聊天/即时通讯、数据库管理、关系数据库集成、Wed/Internet、电子邮件、命令行参数、图形界面集成等。

使用Twisted来实现我们这个简单的例子有牛刀杀鸡的感觉。不过，学东西总要有切入点吧，我们先实现一个“Hello World”的网络应用程序。

像SocketServer一样，Twisted的大部分功能都在它的类里面。在我们的例子中，我们将使用Twisted的Internet组件中reactor和protocol包的类。

16.5.1 创建一个Twisted Reactor TCP服务器

你会发现我们的代码与SocketServer例子有些相似。我们创建一个协议类，并像安装回调函数那样重写几个函数，而不是写一个处理器类。同样的，我们的例子是异步的。先来看服务器：

逐行解释

1～6行

一开始的代码照常是模块导入部分。要注意twisted.internet中protocol和reactor包和端口号常量。

8～14行

我们从Protocol类中派生出TSServProtocol类作为时间戳服务器。然后重写connectionMade()函数，这个函数在有客户端连接的时候被调用，以及dataReceived()函数，这个函数在客户端通过网络发送数据过来时被调用。reactor把数据当成参数传到这个函数中，这样我们就不用自己去解析数据了。

例16.7 Twisted Reactor时间戳服务器（tsTservTW.py）

这是一个使用Twisted Internet类的时间戳TCP服务器。

1 #!/usr/bin/env python
2
3 from twisted.internet import protocol, reactor
4 from time import ctime
5
6 PORT = 21567
7
8 class TSServProtocol(protocol.Protocol):
9　　　def connectionMade(self):
10　　　　　 clnt = self.clnt = self.transport.getPeer().host
11　　　　　 print '...connected from:', clnt
12　　　def dataReceived(self, data):
13　　　　　 self.transport.write('[%s] %s' % (
14　　　　　　　　 ctime(), data))
15
16　factory = protocol.Factory()
17　factory.protocol = TSServProtocol
18　print 'waiting for connection...'
19　reactor.listenTCP(PORT, factory)
20　reactor.run()

我们通过transport实例对象与客户端进行通信。你可以看到在connectionMade()函数中，我们如何得到主机的信息，以及在dataReceived()函数中，我们如何把数据传回客户端。

16～20行

在服务器的最后一部分，我们创建一个protocol Factory()。它被称为“工厂”是因为，每次我们有连接进来的时候，它都会“生产”一个我们的protocol对象。然后在reactor中安装一个TCP监听器以等待服务请求。当有请求进来时，创建一个TSServProtocol实例来服务那个客户端。