注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

Code@Pig Home

喜欢背着一袋Code傻笑的Pig .. 忧美.欢笑.记忆.忘却 .之. 角落

 
 
 

日志

 
 

[twisted] echo server  

2010-06-09 13:56:36|  分类: net_Twisted |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
echo server 就像客户端的 hello world 程序一样,每次都要写一下,哈。

逻辑处理的类,继承自 twisted.internet.protocol.Protocol,一个 instance 对应一个连接,所以数据不要放在 Protocol 上,而是放到 Factory (twisted.internet.protocol.Factory) 中。

可以将一个 factory 绑定不同的 port,则“一个逻辑同时在多个监听端口上”。twisted.internet.interfaces.IReactorTCP.listenTCP。

-----------------------------------------------------------
from twisted.internet.protocol import Protocol, Factory
from twisted.internet import reactor

class Echo(Protocol):
    def connectionMade(self):
        self.factory.numProtocols = self.factory.numProtocols + 1
        if self.factory.numProtocols > 3:
            self.transport.write("Too many connections, try later")
            self.transport.loseConnection()

    def connectionLost(self, reason):
        self.factory.numProtocols = self.factory.numProtocols - 1

    def dataReceived(self, data):
        self.transport.write(data)

class EchoFactory(Factory):
    protocol = Echo
    numProtocols = 0

factory = EchoFactory()

reactor.listenTCP(2100, factory)
reactor.listenTCP(2200, factory)
reactor.run()
-----------------------------------------------------------
如此这般,一个具有连接数控制的 echo server 就完成啦。so simple, huh?

其中的 Protocol.transport 是 twisted.internet.tcp.Server。Server 的继承结构如下:
twisted.internet.abstract.FileDescriptor
    twisted.internet.tcp.Connection
        twisted.internet.tcp.Server

  评论这张
 
阅读(1144)| 评论(0)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017