1. from socket import *
    2. from threading import Thread
    3. def send_msg(udp_socket: socket, dest_ip, dest_port):
    4. while True:
    5. send_data = input("请输入要发送的信息:")
    6. udp_socket.sendto(send_data.encode("utf-8"), (dest_ip, dest_port))
    7. def recv_msg(udp_socket: socket):
    8. while True:
    9. recv_data = udp_socket.recvfrom(1024)
    10. print(recv_data[0].decode("utf-8"))
    11. udp_socket = socket(AF_INET, SOCK_DGRAM)
    12. udp_socket.bind(("", 8890))
    13. dest_ip = input("请输入对方的ip:")
    14. dest_port = int(input("请输入对方的port:"))
    15. t_send = Thread(target=send_msg, args=(udp_socket, dest_ip, dest_port))
    16. t_recv = Thread(target=recv_msg, args=(udp_socket, ))
    17. t_send.start()
    18. t_recv.start()