首页下载资源物联网【PyQT实现MQTT上位机】：协程、paho.mqtt库、json文件读写

ZIP【PyQT实现MQTT上位机】：协程、paho.mqtt库、json文件读写

joker52052259.63KB需要积分:1

资源文件列表:

PyQT实现MQTT上位机.zip 大约有25个文件
  1. PyQT实现MQTT上位机/
  2. PyQT实现MQTT上位机/.idea/
  3. PyQT实现MQTT上位机/.idea/.gitignore 50B
  4. PyQT实现MQTT上位机/.idea/HBB_MQTT.iml 291B
  5. PyQT实现MQTT上位机/.idea/inspectionProfiles/
  6. PyQT实现MQTT上位机/.idea/inspectionProfiles/profiles_settings.xml 174B
  7. PyQT实现MQTT上位机/.idea/misc.xml 284B
  8. PyQT实现MQTT上位机/.idea/modules.xml 275B
  9. PyQT实现MQTT上位机/.idea/workspace.xml 5.22KB
  10. PyQT实现MQTT上位机/data_mqtt_settings.py 99B
  11. PyQT实现MQTT上位机/json_file_processing.py 2.02KB
  12. PyQT实现MQTT上位机/main.py 305B
  13. PyQT实现MQTT上位机/mqtt.py 2.78KB
  14. PyQT实现MQTT上位机/src/
  15. PyQT实现MQTT上位机/src/icon.jpg 36.7KB
  16. PyQT实现MQTT上位机/src/mqtt.png 4.43KB
  17. PyQT实现MQTT上位机/src/settings.json 120B
  18. PyQT实现MQTT上位机/time_stamp.py 164B
  19. PyQT实现MQTT上位机/ui.py 13.12KB
  20. PyQT实现MQTT上位机/__pycache__/
  21. PyQT实现MQTT上位机/__pycache__/data_mqtt_settings.cpython-38.pyc 219B
  22. PyQT实现MQTT上位机/__pycache__/json_file_processing.cpython-38.pyc 1.91KB
  23. PyQT实现MQTT上位机/__pycache__/mqtt.cpython-38.pyc 3.08KB
  24. PyQT实现MQTT上位机/__pycache__/time_stamp.cpython-38.pyc 356B
  25. PyQT实现MQTT上位机/__pycache__/ui.cpython-38.pyc 8.94KB

资源介绍:

