WEB开发网
开发学院软件开发Python 创建一个Twisted Reactor TCP服务器 阅读

创建一个Twisted Reactor TCP服务器

 2010-09-22 11:15:08 来源:WEB开发网   
核心提示: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实例来服务那个客户端。

Tags:创建 一个 Twisted

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接