python网络编程 之 twisted

wisted 是一个完全事件驱动的网络框架。 它允许你使用和开发完全异步的网络应用程序和协议。 在写本书的时候，它还不是 Python 标准库的一部分，要使用它，你必需另外下载并安装它（在本章 最后能找到链接）。它为你创建一个完整系统提供了很大的帮助。系统中可以有：网络协议，线程， 安全和认证，聊天/即时通讯，数据库管理，关系数据库集成，网页/互联网，电子邮件，命令行参 数，图形界面集成等。

使用 Twisted Internet 类的时间戳 TCP 服务器--客户端

#encoding=utf-8
 #Twisted Reactor Timestamp TCP 客户端
from twisted.internet import protocol,reactor

host = 'localhost'
port = 21567

class TSCIntProtocol(protocol.Protocol):
    # 重写函数 connectionMade()和 dataReceived()。
    # 新加一个自己的函数 sendData()，用于在需要发送数据时调用
    def sendData(self):
        data = raw_input('>')
        if data:
            print 'sending %s ' %data
            self.transport.write(data)
        else:
            self.transport.loseConnection()

    def connectionMade(self):
        self.sendData()

    def dataReceived(self,data):
        print data
        self.sendData()

class TSCIntFactory(protocol.ClientFactory):
    protocol = TSCIntProtocol
    clientConnectionLost = clientConnectionFailed = 
    lambda self,connector,reason:reactor.stop()

reactor.connectTCP(host,port,TSCIntFactory())
reactor.run()

---

---

#encoding=utf-8
from twisted.internet import protocol,reactor
from time import ctime

port = 21567

class TSServProtocol(protocol.Protocol):
    #重写 connectionMade()函数，这个函数在有客户连接的时候被调用
    def connectionMade(self):
        clnt = self.clnt = self.transport.getPeer().host
        print 'connected from',clnt

    #dataReceived()函数，这个函数在客户通过网络发送数据过来时被调用。
    #reactor 把数据当成参数传到这个函数中，这样我们就不用自己去解析数据
    def dataReceived(self,data):
        self.transport.write('[%s] %s' % (ctime(),data))

# 我们创建一个 protocol 工厂。它被称为“工厂”是因为，每次我们
# 有连接进来的时候，它都会“生产”一个我们的 protocol 对象。
factory = protocol.Factory()
factory.protocol = TSServProtocol
print 'waiting for connection'

# 在 reactor 中安装一个 TCP
# 监听器以等待服务请求。当有请求进来时，
# 创建一个 TSServProtocol 实例来服务那个客户。
reactor.listenTCP(port,factory)
reactor.run()

 使用 Twisted Internet 类的时间戳 TCP 服务器--服务端