通过物联网管理多台MQTT设备-基于米尔T527开发板

本篇测评由电子工程世界的优秀测评者“JerryZhen”提供。

本文将介绍基于米尔电子MYD-LT527开发板的网关方案测试。

一、系统概述

基于米尔-全志 T527设计一个简易的物联网网关，该网关能够管理多台MQTT设备，通过MQTT协议对设备进行读写操作，同时提供HTTP接口，允许用户通过HTTP协议与网关进行交互，并对设备进行读写操作。

二、系统架构

  1. 网关服务：基于FastAPI框架构建的Web服务，提供HTTP接口。

  2. MQTT客户端：负责与MQTT设备通信，管理设备连接、消息发布和订阅。

  3. 设备管理：维护一个设备列表，记录设备的基本信息和状态。

  4. 数据存储：使用内存或数据库存储设备数据，确保数据持久化。

三、组件设计

  1. MQTT组件：

  • 负责与MQTT broker建立连接。
  • 订阅设备主题，接收设备发送的消息。
  • 发布消息到设备，实现远程控制。

  1. 设备管理组件：

  • 维护一个设备列表，记录设备的唯一标识符（如设备ID）、MQTT主题、连接状态等信息。
  • 提供设备增删改查的方法。

  1. HTTP组件：

  • 基于FastAPI定义HTTP接口。
  • 接收用户请求，调用MQTT组件和设备管理组件进行相应操作。
  • 返回操作结果给用户。

四、接口设计

  1. 设备列表：

  • GET /devices：返回所有设备的列表。
  • POST /devices：添加新设备到网关。
  • DELETE /devices/{device_id}：从网关中删除指定设备。

  1. 设备详情：

  • GET /devices/{device_id}：返回指定设备的详细信息。

  1. 设备数据：

  • GET /devices/{device_id}/data：获取指定设备的最新数据。
  • POST /devices/{device_id}/data：发送数据到指定设备。

  1. 设备控制：

  • POST /devices/{device_id}/control：发送控制命令到指定设备。

五、数据结构设计

  1. 设备信息：

  • 设备ID (device_id)：唯一标识设备的字符串。
  • MQTT主题 (mqtt_topic)：设备在MQTT broker上的主题。
  • 连接状态 (connection_status)：表示设备是否在线的布尔值。
  • 其他设备属性（如名称、描述等）。

  1. 设备数据：

  • 设备ID (device_id)：关联设备信息的设备ID。
  • 时间戳 (timestamp)：数据发送或接收的时间。
  • 数据内容 (data)：设备发送或接收的具体数据，可以是JSON格式或其他格式。

六、安全性考虑

  • 使用HTTPS协议提供安全的HTTP通信。

  • 实现用户认证和授权机制，确保只有授权用户可以访问和操作设备。

  • 对于敏感操作（如删除设备），要求用户进行二次确认或提供额外的安全措施。

七、部署与扩展

  • 使用Docker容器化部署网关服务，便于管理和扩展。

  • 根据需要，可以水平扩展网关实例以处理更多的设备连接和请求。

八、实现步骤

  1. 安装所需的Python库：fastapi, uvicorn, paho-mqtt等。

  2. 创建FastAPI应用并定义路由。

  3. 实现MQTT组件，包括与MQTT broker的连接、订阅、发布等功能。

  4. 实现设备管理组件，维护设备列表并提供增删改查的方法。

  5. 实现HTTP组件，调用MQTT组件和设备管理组件处理用户请求。

  6. 编写测试代码，验证网关的各项功能是否正常工作。

  7. 部署网关服务并监控其运行状态。

该设计方案仅仅是概述，具体实现细节可能需要根据实际需求和项目环境进行调整和优化。在实际开发中，还需要考虑异常处理、日志记录、性能优化等方面的问题。基于上述设计方案，以下是一个简化版的参考代码，展示了如何使用FastAPI和paho-mqtt库来创建一个物联网网关。需要注意，示例中不包含完整的错误处理、用户认证和授权机制，这些在实际生产环境中都是必不可少的。依赖的主要库版本：

fastapi==0.108.0

paho-mqtt==1.6.1

网关模拟代码gateway.py：

