From 22b6f70458b345d24cef590c64a6e62c3f39ab44 Mon Sep 17 00:00:00 2001 From: jakeallen Date: Tue, 26 Mar 2024 15:54:55 +0800 Subject: [PATCH] udp_test --- .idea/UDP_test.iml | 6 ++-- .idea/misc.xml | 2 +- receive.py | 87 +++++++++++++++++++++++++++++++++++++--------- send.py | 65 ++++++++++++++++++++++++++-------- 4 files changed, 126 insertions(+), 34 deletions(-) diff --git a/.idea/UDP_test.iml b/.idea/UDP_test.iml index d0876a7..24ce7f3 100644 --- a/.idea/UDP_test.iml +++ b/.idea/UDP_test.iml @@ -1,8 +1,10 @@ - - + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml index 812ab5a..5cf2b09 100644 --- a/.idea/misc.xml +++ b/.idea/misc.xml @@ -3,5 +3,5 @@ - + \ No newline at end of file diff --git a/receive.py b/receive.py index b5c9bc6..51e79ae 100644 --- a/receive.py +++ b/receive.py @@ -1,23 +1,78 @@ # 相当于天线，默认目标地址为192.168.49.160，端口号为 8080 +# 下行报文指上位机发送给接收机 +import tkinter as tk +from threading import Thread import socket -# 1.创建udp对象 -sk = socket.socket(type=socket.SOCK_DGRAM) -# 2.在网络中注册该主机(绑定ip和端口号) -sk.bind( ("127.0.0.1",9000) ) +class ReceiveApp: + def __init__(self, window): + self.window = window + self.window.title("Receive端") -while True: - # 3.收发数据的逻辑 - """udp协议下,默认第一次只能接收数据(没有三次握手,不清楚对方的ip和端口号)""" - # 接受数据 - msg, addr = sk.recvfrom(1024) - print(msg.decode()) - print(addr) + # 接收区域 + self.recv_frame = tk.Frame(window) + self.recv_frame.pack(padx=10, pady=10) - send_data = input("请输入要发送的数据:") - # 发送数据 - sk.sendto(send_data.encode(), addr) + self.recv_label = tk.Label(self.recv_frame, text="接收数据") + self.recv_label.pack() + + self.recv_text = tk.Text(self.recv_frame, height=15, width=50) + self.recv_text.pack() + + # 发送区域 + self.send_frame = tk.Frame(window) + self.send_frame.pack(padx=10, pady=10) + + self.style_label = tk.Label(self.send_frame, text="指令类型:") + self.style_label.pack(side=tk.LEFT) + + self.style_entry = tk.Entry(self.send_frame) + self.style_entry.pack(side=tk.LEFT) + + self.content_label = tk.Label(self.send_frame, text="指令内容:") + self.content_label.pack(side=tk.LEFT) + + self.content_entry = tk.Entry(self.send_frame) + self.content_entry.pack(side=tk.LEFT) + + self.send_button = tk.Button(self.send_frame, text="发送", command=self.send_message) + self.send_button.pack(side=tk.LEFT) + + self.sk = socket.socket(type=socket.SOCK_DGRAM) + self.sk.bind(("127.0.0.1", 9000)) + + # 开始接收数据的线程 + self.thread = Thread(target=self.receive_data) + self.thread.daemon = True + self.thread.start() + + # 下行报文18字节固定长度 + """帧格式： + 0~3 帧头 BYTE[4] 4 固定为0x58443341 + 4 指令类型 UINT8 1 0x00:开始停止 0x01:工况查询 0x02:设备重置 0x03:授时指令 0x04:频率设置 + 0x05:本机地址设置 0x06:本机位置设置 0x07:开启关闭测试模式 + 5~14 指令内容 BYTE[10] 10 根据指令类型填充，当指令类型为0x01、0x02时可不填充 + 15~17 帧尾 BYTE[3] 3 固定为0x334441 + """ + def send_message(self): + # 1.创建udp对象 + style = self.style_entry.get() + content = self.content_entry.get() + head = "58443341" + tail = "334441" + msg = head + style + content + tail + # sendto( 二进制字节流，ip端口号 ) + self.sk.sendto(msg.encode(), ("127.0.0.1", 5010)) + + def receive_data(self): + while True: + msg, addr = self.sk.recvfrom(1024) + message_to_display = "Received: " + msg.decode() + " from " + str(addr) + self.recv_text.insert(tk.END, message_to_display + "\n") + +if __name__ == "__main__": + root = tk.Tk() + app = ReceiveApp(root) + root.mainloop() -# 4.关闭连接 -sk.close() diff --git a/send.py b/send.py index dc3fc12..9ba97f7 100644 --- a/send.py +++ b/send.py @@ -1,22 +1,57 @@ # 接收机，相当于本机（192.168.49.10，端口号为 5010） +#，上行报文指接收机发送给上位机 +import tkinter as tk +from threading import Thread import socket import time -while True: - # 1.创建udp对象 - sk = socket.socket(type=socket.SOCK_DGRAM) +class SendApp: + def __init__(self, window): + self.window = window + self.window.title("Send端") - # 2.收发数据的逻辑 - # 发送数据 - msg = input("请输入要发送的数据:") + # 发送区域 + self.send_frame = tk.Frame(window) + self.send_frame.pack(padx=10, pady=10) - # sendto( 二进制字节流 , ip端口号 ) - sk.sendto(msg.encode(), ("127.0.0.1", 9000)) + self.send_label = tk.Label(self.send_frame, text="发送数据") + self.send_label.pack(side=tk.LEFT) - # 接受数据 - msg, addr = sk.recvfrom(1024) - print(msg.decode()) - print(addr) - time.sleep(1) - # 3.关闭连接 - sk.close() + self.send_entry = tk.Entry(self.send_frame) + self.send_entry.pack(side=tk.LEFT) + + self.send_button = tk.Button(self.send_frame, text="发送", command=self.send_message) + self.send_button.pack(side=tk.LEFT) + + # 接收区域 + self.recv_frame = tk.Frame(window) + self.recv_frame.pack(padx=10, pady=10) + + self.recv_text = tk.Text(self.recv_frame, height=15, width=50) + self.recv_text.pack() + #创建udp对象 + self.sk = socket.socket(type=socket.SOCK_DGRAM) + self.sk.bind(("127.0.0.1", 5010)) + + # 开始接收数据的线程 + self.thread = Thread(target=self.receive_data) + self.thread.daemon = True + self.thread.start() + + def send_message(self): + msg = self.send_entry.get() + #发送数据 + self.sk.sendto(msg.encode(), ("127.0.0.1", 9000)) + time.sleep(1) + + def receive_data(self): + while True: + #接收数据 + msg, addr = self.sk.recvfrom(1024) + message_to_display = "Received: " + msg.decode() + " from " + str(addr) + self.recv_text.insert(tk.END, message_to_display + "\n") + +if __name__ == "__main__": + root = tk.Tk() + app = SendApp(root) + root.mainloop() \ No newline at end of file