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

news2024/11/17 20:32:00

本篇测评由电子工程世界的优秀测评者“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设备进行通讯管理。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

好玩粘土特效软件分享！3个很火的软件！

好玩粘土特效软件分享！3个很火的软件！

在数字艺术日益发展的今天，粘土特效软件以其独特的魅力和强大的功能，成为众多创意人士和艺术家的得力助手。这些软件不仅能够帮助用户轻松实现粘土动画效果，还能为作品增添生动的质感和细节，让创意无限延伸。那么，究竟…
阅读更多...
Kotlin基本特性

Kotlin基本特性

目录 函数 if when 循环 面向对象 继承 主构造函数 接口 修饰符 ​编辑数据类 单例类 Lambda编程 集合 lambda用法 常见函数式API 空指针 判空辅助工具 字符串内嵌表达式 函数 fun add1(a:Int,b:Int):Int{return ab }fun add2(a:Int,b:Int):Int ab // 只…
阅读更多...
机房IP代理是什么？

机房IP代理是什么？

网络信息时代，数据已成为了重要资源。而数据信息的爬取，离不开代理IP。那么，机房IP代理究竟是什么？ 机房IP代理是指分配给机房中的服务器或网络设备的IP地址，用于提供网络服务和连接到互联网，并作为客户端和…
阅读更多...
vscode go语言开发中在任意包运行和调试代码 Example使用方法

vscode go语言开发中在任意包运行和调试代码 Example使用方法

一般情况下我们在进行go语言开发的时候我们都需要创建一个main方法和main包才能运行go代码， 针对这个问题，go语言给我们内置了功能强大的testing测试框架， 其中一个很有意思的Example测试就非常的方便使用。 他不管你在什么包，也…
阅读更多...
459.重复的子字符串

459.重复的子字符串

给定一个非空的字符串，判断它是否可以由它的一个子串重复多次构成。给定的字符串只含有小写英文字母，并且长度不超过10000。 示例 1: 输入: "abab"输出: True解释: 可由子字符串 "ab" 重复两次构成。 示例 2: 输入: "aba&q…
阅读更多...
解决背包问题：组合优化的应用与建模方法

解决背包问题：组合优化的应用与建模方法

前言 在之前发布的智能解决装箱问题：使用优化算法实现高效包装一文中，我们已经介绍了什么是组合优化问题。这里仅简述： 组合优化是数学优化的一支，专注于从有限集合中选取元素的最优化问题。它涉及将一组对象组合在一起&#xff…
阅读更多...
Ansible之Playbook的Template模板和tags标签

Ansible之Playbook的Template模板和tags标签

文章目录 一、Template模块1、准备template模板文件2、修改主机清单文件3、编写playbook4、执行playbook5、准备测试网页6、访问测试 二、tags模块1、编写脚本2、执行tags"xx01"3、执行tags"xx02" 一、Template模块 Jinja是基于Python的模块引擎。Templat…
阅读更多...
黑马程序员HarmonyOS4+NEXT星河版入门到企业级实战教程【18~23】

黑马程序员HarmonyOS4+NEXT星河版入门到企业级实战教程【18~23】

视频0~17的笔记 页面路由 实现不同页面之间的跳转和数据传递。 页面栈。上限是32个页面，使用router.clear()可以清空页面栈释放内存。 两种跳转模式： 参数一致，都是三个参数 router.pushUrl()，新页面压入页面栈，可以…
阅读更多...
GPT-SoVits：语音克隆，语音融合

GPT-SoVits：语音克隆，语音融合

首发网站 https://tianfeng.space 前言 零样本文本到语音（TTS）： 输入 5 秒的声音样本，即刻体验文本到语音转换。少样本 TTS： 仅需 1 分钟的训练数据即可微调模型，提升声音相似度和真实感。跨语言支持&…
阅读更多...
网易Airtest集群方案大揭秘：小型便携式集群方案来啦

网易Airtest集群方案大揭秘：小型便携式集群方案来啦

一、前言 中小型企业/工作室搭建便携设备集群的制胜法宝是什么？当然非网易Airtest便携式机柜莫属啦。得益于广大企业客户对我们便携式集群的支持，我们团队也一直在坚持优化小型的便携式集群方案，短短2年时间，我们的便携式机柜已经…
阅读更多...
oracle 新_多种块大小的支持9i

