理解Twsited异步网络框架

事件驱动　

　　简而言之，事件驱动分为二个部分：第一，注册事件；第二，触发事件。自定义事件驱动框架，命名为：“弑君者”：

      事件服务器端：

__author__ = 'lizheng'
# !/usr/bin/env python
#-*- coding:utf-8 -*-
event_list = []

def run():
    for event in event_list:
        obj = event()
        obj.execute()


class BaseHandler(object):
    """
    用户必须继承该类，从而规范所有类的方法（类似于接口的功能）
    """
    def execute(self):
        raise Exception('you must overwrite execute')

     事件客户端，注册和触发事件

__author__ = 'lizheng'
# !/usr/bin/env python
#-*- coding:utf-8 -*-
from day10 import event_drive


class MyHandler(event_drive.BaseHandler):

    def execute(self):
        print('MyHandler is executing!')

event_drive.event_list.append(MyHandler)
event_drive.run()

Twsited异步网络框架

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

EchoServer

__author__ = 'lizheng'
# !/usr/bin/env python
#-*- coding:utf-8 -*-
from twisted.internet import protocol
from twisted.internet import reactor
#定义Echo类，相当于socketserver里的MyTCPHandler，继承protocal.Protocal
class Echo(protocol.Protocol):
    def dataReceived(self, data):
        self.transport.write(data)
#定义主函数，将自己定的处理类Echo传给factory.protocol
def main():
    factory = protocol.ServerFactory()
    factory.protocol = Echo
#监听在factory,1234端口
    reactor.listenTCP(1234,factory)
    reactor.run()

if __name__ == '__main__':
    main()

EchoClient

__author__ = 'lizheng'
# !/usr/bin/env python
#-*- coding:utf-8 -*-
from twisted.internet import reactor, protocol

#定义一个客户端协议类，继承protocol.Protocol
class EchoClient(protocol.Protocol):
#一旦连接，发送消息
    def connectionMade(self):
        self.transport.write(bytes("hello alex!",'utf-8'))
#收到消息，打印消息
    def dataReceived(self, data):
        print("Server said:", data)
#打印完消息，调用connectionLost关闭连接
        self.transport.loseConnection()
#关闭连接
    def connectionLost(self, reason):
        print("connection lost")
#定义客户端工厂类
class EchoFactory(protocol.ClientFactory):
#将EchoClient传给protocol
    protocol = EchoClient
#连接失败处理
    def clientConnectionFailed(self, connector, reason):
        print("Connection failed - goodbye!")
        reactor.stop()
#连接丢失处理
    def clientConnectionLost(self, connector, reason):
        print("Connection lost - goodbye!")
        reactor.stop()



def main():
#客户端工厂实例化
    f = EchoFactory()
#绑定本机的1234端口连接上服务端，传入客户端工厂实例进行消息发送和处理
    reactor.connectTCP("localhost", 1234, f)
    reactor.run()

#程序主体
if __name__ == '__main__':
    main()