1 客户端

  1. from socket import *
  2. from threading import Thread
  4. class UdpClient():
  5.     def __init__(self, src_port, dst_host, dst_port):
  6.         self.cli = socket(AF_INET, SOCK_DGRAM)
  7.         self.cli.bind(('', src_port))
  8.         self.dst_host = dst_host
  9.         self.dst_port = dst_port
  11.     def send(self, msg: str):
  12.         self.cli.sendto(msg.encode(), (self.dst_host, self.dst_port))
  13.         print('消息发送成功')
  15.     def recv(self):
  16.         try:
  17.             data, addr = self.cli.recvfrom(1024)
  18.         except:
  19.             return
  20.         response = data.decode()
  21.         print('接收到来自{}的消息:{}'.format(addr, response))
  24. def t_read(cli: UdpClient):
  25.     while True:
  26.         print('正在等待消息...')
  27.         cli.recv()
  30. def t_write(cli: UdpClient):
  31.     while True:
  32.         msg = input('输入要发的消息:')
  33.         cli.send(msg)
  36. cli = UdpClient(8347, '192.168.3.67', 8367)
  37. t1 = Thread(target=t_read, args=(cli,))
  38. t2 = Thread(target=t_write, args=(cli,))
  39. t1.start()
  40. t2.start()
  41. t1.join()
  42. t2.join()

2 WireShark抓包

image.png