from fastapi import FastAPI, HTTPException, Body, status
from paho.mqtt.client import Client as MQTTClient
from typing import List, Dict, Any
import asyncio
import jsonapp = FastAPI()
mqtt_client = None
device_data = {}  subtopic="gateway/device/#"# MQTT回调函数
def on_message(client, userdata, msg): payload = msg.payload.decode()topic = msg.topicdevice_id = topic.split('/')[-1]device_data[device_id] = payloadprint(f"Received message from {device_id}: {payload}")  # MQTT连接和订阅
def mqtt_connect_and_subscribe(broker_url, broker_port):global mqtt_clientmqtt_client = MQTTClient()mqtt_client.on_message = on_messagemqtt_client.connect(broker_url, broker_port, 60)mqtt_client.subscribe(subtopic)mqtt_client.loop_start()# MQTT发布消息
async def mqtt_publish(topic: str, message: str):if mqtt_client is not None and mqtt_client.is_connected():mqtt_client.publish(topic, message)else: print("MQTT client is not connected!")# 设备管理：添加设备
@app.post("/devices/", status_code=status.HTTP_201_CREATED)
async def add_device(device_id: str):device_data[device_id] = Nonereturn {"message": f"Device {device_id} added"}# 设备管理：获取设备列表
@app.get("/devices/")
async def get_devices(): return list(device_data.keys())# 设备管理：获取设备数据
@app.get("/devices/{device_id}/data")
async def get_device_data(device_id: str):if device_id not in device_data:raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail=f"Device {device_id} not found")return device_data.get(device_id)# 设备管理：发送数据到设备
@app.post("/devices/{device_id}/data")
async def send_data_to_device(device_id: str, data: Dict[str, Any] = Body(...)):topic = f"devices/{device_id}"message = json.dumps(data)await mqtt_publish(topic, message)return {"message": f"Data sent to {device_id}"}# 设备控制：发送控制命令到设备
@app.post("/devices/{device_id}/control")
async def control_device(device_id: str, command: str):topic = f"devices/device/{device_id}"await mqtt_publish(topic, command)return {"message": f"Control command sent to {device_id}"}# FastAPI启动事件
@app.on_event("startup")
async def startup_event():mqtt_connect_and_subscribe("127.0.0.1", 1883)# FastAPI关闭事件
@app.on_event("shutdown")
async def shutdown_event():if mqtt_client is not None:mqtt_client.loop_stop()mqtt_client.disconnect()# 运行FastAPI应用
if __name__ == "__main__":import uvicornuvicorn.run(app, host="127.0.0.1", port=8000)

设备1模拟代码 dev1.py：

import paho.mqtt.client as mqtt# 连接成功回调
def on_connect(client, userdata, flags, rc):print('Connected with result code '+str(rc))client.subscribe('devices/1')# 消息接收回调
def on_message(client, userdata, msg):print(msg.topic+" "+str(msg.payload))client.publish('gateway/device/1',payload=f'echo {msg.payload}',qos=0)client = mqtt.Client()# 指定回调函数
client.on_connect = on_connect
client.on_message = on_message# 建立连接
client.connect('127.0.0.1', 1883)
# 发布消息
client.publish('gateway/device/1',payload='Hello, I am device',qos=0)client.loop_forever()

设备2模拟代码 dev2.py

import paho.mqtt.client as mqtt# 连接成功回调
def on_connect(client, userdata, flags, rc):print('Connected with result code '+str(rc))client.subscribe('devices/2')# 消息接收回调
def on_message(client, userdata, msg):print(msg.topic+" "+str(msg.payload))client.publish('gateway/device/2',payload=f'echo {msg.payload}',qos=0)client = mqtt.Client()# 指定回调函数
client.on_connect = on_connect
client.on_message = on_message# 建立连接
client.connect('127.0.0.1', 1883)
# 发布消息
client.publish('gateway/device/2',payload='Hello, I am device',qos=0)client.loop_forever()

运行网关代码，打开网页得到api接口：

 通过api分别添加设备1和设备2，

在另外两个控制台中分别运行模拟设备1和模拟设备2的代码

通过网页API向设备1发送数据

通过网页API获得设备回复的数据，设备代码中只是简单的把网关发过来的数据进行回传

我们在网关的后台可以看到完整的数据流

至此一个简易的网关已经实现了，接下来将会尝试实现楼宇里的最常见的bacnet设备进行通讯管理。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/324510.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

前端框架-echarts

前端框架-echarts

Echarts 项目中要使用到echarts框架&#xff0c;从零开始在csdn上记笔记。 这是一个基础的代码&#xff0c;小白入门看一下 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" co…
阅读更多...
x6.js bug记录-流程图json数据导入进来之后拖拽节点，节点直接飞走了

x6.js bug记录-流程图json数据导入进来之后拖拽节点，节点直接飞走了

