Chinaunix

标题: 谁能提供一下简单的基于twisted的聊天室代码吗？ [打印本页]
作者: xmichen    时间: 2007-04-03 09:01
标题: 谁能提供一下简单的基于twisted的聊天室代码吗？
谁能提供一下简单的基于twisted的聊天室代码吗？
基于telnet服务的
只要最简单的就好了，监听一个端口，接受CLIENT连接
每个CLIENT连接的时候，向所有已经连接的CLIENT broardcast一个某某登陆的消息
下面是参考网上的文章写的，但不知道如何实现broardcast消息。。
原想在connectionMade里面增加一个LIST记录所有客户端
好象也不行，，请指教



  2. #!/usr/local/python24/bin/python
  3. #-*- encoding:gb2312 -*-

  5. from twisted.internet import protocol
  6. from twisted.protocols import basic
  7. from twisted.python import log
  8. from twisted.internet import reactor
  9. import sys

  11. class ConfigServer(basic.LineReceiver):
  12.     def __init__(self):
  13.         pass

  15.     def lineReceived(self,line):
  16.         if line == 'quit':
  17.             self.sendLine("Goodbye.")
  18.             self.transport.loseConnection()
  19.         else:
  20.             self.sendLine("You said: %s" % line)
  21.         
  22.     def connectionMade(self):
  23.         print "Connect from %s.." % self.transport.getHost()
  24.         self.sendLine("Welcome...%s" % self.transport.getHost())

  26.     def connectionLost(self,reason):
  27.         pass

  29. class ConfigServerFactory(protocol.ServerFactory):
  30.     protocol=ConfigServer

  32. def main():
  33.     log.startLogging(sys.stdout)
  34.     reactor.listenTCP(8080,ConfigServerFactory())
  35.     reactor.run()
  36.    
  37. if __name__ == '__main__':      
  38.     main()


复制代码
作者: xmichen    时间: 2007-04-03 16:57
研究出来了，，请指教。。


  2. #!/usr/local/python24/bin/python
  3. #-*- encoding:gb2312 -*-

  5. from twisted.internet import protocol
  6. from twisted.protocols import basic
  7. from twisted.python import log
  8. from twisted.internet import reactor
  9. import sys

  11. class ConfigServer(basic.LineReceiver):
  12.     def __init__(self):
  13.         pass

  15.     def lineReceived(self, line):
  16.         if line == 'quit':
  17.             self.sendLine("Goodbye.")
  18.             self.transport.loseConnection()
  19.         else:
  20.             self.broadcast(line)
  21.    
  22.     def broadcast(self, msg):
  23.         for client in self.factory.clients:
  24.             client.sendLine("someone said: %s" % msg);

  26.     def connectionMade(self):
  27.         self.factory.clients.append(self)
  28.         print "Connect from %s.." % self.transport.getHost()
  29.         self.sendLine("Welcome...%s" % self.transport.getHost())

  31.     def connectionLost(self, reason):
  32.         self.factory.clients.remove(self)
  33.         # self.sendLine("Disconnect...%s" % self.transport.getHost())
  34.         pass

  36. class ConfigServerFactory(protocol.ServerFactory):
  37.     protocol = ConfigServer
  38.     clients = []

  40. def main():
  41.     log.startLogging(sys.stdout)
  42.     reactor.listenTCP(8080,ConfigServerFactory())
  43.     reactor.run()
  44.    
  45. if __name__ == '__main__':      
  46.     main()


复制代码




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2