这篇文章主要介绍了使用Python的Twisted框架实现一个简单的服务器,翻译自Twisted的文档,需要的朋友可以参考下
预览
twisted是一个被设计的非常灵活框架以至于能够让你写出非常强大的服务器。这种灵活的代价是需要好通过好几个层次来实现你的服务器， 本文档描述的是Protocol层，你将在这个层次中执行协议的分析和处理，如果你正在执行一个应用程序，那么你应该在读过top level的为twisted写插件一节中的怎样开始写twisted应用程序之后阅读本章。这个文档只是和TCP，SSL和Unix套接字服务器有关，同时也将有另一份文档专门讲解UDP。
你的协议处理类通常是twisted.internet.protocol.Protocol的子类。许多协议处理继承于该类或者比该类更加方便的该类的子类。一个protocol类的实例可能反复连接，也可能在连接关闭之后销毁。这就意味着这些持续不断的配置信息不是保存在Protocol中。
这些持久性的配置被保存在工厂(Factory)类中，这些工厂类通常继承至twisted.internet.protocol.Factory，默认 的工厂类仅仅是实例化每个Protocol，然后设置他们的factory属性为这个默认的工厂实例本身。这就让每个Protocol都被存储，然后可能 修改，于是这样就形成了Protocol的持久性。
通常为多个端口或网络地址提供相同的服务是非常有用的。这就是为什么Factory不监听连接，并且实际上它不知道关于网络的任何事情。看 twisted.internet.interfaces.IReactorTCP.listenTCP，另一个IReactor*.listen*获得 更多的信息。
本文档将要讲解各个步骤。
Protocol
如上所述，这里将通过更多代码的辅助类和函数来了解它。一个twisted protocl通过异步方式处理数据。这就意味着protocol从不等待任何事件。相反的是在事件通过网络到达的时候作出响应。
from twisted.internet.protocol import Protocol class Echo(Protocol): def dataReceived(self,data): self.transport.writed(data)
这是个非常简单的协议处理，仅仅是在获得数据的事件中简单的将接收到的数据发送回去，并没有对所有的事件进行响应。这里有一个Protocol响应其他事件的例子如下：
from twisted.internet.protocol import Protocol class QOTD(Protocol): def connectionMade(self): self.transport.write("An apple a day keeps the doctor away/r/n") self.transport.loseConnection()
本Protocl在一个已知的引用刚开始连接上来的时候作出响应，发送了一条消息，然后终止了连接connectionMade事件通常是在由于连接对象建立初始连接时触发，就像上面的QOTD类实际上是RFC865号文档的一个协议基类connectionLost事件将在断开连接的时候触发。实例：
<span style="font-family: Monospaced;color: #0000a0"><strong>PythonCode: </strong></span><table style="width: 100%;height: 20px" align="center" bgcolor="#e3dfe3" border="1" cellpadding="0" cellspacing="0"> <tbody><tr><td> <div class="textBackGround" style="font-family:Courier New;font-size:9pt"><pre class="prettyprint linenums"><span style="color: blue">from</span> twisted.internet.protocol <span style="color: blue">import</span> Protocol <span style="color: blue">class</span> Echo(Protocol): <span style="color: blue">def</span> connectionMade(self): self.factory.numProtocols = self.factory.numProtocols+1 <span style="color: blue">if</span> self.factory.numProtocols > 100: self.transport.write(<span style="color: #ff44a2">"Too many connections, <span style="color: blue">try</span> later"</span>) self.transport.loseConnection() <span style="color: blue">def</span> connectionLost(self, reason): self.factory.numProtocols = self.factory.numProtocols-1 <span style="color: blue">def</span> dataReceived(self, data): self.transport.write(data)
本实例中，connectionMade和connectionLost相互协作工作以保持factory内部的活动连接数量最多为100。每当有用户协议连接近来的时候，就先检测factory内部的活动连接数，如果数量超过100，就发送连接数太多等下试的消息，然后断开连接而connectionLost则在断开一个协议的时候触发，减去factory内部的协议数量。
Using the Protocol
在本节，我将要讲解怎样简单的去测试你的protocol。（想知道如何写出一个好的twisted的服务器，请看 Writing Plug-Ins
for Twisted），这里有一个代码将运行我们上面谈论的QOTD服务器：
<!-- .textBackGround {background-color: #F0F5FD;} --><span style="font-family: Monospaced;color: #0000a0"><strong>PythonCode: </strong></span><table style="width: 100%;height: 20px" align="center" bgcolor="#e3dfe3" border="1" cellpadding="0" cellspacing="0"> <tbody><tr><td> <div class="textBackGround" style="font-family:Courier New;font-size:9pt"><pre class="prettyprint linenums"><span style="color: blue">from</span> twisted.internet.protocol <span style="color: blue">import</span> Protocol, Factory <span style="color: blue">from</span> twisted.internet <span style="color: blue">import</span> reactor <span style="color: blue">class</span> QOTD(Protocol): <span style="color: blue">def</span> connectionMade(self): self.transport.write(<span style="color: #ff44a2">"An apple a day keeps the doctor away/r/n"</span>) self.transport.loseConnection() <span style="color: green"># Next lines are magic:</span> factory = <p style="color:transparent">来源gao!daima.com搞$代!码网</p>Factory() factory.protocol = QOTD <span style="color: green"># 8007 <span style="color: blue">is</span> the port you want to run under. Choose something >1024</span> reactor.listenTCP(8007, factory) reactor.run()