oracle 新_多种块大小的支持9i

oracle 新_多种块大小的支持 conn sys/sys as sysdba SHOW PARAMETER CACHE ALTER SYSTEM SET DB_CACHE_SIZE16M; ALTER SYSTEM SET DB_4K_CACHE_SIZE8M; CREATE TABLESPACE K4 DATAFILE F:\ORACLE\ORADATA\ZL9\K4.DBF SIZE 2M BLOCKSIZE 4K; CREATE TABLE SCOTT.A1 TABLESP…
阅读更多...
【csdn】数据工程实践：从网络抓取到API调用，解析共享单车精准投放所需要的数据

【csdn】数据工程实践：从网络抓取到API调用，解析共享单车精准投放所需要的数据

共享单车作为一种便捷的出行方式，有效缓解了“最后一公里”难题，同时促进了绿色出行。然而，在高峰时段，供需不均和停车难成为普遍挑战，尤其是在通勤时间，热门地点如地铁站附近和办公区常常面临车辆短缺或停…
阅读更多...
【C语言】/*操作符(上)*/

【C语言】/*操作符(上)*/

目录 一、算数操作符：、-、*、/、% 1.1 和 - 1.2 * 1.3 / 1.4 % 二、赋值操作符： 和符合赋值 2.1 连续赋值 2.2 复合赋值(自操作) 三、单目操作符：、--、(正号)、-(负号) 3.1 和 -- 3.1.1 前置 3.1.2 后置 3.1.3 前置-- …
阅读更多...
汽车EDI：安通林Antolin EDI 项目案例

汽车EDI：安通林Antolin EDI 项目案例

安通林（Antolin）是一家全球性的汽车零部件制造商，专注于汽车内饰系统和零部件的生产，致力于创新和采用先进的技术。近年来 安通林Antolin 推动其供应商部署EDI系统，使得双方能够通过EDI传输业务单据，极大提…
阅读更多...
IDEA使用技巧2—发布web项目

IDEA使用技巧2—发布web项目

作者：私语茶馆 1.War包类型 发布Web项目有两种模式：war和war exploded， war模式：将WEB工程以包的形式上传到服务器 ；war exploded模式：将WEB工程以当前文件夹的位置关系上传到服务器； war ex…
阅读更多...
java日历类概述

java日历类概述

Java中的Calendar类位于java.util包下，它是一个抽象类，用于表示和管理日期及时间。Calendar类并不是直接实例化的，而是通过其提供的静态方法来获取实例。通常情况下，当你尝试创建一个Calendar实例时，实际上你得到的是G…
阅读更多...
在 Navicat 17 中探索表配置文件

在 Navicat 17 中探索表配置文件

距离 Navicat 17（英文版）的发布还有不到一周的时间，现在是深入研究新的表配置文件功能的最佳时机。它允许我们保存经常用于表的筛选、排序和列显示的不同组合。所以，事不宜迟，让我们开始吧！ 创建表配置文件…
阅读更多...
LeetCode 106.从中序与后序遍历序列构造二叉树

LeetCode 106.从中序与后序遍历序列构造二叉树

LeetCode 106.从中序与后序遍历序列构造二叉树 1、题目 题目链接：106. 从中序与后序遍历序列构造二叉树 给定两个整数数组 inorder 和 postorder ，其中 inorder 是二叉树的中序遍历， postorder 是同一棵树的后序遍历，请你构造并…
阅读更多...
思维导图在线怎么制作？推荐这些工具

思维导图在线怎么制作？推荐这些工具

思维导图在线怎么制作？在如今的快节奏时代中，思维导图作为一种高效的信息组织与思考工具，受到了广泛的应用。在线制作思维导图成打破了时间和空间的限制，使得团队协作变得更加便捷，个人创作也更为灵活。以下是四款备受…
阅读更多...
2024年生物医学、医学图像与信号处理国际会议(ICBMISP2024)

2024年生物医学、医学图像与信号处理国际会议(ICBMISP2024)

2024年生物医学、医学图像与信号处理国际会议(ICBMISP2024) 会议简介 2024年国际生物医学、医学成像和信号处理会议（ICBMISP2024）很高兴邀请您提交主题为“生物医学、医学图像和信号处理的当前挑战和未来前景”的原稿。通过ICBMISP2024，生物…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023