@

• 前言
• 架构图
  • 一、设备接入
  • 二、处理设备遥测数据
  • 三、设备控制
  • 四、管理后台
  • 五、数据存储
  • 六、规则引擎
• 环境准备
  • 1、安装EMQX
  • 2、创建解决方案
  • 3、安装Dapr开发环境

前言

本系列文章以IoT开发小白的角度，从零开始使用.Net为主要技术搭建一个简单的IoT平台，由于是入门系列，所有代码以围绕IoT基础业务场景为主，不会涉及DDD等设计思想。

架构图

这里是我们整个IoT平台的架构图。

一、设备接入

1、针对可以联网的设备，直接通过MQTT协议连接到我们的MQTT服务上（可以使用国内的阿里云、Onenet也可以使用开源EMQX实现）。绿色线框部分
2、针对不能联网的设备，例如只能通过红外、短信、等其他非互联网技术通讯的，采用设备网关统一接管，这里主要涉及硬件相关内容我们不深入讨论。橙色线框部分

二、处理设备遥测数据

我们通过MQTT Hub 订阅设备发布到MQTT的消息，并通过Dapr的Pub/Sub 方式发送给我们的IoT Core集群，我们可以通过MQTT 5.0协议中的共享订阅方式实现我们高可用集群。蓝色线框部分

三、设备控制

直接在IoT Core中直接向MQTT发布控制指令。红色箭头所示

四、管理后台

管理后台我们采用Blazor搭建结合MASA Auth实现权限控制，红色线框部分，在IoT Core和IoT UI中间有一层Gateway，主要是方便我们在这一层Mock一些依赖的第三方业务接口，例如某个环节我需要从生产的MES系统获取某些信息才能继续下面的操作，我们可以在Gateway层去Mock这些接口和数据，方便我们测试。

五、数据存储

业务数据我们存储到关系型数据库中，设备的消息数据（遥测数据），我们存储到时序库中，方便统计查找，和生成报表。

六、规则引擎

针对不同类型的消息，我们可以在规则引擎中配置，使消息可以走不同的处理流程，例如接入的第三方系统设备，设备消息可能是加密的，我们就通过规则引擎将这种类型的消息发送到第三方系统解密之后再存储到数据库中，也可以在这里针对遥测数据进行分析和过滤，产生分级告警信息，发送到对应的处理系统或者干系人邮箱等。

环境准备

1、安装EMQX

1、运行以下命令获取 Docker 镜像：

docker pull emqx/emqx:5.0.20

2、运行以下命令启动 Docker 容器

docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:5.0.20

2、创建解决方案

创建解决方案MASA.IoT，分别添加
1、WebApi项目MASA.IoT.Core，对应架构图中IoT Core
2、WebApi项目MASA.IoT.Hub，对应架构图中IoT Hub
3、Blazor应用MASA.IoT.UI,对应架构图中的IoT.UI,也就是管理后台
4、类库MASA.IoT.Common，存放一些静态的公共方法

3、安装Dapr开发环境

https://blog.csdn.net/sunday866/article/details/129698679

参考这篇文章使用Masa DaprStarter安装Dapr环境

例如：以上就是今天要讲的内容，本文仅仅简单介绍了我们IoT后台的基本架构，下一章我们讲设备的生命周期