python 编程之twisted详解及简单实例

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's your name?")

  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("Name taken, please choose another.")

      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={}# maps user names to Chat instances

  defbuildProtocol(self, addr):

    returnChat(self.users)

  defstartFactory(self):

    print'start'

  defstopFactory(self):

    print'stop'

reactor.listenTCP(8123, ChatFactory())

reactor.run()