添加josn数据进来之后虽然能正常渲染&#xff0c;但是只要一拖拽&#xff0c;则节点就直接飞走了&#xff0c;看不到了。 找了一下午的问题&#xff0c;最后发现。保存的json坐标位置是字符串类型&#xff0c;而这边的位置必须是数字类型。如下&#xff1a; {position: { x: &…
阅读更多...
关于vs2019 c++ STL 中容器的迭代器的 -＞ 运算符的使用，以 list 双向链表为例

关于vs2019 c++ STL 中容器的迭代器的 -＞ 运算符的使用，以 list 双向链表为例

&#xff08;1&#xff09;如下的结构体 A &#xff0c;若有指针 p new A() &#xff1b;则可以使用 p->m &#xff0c; p->n 解引用运算符。 struct A { int m ; int n; } 对于 STL 中提供的迭代器&#xff0c;提供了类似于指针的功能。对迭代器也可以使用 -> 运算…
阅读更多...
RS3236-ADJ8YF5功能和参数介绍及PDF资料

RS3236-ADJ8YF5功能和参数介绍及PDF资料

RS3236-ADJ8YF5功能和参数介绍及PDF资料-公司新闻-配芯易-深圳市亚泰盈科电子有限公司 品牌: RUNIC(润石) 封装: SOT-23-5 描述: 输出电压可调(参考电压0.81V),Iout500mA(Max),Vin7.5V(Max),带过温保护 输出类型: 可调 最大输入电压: 7.5V 输出电压: 810mV~6.6V 最大输出电流…
阅读更多...
订单超时自动取消的实践方案

订单超时自动取消的实践方案

1、定时任务方案 方案流程&#xff1a; 每隔 30 秒查询数据库&#xff0c;取出最近的 N 条未支付的订单。 遍历查询出来的订单列表&#xff0c;判断当前时间减去订单的创建时间是否超过了支付超时时间&#xff0c;如果超时则对该订单执行取消操作。 定时任务方案工程实现相…
阅读更多...
QT--5

QT--5

1> 将网络聊天室重新实现一遍 服务器端 #include "widget.h" #include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget) {ui->setupUi(this);ser new QTcpServer(this); }Widget::~Widget() {delete ui; }vo…
阅读更多...
IDEA 好用的插件

IDEA 好用的插件

图标插件&#xff1a;Atom Material Icons 此插件的作用就是更好的显示各种文件的类别&#xff0c;使之一目了然 汉化包 Chinese ​(Simplified)​ Language Pack / 中文语言包 作用就是 汉化 AI编码助手 GitHub Copilot AI编码助手&#xff1a;提示代码很好用 缺点&#xff1a…
阅读更多...
八款免费好用的3D建模AI工具，让你的设计更简单！

八款免费好用的3D建模AI工具，让你的设计更简单！

随着人工智能和大语言模型的不断发展&#xff0c;AI工具正逐渐渗透到3D建模领域中。传统上&#xff0c;3D建模师需使用如3ds Max、Maya等这类复杂的3D建模软件&#xff0c;投入大量的时间与精力来创作精细的模型。然而&#xff0c;有了AI工具的辅助&#xff0c;设计过程不仅对专…
阅读更多...
json返回工具类|世界协调时间（UTC）

json返回工具类|世界协调时间（UTC）

一、问题 世界协调时间&#xff08;UTC&#xff09;是一个标准的时间参考&#xff0c;通常被用于跨越不同时区的时间标准。要将 UTC 时间转换为中国时间&#xff08;中国标准时间&#xff09;&#xff0c;你需要将时间加上8个小时&#xff0c;因为中国位于 UTC8 时区。 初中知…
阅读更多...
时尚圈的节制美学 — 奥柔拉 AVRALA的独特设计理念

时尚圈的节制美学 — 奥柔拉 AVRALA的独特设计理念

在这个多元化的时代&#xff0c;女性正在经历一场前所未有的角色变革。她们不再仅仅满足于传统的社会角色&#xff0c;而是勇敢地追求个人职业发展和自我实现。在这样的背景下&#xff0c;服饰不仅仅是外在的装饰&#xff0c;更是内心故事的讲述者、个性自我的表达者、身份归属…
阅读更多...
【go项目01_学习记录10】

【go项目01_学习记录10】

操作数据库 1 插入数据2 显示文章2.1 修改 articlesShowHandler() 函数2.2 代码解析 3 编辑文章3.1 添加路由3.2 编辑articlesEditHandler()3.3 新建 edit 模板3.4 代码重构3.5 完善articlesUpdateHandler()3.6 测试更新3.7 封装表单验证 1 插入数据 . . . func articlesStore…
阅读更多...
扩展学习|本体研究进展

