简介面向物联网场景的完整嵌入式代码工程基于STM32F103通过SPI驱动W5500以太网模块并借助MQTT协议接入阿里云物联网平台实现温湿度上报和远程Web控制继电器。方案覆盖智慧养老、智慧医疗、智慧农业等典型应用适合有单片机基础、希望参照完整项目做设备上云开发的工程师或学生。工程使用KEIL编写当前在STM32F103C8T6上运行换用其他F103型号时只需调整芯片型号和Flash容量代码包含数据上行、指令下行、继电器状态反馈、温湿度采集等关键模块。压缩包共218个文件以C源码、H头文件和uvprojx工程文件为主兼顾hex、axf等编译产物及标准外设驱动整体大小6.99MB可直接打开编译或烧录。目前已有1587人学习下载对于快速理解MQTT对接阿里云、W5500网络编程和嵌入式项目结构都有实际参考价值。1. 一条STM32W5500的MQTT链路为什么会成为物联网项目的首选模板很多人在做基于STM32的毕业设计或产品原型时第一直觉是给板子挂个ESP8266或GSM模块走Wi-Fi/4G联网但一旦遇到厂房、机柜、楼道这类需要稳定在线、长时间连续运行的场景Wi-Fi的掉线重连和4G的流量成本就会变成头号麻烦。相比之下STM32W5500通过以太网口直连有线网络W5500硬件协议栈把TCP/IP从MCU中解放出来再叠加一个开源的MQTT客户端以不到10KB的RAM占用接入阿里云物联网平台。整套方案把设备端从无脑收发提升到了可双向控制设备往云端上报温湿度云端下发继电器开关指令用户在浏览器或手机上操作WEB控制台即时生效。整个链路不依赖路由器做端口映射也无需设备端暴露公网IP安全性和可维护性都更有保障。这个方案最适合两类人一类是准备用STM32做毕设或竞赛项目的学生想完整体验从裸机驱动到云平台联调的全过程另一类是负责产线设备信息化的工程师需要在不改动现有工业以太网架构的前提下用低成本模组把传统继电器设备接入物联网平台。接下来我会按照自己实际做过的移植顺序从W5500的底层初始化讲起一步步拆到MQTT报文封装、阿里云签名鉴权最后补上WEB控制链路中容易被忽视的几个细节保证你拿到思路就能自己在开发板上复现。2. 底层准备W5500的SPI驱动、Socket初始化与网络参数该如何设置2.1 先搞清W5500把TCP/IP栈替你做了哪些事W5500是WIZnet推出的一款硬核TCP/IP以太网控制器内置10/100M以太网MAC和PHY唯一需要MCU介入的是通过SPI访问其内部寄存器区和Socket缓冲区。它最大的价值在于TCP的三次握手、四次挥手、重传、分片、ARP、ICMP等协议处理全部由芯片内部的硬件逻辑完成不需要在STM32上跑lwIP或uIP协议栈也不需要为协议栈分配大量堆内存。这意味着你在代码层面不必操心以太网帧是如何封装和解析的只需要把注意力集中在两件事上一是正确初始化W5500的PHY配置和Socket寄存器二是用一个环形缓冲去处理收发数据。常见做法是把W5500挂到STM32的SPI2上片选引脚、复位引脚各占用一个GPIO然后按datasheet规定的时序完成上电复位。2.2 STM32 SPI2初始化与W5500寄存器读写的最小代码下面这段初始化代码是一个可用的基础版本适用STM32F103系列SPI时钟配置为9MHz能满足W5500的最高SPI时钟限制通常在33.3MHz以内但实际走线过长时建议降到10MHz以下。void W5500_Init(void) { GPIO_InitTypeDef GPIO_InitStructure; SPI_InitTypeDef SPI_InitStructure; // 使能SPI2和GPIOB/GPIOC时钟 RCC_APB1PeriphClockCmd(RCC_APB1Periph_SPI2, ENABLE); RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB | RCC_APB2Periph_GPIOC, ENABLE); // SPI2_SCK: PB13, SPI2_MISO: PB14, SPI2_MOSI: PB15 GPIO_InitStructure.GPIO_Pin GPIO_Pin_13 | GPIO_Pin_14 | GPIO_Pin_15; GPIO_InitStructure.GPIO_Mode GPIO_Mode_AF_PP; GPIO_InitStructure.GPIO_Speed GPIO_Speed_50MHz; GPIO_Init(GPIOB, GPIO_InitStructure); // W5500_RST - PC5, W5500_SCS - PC6 GPIO_InitStructure.GPIO_Pin GPIO_Pin_5 | GPIO_Pin_6; GPIO_InitStructure.GPIO_Mode GPIO_Mode_Out_PP; GPIO_Init(GPIOC, GPIO_InitStructure); GPIO_SetBits(GPIOC, GPIO_Pin_5 | GPIO_Pin_6); SPI_InitStructure.SPI_Direction SPI_Direction_2Lines_FullDuplex; SPI_InitStructure.SPI_Mode SPI_Mode_Master; SPI_InitStructure.SPI_DataSize SPI_DataSize_8b; SPI_InitStructure.SPI_CPOL SPI_CPOL_Low; SPI_InitStructure.SPI_CPHA SPI_CPHA_Low; SPI_InitStructure.SPI_NSS SPI_NSS_Soft; SPI_InitStructure.SPI_BaudRatePrescaler SPI_BaudRatePrescaler_8; SPI_InitStructure.SPI_FirstBit SPI_FirstBit_MSB; SPI_InitStructure.SPI_CRCPolynomial 7; SPI_Init(SPI2, SPI_InitStructure); SPI_Cmd(SPI2, ENABLE); W5500_RST_LOW(); delay_ms(10); W5500_RST_HIGH(); delay_ms(200); // 等待PHY就绪 W5500_Write_Reg(VERSIONR, 0x00); // 读取版本寄存器验证SPI通路 }初始化流程中有两个细节值得留意复位后必须延时至少150ms再开始写寄存器因为W5500内部PHY上电需要时间完成自校准之后读取VERSIONR寄存器地址0x0039时如果返回值是0x04就说明SPI收发通路正常。若读到0xFF或0x00先查硬件接线和SPI极性配置这能在移植初期节省大量排查时间。2.2.1 Socket的初始化与TCP连接参数表W5500有8个独立的Socket每个Socket都是一组寄存器加一个收发缓冲区。建立TCP连接到阿里云MQTT服务器时你需要额外配置以下几个关键参数目标IP、目标端口、源端口、Socket工作模式以及收发包超时时间。以下是一份在多个项目中验证过的参数对照实际开发时直接套用即可参数名称推荐值说明Socket_n_MR0x01TCP模式Socket寄存器中的协议模式选择Socket_n_CR0x01OPEN打开Socket之后依次执行0x04CONNECTSn_DIPR/Sn_DPORT阿里云IP / 1883目标服务器地址与MQTT端口Sn_PORTR1024~65535随机值本地源端口用于区分不同连接SOCKET_TIMEOUT2000ms连接失败后重试的间隔时间避免频繁重连uint8_t W5500_Socket_Connect(uint8_t sn, uint8_t *ip, uint16_t port, uint16_t local_port) { W5500_Write_Reg16(Sn_PORT(sn), local_port); // 设置本地端口 W5500_Write_Reg(Sn_MR(sn), 0x01); // TCP模式 W5500_Socket_CMD(sn, 0x01); // OPEN命令 // 写入目标IP与端口 W5500_Write_Buffer(Sn_DIPR(sn), ip, 4); W5500_Write_Reg16(Sn_DPORT(sn), port); W5500_Socket_CMD(sn, 0x04); // CONNECT命令 uint32_t timeout 2000; while (timeout--) { uint8_t status W5500_Read_Reg(Sn_SR(sn)); if (status 0x00) // SOCK_ESTABLISHED return 0; delay_ms(1); } return 0xFF; // 连接超时 }注意这里发送CONNECT命令之后不能立刻去检查目标端口是否可通而是要看Sn_SR寄存器是否从SOCK_INIT0x13跳到SOCK_ESTABLISHED0x00。如果一直停留在SOCK_INIT基本可以断定网络不通或目标IP不可达此时再用ping命令验证一下本地网关与DNS配置是否正确比反复修改代码高效得多。2.3 静态IP与DHCP取舍生产环境建议直接绑定静态IPW5500内部没有DHCP客户端动态获取IP需要你额外移植DHCP代码而且如果路由器没有做IP-MAC绑定每次DHCP租约更新后获取到的IP都可能变化导致后面定位问题变麻烦。在工业以太网场景下布设设备时直接给每块板子分配固定的IP地址更可靠。设备上电后代码里把IP、网关、子网掩码写入SIPR、GAR、SUBR寄存器组即可完整示例代码如下void W5500_Net_Config(uint8_t *ip, uint8_t *mask, uint8_t *gateway) { W5500_Write_Buffer(SIPR, ip, 4); W5500_Write_Buffer(SUBR, mask, 4); W5500_Write_Buffer(GAR, gateway, 4); // 通过DNS解析获得阿里云MQTT服务器域名可选 // W5500也支持DNS功能需要外部提供DNS服务器地址 uint8_t dns[4] { 8, 8, 8, 8 }; W5500_Write_Buffer(Sn_DNSR, dns, 4); // 有些库版本用私有寄存器 }配好IP之后下一步才能进入TCP层之上的MQTT协议封装。这也是整个方案中最核心、代码量最大的部分虽然W5500处理了TCP/IP层但MQTT协议报文依旧需要你手动构造。3. 阿里云IoT平台的设备接入参数MQTT连接、HMAC鉴权与物模型Topic3.1 在阿里云控制台创建产品和设备的完整步骤阿里云物联网平台的位置在产品首页搜索物联网平台即可进入。创建流程非常固定新建产品时选择节点类型为设备联网方式选以太网数据格式选ICA标准数据格式Alink JSON。产品创建完成后在产品下添加设备系统会生成设备证书三元组参数示例用途ProductKeya1pKxlJmGdf标识产品全局唯一DeviceNamerelay_001设备标识同一产品下唯一DeviceSecret4e3d2c1f8a9b...设备密钥用于HMAC-SHA1签名这三个参数需要烧录到STM32的Flash或配置文件中千万不要把DeviceSecret明文写到公共代码仓库即使只是毕设也建议把密钥单独定义到一个device_config.h头文件中并加入gitignore。除了三元组还需要在产品功能定义中添加物模型属性。在这个项目里我们需要温度Temperature、湿度Humidity两个只读属性以及继电器开关RelaySwitch一个读写属性。系统会自动为每个属性分配标识符后续发布消息时使用。3.2 MQTT CONNECT报文的三元组签名规则与代码实现阿里云IoT平台的MQTT接入地址格式是${ProductKey}.iot-as-mqtt.${RegionId}.aliyuncs.com华东2上海节点的端口是1883。设备端发起MQTT连接时CONNECT报文中的clientId、username、password三个字段必须严格遵循平台规则否则连接直接被拒。以设备名relay_001、产品密钥a1pKxlJmGdf、设备密钥4e3d2c1f8a9b...为例连接参数构造方式为消息字段格式与示例clientIdrelay_001usernamerelay_001a1pKxlJmGdfpasswordHmacSHA1(明文, 设备密钥)其中明文为clientIdrelay_001deviceNamerelay_001productKeya1pKxlJmGdftimestamp2524608000000签名算法是HmacSHA1。这里的clientId可以自定义但必须带上前缀设备名并使用竖线分隔附加参数。timestamp可以填固定值但如果你不填平台会使用系统当前时间容易因为设备时钟偏差导致签权失败。因此在STM32没有RTC电池供电、每次开机时间都不准的情况下建议直接写死一个大一点的timestamp固定值例如填入2524608000000相当于2099年的毫秒时间戳这样签名不受设备时钟漂移影响。void build_auth_info(char *client_id, char *username, char *password, const char *product_key, const char *device_name, const char *device_secret) { char sign_content[200]; char timestamp[] 2524608000000; char sign_method[] hmacsha1; // 构造clientId sprintf(client_id, %s|securemode3,signmethod%s,timestamp%s|, device_name, sign_method, timestamp); // 构造username sprintf(username, %s%s, device_name, product_key); // 构造待签名字符串 sprintf(sign_content, clientId%sdeviceName%sproductKey%stimestamp%s, device_name, device_name, product_key, timestamp); hmac_sha1_hex(sign_content, device_secret, password); // password为40位十六进制小写字符串 }注意签名字符串的拼接顺序是固定的先clientId再deviceName再productKey最后timestamp字符之间没有多余分隔符HMAC密钥用的是DeviceSecret原始字符串。如果连接返回0x02MQTT CONNACK表示不允许连接优先检查password的签名结果是否与阿里云在线签名工具生成的结果一致。这里的hmac_sha1_hex函数可以在标准mbedtls库中复用网上也有大量的轻量实现不必重复造轮子。3.3 物模型的发布订阅Topic与JSON数据格式在阿里云物联网平台中设备端与云端通信的Topic已经预定义好常用的有Topic类型作用Topic示例属性上报设备往云端上报属性/sys/{pk}/{dn}/thing/event/property/post服务下发云端调用设备服务/sys/{pk}/{dn}/thing/service/{identifier}属性设置云端设置设备属性WEB控制用/sys/{pk}/{dn}/thing/service/property/set保护消息设备响应服务调用/sys/{pk}/{dn}/thing/service/{identifier}_reply设备端需要订阅/sys/{pk}/{dn}/thing/service/property/set这个Topic来接收WEB控制台发来的继电器操作指令。指令内容是JSON格式例如{ method: thing.service.property.set, id: 123456789, params: { RelaySwitch: 1 }, version: 1.0 }解析这段JSON时用cJSON库判断params节点下的RelaySwitch值为1表示吸合继电器为0表示断开。这是WEB控制能指哪打哪的核心链路网页按钮 → 阿里云物模型 → MQTT下行 → STM32解析JSON → GPIO拉高/拉低。4. STM32端MQTT客户端落地温湿度上报与继电器下发的完整代码路径4.1 MQTT报文在STM32上如何封装以PUBLISH和PINGREQ为例MQTT协议报文的结构不复杂但是没有现成的官方库可用时很多人会卡在可变头部Variable Header的剩余长度计算上。在STM32上自己封装MQTT报文时核心是构造3种报文CONNECT、PUBLISH、SUBSCRIBE以及周期性的PINGREQ心跳保活。固定头部第一个字节的低4位表示报文类型PUBLISH类型为0x30SUBSCRIBE类型为0x80CONNECT类型为0x10。下面是发送温湿度属性上报最关键的一段函数也是把MQTT PUBLISH报文和物模型JSON组合在一起的完整实现void publish_property(float temperature, float humidity) { char payload[256]; char topic[128]; uint8_t packet[320]; int topic_len, payload_len, remain_len, packet_len; // 构造物模型JSON数据 sprintf(payload, {\method\:\thing.event.property.post\,\id\:\%ld\, \params\:{\Temperature\:%.1f,\Humidity\:%.1f},\version\:\1.0\}, (long)time(NULL), temperature, humidity); // 拼接上报Topic sprintf(topic, /sys/%s/%s/thing/event/property/post, PRODUCT_KEY, DEVICE_NAME); topic_len strlen(topic); payload_len strlen(payload); // 组装PUBLISH报文 packet[0] 0x30; // PUBLISH消息QoS0 remain_len topic_len payload_len; packet[1] remain_len; // 简化实现未处理超过127字节的拓展长度 memcpy(packet[2], topic, topic_len); memcpy(packet[2 topic_len], payload, payload_len); packet_len 2 remain_len; W5500_Socket_Send(SOCKET_MQTT, packet, packet_len); }MQTT要求topic与payload之间有一个长度为2字节的主题长度前缀但阿里云平台对QoS0消息的处理方式是Payload部分整体被视为二进制数据只要JSON格式合法即可上报成功。上面的代码没有加上主题长度前缀如果你直接照着移植到其他MQTT Broker比如自建的Emqx服务器可能会被告知topic不能为空。在实际项目里建议把PUBLISH报文严格按MQTT协议格式组装即在topic前加两字节的topic_len不然后续换平台很痛苦。严格版本的组装方式是在packet[2]处先放topic_len 8和topic_len 0xFF再放topic字符串。参数说明PRODUCT_KEY、DEVICE_NAME在device_config.h里宏定义time(NULL)虽然是从C标准库拿的但在STM32上没有实现时可以直接用一个自增变量替代因为云端只关心id是否唯一不要求它是真实Unix时间戳。这条报文的QoS级别是0意味着如果网络瞬间抖动这条数据可能丢失。对于定时上报的温湿度数据而言QoS0丢失一次半次问题不大但如果你要确保每一次开关指令都到达设备端下行指令必须使用QoS1设备端收到PUBLISH后回发PUBACK。4.2 温湿度采集与数据上报的主循环逻辑温湿度传感器最常见的型号是DHT11和SHT30。DHT11成本低但精度只有±2℃SHT30精度更高且支持I2C接口在STM32上驱动更简单。实际项目中建议选SHT30理由有两个其一DHT11在连续读取时对时序要求非常苛刻稍有中断延迟就会丢数据其二SHT30的I2C地址固定为0x44初始化时只需发送一条0x2C 0x06命令即可进入周期采集模式。主循环的逻辑并不需要复杂到使用操作系统一个简单的while(1)就足够int main(void) { // 系统初始化省略 W5500_Init(); W5500_Net_Config(ip, mask, gateway); network_connect(ip, port); // TCP连接阿里云 mqtt_connect(); // 发送CONNECT报文 mqtt_subscribe_property_set(); // 订阅属性设置Topic while (1) { // 1. 读取温湿度 sht30_read(temperature, humidity); if (temperature 0 || temperature 60) temperature 0; // 滤波保护防止传感器异常数据上报 // 2. 上报属性可带上设备时间戳 publish_property(temperature, humidity); // 3. 处理下行消息非阻塞 handle_downlink_message(); // 4. 心跳保活 if (keepalive_tick 60) { send_pingreq(); keepalive_tick 0; } delay_ms(5000); } }主循环周期设置成5秒一次这个频率能覆盖温度变化速度也不会对阿里云造成过大压力。如果你用DHT11记得在两次采集之间加1秒以上的器件启动延时否则极易读到初始化的错误值。4.3 下行控制订阅property/set主题后如何驱动继电器下行消息处理是整个方案的另一个核心关卡。TCP层收到数据后需要做两个判断第一这个包是不是一个完整的MQTT帧第二消息里的JSON内容是否包含RelaySwitch字段。代码如下void handle_downlink_message(void) { uint16_t len W5500_Socket_Recv(SOCKET_MQTT, rx_buffer, sizeof(rx_buffer)); if (len 0) return; // 简单的报文类型判断0x31表示QoS1的PUBLISH if ((rx_buffer[0] 0xF0) 0x30) { cJSON *root cJSON_Parse((char *)rx_buffer 8); // 跳过固定头部Topic区域 if (root NULL) return; cJSON *params cJSON_GetObjectItem(root, params); cJSON *relay cJSON_GetObjectItem(params, RelaySwitch); if (relay ! NULL) { if (relay-valueint 1) GPIO_SetBits(RELAY_PORT, RELAY_PIN); // 吸合继电器 else GPIO_ResetBits(RELAY_PORT, RELAY_PIN); // 断开继电器 } cJSON_Delete(root); } }这段代码的解析方式是基于固定偏移量实际项目中更稳妥的做法是使用w5500_recv时记录topic长度在解析时跳过2 topic_len字节后再进入cJSON解析。因为阿里云下发的payload前部包含topic和固定头部长度不同Topic消息的开头字节数不同如果直接写死偏移量8一旦服务端Topic长度变化就会解析失败。RelaySwitch是物模型属性定义时的identifier前后必须完全一致大小写搞错会找不到字段。另外继电器驱动外部负载时务必在继电器线圈两端反向并联一个续流二极管并在继电器触点加RC吸收电路否则高压感性负载在开关瞬间产生的大电流毛刺很容易通过地线干扰到W5500的以太网变压器的信号完整性造成偶发性掉线。5. WEB控制链路的搭建与联调技巧5.1 用阿里云IoT Studio快速搭出温湿度仪表盘和开关按钮设备端接入完成后WEB控制端最省力的做法是使用阿里云物联网平台自带的IoT StudioWeb可视化开发。它支持直接关联产品和设备通过拖拽图表组件绑定物模型属性无需写一行前端代码即可生成一个包含实时数据曲线和按钮开关的网页应用。创建时先新建一个空白Web应用然后在左侧组件库拖入仪表盘组件数据源选择设备属性Temperature再拖入一个开关组件绑定属性RelaySwitch。发布后系统会分配一个公网访问链接手机上也能直接打开。如果想要自定义样式也可以选择用设备上行的数据通过阿里云规则引擎流转到RDS数据库再用自己的Vue3前端读取展示但这会多出前后端联调的复杂度对毕设而言IoT Studio完全够用。5.2 联调时观察云端日志和消息轨迹定位掉线问题设备接入后最耗时间的环节就是排错。阿里云IoT平台在控制台提供了几个非常实用的调试入口按排查优先级排序如下排查入口看什么能发现什么问题设备-日志服务上行消息记录设备是否成功上报JSON数据格式是否合法设备-消息轨迹一条消息从设备到云端的全链路状态TCP连接是否存在、ACK是否正常、交付是否超时监控运维-在线调试调用物模型服务下发指令下行指令是否触发设备端订阅回调设备-状态设备在线/离线时间线网络闪断、心跳保活是否丢失掉线上电后先不接传感器让设备空跑并持续发送心跳观察设备在线状态是否能长时间保持绿色。如果在线的同时收到设备端在未操作的情况下自行离线的告警优先查两件事一是W5500的TCPKeepAlive没有开启二是STM32主循环里长时间阻塞导致PINGREQ没有发出去阿里云在超过120秒没有收到任何报文时会主动断开连接。5.3 继电器WEB控制联调时容易忽略的三个键点第一个键点是保活与重连机制。TCP连接被云端断开后设备端不能只在下一轮心跳时才感知必须在数据发送失败时立刻进入重连流程。我习惯的做法是每次send()返回失败后关闭当前Socket重新走一遍TCP连接-MQTT CONNECT-SUBSCRIBE的完整流程而不是只重发数据包因为MQTT session在云端已经重建不重新订阅就收不到下行指令。第二个键点是HMAC签名的细节。阿里云对密码签名结果的大小写不敏感但组装待签名的原始字符串时必须使用clientId{clientId}deviceName{deviceName}productKey{productKey}的顺序。有些教程里把deviceName和productKey写反了这是常见的签名验证失败原因把签名结果和在线工具对比就能快速定位。第三个键点是清除保留会话标志位Clean Session。在MQTT CONNECT报文中将cleanSession标志位置1可以让云端在设备断线后自动清除未确认的下行消息。这个做法在弱网环境中避免设备重连后收到旧消息造成误动作缺点是断线期间平台下发的开关指令会丢失。如果你控制的设备有定时器联锁之类的安全逻辑那么需要改成cleanSession0同时自行承担消息积压带来的重放风险。实践时还可以在W5500的RX缓冲区满的临界值下功夫。默认每Socket收发缓冲区是2KB阿里云下发JSON时如果附带大量在线诊断信息2KB可能被撑满一旦缓冲区溢出收发指针错位后整个Socket都会瘫痪。建议把MQTT使用的Socket收发缓冲dun区扩大至4KB或8KB改W5500的SOCKET_BUFFER_CONFIG寄存器即可代价是W5500总共32KB缓冲区会被占用量增大其他Socket可用的会变小。对目前只用单Socket的项目来说这个取舍非常划算。把缓冲区调大后可以反复按WEB控制台上的开关按钮做100次连续切换测试确认每次点击都能准确控制继电器通断这套基于STM32W5500MQTT的远程控制链路就算完整落地了。本文还有配套的精品资源点击获取