多任务udp聊天器完整版

import socket
import threading


def send_msg(udp_socket,dest_ip,dest_port):
    while True:
        send_data = input("请输入要发送的内容：")
        udp_socket.sendto(send_data.encode("utf-8"),(dest_ip,dest_port))


def recv_msg(udp_socket):
    while True:
        recv_data = udp_socket.recvfrom(1024)
        print("
%s接收到的内容是：%s " % (recv_data[1],recv_data[0].decode("gbk")))


def main():
    # 创建套接字
    udp_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
    # 绑定端口
    udp_socket.bind(("",7788))

    # 要发送的ip和port
    dest_ip =  input("请输入IP：")
    dest_port = int(input("请输入端口号："))

    # 创建接收和发送消息的线程 传参args= 要以元祖的形式传
    t_recv = threading.Thread(target=recv_msg,args=(udp_socket,))
    t_send = threading.Thread(target=send_msg,args=(udp_socket,dest_ip,dest_port))

    # 启动线程
    t_recv.start()
    t_send.start()