eefocus_4087784 发表于 2026-2-28 16:53:03

零知IDE——基于STM32与W5500的UDP通信实现温湿度监控

​✔零知开源(零知IDE)是一个专为电子初学者/电子兴趣爱好者设计的开源软硬件平台,在硬件上提供超高性价比STM32系列开发板、物联网控制板。取消了Bootloader程序烧录,让开发重心从 “配置环境” 转移到 “创意实现”,极大降低了技术门槛。零知IDE编程软件,内置上千个覆盖多场景的示例代码,支持项目源码一键下载,项目文章在线浏览。零知开源(零知IDE)平台通过软硬件协同创新,让你的创意快速转化为实物,来动手试试吧!✔访问零知实验室,获取更多实战项目和教程资源吧!
www.lingzhilab.com

项目概述
       本项目基于零知增强板(主控STM32F407VET6)结合W5500以太网模块,实现了一套完整的UDP通信温湿度监控系统。系统通过DHT11传感器实时采集环境温湿度数据,通过W5500以太网模块建立UDP通信链路,将数据发送至PC上位机。同时,上位机可通过UDP协议发送控制指令,远程控制开发板上的LED灯开关状态项目难点及解决方案
      问题描述:多网卡路由冲突导致路由表混乱,UDP包丢失解决方案:网段隔离与静态配置,将网络拓扑从混合网段改为独立网段;代码中禁用DHCP功能,网关和DNS强制指向PC的以太网IP;同时网段检测逻辑

一、系统硬件部分1.1 元件清单
硬件名称数量备注
零知增强板(STM32F407VET6)                        1主控核心板
W5500 以太网模块1带 SPI 接口的以太网模块
DHT11 温湿度传感器1数字型温湿度传感器
LED 发光二极管1用于远程控制演示
10K 上拉电阻1DHT11 数据脚需接
杜邦线若干连接各模块
网线1PC 与 W5500 直连
PC(带以太网口)1运行 Python 上位机

1.2 接线方案表请务必严格按照代码中的定义进行连接,否则会导致初始化失败。
零知增强板引脚外接设备设备引脚功能说明
7DHT11DATA温湿度数据传输
8LED正极LED 控制引脚(低电平熄灭)
GNDDHT11/LED/W5500GND公共接地
5VW5500/DHT115V / +供电(W5500 需 5V)
3.3V可选DHT11 (+)DHT11 也可接 3.3V
A5 (SCLK)W5500SCLKSPI 时钟线
A6 (MISO)W5500MISOSPI 主机输入 / 从机输出
A7 (MOSI)W5500MOSISPI 主机输出 / 从机输入
A4 (SCS)W5500CSW5500 片选引脚

1.3 接线示意图

W5500 的 SPI 接线必须严格对应零知增强板 的 SPI 引脚(SCK/MISO/MOSI/CS)

1.4 实物连接图

二、安装与使用部分2.1 开源平台-输入"W5500的UDP通信"并搜索-代码下载自动打开

2.2 连接-验证-上传

2.3 调试-串口监视器


三、核心代码讲解      本项目的代码设计体现了模块化和健壮性的特点,以下将对核心的四个部分进行详细剖析
3.1 网络初始化与配置      网络初始化是本项目的核心,采用PC直连静态IP模式,确保通信稳定
// ==================== 网络配置 - PC直连模式 ====================
byte mac[] = {0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED};

// 静态IP配置
IPAddress staticIP(192, 168, 10, 22);      // W5500的IP
IPAddress gateway(192, 168, 10, 1);      // 设为PC的以太网卡IP
IPAddress subnet(255, 255, 255, 0);      
IPAddress dnsip(192, 168, 10, 1);          // DNS指向PC

// PC的以太网卡IP
IPAddress pcIP(192, 168, 10, 17);