这份资源提供了一套完整的Python代码示例，用于构建一个基于PyQT图形界面的MQTT协议上位机应用程序。它集成了现代异步编程技术（协程）、流行的paho.mqtt客户端库以及JSON格式的数据处理能力，适用于需要实时监控和控制远程设备的应用场景。 图形用户界面：利用PyQT设计直观易用的操作界面，支持消息订阅/发布、主题管理等功能。 异步通信：通过协程实现非阻塞式的网络通讯和文件读写，确保GUI响应迅速且流畅。 MQTT协议支持：采用paho.mqtt库来连接至MQTT代理服务器，支持消息收发及QoS质量服务级别设定。 配置管理：使用JSON文件存储应用配置信息，实现离线存储，重新运行软件可以获取之前的配置信息。
from PyQt5.QtGui import QIcon, QFont import data_mqtt_settings import time_stamp import mqtt from PyQt5.QtCore import QSize, Qt, QThread, QObject, pyqtSignal from PyQt5.QtWidgets import QApplication, QMainWindow, QPushButton, QTextEdit, QGridLayout, QWidget, QLabel, QLineEdit, \ QHBoxLayout, QVBoxLayout, QMessageBox, QSizePolicy from json_file_processing import GET_JSON, SET_JSON width = 900 height = 700 mqtt_settings = data_mqtt_settings.mqtt_settings mqtt_receive_flag = False mqtt_loop_publish_flag = False class MainWindow(QMainWindow): def __init__(self): super().__init__() # 配置界面组件 self.btn_ensure = None self.edit_client_id = None self.edit_topic = None self.edit_port = None self.edit_broker = None # 日志界面组件 self.btn_start = None self.edit_log = None # MQTT self.client = None # 协程和实体的空初始化定义 self.get_json_worker = None self.json_thread = None self.init_ui() self.create_thread_json(1) def init_ui(self): self.setWindowTitle("HBB_MQTT") # 设置窗口名称 self.setGeometry(100, 100, width, height) # 默认大小和位置 # self.setFixedSize(QSize(width, height)) # 调整窗体大小 self.setWindowIcon(QIcon("src/mqtt.png")) # 设置图标 layout_main = QVBoxLayout() # 主布局纵向布局 self.setup_server_section(layout_main) self.setup_log_section(layout_main) self.setup_publish_section(layout_main) widget = QWidget() widget.setLayout(layout_main) self.setCentralWidget(widget) def setup_server_section(self, layout_main): """ 服务器配置部分 """ layout_server = QGridLayout() layout_server.setContentsMargins(50, 20, 50, 20) # 设置表格布局四周的margin间隔 ''' 设置服务器配置部分界面元素 ''' # 标签 lab_broker = QLabel("服务器地址") lab_port = QLabel("端口号") lab_topic = QLabel("订阅主题") lab_client_id = QLabel("客户端ID") # 单行文本输入框 self.edit_broker = QLineEdit(self) self.edit_port = QLineEdit(self) self.edit_topic = QLineEdit(self) self.edit_client_id = QLineEdit(self) # 确认按键 self.btn_ensure = QPushButton("连接") ''' 设置服务器配置部分界面元素 ''' layout_server.addWidget(lab_broker, 0, 0, 1, 1) layout_server.addWidget(self.edit_broker, 0, 1, 1, 1) layout_server.addWidget(lab_port, 0, 2, 1, 1) layout_server.addWidget(self.edit_port, 0, 3, 1, 1) layout_server.addWidget(lab_topic, 1, 0, 1, 1) layout_server.addWidget(self.edit_topic, 1, 1, 1, 1) layout_server.addWidget(lab_client_id, 1, 2, 1, 1) layout_server.addWidget(self.edit_client_id, 1, 3, 1, 1) layout_server.addWidget(self.btn_ensure, 2, 3, 1, 1) ''' 绑定按键响应函数 ''' self.btn_ensure.clicked.connect(self.ensure_settings) layout_main.addLayout(layout_server) def setup_log_section(self, layout_main): """ 日志部分 """ layout_log = QGridLayout() layout_log.setContentsMargins(50, 0, 20, 0) # 设置表格布局四周的margin间隔 ''' 设置日志部分界面元素 ''' self.edit_log = QTextEdit() # 富文本框 # self.edit_log.setFixedSize(width - 250, height - 250) self.edit_log.setReadOnly(True) # 只读（不允许用户输入） self.btn_start = QPushButton("开始接收") btn_clear = QPushButton("清空日志") # 按键 ''' 添加日志部分界面元素到对应布局 ''' layout_log.addWidget(self.edit_log, 0, 0, 5, 1) layout_log.addWidget(self.btn_start, 1, 1, 1, 1) layout_log.addWidget(btn_clear, 2, 1, 1, 1) ''' 绑定日志部分按键响应函数 ''' self.btn_start.clicked.connect(self.msg_receive) btn_clear.clicked.connect(self.clear_log) layout_main.addLayout(layout_log) def setup_publish_section(self, layout_main): """ MQTT数据发送部分 """ layout_publish_main = QVBoxLayout() layout_publish = QHBoxLayout() # 横向布局 self.edit_publish_msg = QLineEdit(self) # 数据发送部分包含一个按钮、一个发布消息输入框 btn_publish = QPushButton("发布") layout_publish.addWidget(self.edit_publish_msg) # 添加数据部分界面元素到对应布局 layout_publish.addWidget(btn_publish) btn_publish.clicked.connect(self.publish_msg) layout_loop = QHBoxLayout() # 横向布局 self.edit_loop_publish_msg = QLineEdit(self) self.btn_loop_publish = QPushButton("循环发布(3s)") layout_loop.addWidget(self.edit_loop_publish_msg) # 添加数据部分界面元素到对应布局 layout_loop.addWidget(self.btn_loop_publish) self.btn_loop_publish.clicked.connect(self.loop_publish_msg) layout_publish_main.addLayout(layout_publish) layout_publish_main.addLayout(layout_loop) layout_main.addLayout(layout_publish_main) def ensure_settings(self): """ 连接、解锁按键的响应函数 """ if self.edit_port.isEnabled(): # 如果存在输入框为空的情况，跳出弹窗提醒 fields = [self.edit_client_id.text(), self.edit_port.text(), self.edit_broker.text(), self.edit_topic.text()] if any(field == "" for field in fields): QMessageBox.critical(self, "错误", "请将配置信息填写完整") else: # 更新全局变量 global mqtt_settings settings_info = { 'broker': self.edit_broker.text(), 'port': self.edit_port.text(), 'topic': self.edit_topic.text(), 'client_id': self.edit_client_id.text() } mqtt_settings.update(settings_info) # 保存到json文件，保存完成之后调用MQTT函数连接 self.create_thread_json(2) # 锁定参数界面 self.lock_setting() else: self.unlock_setting() def lock_setting(self): """ 配置锁定函数，绑定到按键响应上（ensure_settings 调用） """ self.btn_ensure.setText("解锁") self.edit_port.setDisabled(True) self.edit_broker.setDisabled(True) self.edit_topic.setDisabled(True) self.edit_client_id.setDisabled(True) def unlock_setting(self): """ 配置解锁函数，绑定到按键响应上 （ensure_settings 调用） """ self.btn_ensure.setText("连接") self.edit_port.setDisabled(False) self.edit_broker.setDisabled(False) self.edit_topic.setDisabled(False) self.edit_client_id.setDisabled(False) def msg_receive(self): """ 数据接收开始按键 """ global mqtt_receive_flag if not mqtt_receive_flag: if self.edit_port.isEnabled(): QMessageBox.critical(self, "错误", "请先连接MQTT服务器") else: self.btn_start.setCheckable(True) self.btn_start.toggle() self.btn_start.setText("停止接收") mqtt.subscribe(self.client, mqtt_settings["topic"], callback=self.set_receive_data) self.client.loop_start() mqtt_receive_flag = True else: # 关闭数据发送 self.btn_start.setCheckable(False)
100+评论
captcha

    相关资源

    1. 微软字体用于PHP生成图片

      f897907070#后端ZIP4.7MB5月前
      资源摘要:微软字体用于PHP生成图片

    2. ModStartBlog v9.8.0 标签云支持，富文本上传优化

      qq_26450889#后端ZIP35.07MB5月前
      资源摘要:2024年09月23日ModStartBlog Laravel9发布v9.8.0版本，增加了以下17个特性：[新功能] ComplexFields 组件支持图片链接字段类型[新功能] 项目静态资源文件增加 .nvmrc 文件，方便开发者使用 nvm 管理 node 版本[新功能] 前端加密基础库[新功能] Grid 增加 hookPreQuery 支持数据查询前的钩子处理[新功能] 图片上传新增支持 svg 格式文件[新功能] 适配支持标签云 TagManager 模块[新功能] 图片可视化设计增加图片占位符显示[新功能] 模型查询条件支持自定义过滤功能 ModelUtil::queryRemoveCondition[系统优化] 爬虫机器人检测规则优化，支持更多机器人识别[系统优化] 图片上传增加处理提示，避免出现无状态情况[系统优化] 链接生成参数合并过滤异常的 amp; 字段[系统优化] 自定义字段序列化为空时异常处理[系统优化] 图片可视化设计库尺寸缩放问题优化[Bug修复] 图片选择直接弹出相机问题[Bug修复] 图片

    3. ROCKEY4加密狗win10以上驱动 亲测可用

      2401_87604730#移动开发ZIP2.37MB5月前
      资源摘要:飞天诚信加密狗驱动程序

    4. flowable-7.0.0.zip ( 0 积分下载 )

      weixin_42703501#后端ZIP96.87MB5月前
      资源摘要:flowable-7.0.0.zip Github 下载很慢，给不方便上网的同学一个选择

    5. 得帆云考试依赖得帆云考试依赖

      m0_58414041#后端ZIP226.09KB5月前
      资源摘要:得帆云考试依赖得帆云考试依赖

    6. 企业网搭建 二层直连组网 华为ensp

      m0_74741186#网络技术ZIP426.1KB5月前
      资源摘要:网络拓扑采用二层直连组网，AC作为DHCP服务器为AP分配IP地址，交换机作为DHCP服务器为STA分配IP地址，业务数据采用直接转发方式。配置项数据VLAN规划STA业务VLANVLAN100AP管理VLANVLAN101SW1配置DHCP服务器SW1作为DHCP服务器为STA分配IP地址基于VLANIF100接口配置dns-list 114.114.114.114 223.5.5.5STA的IP地址池10.23.101.2～10.23.101.254/24AC1配置DHCP服务器AC作为DHCP服务器为AP分配IP地址AP的IP地址池172.16.101.2～172.16.101.254/24AC的源接口IP地址VLANIF101：172.16.101.1/24AP组名称：ap-group1引用模板：VAP模板Internet、域管理模板default（defalut模板默认域模板，无需创建）SSID模板名称：InternetSSID名称：Internet安全模板名称：Internet安全策略：WPA2+PSK+AES

    7. consolas-nerd LXGW字体

      u014404513#信息化管理ZIP68.71MB5月前
      资源摘要:consolas-nerd LXGW字体

    8. 订图软件，很好用的，订图软件

      qq_35257512#硬件开发ZIP77.57MB5月前
      资源摘要:订图软件，很好用的，订图软件
    站长QQ:九六九五七三七