Python学习路程day10

Posted 2020-07-04

Twsited异步网络框架

Twisted是一个事件驱动的网络框架，其中包含了诸多功能，例如：网络协议、线程、数据库管理、网络操作、电子邮件等。

　

事件驱动

简而言之，事件驱动分为二个部分：第一，注册事件；第二，触发事件。

自定义事件驱动框架，命名为：“弑君者”：

 1 #!/usr/bin/env python
 2 # -*- coding:utf-8 -*-
 3  
 4 # event_drive.py
 5  
 6 event_list = []
 7  
 8  
 9 def run():
10     for event in event_list:
11         obj = event()
12         obj.execute()
13  
14  
15 class BaseHandler(object):
16     """
17     用户必须继承该类，从而规范所有类的方法（类似于接口的功能）
18     """
19     def execute(self):
20         raise Exception(‘you must overwrite execute‘)
21  
22 最牛逼的事件驱动框架

程序员使用“弑君者框架”：

 1 #!/usr/bin/env python
 2 # -*- coding:utf-8 -*-
 3  
 4 from source import event_drive
 5  
 6  
 7 class MyHandler(event_drive.BaseHandler):
 8  
 9     def execute(self):
10         print ‘event-drive execute MyHandler‘
11  
12  
13 event_drive.event_list.append(MyHandler)
14 event_drive.run()

Protocols

Protocols描述了如何以异步的方式处理网络中的事件。HTTP、DNS以及IMAP是应用层协议中的例子。Protocols实现了IProtocol接口，它包含如下的方法：

makeConnection               在transport对象和服务器之间建立一条连接
connectionMade               连接建立起来后调用
dataReceived                 接收数据时调用
connectionLost               关闭连接时调用

Transports

Transports代表网络中两个通信结点之间的连接。Transports负责描述连接的细节，比如连接是面向流式的还是面向数据报的，流控以及可靠性。TCP、UDP和Unix套接字可作为transports的例子。它们被设计为“满足最小功能单元，同时具有最大程度的可复用性”，而且从协议实现中分离出来，这让许多协议可以采用相同类型的传输。Transports实现了ITransports接口，它包含如下的方法：

write                   以非阻塞的方式按顺序依次将数据写到物理连接上
writeSequence           将一个字符串列表写到物理连接上
loseConnection          将所有挂起的数据写入，然后关闭连接
getPeer                 取得连接中对端的地址信息
getHost                 取得连接中本端的地址信息

将transports从协议中分离出来也使得对这两个层次的测试变得更加简单。可以通过简单地写入一个字符串来模拟传输，用这种方式来检查。

 

 

EchoServer

 1 from twisted.internet import protocol
 2 from twisted.internet import reactor
 3  
 4 class Echo(protocol.Protocol):
 5     def dataReceived(self, data):
 6         self.transport.write(data)
 7  
 8 def main():
 9     factory = protocol.ServerFactory()
10     factory.protocol = Echo
11  
12     reactor.listenTCP(1234,factory)
13     reactor.run()
14  
15 if __name__ == ‘__main__‘:
16     main()

EchoClient

 1 from twisted.internet import reactor, protocol
 2  
 3  
 4 # a client protocol
 5  
 6 class EchoClient(protocol.Protocol):
 7     """Once connected, send a message, then print the result."""
 8  
 9     def connectionMade(self):
10         self.transport.write("hello alex!")
11  
12     def dataReceived(self, data):
13         "As soon as any data is received, write it back."
14         print "Server said:", data
15         self.transport.loseConnection()
16  
17     def connectionLost(self, reason):
18         print "connection lost"
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         reactor.stop()
30  
31  
32 # this connects the protocol to a server running on port 8000
33 def main():
34     f = EchoFactory()
35     reactor.connectTCP("localhost", 1234, f)
36     reactor.run()
37  
38 # this only runs if the module was *not* imported
39 if __name__ == ‘__main__‘:
40     main()

运行服务器端脚本将启动一个TCP服务器，监听端口1234上的连接。服务器采用的是Echo协议，数据经TCP transport对象写出。运行客户端脚本将对服务器发起一个TCP连接，回显服务器端的回应然后终止连接并停止reactor事件循环。这里的Factory用来对连接的双方生成protocol对象实例。两端的通信是异步的，connectTCP负责注册回调函数到reactor事件循环中，当socket上有数据可读时通知回调处理。