// 网络初始化函数
void initNetwork() {
// 静态IP配置
Ethernet.begin(mac, staticIP, dnsip, gateway, subnet);

// 验证网络配置
IPAddress ip = Ethernet.localIP();
if (ip == IPAddress(0, 0, 0, 0)) {
    Serial.println("✗✗✗ 错误: 以太网初始化失败! ✗✗✗");
    // 错误处理...
}

// 启动UDP服务
Udp.begin(localPort);
}PC以太网卡不提供DHCP服务,必须使用静态IP;网关设置指向PC,点对点直连网络

3.2 DHT11数据采集与处理      DHT11传感器数据采集需要精确的时序控制,并处理可能的读取失败情况
// DHT11初始化
DHT dht(DHTPIN, DHTTYPE);

// 读取DHT数据函数
void readDHTData() {
unsigned long currentTime = millis();

// 每10秒读取一次
if (currentTime - lastDHTReadTime >= 10000) {
    lastDHTReadTime = currentTime;
   
    float h = dht.readHumidity();
    float t = dht.readTemperature();
   
    if (isnan(h) || isnan(t)) {
      Serial.println("✗ DHT11读取失败!");
      dhtValid = false;
    } else {
      humidity = h;
      temperature = t;
      dhtValid = true;
      
      // 发送数据
      sendDHTData();
    }
}
}

// 发送DHT数据函数
void sendDHTData() {
if (dhtValid) {
    messageCount++;
   
    char tempStr;
    char humiStr;
    floatToString(tempStr, temperature, 2);// 2位小数精度
    floatToString(humiStr, humidity, 2);
   
    // 构建JSON格式数据
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"dht\",\"count\":%lu,\"temp\":%s,\"humi\":%s,\"time\":%lu}",
             messageCount, tempStr, humiStr, millis() / 1000);
   
    sendUDP(sendBuffer);
}
}DHT11设置为10秒的读取间隔,使用自定义floatToString()函数处理浮点数

3.3 UDP通信协议解析      实现简单的命令解析机制,支持多种控制指令
// 协议解析函数
void parseCommand(const char* cmd, IPAddress remoteIP, int remotePort) {
// LED_ON命令
if (strcmp(cmd, "LED_ON") == 0) {
    digitalWrite(LED_CONTROL_PIN, HIGH);
    ledControlState = true;
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"LED_ON\",\"status\":\"success\",\"led_state\":true}");
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
}
// GET_DHT命令
else if (strcmp(cmd, "GET_DHT") == 0) {
    float h = dht.readHumidity();
    float t = dht.readTemperature();
   
    if (isnan(h) || isnan(t)) {
      snprintf(sendBuffer, sizeof(sendBuffer),
               "{\"type\":\"response\",\"cmd\":\"GET_DHT\",\"status\":\"error\",\"error\":\"read_failed\"}");
    } else {
      char tempStr;
      char humiStr;
      floatToString(tempStr, t, 2);
      floatToString(humiStr, h, 2);
      
      snprintf(sendBuffer, sizeof(sendBuffer),
               "{\"type\":\"response\",\"cmd\":\"GET_DHT\",\"status\":\"success\",\"temp\":%s,\"humi\":%s}",
               tempStr, humiStr);
    }
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
}
// 其他命令处理...
}支持的命令列表

指令功能说明返回信息
LED_ON点亮LED返回成功状态和LED状态
LED_OFF熄灭LED返回成功状态和LED状态
GET_DHT读取实时温湿度返回数据或错误信息
STATUS获取设备完整状态信息返回设备状态
每个命令都有明确的成功/失败状态返回,接收到命令后立即处理并返回结果

3.4 系统状态维护与心跳机制      系统需要维护多个状态变量,并实现心跳机制确保连接正常// 全局状态变量
unsigned long lastDHTReadTime = 0;    // 上次DHT读取时间
unsigned long lastSendTime = 0;       // 上次发送时间
unsigned long messageCount = 0;       // 消息计数器
unsigned long lastHeartbeat = 0;      // 上次心跳时间

bool dhtValid = false;                // DHT数据有效性
bool ledControlState = false;         // LED控制状态
bool networkInitialized = false;      // 网络初始化状态

