python 编程之twisted详解及简单实例
python编程之twisted详解
前言:
我不擅长写socket代码。一是用c写起来比较麻烦,二是自己平时也没有这方面的需求。等到自己真正想了解的时候,才发现自己在这方面确实有需要改进的地方。最近由于项目的原因需要写一些Python代码,才发现在python下面开发socket是一件多么爽的事情。
对于大多数socket来说,用户其实只要关注三个事件就可以了。这分别是创建、删除、和收发数据。python中的twisted库正好可以帮助我们完成这么一个目标,实用起来也不麻烦。下面的代码来自twistedmatrix网站,我觉得挺不错的,贴在这里和大家分享一下。如果需要测试的话,直接telnetlocalhost8123就可以了。如果需要在twisted中处理信号,可以先注册signal函数,在signal函数中调用reactor.stop(),后面twisted继续callstop_factory,这样就可以继续完成剩下的清理工作了。
fromtwisted.internet.protocolimportFactory fromtwisted.protocols.basicimportLineReceiver fromtwisted.internetimportreactor classChat(LineReceiver): def__init__(self,users): self.users=users self.name=None self.state="GETNAME" defconnectionMade(self): self.sendLine("What'syourname?") defconnectionLost(self,reason): ifself.nameinself.users: delself.users[self.name] deflineReceived(self,line): ifself.state=="GETNAME": self.handle_GETNAME(line) else: self.handle_CHAT(line) defhandle_GETNAME(self,name): ifnameinself.users: self.sendLine("Nametaken,pleasechooseanother.") return self.sendLine("Welcome,%s!"%(name,)) self.name=name self.users[name]=self self.state="CHAT" defhandle_CHAT(self,message): message="<%s>%s"%(self.name,message) forname,protocolinself.users.iteritems(): ifprotocol!=self: protocol.sendLine(message) classChatFactory(Factory): def__init__(self): self.users={}#mapsusernamestoChatinstances defbuildProtocol(self,addr): returnChat(self.users) defstartFactory(self): print'start' defstopFactory(self): print'stop' reactor.listenTCP(8123,ChatFactory()) reactor.run()
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!