1.案例

1.案例

代码实现

import  threading

import  time

import  socket

def rev_msg(udp_socket):

    while True:

        recv_data = udp_socket.recvfrom(1024)

        print("接来自%s收到的数据：%s" % (str(recv_data[1]),recv_data[0].decode("utf-8")))

def send_msg(udp_socket,dest_add):

    while True:

        send_data = input("输入要发送的数据：")

        udp_socket.sendto(send_data.encode("utf-8"), dest_add)

def main():

    """完成UDP聊天器的整体控制"""

    #1.创建套接字

    udp_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

    #2.绑定本地的信息

    self_port = int(input("请输入自己的端口号："))

    udp_socket.bind(("",self_port))

    #获取对方的地址

    dest_ip = input("输入对方的ip：")

    dest_port = int(input("请输入对方的端口号："))

    dest_add = (dest_ip,dest_port)

    # 接收数据

    #发送数据

    #创建2个线程，去执行相应的功能

    t_recv = threading.Thread(target=rev_msg,args=(udp_socket,))

    t_send = threading.Thread(target=send_msg,args=(udp_socket,dest_add,))

    t_recv.start()

    t_send.start()

if __name__ == '__main__':

    main()

说明

1.该聊天器只有一个socket套接字

2.两个线程同时打开，此时都在抢socket

3.当输入数据发送的时候，接收端没有数据进来所以发送端抢到，当另外一个回复消息的时候，发送端没有输入，故接收端抢到

4.接受发送不可能同时

巴特西

多任务-python实现-UDP多线程聊天（2.1.6）

1.案例

最新文章

热门文章