unsigned long packetsSent = 0;      // 发送数据包计数
unsigned long packetsReceived = 0;    // 接收数据包计数

// 心跳包发送函数
void sendHeartbeat() {
unsigned long currentTime = millis();

if (currentTime - lastHeartbeat >= 30000) {// 每30秒
    lastHeartbeat = currentTime;
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"heartbeat\",\"uptime\":%lu,\"packets_sent\":%lu,\"packets_received\":%lu}",
             millis() / 1000, packetsSent, packetsReceived);
    sendUDP(sendBuffer);
}
}

// 状态LED指示函数
void updateStatusLED() {
unsigned long currentTime = millis();

if (currentTime - lastBlinkTime >= 500) {// 每500ms闪烁一次
    lastBlinkTime = currentTime;
    ledBlinkState = !ledBlinkState;
    digitalWrite(LED_BUILTIN, ledBlinkState ? LOW : HIGH);
}
}统计发送和接收的数据包数量,用于监控通信质量;定期发送心跳包,让上位机知道设备在线状态

3.5 系统完整代码
/**************************************************************************************
* 文件: W5500_UDP_DHT11_Control.ino
* 作者:零知实验室(深圳市在芯间科技有限公司)
* -^^- 零知实验室,让电子制作变得更简单! -^^-
* 时间: 2026-02-09
* 网络拓扑:
*   路由器(192.168.3.1) ←WiFi→ PC(WiFi: 192.168.3.17, 以太网: 192.168.10.1)
*                                    ↓ 直连网线
*                               W5500(192.168.10.22)
*
* 功能说明:
* W5500以太网模块UDP通信、DHT11温湿度传感器数据采集和上报、远程LED控制功能、简单协议解析和响应、修复JSON浮点数格式化问题(snprintf不支持%f)
************************************************************************************/

#include <SPI.h>
#include <Ethernet_STM.h>
#include <EthernetUdp.h>
#include "DHT.h"

// ==================== 硬件配置 ====================
#define DHTPIN 7
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);

#define LED_CONTROL_PIN 8


// ==================== 网络配置 - PC直连模式 ====================
#if defined(WIZ550io_WITH_MACADDRESS)
// WIZ550io有内置MAC地址
#else
byte mac[] = {0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED};
#endif

//PC直连模式 - 必须使用静态IP!
// PC的以太网卡不提供DHCP服务,所以DHCP无法工作
#define USE_DHCP false

// ==================== 重要: 网段配置说明 ====================
// 使用 192.168.10.x 网段,与PC的WiFi网段(192.168.3.x)分开
// 避免IP冲突和路由混乱

// 静态IP配置
IPAddress staticIP(192, 168, 10, 22);      // W5500的IP
IPAddress gateway(192, 168, 10, 1);      // 设为PC的以太网卡IP
IPAddress subnet(255, 255, 255, 0);      
IPAddress dnsip(192, 168, 10, 1);          // DNS指向PC

// PC的以太网卡IP (连接W5500的那个网卡)
//不是WiFi的IP (192.168.3.17)!
IPAddress pcIP(192, 168, 10, 17);

// UDP端口
unsigned int localPort = 8888;
unsigned int pcPort = 9003;

// ==================== 如果您的PC以太网卡IP是其他值 ====================
// 请相应修改上面的配置,例如:
//
// 如果PC以太网卡是 192.168.137.1 (启用了ICS):
//   IPAddress staticIP(192, 168, 137, 22);
//   IPAddress gateway(192, 168, 137, 1);
//   IPAddress dnsip(192, 168, 137, 1);
//   IPAddress pcIP(192, 168, 137, 1);
//
// 如果PC以太网卡是 192.168.3.215 (不推荐,会与WiFi冲突):
//   IPAddress staticIP(192, 168, 3, 22);
//   IPAddress gateway(192, 168, 3, 215);// 指向PC,不是路由器!
//   IPAddress dnsip(192, 168, 3, 215);
//   IPAddress pcIP(192, 168, 3, 215);


