通过物联网管理多台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 json

app = FastAPI()
mqtt_client = None
device_data = {}  

subtopic="gateway/device/#"

# MQTT回调函数
def on_message(client, userdata, msg): 
     payload = msg.payload.decode()
     topic = msg.topic
     device_id = topic.split('/')[-1]
     device_data[device_id] = payload
     print(f"Received message from {device_id}: {payload}")  
     
# MQTT连接和订阅
def mqtt_connect_and_subscribe(broker_url, broker_port):
      global mqtt_client
      mqtt_client = MQTTClient()
      mqtt_client.on_message = on_message
      mqtt_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] = None
      return {"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 uvicorn
      uvicorn.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设备进行通讯管理。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

CMakeLists.txt语法规则：改变行为的变量说明一

CMakeLists.txt语法规则：改变行为的变量说明一

一. 简介 前面一篇文章学习了 CMakeLists.txt语法中的 部分常量变量，具体学习提供信息的变量，文章如下： CMakeLists.txt语法规则：提供信息的变量说明一-CSDN博客 CMakeLists.txt语法规则：提供信息的变量说明二-CSD…
阅读更多...
【JavaEE网络】HTTPS详解：从对称与非对称加密到证书认证

【JavaEE网络】HTTPS详解：从对称与非对称加密到证书认证

目录 HTTPSHTTPS 是什么“加密” 是什么HTTTPS 的工作过程引入对称加密引入非对称加密引入证书完整流程总结 HTTPS HTTPS 是什么 HTTPS 也是一个应用层协议. 是在 HTTP 协议的基础上引入了一个加密层. HTTP 协议内容都是按照文本的方式明文传输的. 这就导致在传输过程中出现…
阅读更多...
大数据Scala教程从入门到精通第八篇：Scala在IDEA中编写Hello World

大数据Scala教程从入门到精通第八篇：Scala在IDEA中编写Hello World

一：Scala在IDEA中编写Hello World object HelloWorld {def main(args: Array[String]): Unit {println("hello world")}}这个对象也单例的。 特殊的Java类库需要import
阅读更多...
利用一下Chat-GPT写两段处理字符串的简单样例ABAP程序。这样可以大大提高工作效率。Chat-GPT的能力真是让人震撼。

利用一下Chat-GPT写两段处理字符串的简单样例ABAP程序。这样可以大大提高工作效率。Chat-GPT的能力真是让人震撼。

我让Caht-GPT写两段ABAP 程序，第一段程序要求如下： 判读字符串里面是否含有特殊字符，这里说的特殊字符不包括键盘上能够输入的字符，如果有这样的特殊字符则输出来。 DATA: lv_string TYPE string VALUE 你的字符串,lv_result TYP…
阅读更多...
08.2.grafana插件安装

08.2.grafana插件安装

grafana插件安装 官方网站下载地址(可自定义选择版本)： https://grafana.com/grafana/download/6.3.0?pgget&plcmtselfmanaged-box1-cta1 清华源下载grafana的rpm包 https://mirror.tuna.tsinghua.edu.cn/grafana/yum/el7/ 直接命令行安装,或者包下载下来本地…
阅读更多...
docker runc升级1.1.12

docker runc升级1.1.12

上传runc-1.1.12制品至中控机 874e970eaa932a97de9888344ae08f24 runc.arm64 将所有节点的runc文件备份 所有节点（包括master+node） vim host [all] 10.1.0.183 ansible_password=Bigdata@Ksyun123 ansible_user=root ansible_port=22 10.1.0.249 ansible_password=Bigdata…
阅读更多...
AcwingWeb应用课学习笔记

AcwingWeb应用课学习笔记

y总Web课链接&#xff1a; VSCode自动格式化 选中Format On Save不起作用 在设置中搜索default formatter&#xff0c;修改成Prettier-Code formatter 标签 文本标签虽然很多&#xff0c;但大部分可看成是预定好样式的<div>和<span>。&#xff08;div也是由sp…
阅读更多...
电脑nvidia驱动和合适版本的duda--自用 回忆版

电脑nvidia驱动和合适版本的duda--自用 回忆版

参考文献&#xff1a;http://t.csdnimg.cn/ecDuG 内容很多抄的这个&#xff0c;主要害怕链接失效 一、Ubuntu 18.04 安装NVIDIA显卡驱动 1、查看本机显卡能够配置的驱动信息 ubuntu-drivers devices所以可以看出&#xff0c;推荐 nvidia-driver-530 - distro non-free 2、安…
阅读更多...
使用SPI驱动串行LCD的驱动实现(STM32F4)

使用SPI驱动串行LCD的驱动实现(STM32F4)

目录 概述 1. 硬件介绍 1.1 ST7796-LCD 1.2 MCU IO与LCD PIN对应关系 2 功能实现 2.1 使用STM32Cube配置Project 2.2 STM32Cube生成工程 3 代码实现 3.1 SPI接口实现 3.2 LCD驱动程序实现 3.3 测试程序实现 4 测试 源代码下载地址&#xff1a; https://gitee.com/mf…
阅读更多...
2024年最新趋势跨境电商平台开发需了解的新技术

2024年最新趋势跨境电商平台开发需了解的新技术

随着数字化技术的不断演进和全球市场的日益融合&#xff0c;跨境电商平台开发将面临前所未有的挑战和机遇。为了更好地适应并引领这一发展&#xff0c;开发者需要密切关注2024年最新的技术趋势&#xff0c;以确保他们的平台能够在竞争激烈的市场中脱颖而出。本文将对跨境电商平…
阅读更多...
音视频-H264编码封装- MP4格式转Annex B格式

音视频-H264编码封装- MP4格式转Annex B格式

目录 1&#xff1a;H264语法结构回顾 2&#xff1a;H264编码补充介绍 3&#xff1a;MP4模式转Annex B模式输出到文件示例 1&#xff1a;H264语法结构回顾 在之前文章里介绍过H264的语法结构。 传送门: 视音频-H264 编码NALU语法结构简介 2&#xff1a;H264编码补充介绍 H…
阅读更多...
镓未来助力联想笔记本GaN适配器标配化，赋能高效用户体验

镓未来助力联想笔记本GaN适配器标配化，赋能高效用户体验

镓未来赋能笔记本电脑GaN适配器标配化 据悉&#xff0c;Lenovo 2024年推出搭配的多款新型笔记本原装适配器电源ADL100UDGC3A&#xff0c;采用了镓未来集成型Cascode技术氮化镓功率器件G1N65R150PB。新款方案相较上一代工艺&#xff0c;体积减小23%&#xff0c;重量降低18%&…
阅读更多...
JavaScript之数据类型（3）——object进阶

JavaScript之数据类型（3）——object进阶

前言&#xff1a; 利用基础知识来构建对象会发现十分复杂&#xff0c;我们可以结合其他的知识点来为我们object的构建进行优化。 <1>工厂法&#xff1a; 基本格式&#xff1a; function creatObject(属性值1,属性值2,属性值3,...,属性值n) {var 对象名 new Object();对…
阅读更多...
parallels desktop19最新免费Mac电脑虚拟机软件

parallels desktop19最新免费Mac电脑虚拟机软件

Parallels Desktop是一款运行在Mac电脑上的虚拟机软件&#xff0c;它允许用户在Mac系统上同时运行多个操作系统&#xff0c;比如Windows、Linux等。通过这款软件&#xff0c;Mac用户可以轻松地在同一台电脑上体验不同操作系统的功能和应用程序&#xff0c;而无需额外的硬件设备…
阅读更多...
https免费证书获取

https免费证书获取

获取免费证书的网址&#xff1a; Certbot 1. 进入你的linux系统&#xff0c;先安装snapd&#xff0c; yum install snapd 2. 启动snapd service snapd start 3.安装 Certbot snap install --classic certbot 注意如下出现此错误时&#xff0c;需要先建立snap 软连接后&am…
阅读更多...
正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-15.5讲 GPIO中断实验-通用中断驱动编写

正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-15.5讲 GPIO中断实验-通用中断驱动编写

前言&#xff1a; 本文是根据哔哩哔哩网站上“正点原子[第二期]Linux之ARM&#xff08;MX6U&#xff09;裸机篇”视频的学习笔记&#xff0c;在这里会记录下正点原子 I.MX6ULL 开发板的配套视频教程所作的实验和学习笔记内容。本文大量引用了正点原子教学视频和链接中的内容。…
阅读更多...
MYSQL中的DQL

MYSQL中的DQL

语法&#xff1a; select 字段列表 from 表名列表 where 条件列表 group by 分组字段列表 having 分组后条件列表 order by 排序字段 limit 分页参数 条件查询 语法&#xff1a; 查询多个字段&#xff1a;select 字段1&#xff0c;字段2 from表名 查询所有字段&#xff1a…
阅读更多...
计算机视觉——OpenCV实现Lucas-Kanade 光流追踪

计算机视觉——OpenCV实现Lucas-Kanade 光流追踪

1.光流 光流法是计算机视觉中用于估计图像序列中物体运动的关键技术。它类似于观察夜空中的彗星&#xff0c;通过其在天空中的运动轨迹来追踪它的路径。在图像处理中&#xff0c;光流帮助我们理解像素点如何在连续的帧之间移动。 1.1 稀疏光流法 稀疏光流法关注于图像中的关…
阅读更多...
【算法】最短路问题 bfs 到 dijkstra

【算法】最短路问题 bfs 到 dijkstra

1976、到达目的地的方案数 你在一个城市里&#xff0c;城市由 n 个路口组成&#xff0c;路口编号为 0 到 n - 1 &#xff0c;某些路口之间有 双向 道路。输入保证你可以从任意路口出发到达其他任意路口&#xff0c;且任意两个路口之间最多有一条路。 给你一个整数 n 和二维整…
阅读更多...
Coze扣子开发指南：AI零代码编程创建插件

Coze扣子开发指南：AI零代码编程创建插件

在Coze扣子中创建插件&#xff0c;有两种方式&#xff0c;一是用API&#xff0c;具体方式参照上一篇文章《Coze扣子开发指南&#xff1a;用免费API自己创建插件》&#xff0c;还有一种方式就是编程&#xff0c;不过有了AI的帮助&#xff0c;即使不会编程的人&#xff0c;也可以…
阅读更多...
最新文章

Copyright @ 2022~2023