twisted task clientfactory 问题

moartel

想实现的功能,
客户端每10秒发送一次数据到服务器

1. from twisted.internet.protocol import Protocol,ClientFactory,Factory
   
2. from twisted.internet import reactor,task
   
3. 
   
4. host = '10.150.195.48'
   
5. port = 56677
   
6. 
   
7. class Echo(Protocol):
   
8.     def connectionMade(self):
   
9.         self.transport.write("An apple a day keeps the doctor away")
   
10.         #self.transport.write("An apple a day keeps the doctor away\r\n")
    
11.         self.transport.loseConnection()
    
12. 
    
13. class EchoClientFactory(ClientFactory):
    
14.     def startedConnecting(self, connector):
    
15.         print 'Started to connect.'
    
16. 
    
17.     def buildProtocol(self, addr):
    
18.         print 'Connected.'
    
19.         return Echo()
    
20. 
    
21. #    reactor.stop()
    
22. #    def clientConnectionLost(self, connector, reason):
    
23. #        print 'Lost connection.  Reason:', reason
    
24. 
    
25. #    def clientConnectionFailed(self, connector, reason):
    
26. #        print 'Connection failed. Reason:', reason
    
27. def main():
    
28.     reactor.connectTCP(host, port, EchoClientFactory())
    
29.     reactor.run()
    
30. #if __name__ == '__main__':
    
31. #    main()
    
32. 
    
33. m = task.LoopingCall(main())
    
34. m.start(10.0)
    
35. 
    
36. 
    
37. reactor.run()

复制代码

尝试写了代码,可是不工作,请教各位如何实现