// ==================== 全局变量 ====================
EthernetUDP Udp;
char receiveBuffer;
char sendBuffer;

// 定时器
unsigned long lastDHTReadTime = 0;
unsigned long lastSendTime = 0;
unsigned long messageCount = 0;
unsigned long lastHeartbeat = 0;

// DHT数据
float temperature = 0.0;
float humidity = 0.0;
bool dhtValid = false;

// LED状态
bool ledControlState = false;
unsigned long lastBlinkTime = 0;
bool ledBlinkState = false;

// 网络状态
bool networkInitialized = false;
unsigned long lastSuccessTime = 0;
unsigned long packetsSent = 0;
unsigned long packetsReceived = 0;


// ==================== 函数声明 ====================
void floatToString(char* buffer, float value, int decimalPlaces);


// ==================== 浮点数转字符串 ====================
void floatToString(char* buffer, float value, int decimalPlaces) {
int intPart = (int)value;
int decPart = (int)((value - intPart) * pow(10, decimalPlaces));

if (decPart < 0) decPart = -decPart;

if (decimalPlaces == 1) {
    sprintf(buffer, "%d.%01d", intPart, decPart);
} else if (decimalPlaces == 2) {
    sprintf(buffer, "%d.%02d", intPart, decPart);
}
}


// ==================== 初始化 ====================
void setup() {
Serial.begin(115200);
delay(100);

Serial.println("\n\n");
Serial.println("========================================");
Serial.println("W5500 UDP + DHT11温湿度监控系统");
Serial.println("零知实验室");
Serial.println("版本: v3.1 (PC直连专用版)");
Serial.println("========================================\n");

Serial.println("网络模式: PC直连(静态IP)");
Serial.println("请确保PC的以太网卡已配置静态IP!\n");

initHardware();
initNetwork();
initDHT();

Serial.println("\n========================================");
Serial.println("系统启动完成!");
Serial.println("========================================\n");

printSystemInfo();
sendStartupMessage();

Serial.println("\n开始工作...\n");
Serial.println("----------------------------------------\n");
}


// ==================== 硬件初始化 ====================
void initHardware() {
Serial.println(" 初始化硬件...");

pinMode(LED_BUILTIN, OUTPUT);
digitalWrite(LED_BUILTIN, HIGH);

pinMode(LED_CONTROL_PIN, OUTPUT);
digitalWrite(LED_CONTROL_PIN, LOW);
ledControlState = false;

// 启动提示 - LED快闪3次
for(int i = 0; i < 3; i++) {
    digitalWrite(LED_BUILTIN, LOW);
    delay(100);
    digitalWrite(LED_BUILTIN, HIGH);
    delay(100);
}

Serial.println("✓ 硬件初始化完成!");
}


// ==================== 网络初始化 ====================
void initNetwork() {
Serial.println("\n 初始化W5500以太网模块...");
Serial.println("模式: 静态IP (PC直连)");
delay(500);

// 静态IP配置
#if defined(WIZ550io_WITH_MACADDRESS)
    Ethernet.begin(staticIP, dnsip, gateway, subnet);
#else
    Ethernet.begin(mac, staticIP, dnsip, gateway, subnet);
#endif

delay(1000);

// 验证网络配置
IPAddress ip = Ethernet.localIP();

if (ip == IPAddress(0, 0, 0, 0)) {
    Serial.println("\n✗✗✗ 错误: 以太网初始化失败! ✗✗✗");
    Serial.println("\n请检查:");
    Serial.println("1. W5500模块SPI接线是否正确");
    Serial.println("2. 网线是否连接到PC的以太网口");
    Serial.println("3. PC的以太网卡是否已配置静态IP");
    Serial.println("\n设备将进入错误指示模式");
   
    while(1) {
      digitalWrite(LED_BUILTIN, !digitalRead(LED_BUILTIN));
      delay(100);
    }
}

Serial.println("\n✓ W5500初始化成功!");
Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
Serial.print("本机IP:   ");
Serial.println(ip);
Serial.print("子网掩码: ");
Serial.println(Ethernet.subnetMask());
Serial.print("网关:   ");
Serial.println(Ethernet.gatewayIP());
Serial.print("DNS:      ");
Serial.println(Ethernet.dnsServerIP());
Serial.println("模式:   静态IP (PC直连)");
Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");

// 显示PC配置提示
Serial.println("\n📌 PC网络配置要求:");
Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
Serial.print("以太网卡IP: ");
Serial.println(pcIP);
Serial.print("子网掩码:   ");
Serial.println(subnet);
Serial.println("默认网关:   (留空)");
Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
Serial.println("请确保PC的以太网卡已设置为上述静态IP!");
Serial.println("   否则无法通信!\n");

// 启动UDP
Serial.println(" 启动UDP服务...");
Udp.begin(localPort);
Serial.print("- 监听端口: ");
Serial.println(localPort);
Serial.print("- 目标PC:   ");
Serial.print(pcIP);
Serial.print(":");
Serial.println(pcPort);
Serial.println("✓ UDP服务启动成功!");

networkInitialized = true;
}


