快捷導(dǎo)航

python如何通過(guò)twisted搭建socket服務(wù)

更新時(shí)間：2020年02月03日 08:55:30 作者：一起來(lái)學(xué)python

這篇文章主要介紹了python如何通過(guò)twisted搭建socket服務(wù),文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

服務(wù)端

# -*- coding: utf-8 -*-
# @Time : 2018/9/19 21:41
# @Author : cxa
# @File : tsTservTW.py
# @Software: PyCharm
'''
Twisted Reactor時(shí)間戳TCP服務(wù)器
'''
from twisted.internet import protocol, reactor
from time import ctime
import msgpack

PORT = 21567


class TSServProtocol(protocol.Protocol):
  def connectionMade(self):
    '''
    當(dāng)客戶端連接的時(shí)候會(huì)執(zhí)行該方法
    :return:
    '''
    clnt = self.clnt = self.transport.getPeer().host
    print(f"...來(lái)自的{clnt}鏈接:")

  def dataReceived(self, data):
    '''
    接收到客戶端的數(shù)據(jù)
    :param data:
    :return:
    '''
    print(f"來(lái)自客戶端:{msgpack.unpackb(data,encoding='utf')}")
    data = f"{ctime()}:來(lái)自服務(wù)器:你好"
    self.transport.write(msgpack.packb(data))


if __name__ == '__main__':
  # 創(chuàng)建一個(gè)協(xié)議工廠，之所以稱(chēng)之為工廠是因?yàn)?，每次得到一個(gè)
  # 接入連接時(shí)，都能"制造"協(xié)議的一個(gè)實(shí)例。
  factory = protocol.Factory()

  factory.protocol = TSServProtocol
  print("....等待鏈接..")
  # 使用reactor安裝一個(gè)TCP監(jiān)聽(tīng)器，檢查服務(wù)請(qǐng)求。
  # 當(dāng)它接收到一個(gè)請(qǐng)求時(shí),就會(huì)創(chuàng)建一個(gè)TSServProtocol實(shí)例來(lái)處理那個(gè)客戶端的事務(wù)。
  reactor.listenTCP(PORT, factory)
  reactor.run()

客戶端

# -*- coding: utf-8 -*-
# @Time : 2018/9/19 21:57
# @Author : cxa
# @File : tsTclntTW.py
# @Software: PyCharm
'''
創(chuàng)建Twisted Reactor TCP客戶端
'''
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'...發(fā)送數(shù)據(jù) {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()

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: