【YFIOs】用C#开发硬件之设备上云
设备初始化到数据上传的完整实现。NuGet 软件包包名版本用途nanoFramework.CoreLibrary1.17.11基础运行时System 命名空间nanoFramework.Hardware.Esp321.6.37ESP32 引脚功能配置I2C/SPI/UARTnanoFramework.Iot.Device.DhcpServer1.2.938AP 模式 DHCP 服务器nanoFramework.Logging1.1.161日志记录ILoggernanoFramework.M2Mqtt5.1.212MQTT 客户端连接叶帆物联平台nanoFramework.Networking.Sntp1.6.42NTP 时间同步nanoFramework.System.Collections1.5.67Hashtable / ArrayList属性上传nanoFramework.System.Device.Gpio1.1.57GPIO 控制LED/按钮/继电器/数字输入nanoFramework.System.Device.I2c1.1.29I2C 通信SHT30 温湿度传感器nanoFramework.System.Device.Wifi1.5.141WiFi STA/AP 管理nanoFramework.System.Math1.5.116数学运算指数退避重连nanoFramework.System.Net1.11.50DNS 解析网络可达性检测nanoFramework.System.Net.Http.Server1.5.204Web 服务器配网页面nanoFramework.System.Text1.3.42StringBuilder / UTF-8 编码nanoFramework.System.Threading1.1.52线程/定时器nanoFramework.WebServer1.2.140WebServer 路由框架属性路由系统架构┌─────────────────────────────────────────────────────────┐│ YF3300-ESP32S3 设备 ││ ││ ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌─────────┐ ││ │ SHT30 │ │ 继电器 │ │ 数字输入 │ │ BOOT │ ││ │ 温湿度 │ │ GPIO48 │ │ GPIO21/47│ │ GPIO0 │ ││ └────┬─────┘ └────┬─────┘ └────┬─────┘ └────┬────┘ ││ │ I2C │ GPIO │ GPIO │ GPIO ││ ┌────▼──────────────▼────────────▼──────────────▼─────┐ ││ │ 驱动层 (Drivers/) │ ││ │ Sht30Sensor │ RelayDriver │ DigitalInputDriver │ ││ │ ButtonDriver│ LedManager │ ││ └────────────────────────┬────────────────────────────┘ ││ │ ││ ┌────────────────────────▼────────────────────────────┐ ││ │ 管理层 (Managers/) │ ││ │ MqttClientManager ←→ WifiManager ←→ APConfigManager│ ││ │ NtpTimeManager │ ConfigurationManager │ ││ └────────────────────────┬────────────────────────────┘ ││ │ MQTT (YFLink协议) │└───────────────────────────┼──────────────────────────────┘│┌────────▼────────┐│ 叶帆物联网平台 ││ iot.yfios.net ││ MQTT:1883 │└─────────────────┘启动流程12步初始化程序在Main()中按顺序执行12个步骤完成系统初始化步骤组件GPIO/接口说明1Logger-初始化 DebugLoggerFactory 日志系统2GPIO-创建 GpioController 实例3LEDGPIO39/40黄色(网络状态) 绿色(配网状态)4RelayGPIO481路继电器输出驱动5Digital InputGPIO21/472路开关量输入回调模式6SHT30I2C(17/18)温湿度传感器地址0x447ButtonGPIO0BOOT按钮短按切换继电器/长按配网8Configuration-WiFi凭证读写的配置管理器9WiFi Manager-STA/AP双模式WiFi管理10WiFi Connect-加载配置连接WiFi成功后初始化NTP11AP Config-AP配网管理器含Web服务器12MQTT Connect-连接叶帆物联网平台主循环逻辑┌──────────────┐│ counter │└──────┬───────┘│▼┌──────────────┐ 每5秒读取一次│ 读取传感器 │◄── NTP时间 / 温湿度 / 数字输入 / 继电器状态└──────┬───────┘│▼┌──────────────┐ counter % 6 0 (约30秒)│ 是否上传 │─── NO ──► Sleep(5000ms) ──► 循环└──────┬───────┘│ YES▼┌──────────────┐│ UploadData │ 构建属性Hashtable → MQTT发布│ ToCloud() │ 属性: H(湿度) T(温度) I1 I2 Q1└──────────────┘核心代码详解1. 硬件引脚定义 (Hardware/YF3300_ESP32S3.cs)Hardware/YF3300_ESP32S3.csusing System;namespace YFSoft.Hardware.YF3300_ESP32S3{public static class CPU{public static class Pins{// GPIO 0-48 全部定义public const int GPIO0 0;public const int GPIO9 9; // RS485 TXpublic const int GPIO10 10; // RS485 RXpublic const int GPIO11 11; // RS232 TXpublic const int GPIO12 12; // RS232 RXpublic const int GPIO17 17; // I2C SDApublic const int GPIO18 18; // I2C SCLpublic const int GPIO21 21; // 开关量输入1public const int GPIO39 39; // 绿色LEDpublic const int GPIO40 40; // 黄色LEDpublic const int GPIO47 47; // 开关量输入2public const int GPIO48 48; // 继电器1}}public static class Mainboard{public static class Pins{public const int YellowLED CPU.Pins.GPIO40; // 网络状态public const int GreenLED CPU.Pins.GPIO39; // 配网状态public const int BOOT CPU.Pins.GPIO0;public const int I1 CPU.Pins.GPIO21;public const int I2 CPU.Pins.GPIO47;public const int Q1 CPU.Pins.GPIO48;}public static class RS485{public const string PortName COM1;public const int TxPin CPU.Pins.GPIO9;public const int RxPin CPU.Pins.GPIO10;}public static class I2C{public const int BusId 1;public const int SdaPin CPU.Pins.GPIO17;public const int SclPin CPU.Pins.GPIO18;}}// LED闪烁时序定义毫秒public static class LEDTiming{// 黄色LED - 网络状态public const int NetworkConnecting_On 0; // 常亮public const int NetworkNormal_On 500; // 慢闪public const int NetworkNormal_Off 1500;public const int NetworkError_On 200; // 快闪public const int NetworkError_Off 200;// 绿色LED - 配网状态public const int ConfigAP_On 0; // 常亮(配网中)public const int ConfigSuccess_On 500; // 慢闪(成功)public const int ConfigFailed_On 200; // 快闪(失败)}// 系统配置常量public static class SystemConfig{public const int WiFiConnectTimeout 15000; // WiFi连接超时(ms)public const int WiFiReconnectInterval 5000; // 重连间隔(ms)public const int MqttKeepAliveInterval 60; // MQTT心跳(s)public const string APSSID YF3300_ESP32S3;public const string APPassword yf123456;public const string APIP 192.168.4.1;public const int APConfigTimeout 600000; // 配网超时(10分钟)public const int SensorReadInterval 30000; // 传感器读取间隔public const int DataUploadInterval 30000; // 数据上传间隔}}2. YFLink 协议模型 (Models/YFLinkModels.cs)YFLink协议使用JSON格式通过MQTT通信所有请求都包含id、ver版本号1.3.0、timestamp三个基础字段。Models/YFLinkModels.csusing System.Collections;namespace YeFanIoTTest.Models{// 基础请求/响应public class YFLinkRequest{public int id { get; set; } // 消息IDpublic string ver { get; set; } 1.3.0; // 协议版本public long timestamp { get; set; } // Unix毫秒时间戳}public class YFLinkResponse{public int id { get; set; }public int code { get; set; } // 200成功public string message { get; set; }}// ★ 属性上传public class PropertyPostRequest : YFLinkRequest{public Hashtable parameters { get; set; } // 属性键值对}// 事件上传public class EventPostRequest : YFLinkRequest{public ArrayList parameters { get; set; } // 事件数据列表}public class EventData{public int type { get; set; } // 0-信息 1-告警 2-故障public int code { get; set; } // 事件编码public string content { get; set; } // 事件内容(≤1024字节)public long time { get; set; } // 事件时间戳}// 服务下发云端→设备public class ServiceSendRequest : YFLinkRequest{public int serviceType { get; set; } // 0-命令 1-参数public ServiceParams parameters { get; set; }}public class ServiceParams{public string command { get; set; }public string parameter { get; set; }}// NTP校时public class NtpRequest : YFLinkRequest{public NtpParams parameters { get; set; }}public class NtpParams{public long deviceSendTime { get; set; }}public class NtpResponse : YFLinkResponse{public NtpResponseParams parameters { get; set; }}public class NtpResponseParams{public long deviceSendTime { get; set; }public long serverRecvTime { get; set; }public long serverSendTime { get; set; }}}3. MQTT 连接与YFLink认证 (Managers/MqttClientManager.cs)这是与叶帆物联网平台通信的核心代码包含YFLink协议的三元组认证HMAC-SHA1签名。3.1 MQTT连接参数// MQTT服务器private const string MqttServer iot.yfios.net;private const int MqttPort 1883;// YFLink三元组private const string ProjectId YFIoT_TEST;private const string ProductId YF3300_ESP32S3;private const string DeviceId YF3300_ESP32S301;private const string DeviceKey dxR99LCS7Uldc7KUnurFBeBi;// MQTT主题V1.3.0格式private const string PropertyPostTopic {0}/{1}/{2}/property/post; // 属性上传private const string EventPostTopic {0}/{1}/{2}/event/post; // 事件上传private const string ServiceSendTopic {0}/{1}/{2}/service/send; // 服务下发3.2 HMAC-SHA1 认证算法认证公式clientId {项目ID}-{产品ID}-{设备ID}userName {项目ID}{产品ID}{设备ID}password HMAC-SHA1(DeviceKey, clientId userName).toLowerCase(hex)Managers/MqttClientManager.cs - Connect方法public bool Connect(){// clientId: YFIoT_TEST-YF3300_ESP32S3-YF3300_ESP32S301// userName: YFIoT_TESTYF3300_ESP32S3YF3300_ESP32S301// password: HMAC-SHA1签名 → 小写十六进制string clientId ${ProjectId}-{ProductId}-{DeviceId};string username ${ProjectId}{ProductId}{DeviceId};string password CalculateHmacSha1(clientId username, DeviceKey).ToLower();_mqttClient new MqttClient(MqttServer, MqttPort, false, null, null, MqttSslProtocols.None);// 注册回调_mqttClient.MqttMsgPublishReceived OnMessageReceived;_mqttClient.ConnectionClosed OnConnectionClosed;var result _mqttClient.Connect(clientId, username, password, false, 60);if (result MqttReasonCode.Success){SubscribeServiceTopic(); // 订阅服务下发主题return true;}return false;}3.3 属性上传属性上传使用自定义JSON序列化nanoFramework的System.Text.Json功能有限public bool PublishProperties(Hashtable properties){var request new PropertyPostRequest{id GenerateMessageId(),timestamp GetCurrentTimestamp(),parameters properties // { H:36.2, T:29.3, I1:0, I2:0, Q1:0 }};string json SerializeToJson(request);string topic string.Format(PropertyPostTopic, ProjectId, ProductId, DeviceId);_mqttClient.Publish(topic, Encoding.UTF8.GetBytes(json), null, null,MqttQoSLevel.AtLeastOnce, false);return true;}上传的JSON格式{id: 1234578,timestamp: 1716355200000,params: {H: 36.2,T: 29.3,I1: 0,I2: 0,Q1: 0}}
