python -- twisted初探

時間 2019-12-12

原文原文鏈接

Twisted是用python實現的基於事件驅動的網絡引擎框架。python

初步使用twistedreact

 1 #!/usr/bin/env python
 2 # -*- coding: utf-8 -*-
 3 
 4 from twisted.internet import protocol
 5 from twisted.internet import reactor
 6 
 7 class Echo(protocol.Protocol):
 8     def dataReceived(self, data):
 9         self.transport.write(bytes("I am server | %s" %data.decode('utf8'),'utf8'))
10 
11 def main():
12     factory = protocol.ServerFactory()
13     factory.protocol = Echo
14     reactor.listenTCP(9999,factory,interface='localhost')
15     reactor.run()
16 
17 if __name__ == '__main__':
18     print("\033[32;1m server is waiting... \033[0m")
19     main()

echo_server

 1 #!/usr/bin/env python
 2 # -*- coding: utf-8 -*-
 3 
 4 from twisted.internet import protocol
 5 from twisted.internet import reactor
 6 
 7 
 8 class EchoClient(protocol.Protocol):
 9     def connectionMade(self):
10         self.transport.write(bytes("hello root",'utf8'))
11 
12     def dataReceived(self, data):
13         print("Server said:",data.decode('utf8'))
14         self.transport.loseConnection()
15 
16     def connectionLost(self,reason):
17         print("connection lost")
18 
19 
20 class EchoFactory(protocol.ClientFactory):
21     protocol = EchoClient
22 
23     def clientConnectionFailed(self, connector, reason):
24         print("Connection failed - goodbye!")
25         reactor.stop()
26 
27     def clientConnectionLost(self, connector, reason):
28         print("Connection lost - goodbye!")
29 
30 
31 def main():
32     f = EchoFactory()
33     reactor.connectTCP('localhost',9999,f)
34     reactor.run()
35 
36 if __name__ == '__main__':
37     main()
38