简介基于STM32F103与W5500以太网模块的物联网实战源码面向单片机开发者、物联网爱好者及智慧养老、智慧医疗、智慧农业等场景从业者解决设备快速接入阿里云平台并实现远程控制与数据上报的需求。资源包含完整KEIL工程支持MQTT协议主动上报温湿度与继电器状态同时接收云平台下发指令执行控制并附有硬件设计、软件开发与联网调试的联络支持。资源包共218个文件以C源码48个.c、头文件50个.h、编译中间文件及Keil工程配置为主另有hex烧录文件、uvprojx工程文件与调试辅助文件整体约6.99MB目录结构清晰便于二次开发与移植。已有1587人学习浏览适合具备基础STM32开发经验、希望参考完整MQTT上云例程的工程师快速上手。1. 为什么是W5500而不是ESP8266有线接入阿里云的工程逻辑做物联网设备接入阿里云很多开发者第一反应是ESP8266但在这个项目里选择W5500是基于一个很重要的工程现实当设备处于工业现场、养鸡棚、机房或者医疗设备旁边时Wi-Fi的稳定性往往撑不起7×24小时的数据上报任务。W5500内置了完整的TCP/IP协议栈MCU只需要通过SPI接口读写寄存器就可以完成网络通信不占用STM32的协议栈开销也不会因为Wi-Fi信道拥塞导致掉线。本项目以STM32F103C8T6为主控通过SPI驱动W5500再以MQTT协议接入阿里云物联网平台实现温湿度采集上报、继电器状态同步和云端下发控制指令。整个代码基于KEIL工程直接烧录即可运行。适合正在做智慧农业、智慧养老、智慧医疗等场景的单片机开发者尤其是那些需要可靠网络链路的设备接入方案。2. W5500从寄存器到SocketSPI驱动与以太网链路搭建2.1 W5500的SPI帧格式和寄存器映射W5500和STM32之间只有4根线SCS、SCLK、MOSI、MISO。它是标准的SPI从设备但和普通SPI外设不同的是W5500的SPI帧不是简单的地址加数据而是固定为地址段16位 控制段8位 数据段可变长度。uint8_t W5500_ReadByte(uint32_t reg_addr, uint8_t block) { uint8_t data 0; SPI_CS_LOW(); SPI_SendByte((uint8_t)(reg_addr 8)); // 地址高8位 SPI_SendByte((uint8_t)(reg_addr 0xFF)); // 地址低8位 SPI_SendByte((block 3) | 0x00); // 控制字节读模式 data SPI_ReceiveByte(); SPI_CS_HIGH(); return data; }这段代码看起来简单但有一个关键参数容易被忽略控制字节的BIT2-BIT0决定当前操作的是哪个寄存器块。W5500内部寄存器分为公共寄存器块、Socket 0-7寄存器块和TX/RX Buffer块。在后续的驱动封装中block参数非常重要。比如读写Socket 0的发送缓冲区时控制字节是(block2) 3对应0x10而不是0x00。如果你把Socket寄存器当成公共寄存器来读写最典型的故障就是W5500的Socket状态一直停留在SOCK_CLOSED无法进入SOCK_INIT。2.2 Socket方式的网络层封装W5500和STM32的分工是明确且合理的网络层、传输层由W5500硬件处理应用层数据的产生和解析由STM32处理。在这种架构下STM32程序里不会出现TCP三次握手的状态机代码你需要做的是按照W5500的Socket API流程来操作。uint8_t W5500_Socket_Connect(uint8_t sock, uint8_t *dest_ip, uint16_t dest_port) { // 设置目的IP和端口 W5500_WriteByte(SOCK_REG(sock, Sn_DIPR0), dest_ip[0]); W5500_WriteByte(SOCK_REG(sock, Sn_DPORT0), (uint8_t)(dest_port 8)); W5500_WriteByte(SOCK_REG(sock, Sn_DPORT1), (uint8_t)(dest_port 0xFF)); // 执行OPEN命令 W5500_WriteByte(SOCK_REG(sock, Sn_CR), SOCK_CR_OPEN); DelayMs(10); // 检查状态 uint8_t status W5500_ReadByte(SOCK_REG(sock, Sn_SR), 1); if (status SOCK_INIT) { // 执行CONNECT命令 W5500_WriteByte(SOCK_REG(sock, Sn_CR), SOCK_CR_CONNECT); // 等待连接建立 uint32_t timeout 0; do { DelayMs(5); status W5500_ReadByte(SOCK_REG(sock, Sn_SR), 1); timeout; } while ((status ! SOCK_ESTABLISHED) (timeout 100)); return (status SOCK_ESTABLISHED) ? 1 : 0; } return 0; }SOCK_REG(sock, Sn_CR)是一个宏定义等价于(sock * 0x100 Sn_CR)也就是把Socket 0-7的寄存器偏移算出来。这里有一个容易忽略的细节SOCK_REG的偏移计算中Sn_CR是相对于该Socket基地址的偏移实际读取时要把sock * 0x100加上。上面的SOCK_CR_OPEN和SOCK_CR_CONNECT命令值分别是0x01和0x04。如果你的代码执行了SOCK_CR_CONNECT但一直返回超时重点检查是不是在SOCK_INIT状态下才发的CONNECT指令。2.3 DHCP静态IP的策略选择W5500自带的硬字库里有DHCP客户端功能但在这个项目里推荐使用静态IP原因如下一是设备放在内网固定IP有助于远程调试时直接抓包诊断二是如果把分配到的IP写入配置参数反而增加了外部依赖。静态IP配置只需要四段字节uint8_t local_ip[4] {192, 168, 1, 88}; uint8_t subnet[4] {255, 255, 255, 0}; uint8_t gateway[4] {192, 168, 1, 1}; W5500_WriteByte(COMMON_REG(SHAR), local_ip[0]); // 源IP地址 W5500_Set_Subnet(subnet); W5500_Set_Gateway(gateway);阿里云MQTT要求的网络链路是设备出公网所以网关地址必须写对否则TCP SYN包无法出局域网。很多开发者在本地测试时使用192.168.31.x网段如果无线路由器做了AP隔离即使IP、掩码都正确也无法和阿里云建立MQTT连接。我一般会在初始化完成后用PING命令验证一下网关的连通性但这需要额外代码在串口输出调试时很有用。3. MQTT客户端协议解析与阿里云连接参数封装3.1 CONNECT报文的结构拆解MQTT协议本身不复杂难点在于把报文按协议规范逐字节组装并保证KeepAlive逻辑能在W5500的Socket上正常工作。MQTT报文的最小单位是固定报头1字节控制包类型1字节剩余长度然后才是变长报头和数据区。这就是为什么网上很多移植代码里会看到一大串uint8_t buffer[256]的赋值语句——实际上就是逐字节组装。以CONNECT报文为例连接阿里云时需要进行三处改编报文段阿里云要求说明Payload中的ClientID固定格式deviceNamesecuremode3,signmethodhmacsha1,timestampxxxUsername格式deviceNameproductKey两个参数用连起来不是下划线Password对productKey、deviceName等组合参数做HMAC-SHA1签名后转十六进制字符串签名串的拼接顺序不能错关键代码体现在密码签名那一步因为STM32F103没有硬件加密外设需要引入一个轻量级的HMAC-SHA1算法文件。很多下载包里已经包含了hmac_sha1.c你在KEIL工程里不要漏掉添加。// 签名内容deviceName productKey deviceSecret timestamp char sign_source[128]; sprintf(sign_source, deviceName%sproductKey%stimestamp%s, deviceName, productKey, timestamp); uint8_t mac[20]; HmacSha1((uint8_t*)sign_source, strlen(sign_source), (uint8_t*)deviceSecret, strlen(deviceSecret), mac); // 将mac[20]转换为40字节的十六进制字符串作为Password for (int i 0; i 20; i) { sprintf(password[2*i], %02x, mac[i]); }这里的deviceSecret是三元组中最敏感的字段如果你是直接烧录调试可以写死在config.h里但如果是给别人交付源码建议做成一个独立的参数配置文件并明确标注需要用户自行替换。HMAC-SHA1签名结果的十六进制需要全部小写这一点阿里云的签名校验是区分大小写的一旦写成了大写连接服务器会直接返回CONNACK拒绝。3.2 PUBLISH报文的主题与QoS选择阿里云的物模型通信遵循一个固定的Topic格式设备上报属性/sys/{productKey}/{deviceName}/thing/event/property/post云端下发属性设置/sys/{productKey}/{deviceName}/thing/service/property/set在这个项目里温湿度就是两个属性继电器的开关状态也是属性。Topic里的productKey和deviceName和CONNECT报文里填的是同一组一旦不匹配就会被阿里云直接断开。QoS建议全部设为0。原因有两个其一W5500的硬件TCP协议栈本身就带了ACK重传机制MQTT层的QoS1会在此基础上再增加一次PUBACK握手双重确认在高延迟链路上反而带来更多的交互数据量其二阿里云物联网平台对设备端和云端之间的QoS1报文数量有一定限制如果设备每次上报都使用QoS1在频繁采集数据的场景下容易触发流控策略导致连接被服务端短暂拉黑。上报属性的MQTT报文我来写一个最小可用的组装函数static void Mqtt_PublishProperty(float temp, float humi, uint8_t relay_status) { char payload[256]; // 按阿里云物模型JSON格式组织属性数据 sprintf(payload, {\id\:\123\,\version\:\1.0\,\params\:{\Temperature\:%.2f,\Humidity\:%.2f,\RelayStatus\:%d},\method\:\thing.event.property.post\}, temp, humi, relay_status); uint8_t pkt[512]; // 固定报头PUBLISH(0x30) QoS0主题名后面跟payload uint8_t topic_len strlen(topic_property_post); pkt[0] 0x30; // bit3: DUP0, QoS0, RETAIN0 pkt[1] (uint8_t)(2 topic_len strlen(payload)); // 剩余长度 pkt[2] (uint8_t)(topic_len 8); pkt[3] (uint8_t)(topic_len 0xFF); memcpy(pkt[4], topic_property_post, topic_len); memcpy(pkt[4 topic_len], payload, strlen(payload)); W5500_Socket_Send(sock_mqtt, pkt, 4 topic_len strlen(payload)); }剩余长度字段的编码方式是MQTT里最容易出错的点之一。当前例子中剩余长度小于128所以1字节就能表示。但如果你的payload很大超过127字节剩余长度就需要用可变长编码低7位存储数据第8位作为连续位。建议在工程里写一个Mqtt_EncodeLength函数来统一处理这样后续添加OTA或文件上传功能时不用返工。3.3 KeepAlive心跳和连接保活的状态机阿里云物联网平台的服务端会在45秒内没有收到任何报文的情况下主动关闭连接。所以客户端需要在保活时间内持续发送PINGREQ报文。W5500的Socket连接一旦被服务端断开自己不会主动感知只有在发送数据时才会通过Sn_SR状态反映出来。这里就需要在MCU的主循环里维护一个MQTT层的状态机。typedef enum { MQTT_STATE_DISCONNECTED 0, MQTT_STATE_CONNECTING, MQTT_STATE_CONNECTED, MQTT_STATE_RECONNECT_WAIT } mqtt_state_t; // 在主循环中每100ms调用一次 void Mqtt_Task(void) { static uint32_t last_heartbeat 0; switch (mqtt_state) { case MQTT_STATE_CONNECTED: // 每60秒发送一次PINGREQ if (GetTickMs() - last_heartbeat 60000) { W5500_Socket_Send(sock_mqtt, (uint8_t*)\xC0\0, 2); last_heartbeat GetTickMs(); } break; case MQTT_STATE_RECONNECT_WAIT: // 重连退避避免频繁撞上服务端的限流 if (GetTickMs() - last_heartbeat 30000) { Mqtt_ConnectServer(); } break; default: break; } }PINGREQ报文本身就是固定报头\xC0剩余长度\x00总共2字节。服务端回应的是\xD0\x00的PINGRESP。在调试时用Wireshark抓包是最直观的比如抓包后你会看到每个约60秒出现一次PINGREQ和PINGRESP的往返。值得留意的是阿里云在TCP半开连接检测上相当积极如果你的W5500长时间没有发送数据且网络中间设备断了链路等你想发数据时Socket状态还是ESTABLISHED只有实际发送时才会触发重传继而发现连接已死。所以建议在MQTT_STATE_CONNECTED状态下每次上报数据后不要清空心跳计时器而是让PINGREQ独立运行这样故障发现时间可控。4. 阿里云物模型定义与JSON数据流的双向链路4.1 阿里云控制台的产品创建与功能定义要让设备接上阿里云代码只占一半另一半在云端的物模型设计和Topic配置上。在物联网平台控制台创建产品时节点类型选择设备联网方式选择以太网数据格式推荐选择ICA标准数据格式也就是JSON格式因为W5500的RAM有限不适合透传模式还要自己设计物模型解析逻辑。定义三个属性即可满足这个项目的核心功能属性标识符数据类型读写类型说明Temperaturefloat只读上报温度值精度0.01Humidityfloat只读上报湿度值精度0.01RelayStatusintBool读写云端可下发0或1控制继电器三个属性的标识符和你在代码里拼JSON时的key必须完全一致包括大小写。很多初学者在测试时发现数据上报成功但控制台看不到数据通常就是这里不一致。还有个细节是你需要在产品详情页找到productKey和productSecret并把设备注册后生成的deviceSecret填到STM32的代码里。4.2 设备端如何接收云端下发的指令接收云端下发指令有两种典型方式第一种是在MQTT层订阅属性设置Topic第二种是让设备上报数据后云端通过服务调用下发。本项目用的是订阅模式设备端在连接成功后要立即发送SUBSCRIBE报文订阅下行Topic// 订阅下行Topic: /sys/{productKey}/{deviceName}/thing/service/property/set uint8_t sub_pkt[256]; uint16_t topic_len strlen(topic_property_set); sub_pkt[0] 0x82; // SUBSCRIBE报文固定报头0x82 sub_pkt[1] (uint8_t)(2 2 topic_len 1); // 报文标识符2字节 Topic长度2字节 Topic QoS1字节 sub_pkt[2] 0x00; sub_pkt[3] 0x01; // 报文标识符 sub_pkt[4] (uint8_t)(topic_len 8); sub_pkt[5] (uint8_t)(topic_len 0xFF); memcpy(sub_pkt[6], topic_property_set, topic_len); sub_pkt[6 topic_len] 0x00; // 请求的QoS级别 W5500_Socket_Send(sock_mqtt, sub_pkt, 6 topic_len 1);SUBSCRIBE报文的剩余长度计算里容易漏掉报文标识符的2字节这会导致报文结构错乱服务端返回SUBACK的报文标识符不匹配设备端可能一直收不到控制指令。收到SUBACK后报文类型为0x90再确认返回码是否为0x00成功然后再进入主循环的接收解析流程。4.3 W5500接收环形缓冲与JSON字段解析W5500的RX Buffer默认8KB如果收到的数据量不大可以简化成一个线性缓冲逐个字节读取。实际项目中我建议直接在Socket的接收函数中处理。uint16_t len W5500_Socket_Recv(sock_mqtt, rx_buffer, sizeof(rx_buffer)); if (len 0) { // 逐条取出MQTT报文 switch (rx_buffer[0] 0xF0) { case 0x30: // PUBLISH // 从报文里提取Topic和Payload Mqtt_HandlePublish(rx_buffer, len); break; case 0xD0: // PINGRESP心跳保活通了 break; default: break; } }Mqtt_HandlePublish里要做的是找到Topic字段的位置判断是不是property/set这个Topic如果是就提取Payload中的JSON然后用cJSON库解析出params下的RelayStatus值。cJSON在STM32上跑完全没问题但注意cJSON的malloc/free在高频调用下会产生内存碎片建议在任务里复用JSON解析对象并使用cJSON_Delete及时释放。解析到RelayStatus的值后通过GPIO控制PB12引脚的继电器。cJSON *root cJSON_Parse(payload); if (root ! NULL) { cJSON *params cJSON_GetObjectItem(root, params); cJSON *relay cJSON_GetObjectItem(params, RelayStatus); if (cJSON_IsNumber(relay)) { GPIO_WriteBit(GPIOB, GPIO_Pin_12, relay-valueint ? Bit_SET : Bit_RESET); // 更新本地状态等待下一次上报时同步到云端 local_relay_status relay-valueint; } cJSON_Delete(root); }注意这里的GPIO用的是GPIO_WriteBit而不是GPIO_SetBits或GPIO_ResetBits这是为了统一控制逻辑。典型的错误是在条件判断中把RelayStatus误写成relay_status和物模型标识符大小写不一致解析永远返回NULL。4.4 上报频率和QoS的进阶取舍温湿度传感器使用DHT11或SHT30采集周期建议不低于2秒一次。DHT11本身的数据更新周期就是1秒太快没有意义而且高频上报会给MQTT链路带来不必要的负载。在阿里云平台的设备-日志服务里可以看到每条消息的记录如果上报频率过高排查问题时日志刷新太快很难定位有效信息。我一般会设置一个5秒的上报周期既能满足WEB控制页面的实时性要求又不会因为频繁发送导致W5500的TX Buffer溢出。5. KEIL工程移植的硬件边界与调试手法5.1 芯片型号切换和FLASH容量配置这个工程原本在STM32F103C8T6上运行如果换到其他型号只需要在KEIL的魔术棒界面修改Device栏的芯片型号以及Target标签页里的IROM1起始地址和大小。比如从C8T6的64KB Flash换到RCT6的256KB Flash就需要把IROM1的Size从0x10000改成0x40000起始地址都是0x08000000不变。如果工程里开了USE_STDPERIPH_DRIVER宏还要检查芯片型号对应的stm32f10x.h中的器件系列宏比如STM32F10X_MD还是STM32F10X_HD这决定了启动文件使用的是startup_stm32f10x_md.s还是hd.s。宏定义选错最直观的表现是程序下进去不跑或跑飞且调试时看不出明显问题。下载器方面工程需要对应KEIL的Debug选项卡中ULINK/JLINK/ST-Link的选择。当前代码如果用ST-Link在Flash Download里勾选Reset and Run地址范围要和IROM1匹配。如果在烧录时看到Flash Download failed - Cortex-M3优先检查芯片型号和Utilities中的Settings里的Flash大小是否匹配。5.2 Wireshark抓包验证MQTT连接全过程验证整个链路是否正确最直接的方法不是看串口打印而是用一个通道把W5500的报文镜像出来。这里有一个可执行的调试技巧在STM32和W5500之间加一个SPI逻辑分析仪或者直接在代码里把W5500_Socket_Send和Socket_Recv中的所有数据通过串口打印到PC端在PC上用Wireshark打开串口捕获的数据。如果你用串口打印报文建议使用XCOM或SSCOM工具将串口接收到的数据保存为二进制文件然后用Wireshark的Import from Hex Dump功能导入。注意导入时要选择封装类型为Raw IPWireshark才会自动解析TCP/IP报文。这样你可以清晰看到CONNECT报文的Payload里是否包含正确格式的ClientId和Username。如果看到服务端回的是CONNACK的第二字节为0x05未授权说明三元组或签名有问题去检查ProductKey和DeviceSecret的拼接字符。另一种验证手段是直接看W5500的Sn_SR寄存器值。连接成功时Sn_SR为0x17SOCK_ESTABLISHED数据发送后变为SOCK_SEND等短暂状态然后恢复。如果Sn_SR一直停留在SOCK_INIT或SOCK_CLOSED说明TCP三次握手都没完成这个时候问题大概率出在网络层而不是MQTT层。这是判断方向的分水岭停留在SOCK_INIT查MAC和IP配置若是SYNSENT则查路由和防火墙若是ESTABLISHED但发不出数据才查MQTT代码。5.3 一个容易被忽略的重连机制缺陷在MQTT连接断开后重连时W5500的Socket需要先执行DISCONNECT命令然后重新走OPEN - CONNECT流程。如果W5500的硬件缓冲里还有未发送完的数据直接重新OPEN可能导致TCP序列号错乱服务端丢弃连接或触发RST。所以在每次重连前要执行。W5500_WriteByte(SOCK_REG(sock, Sn_CR), SOCK_CR_DISCON); DelayMs(50); W5500_WriteByte(SOCK_REG(sock, Sn_CR), SOCK_CR_CLOSE); DelayMs(50);另外阿里云平台的设备连接有时间戳的有效窗口timestamp参数在CONNECT报文中和当前UTC时间偏差超过一定阈值时签名验证会直接失败。如果设备没有带RTC或没有做NTP时间同步那你的CONNECT报文里的timestamp就会是一个固定的历史时间第一次连接也许不会失败但在设备冷启动后再次连接、或者云端时间偏移超过限制后会收到错误码。处理方式一是用阿里云的时间服务器做一个简单的SNTP请求二是直接用0值并开启securemode2的TLS模式但W5500硬件不支持TLS更务实的方案是每次设备上电时先通过UDP访问ntp.aliyun.com获取当前时间戳再填入CONNECT报文ntp.aliyun.com的解析上可以用阿里云的公共DNS固定IP203.107.6.88。本文还有配套的精品资源点击获取