基于python的UDP传输整型与浮点型数据

  • Post author:
  • Post category:python




1.构建一个数据结构

lat = 1
lon = 13.435456

# 通过struct.pack方法压缩数据
send_data = struct.pack('!if', lat, lon)

#同时可以通过struct.unpack方法解压缩
data_float = struct.unpack('!if',recv_data[0])



2.UDP服务端

import socket
import struct

def GetHostIP():
    try:
        Socke = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        Socke.connect(('8.8.8.8', 80))
        IP = Socke.getsockname()[0]
    finally:
        Socke.close()
 
    print(IP)
    return IP

def main():
    IP_daar = GetHostIP()
    while True:
        # 1.创建一个udp套接字
        udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

        # 2.绑定本地的相关信息,如果一个网络程序不绑定,则系统会随机分配
        # 30000  表示本地的端口 ip一般不用写
        local_addr = (IP_daar, 6666)
        udp_socket.bind(local_addr)

        # 3. 等待接收对方发送的数据
        recv_data = udp_socket.recvfrom(1024)  
        # 1024表示本次接收的最大字节数

        # 6. 显示对方发送的数据
        # 接收到的数据recv_data是一个元组
        # 第1个元素是对方发送的数据
        # 第2个元素是对方的ip和端口
        data_float = struct.unpack('!if',recv_data[0])
        print(data_float[0])
        print(data_float)

        # 3.关闭套接字
        udp_socket.close()


if __name__ == "__main__":
    main()



3.UDP客户端

import socket
from threading import Thread
from time import sleep
import struct

def GetHostIP():
    try:
        Socke = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        Socke.connect(('8.8.8.8', 80))
        IP = Socke.getsockname()[0]
    finally:
        Socke.close()
 
    print(IP)
    return IP

def send_data():
	IP_daar = GetHostIP()
	while True:
	    # 1. 创建udp套接字
	    udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

	    # 2. 准备接收方的地址        
	    dest_addr = (IP_daar, 6666)  # 注意 是元组,ip是字符串,端口是数字

	    # 3. 从键盘获取数据
	    lat = 1
	    lon = 13.435456
	    # alt = 3.5657732

	    send_data = struct.pack('!if', lat, lon)
	    # send_data = b'\x08\x00\x00\x00\x81@\x02\x00\x1d\x00\x00\x00\x10'

	    # send_data = input("请输入要发送的数据:")

	    # 4. 发送数据到指定的电脑上的指定程序中
	    udp_socket.sendto(send_data, dest_addr)
	    print("发送给客户端 %s 的数据: %s\n" % (dest_addr, send_data))
	    sleep(1)

	    # 5. 关闭套接字
	    udp_socket.close()

if __name__ == "__main__":
    send_data()






(1)先打开一个终端运行服务端,然后再运行客户端



(2)上面定义了一个GetHostIP函数,如果是两台机器通信的话,注意修改IP



参考链接


参考链接1



参考链接2



版权声明:本文为weixin_41837701原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。