1 TCP服务端

  1. from socket import *
  2. from threading import Thread
  4. class TcpServer():
  5.     def __init__(self, host, port):
  6.         self.server = socket()
  7.         self.server.bind((host, port))
  8.         self.server.listen()
  10.     def start(self):
  11.         while True:
  12.             print('正在等待新客户端...')
  13.             conn, addr = self.server.accept()
  14.             Thread(target=self.handle, args=(conn,), daemon=True).start()
  16.     def handle(self, conn: socket):
  17.         while True:
  18.             print('正在等待客户端发送...')
  19.             try:
  20.                 data = conn.recv(1024)
  21.             except:
  22.                 data = b''
  23.             data = data.decode()
  24.             if data == '':
  25.                 print('客户端{}断开连接'.format(conn.getpeername()))
  26.                 conn.close()
  27.                 return
  28.             print('收到客户端的消息:', data)
  29.             conn.send('hello'.encode())
  32. server = TcpServer('192.168.3.67', 9000)
  33. server.start()

2 TCP客户端

  1. from socket import *
  3. class TcpClient():
  4.     def __init__(self, host, port):
  5.         self.client = socket()
  6.         self.client.connect((host, port))
  8.     def send_recv(self, msg: str):
  9.         self.client.send(msg.encode())
  10.         response = self.client.recv(1024).decode()
  11.         return response
  13. cli = TcpClient('192.168.3.67', 9000)
  14. response = cli.send_recv('hi')
  15. print(response)

3 WireShark抓包

  • 服务端：192.168.3.67
  • 客户端：192.168.3.47

image.png