编程语言
首页 > 编程语言> > python通过twisted搭建socket服务介绍

python通过twisted搭建socket服务介绍

作者:互联网

  服务端

  # -*- 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()


标签:__,msgpack,protocol,socket,python,self,twisted,data,reactor
来源: https://blog.51cto.com/14503791/2479381