// ==================== DHT11初始化 ====================
void initDHT() {
Serial.println("\n初始化DHT11传感器...");
dht.begin();
delay(2000);

humidity = dht.readHumidity();
temperature = dht.readTemperature();

if (isnan(humidity) || isnan(temperature)) {
    Serial.println("    DHT11首次读取失败,将继续尝试...");
    dhtValid = false;
} else {
    Serial.println("✓ DHT11初始化成功!");
    Serial.print("- 温度: ");
    Serial.print(temperature);
    Serial.println(" °C");
    Serial.print("- 湿度: ");
    Serial.print(humidity);
    Serial.println(" %");
    dhtValid = true;
}
}


// ==================== 系统信息显示 ====================
void printSystemInfo() {
Serial.println("\n系统配置: ");
Serial.print("- DHT11引脚: ");
Serial.println(DHTPIN);
Serial.print("- LED控制引脚: ");
Serial.println(LED_CONTROL_PIN);
Serial.println("- 网络模式: PC直连静态IP");
Serial.println("\n支持的命令:");
Serial.println("- LED_ON   : 点亮LED");
Serial.println("- LED_OFF    : 熄灭LED");
Serial.println("- GET_DHT    : 立即获取温湿度");
Serial.println("- STATUS   : 获取设备状态");
Serial.println("- PING       : 测试连接");
Serial.println("\n自动功能:");
Serial.println("- 每10秒自动上报温湿度数据");
Serial.println("- 每30秒发送心跳包");
Serial.println("- 板载LED慢闪表示正常运行");

Serial.println("\n网络诊断:");
Serial.print("- W5500 IP: ");
Serial.println(Ethernet.localIP());
Serial.print("- PC IP:    ");
Serial.println(pcIP);
Serial.print("- 是否同网段: ");

// 检查是否在同一网段
IPAddress w5500IP = Ethernet.localIP();
bool sameSubnet = (w5500IP == pcIP &&
                     w5500IP == pcIP &&
                     w5500IP == pcIP);

if (sameSubnet) {
    Serial.println("✓ 是");
} else {
    Serial.println("✗ 否 (无法通信!)");
    Serial.println("\n [警告] IP地址不在同一网段!");
    Serial.println("请检查网络配置!");
}
}


// ==================== 发送启动消息 ====================
void sendStartupMessage() {
IPAddress ip = Ethernet.localIP();

snprintf(sendBuffer, sizeof(sendBuffer),
         "{\"type\":\"startup\",\"ip\":\"%d.%d.%d.%d\",\"port\":%d,\"mode\":\"pc_direct\",\"pc_ip\":\"%d.%d.%d.%d\"}",
         ip, ip, ip, ip,
         localPort,
         pcIP, pcIP, pcIP, pcIP);
sendUDP(sendBuffer);

Serial.println("📤 已发送启动消息到PC");
}


