首页 > 编程 > Python > 正文

使用Python的Twisted框架实现一个简单的服务器

2020-02-23 00:45:30
字体:
来源:转载
供稿:网友

预览
  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 Protocolclass Echo(Protocol): def dataReceived(self,data):  self.transport.writed(data)

这是个非常简单的协议处理,仅仅是在获得数据的事件中简单的将接收到的数据发送回去,并没有对所有的事件进行响应。这里有一个Protocol响应其他事件的例子如下:

from twisted.internet.protocol import Protocolclass 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" bordercolor="#9da7ac" cellpadding="0" cellspacing="0">   <tbody><tr><td>      <div class="textBackGround" style="font-family:Courier New;font-size:9pt;"><pre><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)</pre>  </div>  </td>  </tr>  </tbody>  </table>             
发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表