Python基于UDP聊天工具

雨点打透心脏的1/2处 2022-01-10 15:41 267阅读 0赞

import socket
    import threading
    
    # 发送数据
    def send_msg(udp_socket,dest_ip,dest_port):
        while True:
            # 接收用户输入的数据
            send_data = input("请输入您要发送的消息:")
            #输入exit退出聊天
            if send_data == "exit":
                break
            # 发送数据
            udp_socket.sendto(send_data.encode("gbk"), (dest_ip, dest_port))
    
    # 接收数据
    def recv_msg(udp_socket):
        while True:
            # 接收数据 1024:表示每次接收数据的最大字节数
            recv_data, ip_port = udp_socket.recvfrom(1024)
            # 解码数据
            recv_content = recv_data.decode("gbk")
            print(">>>%s:%s" % (str(ip_port), recv_content))
            # print(ip_port[0] + ":" + str(ip_port[1]) + " 回复的消息:" + recv_content) 
    
    if __name__ == '__main__':
        # 创建udpsocket
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
        # 绑定端口， 提示：客户端不强制要求绑定端口
        # 在同一个电脑上端口号不能重复
        udp_socket.bind(("", 8081))
    
        # 创建接收数据的线程
        recv_thread = threading.Thread(target=recv_msg, args=(udp_socket,))
        # 设置成为守护主线程，主线程退出后子线程直接销毁
        recv_thread.setDaemon(True)
        recv_thread.start()
    
    
        # 接收对方的ip地址和端口号
        dest_ip = input("请输入对方的ip地址:")
        dest_port = int(input("请输入对方的端口号:"))
    	# 发送数据
        send_msg(udp_socket,dest_ip,dest_port)
    
        # 关闭socket
        udp_socket.close()

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNTI1MA_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzIxNTI1MA_size_16_color_FFFFFF_t_70]: /images/20220110/2fdc25f977f84ae299b0258afe0b614d.png