// ==================== 发送心跳包 ====================
void sendHeartbeat() {
unsigned long currentTime = millis();

if (currentTime - lastHeartbeat >= 30000) {
    lastHeartbeat = currentTime;
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"heartbeat\",\"uptime\":%lu,\"packets_sent\":%lu,\"packets_received\":%lu}",
             millis() / 1000, packetsSent, packetsReceived);
    sendUDP(sendBuffer);
   
    Serial.println(" 心跳包");
}
}


// ==================== 读取DHT11数据 ====================
void readDHTData() {
unsigned long currentTime = millis();

if (currentTime - lastDHTReadTime >= 10000) {
    lastDHTReadTime = currentTime;
   
    float h = dht.readHumidity();
    float t = dht.readTemperature();
   
    if (isnan(h) || isnan(t)) {
      Serial.println("✗ DHT11读取失败!");
      dhtValid = false;
    } else {
      humidity = h;
      temperature = t;
      dhtValid = true;
      
      Serial.println("📊 DHT11数据:");
      Serial.print("温度: ");
      Serial.print(temperature);
      Serial.println(" °C");
      Serial.print("湿度: ");
      Serial.print(humidity);
      Serial.println(" %");
      
      sendDHTData();
    }
}
}


// ==================== 发送DHT数据 ====================
void sendDHTData() {
if (dhtValid) {
    messageCount++;
   
    char tempStr;
    char humiStr;
    floatToString(tempStr, temperature, 2);
    floatToString(humiStr, humidity, 2);
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"dht\",\"count\":%lu,\"temp\":%s,\"humi\":%s,\"time\":%lu}",
             messageCount, tempStr, humiStr, millis() / 1000);
   
    sendUDP(sendBuffer);
   
    Serial.print("📤 已发送温湿度数据 #");
    Serial.println(messageCount);
}
}


// ==================== 发送UDP数据 ====================
void sendUDP(const char* message) {
if (!networkInitialized) {
    Serial.println("网络未初始化,无法发送");
    return;
}

Udp.beginPacket(pcIP, pcPort);
Udp.write((uint8_t*)message, strlen(message));
Udp.endPacket();

packetsSent++;
lastSuccessTime = millis();
}


// ==================== 协议解析 ====================
void parseCommand(const char* cmd, IPAddress remoteIP, int remotePort) {
Serial.print("📝 解析命令: ");
Serial.println(cmd);

// LED_ON
if (strcmp(cmd, "LED_ON") == 0) {
    digitalWrite(LED_CONTROL_PIN, HIGH);
    ledControlState = true;
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"LED_ON\",\"status\":\"success\",\"led_state\":true}");
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✓ LED已点亮");
}
// LED_OFF
else if (strcmp(cmd, "LED_OFF") == 0) {
    digitalWrite(LED_CONTROL_PIN, LOW);
    ledControlState = false;
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"LED_OFF\",\"status\":\"success\",\"led_state\":false}");
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✓ LED已熄灭");
}
// GET_DHT
else if (strcmp(cmd, "GET_DHT") == 0) {
    float h = dht.readHumidity();
    float t = dht.readTemperature();
   
    if (isnan(h) || isnan(t)) {
      snprintf(sendBuffer, sizeof(sendBuffer),
               "{\"type\":\"response\",\"cmd\":\"GET_DHT\",\"status\":\"error\",\"error\":\"read_failed\"}");
    } else {
      humidity = h;
      temperature = t;
      dhtValid = true;
      
      char tempStr;
      char humiStr;
      floatToString(tempStr, temperature, 2);
      floatToString(humiStr, humidity, 2);
      
      snprintf(sendBuffer, sizeof(sendBuffer),
               "{\"type\":\"response\",\"cmd\":\"GET_DHT\",\"status\":\"success\",\"temp\":%s,\"humi\":%s}",
               tempStr, humiStr);
    }
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✓ 已发送DHT数据");
}
// PING
else if (strcmp(cmd, "PING") == 0) {
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"PING\",\"status\":\"success\",\"message\":\"PONG\"}");
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✓ PONG");
}
// STATUS
else if (strcmp(cmd, "STATUS") == 0) {
    char tempStr;
    char humiStr;
    floatToString(tempStr, temperature, 2);
    floatToString(humiStr, humidity, 2);
   
    IPAddress ip = Ethernet.localIP();
   
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"STATUS\",\"status\":\"success\",\"uptime\":%lu,\"led_state\":%s,\"dht_valid\":%s,\"temp\":%s,\"humi\":%s,\"ip\":\"%d.%d.%d.%d\",\"mode\":\"pc_direct\",\"packets_sent\":%lu,\"packets_received\":%lu}",
             millis() / 1000,
             ledControlState ? "true" : "false",
             dhtValid ? "true" : "false",
             tempStr, humiStr,
             ip, ip, ip, ip,
             packetsSent, packetsReceived);
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✓ 已发送设备状态");
}
// 未知命令
else {
    snprintf(sendBuffer, sizeof(sendBuffer),
             "{\"type\":\"response\",\"cmd\":\"%s\",\"status\":\"error\",\"error\":\"unknown_command\"}",
             cmd);
   
    Udp.beginPacket(remoteIP, remotePort);
    Udp.write((uint8_t*)sendBuffer, strlen(sendBuffer));
    Udp.endPacket();
   
    Serial.println("✗ 未知命令");
}
}


