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()
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!