全栈嵌入式C++、STM32、Modbus、FreeRTOS和MQTT协议:工业物联网(IIoT)可视化系统设计思路(附部分代码解析)
项目概述
随着工业4.0时代的到来,工业物联网(IIoT)在提高生产效率、降低运营成本和实现智能制造方面得到了广泛应用。本项目旨在开发一个全面的工业物联网监控系统,能够实时监测设备的温度、压力、振动和电流等参数,并通过云平台进行数据分析与可视化展示。该系统的设计包括硬件部分、嵌入式软件、云服务器架构和用户界面,力求实现高效、可靠的监控解决方案。
系统设计
硬件设计
本项目的硬件部分主要采用以下组件:
- STM32H7微控制器:作为系统的核心,提供强大的性能和丰富的外设接口。
- 工业级温度传感器:监测设备的工作温度。
- 压力传感器:实时监测流体或气体的压力。
- 振动传感器:监测设备的振动状态,以评估设备的健康状况。
- 电流传感器:监测设备的电流消耗,及时发现异常情况。
- Modbus通信模块:实现与传感器的Modbus RTU/TCP通信。
- Ethernet模块:确保设备与云服务器的网络连接。
- UPS电源管理模块:在电源故障情况下,保证系统的持续运行。
以下是硬件设计的结构示意图:
软件设计
软件部分包括嵌入式软件和云端服务,具体如下:
嵌入式软件
- FreeRTOS:实现多任务管理,确保实时数据采集。
- 传感器驱动程序:与各类传感器进行通信,读取数据。
- Modbus协议栈:支持Modbus RTU和TCP协议,确保数据传输的完整性。
- MQTT协议:用于轻量级消息传递,支持设备与云端的通信。
- 数据采集与处理:负责采集传感器数据并进行初步处理。
- 故障检测算法:实时监测设备状态,及时预警。
云端服务
云端服务主要由以下组件组成:
- AWS IoT / Azure IoT Hub / Google Cloud IoT:提供设备接入及数据存储。
- EMQX / Mosquitto MQTT Broker:实现设备与云端的消息中转。
- Nginx Web服务器:处理HTTP请求,实现Web服务。
- Spring Boot / Node.js API:提供RESTful API,支持前端数据请求。
- PostgreSQL数据库:存储历史数据。
- InfluxDB时序数据库:用于存储时间序列数据,支持高效查询。
以下是系统架构的示意图:
大数据处理
为了处理大量实时数据,本项目采用以下技术:
- Apache Kafka:实现高吞吐量的实时数据流处理。
- Apache Spark:用于实时数据分析,支持复杂数据处理。
- Hadoop:提供大数据存储解决方案。
- Grafana / Kibana:用于数据可视化,提供实时监控面板。
用户界面
用户界面包括移动应用和Web前端,主要使用以下技术栈:
- Flutter / React Native:开发跨平台的移动应用。
- React.js / Vue.js:构建用户友好的Web前端,展示实时监测数据和趋势。
以下是用户界面的结构示意图:
用户界面功能
- 实时监控:用户可以实时查看各传感器的数据(如温度、压力、振动和电流)并进行状态监测。
- 历史数据查询:用户可以选择时间范围,查询历史数据,并生成相应的图表。
- 设备状态管理:用户可以查看设备的运行状态,设置阈值,并接收故障报警。
- 数据可视化:用户界面提供图表和仪表盘供用户查看数据趋势,便于快速分析设备运行情况。
代码实现
在本项目中,嵌入式软件和云端服务的代码实现是系统的核心,以下是一些关键模块的代码示例及详细解释。
1. 传感器数据采集任务
#include "FreeRTOS.h"
#include "task.h"
#include "sensor.h"/* 传感器读取任务 */
void SensorReadTask(void *pvParameters) {while (1) {// 读取温度传感器数据float temperature = ReadTemperatureSensor();// 读取压力传感器数据float pressure = ReadPressureSensor();// 发送数据到MQTT BrokerPublishData(temperature, pressure);// 每1秒读取一次数据vTaskDelay(pdMS_TO_TICKS(1000));}
}
代码解释:
SensorReadTask
是一个FreeRTOS任务,用于定期读取传感器数据。ReadTemperatureSensor()
和ReadPressureSensor()
函数分别读取温度和压力传感器的数据。PublishData()
函数负责将读取的数据通过MQTT发布到云端。vTaskDelay(pdMS_TO_TICKS(1000))
使任务每秒执行一次。
2. MQTT通信模块
#include "mqtt.h"/* MQTT连接回调函数 */
void OnMQTTConnect(mqtt_client_t *client, void *arg) {// 连接成功后,订阅传感器数据主题mqtt_subscribe(client, "sensor/data", 0);
}/* 发布传感器数据 */
void PublishData(float temperature, float pressure) {char payload[100];snprintf(payload, sizeof(payload), "{\"temperature\": %.2f, \"pressure\": %.2f}", temperature, pressure);mqtt_publish(mqtt_client, "sensor/data", payload, strlen(payload), 0, 0);
}
代码解释:
OnMQTTConnect()
函数在成功连接到MQTT Broker后订阅数据主题。PublishData()
将温度和压力数据格式化为JSON字符串,并发布到指定主题。- 使用
snprintf()
构建有效载荷,确保安全性。
3. 数据存储与查询接口
@RestController
@RequestMapping("/api/data")
public class DataController {@Autowiredprivate DataService dataService;@GetMapping("/history")public List<SensorData> getSensorData(@RequestParam String startDate, @RequestParam String endDate) {// 查询指定时间范围内的传感器数据return dataService.fetchDataBetweenDates(startDate, endDate);}
}
代码解释:
- 使用Spring Boot实现RESTful API。
DataController
类提供了一个接口,用于获取历史传感器数据。getSensorData()
方法接收开始和结束日期作为参数,并从数据库中查询对应的数据。
4. 数据可视化组件
import React from 'react';
import { Line } from 'react-chartjs-2';const SensorDataChart = ({ data }) => {const chartData = {labels: data.map(d => d.timestamp), // X轴为时间戳datasets: [{label: 'Temperature (°C)', // 温度数据集data: data.map(d => d.temperature), // 温度值borderColor: 'rgba(75, 192, 192, 1)', // 温度线的颜色fill: false, // 不填充区域},{label: 'Pressure (Pa)', // 压力数据集data: data.map(d => d.pressure), // 压力值borderColor: 'rgba(255, 99, 132, 1)', // 压力线的颜色fill: false, // 不填充区域},],};return (<div><h2>Sensor Data Over Time</h2><Line data={chartData} /> {/* 使用Chart.js绘制折线图 */}</div>);
};export default SensorDataChart;
代码解释:
- 使用 React 和 Chart.js 库构建数据可视化组件。
SensorDataChart
组件接收传感器数据作为属性,生成折线图。chartData
对象定义了X轴标签(时间戳)和两个数据集(温度和压力),分别配置不同的线条颜色。- 最后,组件渲染一个折线图,展示温度和压力随时间变化的趋势。
项目总结
本工业物联网(IIoT)监控系统成功实现了设备的实时监测和数据分析功能,具备以下优点:
-
实时数据采集:通过STM32H7微控制器和各类传感器,系统能够实时采集温度、压力、振动和电流等重要数据,并通过MQTT协议将数据发送至云端。
-
高效的数据处理:采用Apache Kafka和Apache Spark等大数据处理框架,确保海量数据的实时流处理和分析,支持复杂的数据计算和分析需求。
-
数据可视化:通过React.js和Chart.js等技术,系统提供了友好的用户界面,用户可以方便地查看实时数据和历史趋势,帮助做出快速决策。
-
安全性设计:系统通过TLS加密通信和OAuth 2.0用户认证等安全措施,确保数据传输和存储的安全性,防止未授权访问。
-
可扩展性与维护性:采用Docker容器化部署和Kubernetes管理,系统具有良好的可扩展性和维护性,能够适应不断增长的用户需求。
相关文章:
全栈嵌入式C++、STM32、Modbus、FreeRTOS和MQTT协议:工业物联网(IIoT)可视化系统设计思路(附部分代码解析)
项目概述 随着工业4.0时代的到来,工业物联网(IIoT)在提高生产效率、降低运营成本和实现智能制造方面得到了广泛应用。本项目旨在开发一个全面的工业物联网监控系统,能够实时监测设备的温度、压力、振动和电流等参数,并…...
Greenplum数据库中的数据倾斜问题及处理方法
一、数据倾斜问题的原因 数据分布不均匀:当数据在表的分区或分片中不均匀分布时,会导致某些分区或分片的数据量较大,从而引发数据倾斜问题。连接键存在热点数据:如果连接操作中使用的键值存在热点数据,即某些键值出现…...
缓存设计理论
缓存设计理论是一个涉及多个方面的复杂主题,主要目标是优化数据访问速度,减少数据访问延迟,提高系统性能,并同时保持数据的一致性和系统的稳定性。以下是从几个关键方面对缓存设计理论的概述: 一、缓存的作用与目的 …...
IDEA-安装插件 驼峰下划线转换
第一步:安装 file-settings-plugins-在marketplace搜索“CamelCase”-点击安装 第二步:设置 file-settings-editor-camel_case 第三步:使用 选中想转换的遍历 使用快捷键 Alt Shift U...
乾坤: 微前端项目切换时样式闪动(从无样式变为正常样式需要等 css chunk 文件加载完成, 加载延时受网速影响)
背景: 点击基座项目页面左侧目录, 进入微前端子项目页面, 会有短暂的样式未加载效果一闪而过, 造成页面闪烁或更严重的其他样式错位问题 定位: 同事查了 qiankun git 项目的 issue: https://github.com/umijs/qiankun/issues/219 , 找到解决方案 解决: 项目 webpack 打包配…...
《电子元器件之固态电容》
固态电容全称是固态铝质电解电容,它与普通液态铝质电解电容的最大差别在于采用了不同的介电材料。液态铝电容介电材料为电解液,而固态电容的介电材料是固态的导电性高分子材料。 固态电容和液态电容,从外观上区分,就是固态电容顶…...
PLC 远程下载网关
一、 产品概述 SSF-BOX-100 是三石峰科技有限公司推出的工业级 PLC 远程下载网关,主 要用于 PLC 远程调试、程序上下载,为用户提供一种简单可靠的远程维护方案。 1.1 SGBOX 软件 SGBOX 软件是 SSF-BOX-100 网关的配套软件,可以查看设备状态…...
【Django】 读取excel文件并在前端以网页形式显示-安装使用Pandas
文章目录 安装pandas写views写urls安装openpyxl重新调试 安装pandas Pandas是一个基于NumPy的Python数据分析库,可以从各种文件格式如CSV、JSON、SQL、Excel等导入数据,并支持多种数据运算操作,如归并、再成形、选择等。 更换pip源 pip co…...
自动控制:带死区的PID控制算法
带死区的PID控制算法 在计算机控制系统中,为了避免控制动作过于频繁,消除因频繁动作所引起的振荡,可采用带死区的PID控制。带死区的PID控制通过引入一个死区,使得在误差较小的范围内不进行控制动作,从而减少控制系统的…...
橙单后端项目下载编译遇到的问题与解决
今天下载orange-admin项目,不过下载下来运行出现一些问题。 1、涉及到XMLStreamException的几个类都出现下面的错误 The package javax.xml.stream is accessible from more than one module: <unnamed>, java.xml ctrl-shift-t 可以找到这个引入是哪些包里…...
EasyExcel 初使用—— Java 实现多种写入 Excel 功能
前言 大家好,我是雪荷。之前有一篇博客(EasyExcel 初使用—— Java 实现读取 Excel 功能_java easyexcel.read-CSDN博客)介绍了 Java 如何读取 Excel 表格,那么此篇博客就和大家介绍下 Java 如何利用 EasyExcel 写入 Excel。 Ea…...
MySQL 和 SQL Server 中的连表更新 UPDATE JOIN 写法比较
MySQL 和 SQL Server 中的连表更新 UPDATE JOIN 写法比较 一、前言1. MySQL 写法1.1 解释 2. SQL Server 写法2.1 解释 二、总结 一、前言 在关系型数据库管理系统(RDBMS)中,使用 UPDATE 语句进行表格更新是非常常见的操作。特别是当需要根据…...
手把手教你FL Studio 24.1.1.4234中文破解安装激活图文激活教程
在数字化音乐制作的浪潮中,FL Studio 24.1.1.4234中文破解版的发布无疑又掀起了一股新的热潮。这款由Image-Line公司开发的数字音频工作站(DAW)软件,以其强大的功能和易用的界面,赢得了全球无数音乐制作人的青睐。本文…...
使用Spring Boot与Spire.Doc实现Word文档的多样化操作
博客主页: 南来_北往 系列专栏:Spring Boot实战 前言 使用Spring Boot与Spire.Doc实现Word文档的多样化操作具有以下优势: 强大的功能组合:Spring Boot提供了快速构建独立和生产级的Spring应用程序的能力,而Spire.Doc则…...
从食堂采购系统源码到成品:打造供应链采购管理平台实战详解
本篇文章,笔者将详细介绍如何从食堂采购系统的源码开始,逐步打造一个完备的供应链采购管理平台,帮助企业实现采购流程的智能化和高效化。 一、需求分析与规划 一般来说,食堂采购系统需要具备以下基本功能: 1.供应商…...
在window将Redis注册为服务
将redis注册为系统服务,开启自启动 安装服务 默认注册完之后会自动启动,在window中的服务看一下,如果启动类型为自动,状态是自动运行则启动完成。如果是手动,需要右键属性调整为自动,在点击启动,…...
PHP商城案例
http://www.e9933.com/...
Linux:bash在被调用时会读取哪些启动文件?
(本文基于5.1-6ubuntu1.1版本的bash) bash在被调用时会读取哪些启动文件?要回答这个问题,首先要弄清楚两个概念:login shell和interactive shell。 login shell login shell是指这样的shell: 第一个命令行参数(进程…...
帆软FineReport之替换函数
在日常帆软FineReport中经常会使用字符串替换函数,记录下来,方便备查。 一、字符串替换 第一种、指定文本替换 使用SUBSTITUTE函数,语法如下所示 SUBSTITUTE(text,old_text,new_text,instance_num) 字段…...
Redis的应用场景及类型
目录 一、Redis的应用场景 1、限流 2、分布式锁 3、点赞 4、消息队列 二、Redis类型的命令及用法 1、String类型 2、Hash类型 3、List类型 4、Set类型 5、Zset类型 6、Redis工具类 Redis使用缓存的目的就是提升读写性能 实际业务场景下,我们就可以把 Mys…...
【图像处理】不智能的目标识别
目录 目标识别的划分 识别入门 概念学习 滤波 模版 阈值化 形态学操作 开运算 闭运算 编程语言 示例 大家有没有想过在没有人工智能或者说没有机器学习的的时候,计算机是怎么做目标识别的? 计算机视觉时至今日也是急需人才的领域&…...
《500 Lines or Less》(5)异步爬虫
https://aosabook.org/en/500L/a-web-crawler-with-asyncio-coroutines.html ——A. Jesse Jiryu Davis and Guido van Rossum 介绍 网络程序消耗的不是计算资源,而是打开许多缓慢的连接,解决此问题的现代方法是异步IO。 本章介绍一个简单的网络爬虫&a…...
Transformer!自注意力机制的高层级理解Attention Is All You Need!
背景 最近在不断深入学习LLM的相关内容,那么transformer就是一个绕不开的话题。然而对于一个NLP门外汉来说,论文看得是真头疼,总览全网,我们似乎缺少一个至高而下的高层级理解。所以本文就来弥补此方面的缺失~ 本文并不讲解有关…...
关于使用Postman在请求https网址没有响应,但是用浏览器有响应的问题解决
一、问题描述 使用postman调用正式环境的公共接口,无需鉴权,但是产生了返回状态码200,但是data中却无数据,如下 {"code": "200","message": "操作成功","data": {"qr_c…...
【React 】开发环境搭建详细指南
文章目录 一、准备工作1. 安装 Node.js 和 npm2. 选择代码编辑器 二、创建 React 项目1. 使用 Create React App2. 手动配置 React 项目 三、集成开发工具1. ESLint 和 Prettier2. 使用 Git 进行版本控制 在现代前端开发中,React 是一个非常流行的框架,用…...
结构体笔记
结构体 C语言中的数据类型: 基本数据类型:char/int/short/double/float/long 构造数据类型:数组,指针,结构体,共用体,枚举 概念: 结构体是用户自定义的一种数据类型,…...
Elasticsearch:Golang ECS 日志记录 - zerolog
ECS 记录器是你最喜欢的日志库的格式化程序/编码器插件。它们可让你轻松地将日志格式化为与 ECS 兼容的 JSON。在本教程中,我将详述如何 编码器以 JSON 格式记录日志,并以 ECS 错误格式处理错误字段的记录。 默认情况下,会添加以下字段&…...
Ip2region - 基于xdb离线库的Java IP查询工具提供给脚本调用
文章目录 Pre效果实现git clone编译测试程序将ip2region.xdb放到指定目录使用改进最终效果 Pre OpenSource - Ip2region 离线IP地址定位库和IP定位数据管理框架 Ip2region - xdb java 查询客户端实现 效果 最终效果 实现 git clone git clone https://github.com/lionsou…...
研发管理革命:探索顶尖的工时系统选择
国内外主流的10款研发工时管理系统对比:PingCode、Worktile、无鱼项目工时系统、Toggl Track、泽众ALM、Asana、Jira、GitHub、Trello、TrackingTime。 在研发团队中,工时管理常常成为效率瓶颈,尤其是在资源分配和项目进度跟踪方面。选择合适…...
微服务-MybatisPlus下
微服务-MybatisPlus下 文章目录 微服务-MybatisPlus下1 MybatisPlus扩展功能1.1 代码生成1.2 静态工具1.3 逻辑删除1.4 枚举处理器1.5 JSON处理器**1.5.1.定义实体****1.5.2.使用类型处理器** **1.6 配置加密(选学)**1.6.1.生成秘钥**1.6.2.修改配置****…...
【python_将一个列表中的几个字典改成二维列表,并删除不需要的列】
def 将一个列表中的几个字典改成二维列表(original_list,headersToRemove_list):# 初始化一个列表用于存储遇到的键,保持顺序ordered_keys []# 遍历data中的每个字典,添加其键到ordered_keys,如果该键还未被添加for d in original_list:for …...
IDEA的pom.xml显示ignored 的解决办法
问题: idea中创建Maven module时,pom.xml出现ignored。 原因: 相同名称的module在之前被创建删除过,IDEA会误以为新的同名文件是之前删除掉的,将这个新的module的pom.xml文件忽略掉显示ignored. 解决: 在…...
2. 卷积神经网络无法绕开的神——LeNet
卷积神经网络无法绕开的大神——LeNet 1. 基本架构2. LeNet 53. LeNet 5 代码 1. 基本架构 特征抽取模块可学习的分类器模块 2. LeNet 5 LeNet 5: 5 表示的是5个核心层,2个卷积层,3个全连接层.核心权重层:卷积层、全连接层、循环层ÿ…...
【区块链】JavaScript连接web3钱包,实现测试网络中的 Sepolia ETH余额查询、转账功能
审核看清楚了 ! 这是以太坊测试网络!用于学习的测试网络!!! 有关web3 和区块链的内容为什么要给我审核不通过? 别人凭什么可以发! 目标成果: 实现功能分析: 显示账户信…...
关于珞石机器人二次开发SDK的posture函数的算法RX RY RZ纠正 C#
在珞石SDK二次开发的函数钟,获取当前机器人位姿的函数posture函数在输出时会发现数据不正确,与示教器数据不一致。 其中第一个数据正确 第二三各数据为相反 第四五六各数据为弧度制 转换方法为(弧度/PI)*180度 然后发现第四个数据还要加上180度 第五…...
【Three.js基础学习】17.imported-models
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 前言 课程回顾: 如何在three.js 中引入不同的模型? 1. 格式 (不同的格式) https://en.wikipedia.org/wiki/List_of_file_form…...
Spring Bean - xml 配置文件创建对象
类型: 1、值类型 2、null (标签) 3、特殊符号 (< -> < ) 4、CDATA <?xml version"1.0" encoding"UTF-8"?> <beans xmlns"http://www.springframework.org/schema/bea…...
uniapp map组件自定义markers标记点
需求是根据后端返回数据在地图上显示标记点,并且根据数据状态控制标记点颜色,标记点背景通过两张图片实现控制 <mapstyle"width: 100vw; height: 100vh;":markers"markers":longitude"locaInfo.longitude":latitude&…...
Windows:批处理脚本学习
目录 一、第一个批处理文件 1. &&和 | | 2. | 和 & 二、变量 1.传参变量%name 2.初始化变量set命令 3.变量的使用 4.局部变量与全局变量 5.使用环境变量 6.扩充变量语法 三、注释REM和 :: 四:函数 1.定义函数 2.…...
Dav_笔记10:Using SQL Plan Management之4
SQL管理库 SQL管理库(SMB)是驻留在SYSAUX表空间中的数据字典的一部分。它存储语句日志,计划历史记录,SQL计划基准和SQL配置文件。为了允许每周清除未使用的计划和日志,SMB使用自动空间管理。 您还可以手动将计划添加到SMB以获取一组SQL语句。从Oracle Database 11g之前的…...
通过json传递请求参数,如何处理动态参数和接口依赖
嗨,大家好,我是兰若姐姐,今天给大家讲一下如何通过json传递请求参数,如何处理动态参数和接口依赖 1. 使用配置文件和模板 在 test_data.json 中,你可以使用一些占位符或模板变量,然后在运行测试之前&…...
[240727] Qt Creator 14 发布 | AMD 推迟 Ryzen 9000芯片发布
目录 Qt Creator 14 发布Qt Creator 14 版本发布,带来一系列新功能和改进终端用户可通过命令行方式查看此新闻终端用户可通过命令行方式安装软件: AMD 推迟 Ryzen 9000芯片发布 Qt Creator 14 发布 Qt Creator 14 版本发布,带来一系列新功能…...
PLSQL Developer工具查询数据,报错(动态性能表不可访问)
解决的问题: 解决方案: 在配置-首选项-选项,取消勾选“自动统计”,保存之后即可查询数据...
基于 HTML+ECharts 实现智慧交通数据可视化大屏(含源码)
构建智慧交通数据可视化大屏:基于 HTML 和 ECharts 的实现 随着城市化进程的加快,智慧交通系统已成为提升城市管理效率和居民生活质量的关键。通过数据可视化,交通管理部门可以实时监控交通流量、事故发生率、道路状况等关键指标,…...
探索 IT 领域的新宠儿:量子计算
目录 引言:从经典到量子的飞跃 量子计算的基本概念 量子计算的独特优势 量子计算的深度剖析 量子计算的最新进展 量子计算的行业应用前景 面临的挑战与未来展望 结语:迎接量子计算的新时代 引言:从经典到量子的飞跃 在信息技术飞速发…...
TSPNet代码分析
论文《Realigning Confidence with Temporal Saliency Information for Point-Level Weakly-Supervised Temporal Action Localization》的official code分析 论文解读 代码分析 先看看训练过程,执行main if __name__ == __main__:exp = Exp()if exp.config.mode == eval:…...
Ubuntu上安装anaconda创建虚拟环境(各种踩坑版)
之前都是在Windows桌面版进行深度学习的环境部署及训练,今天尝试了一下在Ubuntu上进行环境部署,踩了不少坑,提供一些解决办法给大家避雷。 目录 一、下载和安装anaconda 1. 下载 2. 安装 二、创建虚拟环境 一、下载和安装anaconda 1. …...
DC-5靶机通关
今天我们来学习DC-5靶机!!! 1.实验环境 攻击机:kali2023.2 靶机:DC-5 2.1扫描网段 2.2扫描端口 这里后面这俩端口有点似曾相识啊,在dc3里面好像见过,那咱们给这两个端口来个更详细的扫描&…...
AI学习记录 -使用react开发一个网页,对接chatgpt接口,附带一些英语的学习prompt
实现了如下功能(使用react实现,原创) 实现功能: 1、对接gpt35模型问答,并实现了流式传输(在java端) 2、在实际使用中,我们的问答历史会经常分享给他人,所以下图的 copy …...
MongoDB多数据源配置与切换
在MongoDB中配置和使用多数据源主要涉及以下几个步骤: 定义多个数据源的配置: 在应用程序的配置文件中,定义多个MongoDB的数据源,例如在Spring Boot中可以通过application.yml或application.properties文件进行配置。 创建多个Mo…...