python udp 线程接受 demo

news/2024/5/18 13:17:23 标签: python, udp, 开发语言

udp使用socketserver 接受简单方便
使用是python 的threading 快速构建udp 接受线程
使用 pyqt5的QThread,用于发现信号到ui线程,跟新ui
使用queue接受udp数据,并通过queue在 udp接受线程和数据解析线程间数据传递。

from socketserver import*
import threading
import time
import sys
from queue import *
from PyQt5.QtWidgets import *
from PyQt5.QtCore import *
from PyQt5 import *
'''udp REC线程'''
class MyUDPServer(UDPServer):
    def __init__(self, server_address, RequestHandlerClass, queue):
        self.udp_queue = queue  # 增加的参数
        UDPServer.__init__(self, server_address, RequestHandlerClass, bind_and_activate=True)


class Handler(BaseRequestHandler):
    def handle(self):
        self.data = self.request[0].strip()
        self.server.udp_queue.put(self.data)
        # print(self.server.udp_queue.get())
        # print(self.data)

'''DATA 解析 线程'''
class mythread(QThread):
    signal = pyqtSignal(bytes)
    def __init__(self,queue,rec_data_Instance):
        super( mythread,self).__init__()
        self.running = True
        self.queue = queue
        self.rec_data_Instance=rec_data_Instance
        if self.rec_data_Instance:
            self.signal.connect(self.rec_data_Instance.rec_data)


    def __del__(self):
        self.running = False
        self.wait()

    def run(self):
        while self.running:
            # if self.udp_queue.
            if self.queue.empty()!= True :
                # print(self.queue.get())
                self.signal.emit(self.queue.get())

    def stop(self):
        self.running = False

'''ui 显示线程'''
class MY_Widget(QWidget):
    def __init__(self):
        super().__init__()
        self.initUI()
        self.button_num = 0  
    def initUI(self):
        self.ip = "10.7.28.51"
        self.port = 9999
        ### 窗体大小
        self.height = 100
        self.width = 200
        self.resize(self.width,self.height)
        ### 设置窗体 标题
        self.setWindowTitle("UDP ")
        v1layout = QVBoxLayout()
        self.open_button = QPushButton("打开")
        self.open_button.clicked.connect(self.open_button_func)
        self.edit= QTextEdit(self)
        self.edit.setText("test")
        v1layout.addWidget(self.open_button)
        v1layout.addWidget(self.edit)
        self.setLayout(v1layout)
        self.show()

    def open_udp_server(self,ip,port):  
            ADDR = ip, port
            #接受队列
            self.udp_queue=Queue(maxsize=5)
            #udp 服务
            self.server = MyUDPServer(ADDR, Handler, self.udp_queue)  
            #创建线程,线程用于UDP接收
            self.server_thread = threading.Thread(target=self.server.serve_forever)  
            #设置后台线程
            self.server_thread.setDaemon(True) 
            self.server_thread.start()   
            #创建数据解析
            self.up_mythread = mythread(self.udp_queue,self)
            self.up_mythread.start()
    def close_udp_server(self):  
            self.up_mythread.stop()
            self.server.shutdown()
            self.server.server_close()
    def print_hex(self,bytes):
        l = [hex(int(i)) for i in bytes]
        str = " ".join(l)
        return str

    def rec_data(self,data):
        print(self.print_hex(data))
        self.edit.setText(self.print_hex(data))

    def open_button_func(self):
        self.button_num = self.button_num+1
        if self.button_num %2 == 1:
            self.open_button.setText("关闭")
            self.open_udp_server(self.ip,self.port)

        else:
            self.open_button.setText("打开")
            self.close_udp_server()



if __name__ == "__main__":  
    app = QApplication(sys.argv)
    #创建ui
    ex = MY_Widget()
    app.exit(app.exec_())

http://www.niftyadmin.cn/n/5087937.html

相关文章

服务器与网站部署知识体系目录

1.网站部署必备知识与实践操作 服务器全套基础知识:包含基本概念,作用,服务器选择,服务器管理等域名相关基础知识普及域名备案流程(个人备案,腾讯云 / 阿里云)将网站域名访问从http升级到https…

c语言之strcat函数使用和实现

文章目录 前言一、strcat函数使用二、实现方法 前言 c语言之strcat 函数使用和实现 一、strcat函数使用 原型: char *strcat ( char * destination, const char * source );strcat追加拷贝,追加到目标空间后面,目标空间必须足够大,能容纳下…

淘天集团大模型应用十大挑战命题发布

以AI人工智能为代表的新技术正在成为全球商业发展的新动能。淘天集团从去年开始,就已经在AI重点领域,展开和高校的一系列深入合作。 近期,淘天集团集合基础模型和电商应用场景的具体问题,面向高校师生和全社会发布大模型应用十大挑…

vue3学习(五)--- 父子组件传值

文章目录 defineProps普通写法TS写法 defineEmits普通写法TS写法 defineExpose defineProps 和 defineEmits 都是只能在 <script setup> 中使用的编译器宏。他们不需要导入&#xff0c;且会随着 <script setup> 的处理过程一同被编译掉。 defineProps 接收父组件传…

ubuntu设置开机自启服务脚本

在Ubuntu上设置开机自启服务的步骤如下&#xff1a; 创建一个服务文件&#xff1a;使用文本编辑器创建一个以 .service 结尾的服务文件&#xff0c;例如 demo-service.service。 sudo vim /etc/systemd/system/demo-service.service在服务文件中添加以下内容&#xff1a; [Unit…

flutter问题汇总

一直卡在building a flutter app for general distribution&#xff1b; AS Message窗口显示 依赖下载失败&#xff1a; 1、修改仓库地址的配置&#xff1a;android/build.gradle repositories {maven { url https://download.flutter.io }maven { url "https://maven.a…

机器人硬件在环仿真:解决实体开发与测试挑战,提升效率与安全性

工业机器人具备出色的灵活性和运动能力&#xff0c;广泛应用于工业制造领域。它们可以完成装配、焊接、喷涂、搬运、加工、品质检测等任务&#xff0c;提高了生产效率&#xff0c;保证了产品质量。此外&#xff0c;在医疗领域也有辅助手术等特殊应用&#xff0c;展现了其在多个…

Windows服务器监控工具

随着Windows服务器成为大多数网络不可或缺的一部分&#xff0c;一些关键业务功能永远依赖于它们的正常运行时间。其可用性和性能受到打击可能会对这些功能产生不利影响&#xff0c;进而极大地影响收入。 由于这些情况&#xff0c;通过主动衡量其性能并使用有效的Windows服务器…