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
参考链接
版权声明:本文为weixin_41837701原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。