// ==================== 接收UDP数据 ====================
void receiveUDP() {
int packetSize = Udp.parsePacket();

if (packetSize > 0) {
    int len = Udp.read(receiveBuffer, sizeof(receiveBuffer) - 1);
    if (len > 0) {
      receiveBuffer = '\0';
      
      IPAddress remoteIP = Udp.remoteIP();
      int remotePort = Udp.remotePort();
      
      Serial.println("📥 收到消息:");
      Serial.print("来源: ");
      Serial.print(remoteIP);
      Serial.print(":");
      Serial.println(remotePort);
      Serial.print("内容: ");
      Serial.println(receiveBuffer);
      
      packetsReceived++;
      lastSuccessTime = millis();
      
      parseCommand(receiveBuffer, remoteIP, remotePort);
      
      Serial.println();
    }
}
}


// ==================== LED状态指示 ====================
void updateStatusLED() {
unsigned long currentTime = millis();

if (currentTime - lastBlinkTime >= 500) {
    lastBlinkTime = currentTime;
    ledBlinkState = !ledBlinkState;
    digitalWrite(LED_BUILTIN, ledBlinkState ? LOW : HIGH);
}
}


// ==================== 主循环 ====================
void loop() {
// 读取DHT11数据(每10秒)
readDHTData();

// 发送心跳包(每30秒)
sendHeartbeat();

// 处理UDP数据
receiveUDP();

// 更新状态LED
updateStatusLED();

delay(10);
}
系统流程图

UDP传输协议原理
      UDP用户数据报协议发送数据前不需要建立连接,直接发送;协议头仅8字节,相比TCP的20字节更节省带宽;没有握手和确认过程,延迟更低
UDP实现

// 发送UDP数据
void sendUDP(const char* message) {
Udp.beginPacket(pcIP, pcPort);      // 开始数据包
Udp.write((uint8_t*)message, strlen(message));// 写入数据
Udp.endPacket();                     // 结束并发送

packetsSent++;// 更新统计
}

// 接收UDP数据
void receiveUDP() {
int packetSize = Udp.parsePacket();// 检查是否有数据包

if (packetSize > 0) {
    int len = Udp.read(receiveBuffer, sizeof(receiveBuffer) - 1);
    if (len > 0) {
      receiveBuffer = '\0';// 添加字符串结束符
      // 处理接收到的数据...
    }
}
}UDP数据包结构

四、项目结果演示4.1 操作流程      将PC以太网口的IP设为192.168.10.17,子网掩码255.255.255.0,网关192.168.10.1;运行 Python 代码,确认 UDP 服务启动,监听 9003 端口
以太网配置:

