服务端

　　# -*- coding: utf-8 -*-

　　# @Time : 2018/9/19 21:41

　　# @Author : cxa

　　# @File : tsTservTW.py

　　# @Software: PyCharm

　　'''

　　Twisted Reactor时间戳TCP服务器

　　'''

　　from twisted.internet import protocol, reactor

　　from time import ctime

　　import msgpack

　　PORT = 21567

　　class TSServProtocol(protocol.Protocol):

　　def connectionMade(self):

　　'''

　　当客户端连接的时候会执行该方法

　　:return:

　　'''

　　clnt = self.clnt = self.transport.getPeer().host

　　print(f"...来自的{clnt}链接:")

　　def dataReceived(self, data):

　　'''

　　接收到客户端的数据

　　:param data:

　　:return:

　　'''

　　print(f"来自客户端:{msgpack.unpackb(data,encoding='utf')}")

　　data = f"{ctime()}:来自服务器:你好"

　　self.transport.write(msgpack.packb(data))

　　if __name__ == '__main__':

　　# 创建一个协议工厂，之所以称之为工厂是因为，每次得到一个

　　# 接入连接时，都能"制造"协议的一个实例。

　　factory = protocol.Factory()

　　factory.protocol = TSServProtocol

　　print("....等待链接..")

　　# 使用reactor安装一个TCP监听器，检查服务请求。

　　# 当它接收到一个请求时,就会创建一个TSServProtocol实例来处理那个客户端的事务。

　　reactor.listenTCP(PORT, factory)

　　reactor.run()

　　客户端

　　# -*- coding: utf-8 -*-

　　# @Time : 2018/9/19 21:57

　　# @Author : cxa

　　# @File : tsTclntTW.py

　　# @Software: PyCharm

　　'''

　　创建Twisted Reactor TCP客户端

　　'''郑州妇科医院 http://www.120zzkd.com/

　　from twisted.internet import protocol, reactor

　　import msgpack

　　HOST = 'localhost'

　　PORT = 21567

　　class TSClntProtocol(protocol.Protocol):

　　def sendData(self):

　　data = input('>')

　　if data:

　　print(f'...发送数据 {data}')

　　self.transport.write(msgpack.packb(data))

　　else:

　　self.transport.loseConnection()

　　def connectionMade(self):

　　self.sendData()

　　def dataReceived(self, data):

　　print(msgpack.unpackb(data, encoding="utf8"))

　　self.sendData()

　　class TSClntFactory(protocol.ClientFactory):

　　protocol = TSClntProtocol

　　clientConnctionLost = clientConnctionFailed = lambda self, connector, reason: reactor.stop()

　　if __name__ == '__main__':

　　reactor.connectTCP(HOST, PORT, TSClntFactory())

　　reactor.run()