twisted 网络通信模型
关键字: twisted
一、Twisted基本模型
Twisted 网络编程框架是一种基于事件的网络编程框架,用户需要继承特定的类,并重载其中的方法来处理网络通信中可能出现的各种情况。Twisted的网络通信模型最基本的也要由三部分组成:反应器(reactor)、协议(protocol)、工厂(factory)。其中反应器用来执行事件循环,分发事件处理等等,每个应用程序中一般只能启动一个reactor。协议用来完成与一个已经连接成功的主机的交互功能,主要有数据的接收和发送功能。连接的断开事件也可以在这里处理。工厂负责与一个协议的启动和关闭功能,而且还负责在连接成功时生成一个协议对象,(by gashero)用于与远程主机的交互功能。
一个典型的Twisted应用程序会建立至少一个协议,可以从twisted.internet.protocol.BaseProtocol类或其子类继承。协议还需要实现数据的接收处理,即收到数据之后需要做出何种响应。比较简单的Twisted应用程序可以继承一个空的工厂,来自 twisted.internet.protocol.Factory或其子类。工厂至少应该指定protocol属性,指向协议类。最后就是要启动事件循环,根据连接方向的不同,可以选择用reactor的connectXXX()或listenXXX()方法,然后执行reactor.run()启动事件循环。
二、协议模型
所有协议类的基类是twisted.internet.protocol.BaseProtocol,但是一般使用其子类。不同的协议子类提供了不同的数据接收方法,如LineReceiver子类就允许同时使用行和原始数据两种方法接收数据,使用非常方便。BaseProtocol的接口如下:
class BaseProtocol:
connected=0 #是否已经连接了
transport=None #用于数据发送的传输对象
def makeConnection(self,transport): #建立连接的方法,不是事件方法,一般不要重载
def connectionMade(self): #连接成功事件,可重载
可以看到BaseProtocol可以理解为一个虚基类,实现的功能十分简陋。实际的应用程序一般也不是直接继承BaseProtocol来实现协议,而是继承Protocol类。Protocol类提供了基本完善的协议功能,接口定义如下:
class Protocol(BaseProtocol):
def dataReceived(self,data): #接收到数据事件,可重载
def connectionLost(self,reason=connectionDone): #连接断开事件,可重载,依靠reason区分断开类型
从Protocol类继承就可以完成协议的基本处理了,包括连接的建立和断开事件,还有数据接收事件。
想要完成更加完整的协议功能,可以到twisted.protocols包中寻找(by gashero)更多的答案。如果需要自己实现一种协议,比较推荐的是twisted.protocols.basic.LineReceiver类。 LineReceiver默认按照文本行模型进行通信,接收数据也是以行为单位。但是也可以设置使用原始数据模式进行通信。比较典型的应用就是 HTTPChannel协议类。HTTP协议在请求报文头部和响应报文头部的传送时使用的是行模式,而在实体主体的传输时又是使用的原始数据模型。所以使用LineReceiver是非常合适的。LineReceiver的接口定义如下:
class LineReceiver(protocol.Protocol,_PauseableMixin):
line_mode=1
__buffer=''
delimiter="\r\n"
MAX_LENGTH=16384 #一行的最大长度,字节
def clearLineBuffer(self): #清空缓冲区
def dataReceived(self,data): #继承父类的方法,用于分发事件,不要重载
def setLineMode(self,extra=""): #设置工作状态为行模式
def setRawMode(self): #设置工作状态为原始数据模式
def rawDataReceived(self,data): #原始数据接收事件,可重载
def lineReceived(self,line): #行数据接收事件,可重载
def sendLine(self,line): #以行模式发送数据
def lineLengthExceeded(self,line): #当接收到的一行长度超过了最大值时的错误响应,并断开连接
可以看到LineReceiver类提供的功能已经相当的完善了,可以手动设置工作状态并提供了完善的事件响应方法。如果要发送原始数据,可以使用如下方法:
self.transport.write(data)
至于self.transport对象,这个是所有的协议对象都有的成员,可以看出是从BaseProtocol就已经存在的。 self.transport对象一般使用twisted.internet.protocol.FileWrapper类实现,其主要接口是与文件对象相同的。FileWrapper另外提供的方法包括生产者/消费者的支持,还有就是连接控制。
self.transport.loseConnection() #关闭连接
self.transport.getPeer() #获取对方信息
self.transport.getHost() #获取本机信息
其他还有很多方法,读者可以自己尝试阅读源码并使用。
三、工厂模型
相对于协议,工厂可以发挥的空间就很小了。所有工厂的基类是twisted.internet.protocol.Factory。这个类定义了三个方法,接口如下:
class Factory:
protocol=None #指向一个协议类
def startFactory(self): #开启工厂
def stopFactory(self): #关闭工厂
def buildProtocol(self,addr): #构造协议对象,并给协议对象添加一个factory属性指向工厂,可以重载
从这里可以看到,工厂类中最重要的部分就是protocol属性,将这个属性设置为一个协议类(注意不是协议对象),就可以将这个工厂设置为对应协议的工厂了。前两个方法控制工厂的开启和关闭,用于资源的初始化和释放,可以重载。buildProtocol()方法可以控制协议对象的生成,(by gashero)如果需要多传递一个属性,可以重载,但是重载时应该注意在方法内继承原方法内容。
工厂还分为客户端工厂和服务器工厂。服务器工厂继承自Factory,而没有任何修改,定义如下:
class ServerFactory(Factory):
客户端工厂则有较多内容,接口定义如下:
class ClientFactory(Factory):
def startedConnecting(self,connector): #连接建立成功时
def clientConnectionFailed(self,connector,reason): #客户端连接失败
def clientConnectionLost(self,connector,reason): #连接断开
这三个方法都传递了一个connector对象,这个对象有如下方法可用:
connector.stopConnection() #关闭会话
connector.connect() #一般在连接失败时用于重新连接
四、连接器
连接器指客户端用来连接的包装。
twisted.internet.protocol.ClientCreator是一个连接器,用来连接远程主机,接口定义如下:
class ClientCreator:
def __init__(self,reactor,protocolClass,*args,**kwargs):
def connectTCP(self,host,port,timeout=30,bindAddress=None):
def connectUNIX(self,address,timeout=30,checkPID=0):
def connectSSL(self,host,port,contextFactory,timeout=30,bindAddress=None):
三个连接方法都是返回Deferred对象作为Protocol实例,在不需要工厂时可以直接使用这个类来产生仅使用一次的客户端连接。这时,协议对象之间没有共享状态,也不需要重新连接。
分享到:
相关推荐
twisted网络通信模型
Twisted网络编程必备,Twisted是使用Python编写的,强壮的、面向对象的解释性语言。Python使它的爱好者充满热情。使用Python编程是一种乐趣,易于编写、易于阅读、易于运行。因为Python是跨平台的,所以可以运行...
《twisted网络编程.txt 》学习Python,必须要学的twisted。
Twisted的中文资料比较少,整理出跟大家分享
Twisted Python事件驱动网络框架
第一部分:Twisted理论基础 第二部分:异步编程初探与reactor模式 第三部分:初步认识Twisted 第四部分:由Twisted支持的诗歌客户端 第一个twisted支持的诗歌服务器 第一滴心血 第五部分:由Twisted支持的诗歌...
Twisted网络编程中文文档,使我们一个学习Python框架入门的不错资料,希望对各位爱好学习的同志们有帮助。
英文版本《Twisted Network Programming Essentials》第2版资料,讲Twisted的资料不多,这个资料可算稀缺资源了。
The Twisted Documentation 电子版 pdf twisted 框架 网络编程
Twisted Network Programming Essentials,一本介绍socket异步编程框架twisted
Twisted Info Twisted入门教程源码
twisted资料twisted资料twisted资料
最近有人在twisted邮件列表中问有没有一个可以让人快速学习twisted的文档.总体的来说:这个系列不是这样的一个文档.如果你没有很多时间或者耐心的话,这个系列的文章不太适合你. 不过,如果你对异步编程了解很少的话,...
Twisted与异步编程入门,最好的入门资源。
学习python网络编程必须要学的twisted架构,讲的非常全面,并有丰富的代码示例。
Python Twisted模块 10.2.0Python Twisted模块 10.2.0Python Twisted模块 10.2.0Python Twisted模块 10.2.0Python Twisted模块 10.2.0Python Twisted模块 10.2.0
网络编程中我们越来越感觉twisted的强大,本教材是一本很好的twisted入门级教材
最新twisted是python面向实时通信的应用框架,支持python3,希望做硬件开发、控制的有关人员喜欢
Twisted是一个事件驱动的python网络框架被所有类型的软件使用。
Twisted Network Programming Essentials 2nd Edition BOOK DESCRIPTION Get started with Twisted, the event-driven networking framework written in Python. With this introductory guide, you’ll learn the...