多线程udp聊天器

2020-04-18  本文已影响0人  木叶苍蓝
#coding=utf-8
import socket
import threading

def recv_msg(udp_socket):
    ''' 接收数据并显示 '''
    # 接收数据
    while True:
        recv_data = udp_socket.recvfrom(1024)
        print(recv_data)

def send_msg(udp_socket, dest_ip, dest_port):
    ''' 发送数据 '''
    # 发送数据
    while True:
        send_data = input("输入要发送的数据")
        upd_socket.sendto(send_data.encode("utf-8"), (dest_ip, dest_port))

def main():
    ''' 完成udp聊天器的整体控制 '''
    # 1. 创建本地套接字
    udp_socket = socket.socket(socket.AF_INIT, socket.SOCK_DGRAM)
    # 2. 绑定本地信息
    udp_socket.bind(("", 7890))
    # 3. 获取对方的ip    
    dest_ip = input("请输入对方ip:")
    dest_port = input("请输入对方port:")
    # 4. 创建2个线程,去执行相应的功能
    t_recv = threading.Thread(target=recv_msg, args=(udp_socket, ))
    t_send = threaing.Thread(target=send_msg, args=(udp_socket, dest_ip, dest_port))

    t_recv.start()
    t_send.start()

if __name__ == "__main__":
    main()


上一篇 下一篇

猜你喜欢

热点阅读