上位机启动:
      通过命令行启动程序,执行python udp_dht_controller.py启动python端上位机
功能测试:
①查看串口监视器,确认每 10 秒采集一次温湿度并发送
②在 Python 菜单中选择 1/2 控制 LED 开关,选择 3 获取实时温湿度,选择 4 查看设备状态
③观察 PC 端是否能收到心跳包(每 30 秒一次)

4.2 网络调试助手演示      除 Python 上位机外,也可使用网络调试助手测试 UDP 通信,测试时确保python上位机关闭并且PC的IP地址和端口没有被占用
①打开网络调试助手,选择UDP客户端,本地端口9003,远程IP 192.168.10.22,远程端口8888
②发送'LED_ON',可收到设备端返回的JSON响应
③切换到UDP服务端,监听9003端口,可接收设备端发送的温湿度数据和心跳包


4.3 视频演示
基于W5500的UDP温湿度监控与LED 远程控制系统
视频演示了Python上位机和网络调试助手作为UDP客户端的完整操作流程。展示程序启动界面和配置网络调试助手的本地IP和端口,展示自动上报的温湿度数据。通过菜单选择,python上位机演示了LED点亮/熄灭控制、手动获取温湿度数据、查询设备状态等功能。网络调试助手向设备发送文本命令可以实时接收到JSON格式响应

五、W5500模块技术讲解W5500 核心特性
      支持TCP、UDP、ICMP、IPv4、ARP、IGMP等协议;可同时处理8个网络连接、支持最高80MHz的SPI时钟频率
5.1 SPI通信接口W5500通过SPI接口与主控MCU通信,SPI时序图如下:
SPI帧格式
      W5500 SPI帧由地址阶段的16位偏移地址、8位控制阶段以及N字节数据阶段组成。8位控制阶段由块选择位(BSB)、读/写访问模式位(RWB)和SPI操作模式(OM)重新配置。块选择位用于选择偏移地址所属的块。
W5500 支持连续数据读写。它从基准位置(为 2/4/N 字节连续数据处理设置的偏移地址)开始处理数据,并且通过将偏移地址增加 1(自动递增寻址)来处理下一个数据。

5.2 寄存器结构通用寄存器块
      通用寄存器用于配置 W5500 的通用信息 IP 地址和 MAC 地址,通过 SPI 帧中的 BSB 值选择该寄存器块

GAR(网关地址寄存器)存储网关IP地址、SUBR(子网掩码寄存器)存储子网掩码
Socket 寄存器块
      W5500 支持 8 个用于通信通道的 Socket。每个 Socket 由 Socket n 寄存器块 控制(其中 0≤n≤7)。可通过 SPI 帧中的 BSB 选择 Socket n 寄存器的 n 值。
Sn_MR(Socket模式寄存器)设置Socket工作模式、Sn_CR(Socket命令寄存器)执行Socket命令

W5500 在本项目中的工作原理

六、常见问题解答(FAQ)Q1: W5500模块无法初始化,串口显示IP为全0或者全255      A:可能的原因和解决方案:SPI接线错误、电源问题或者硬件故障,检查SCK、MISO、MOSI、CS、RST引脚,检查3.3V电源供电和SPI时钟频率配置,如果仍然有问题尝试更换W5500模块
Q2: PC无法ping通W5500设备      A:网络配置检查步骤:确认W5500和PC在同一网段,确认双方子网掩码相同、临时关闭Windows防火墙测试、尝试更换网线或检查RJ45接口、确认PC以太网卡已启用且配置了正确的静态IP
Q3:UDP通信不稳定,偶尔丢包      A:提高UDP通信稳定性的方法:确保单次发送数据不超过1472字节、重要数据可在应用层实现简单的确认重发、避免过高的发送频率,给网络处理留出时间
项目资源整合
网络调试助手和上位机程序:
W5500数据手册:                  
W5500以太网库文件:            Ethernet_STM

页: [1]
查看完整版本: 零知IDE——基于STM32与W5500的UDP通信实现温湿度监控