谁能提供一下简单的基于twisted的聊天室代码吗？

xmichen

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

1. 
   
2. #!/usr/local/python24/bin/python
   
3. #-*- encoding:gb2312 -*-
   
4. 
   
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
   
10. 
    
11. class ConfigServer(basic.LineReceiver):
    
12.     def __init__(self):
    
13.         pass
    
14. 
    
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())
    
25. 
    
26.     def connectionLost(self,reason):
    
27.         pass
    
28. 
    
29. class ConfigServerFactory(protocol.ServerFactory):
    
30.     protocol=ConfigServer
    
31. 
    
32. def main():
    
33.     log.startLogging(sys.stdout)
    
34.     reactor.listenTCP(8080,ConfigServerFactory())
    
35.     reactor.run()
    
36.    
    
37. if __name__ == '__main__':      
    
38.     main()
    
39. 
    
40. 
    

复制代码

xmichen

研究出来了，，请指教。。

1. 
   
2. #!/usr/local/python24/bin/python
   
3. #-*- encoding:gb2312 -*-
   
4. 
   
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
   
10. 
    
11. class ConfigServer(basic.LineReceiver):
    
12.     def __init__(self):
    
13.         pass
    
14. 
    
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);
    
25. 
    
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())
    
30. 
    
31.     def connectionLost(self, reason):
    
32.         self.factory.clients.remove(self)
    
33.         # self.sendLine("Disconnect...%s" % self.transport.getHost())
    
34.         pass
    
35. 
    
36. class ConfigServerFactory(protocol.ServerFactory):
    
37.     protocol = ConfigServer
    
38.     clients = []
    
39. 
    
40. def main():
    
41.     log.startLogging(sys.stdout)
    
42.     reactor.listenTCP(8080,ConfigServerFactory())
    
43.     reactor.run()
    
44.    
    
45. if __name__ == '__main__':      
    
46.     main()
    
47. 
    
48. 
    

复制代码