扩展学习|本体研究进展

文献来源&#xff1a; 王向前,张宝隆,李慧宗.本体研究综述[J].情报杂志,2016,35(06):163-170. 一、本体的定义 本体概念被引入人工智能、知识工程等领域后被赋予了新的含义。然而不同的专家学者对本体的理解不同,所给出的定义也有所差异。 人工智能领域的学者Neches(1991)等人对…
阅读更多...
苹果新款 M4 芯片专注于 AI

苹果新款 M4 芯片专注于 AI

爆炸性消息&#xff01;苹果的新一代 M4 芯片来了&#xff01;这家伙拥有 38 万亿次操作的超强神经引擎&#xff0c;速度比苹果 A11 芯片的 NPU 快 60 倍&#xff01;虽然它的速度还没有达到 Snapdragon X Elite 的 45 TOPS&#xff0c;但苹果自夸 M4 将提供与最新 PC 芯片相同…
阅读更多...
QT-TCP通信

QT-TCP通信

网上的资料太过于书面化&#xff0c;所以看起来有的让人云里雾里&#xff0c;看不懂C-tcpsockt和S-tcpsocket的关系 所以我稍微画了一下草图帮助大家理解两个套接字之间的关系。字迹有的飘逸勉强看看 下面是代码 服务端&#xff1a; MainWindow::MainWindow(QWidget *parent) …
阅读更多...
Oracle-一次TX行锁堵塞事件

Oracle-一次TX行锁堵塞事件

问题背景&#xff1a; 接用户问题报障&#xff0c;应用服务出现大量会话堆积现象&#xff0c;数据库锁堵塞严重&#xff0c;需要协助进行问题定位和排除。 问题分析&#xff1a; 登录到数据库服务器上&#xff0c;首先查看一下数据库当前的等待事件情况&#xff0c;通过gv$ses…
阅读更多...
C++ 课程设计，图片元素的获取，拟合椭圆

C++ 课程设计，图片元素的获取，拟合椭圆

WX: help-assignment C 课程设计&#xff0c;图片元素的获取&#xff0c;拟合椭圆 代码实现步骤&#xff1a; 读取.jpg 图片(259219443)&#xff0c;将图片中的x∈(700,1450)y∈(1,1944)的像素值置为0&#xff1b; 提取图片的r、g、b 通道&#xff0c;按照(1r-0.6g-0.3*b)对…
阅读更多...
【QA】Java集合常用的函数

【QA】Java集合常用的函数

文章目录 前言Collection接口通用函数 | Collections工具类通用函数 | List接口 Set接口List接口ArrayListLinkedList Set接口TreeSetHashSetLinkedHashSet Map接口通用函数TreeMapHashMapLinkedHashMap 前言 本文介绍Java集合中常用的函数。 Collection接口 通用函数 | Co…
阅读更多...
林更新博士之路星途璀璨再启航

林更新博士之路星途璀璨再启航

林更新&#xff1a;博士之路&#xff0c;星途璀璨再启航在这个充满机遇与挑战的时代&#xff0c;有一位演员以其出色的演技和不懈的努力&#xff0c;赢得了无数观众的喜爱。他&#xff0c;就是林更新。今日&#xff0c;一条消息如重磅炸弹般在娱乐圈炸开&#xff0c;让无数粉丝…
阅读更多...
Android Studio（AS）使用别人的项目与gradle包并运行项目

Android Studio（AS）使用别人的项目与gradle包并运行项目

一、问题描述 在进行AS开发时&#xff0c;我们可能会使用到别人的项目&#xff0c;但发现别人把项目发给我们后会发现gradle项目同步失败o(≧口≦)o&#xff0c;此时计有三&#xff1a; 1.横行霸道、豪取抢夺&#xff1a;直接空降到项目人那里&#xff0c;强他的电脑占为己有…
阅读更多...
Mac电脑安装打开APP显示问题已损坏 问题解决

Mac电脑安装打开APP显示问题已损坏 问题解决

当MAC电脑安装完软件打开时&#xff0c;显示文件已损坏&#xff0c;无法打开。搜了很多教程终于找到解决方案&#xff0c;记录下方便以后再用。 我的mac电脑是intel芯片的&#xff0c;如果你遇到这个问题&#xff0c;可以参考我的这个方案。 1.首先当打开软件后出现 “xx软件已…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023