import socket import threading class Udp_chat(object): def __init__(self): self.udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) self.udp_socket.bind(('', 8888)) def send_msg(self): dest_ip = input('请输入对方的ip:') dest_port = int(input('请输入对方的端口:')) while True: send_data = input('请输入要发送的内容:') self.udp_socket.sendto(send_data.encode('gbk'), (dest_ip, dest_port)) def recv_msg(self): recv_data = self.udp_socket.recvfrom(1024) recv_msg = recv_data[0].decode('gbk') print(recv_msg) if __name__ == '__main__': u = Udp_chat() t_send = threading.Thread(target=u.send_msg) t_recv = threading.Thread(target=u.recv_msg) t_send.start() t_recv.start()