import socket
import time

def send():

    #创建一个udp socket
    udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    udp_socket.bind(('', 6000))
    dest_addr = ('192.168.1.10', 6000)

    hex_data = '0201aa'
    send_data = bytes.fromhex(hex_data)
    udp_socket.sendto(send_data, dest_addr)

    #关闭socket
    udp_socket.close()
    return None


def recv():
    udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    addr_tuple = ("", 6000)

    #绑定一个本地信息
    udp_socket.bind(addr_tuple)

    while(True):
        #1024表示本次接收的最大字节数
        recv_data = udp_socket.recvfrom(1024)
        recv_msg = recv_data[0]  #存储接收的数据
        send_addr = recv_data[1] #存储发送方的地址信息
        print("%s : %s" % (str(send_addr), recv_msg.decode()))

    udp_socket.close()
    return None

if __name__ == '__main__':
    send()
    recv()

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