单片机IWIP MQTT实验

发布时间：2026/7/3 14:20:08

单片机IWIP MQTT实验

单片机 ：STM32F407
开发板：DMF407电机开发板
平台：keil V5.31

HSE 为8MHZ
HSI为16MHZ

一、Aliyun

主函数

int main(void) { HAL_Init(); /* 初始化HAL库 */ sys_stm32_clock_init(336, 8, 2, 7); /* 设置时钟,168Mhz */ delay_init(168); /* 延时初始化 */ usart_init(115200); /* 串口初始化为115200 */ usmart_dev.init(84); /* 初始化USMART */ led_init(); /* 初始化LED */ lcd_init(); /* 初始化LCD */ key_init(); /* 初始化按键 */ my_mem_init(SRAMIN); /* 初始化内部SRAM内存池 */ my_mem_init(SRAMCCM); /* 初始化内部SRAMCCM内存池 */ freertos_demo(); /* 创建lwIP的任务函数 */ }
void freertos_demo(void) { /* start_task任务 */ xTaskCreate((TaskFunction_t )start_task, (const char * )"start_task", (uint16_t )START_STK_SIZE, (void * )NULL, (UBaseType_t )START_TASK_PRIO, (TaskHandle_t * )&StartTask_Handler); vTaskStartScheduler(); /* 开启任务调度 */ }
void start_task(void *pvParameters) { pvParameters = pvParameters; g_lwipdev.lwip_display_fn = lwip_test_ui; lwip_test_ui(1); /* 加载后前部分UI */ while (lwip_comm_init() != 0) { lcd_show_string(30, 110, 200, 16, 16, "lwIP Init failed!!", RED); delay_ms(500); lcd_fill(30, 50, 200 + 30, 50 + 16, WHITE); lcd_show_string(30, 110, 200, 16, 16, "Retrying... ", RED); delay_ms(500); LED1_TOGGLE(); } while (!ethernet_read_phy(PHY_SR)) /* 检查MCU与PHY芯片是否通信成功 */ { printf("MCU与PHY芯片通信失败，请检查电路或者源码！！！！\r\n"); } while ((g_lwipdev.dhcpstatus != 2) && (g_lwipdev.dhcpstatus != 0XFF)) /* 等待DHCP获取成功/超时溢出 */ { vTaskDelay(5); } taskENTER_CRITICAL(); /* 进入临界区 */ /* 创建lwIP任务 */ xTaskCreate((TaskFunction_t )lwip_demo_task, (const char* )"lwip_demo_task", (uint16_t )LWIP_DMEO_STK_SIZE, (void* )NULL, (UBaseType_t )LWIP_DMEO_TASK_PRIO, (TaskHandle_t* )&LWIP_Task_Handler); /* LED测试任务 */ xTaskCreate((TaskFunction_t )led_task, (const char* )"led_task", (uint16_t )LED_STK_SIZE, (void* )NULL, (UBaseType_t )LED_TASK_PRIO, (TaskHandle_t* )&LEDTask_Handler); vTaskDelete(StartTask_Handler); /* 删除开始任务 */ taskEXIT_CRITICAL(); /* 退出临界区 */ }
void lwip_demo_task(void *pvParameters) { pvParameters = pvParameters; lwip_demo(); while (1) { vTaskDelay(5); } }
void lwip_demo(void) { struct hostent *server; static struct mqtt_connect_client_info_t mqtt_client_info; server = gethostbyname((char *)HOST_NAME); /* 对oneNET服务器地址解析 */ memcpy(&g_mqtt_ip,server->h_addr,server->h_length); /* 把解析好的地址存放在mqtt_ip变量当中 */ char *PASSWORD; PASSWORD = mymalloc(SRAMIN, 300); /* 为密码申请内存 */ lwip_ali_get_password(DEVICE_SECRET, CONTENT, PASSWORD); /* 通过hmac_sha1算法得到password */ /* 设置一个空的客户端信息结构 */ memset(&mqtt_client_info, 0, sizeof(mqtt_client_info)); /* 设置客户端的信息量 */ mqtt_client_info.client_id = (char *)CLIENT_ID; /* 设备名称 */ mqtt_client_info.client_user = (char *)USER_NAME; /* 产品ID */ mqtt_client_info.client_pass = (char *)PASSWORD; /* 计算出来的密码 */ mqtt_client_info.keep_alive = 100; /* 保活时间 */ mqtt_client_info.will_msg = NULL; mqtt_client_info.will_qos = NULL; mqtt_client_info.will_retain = 0; mqtt_client_info.will_topic = 0; myfree(SRAMIN, PASSWORD); /* 释放内存 */ /* 创建MQTT客户端控制块 */ g_mqtt_client = mqtt_client_new(); /* 连接服务器 */ mqtt_client_connect(g_mqtt_client, /* 服务器控制块 */ &g_mqtt_ip, MQTT_PORT,/* 服务器IP与端口号 */ mqtt_connection_cb, LWIP_CONST_CAST(void*, &mqtt_client_info),/* 设置服务器连接回调函数 */ &mqtt_client_info); /* MQTT连接信息 */ while(1) { if (g_publish_flag == 1) { g_temp = 30 + rand() % 10 + 1; /* 温度的数据 */ g_humid = 54.8 + rand() % 10 + 1;/* 湿度的数据 */ sprintf((char *)g_payload_out, "{\"params\":{\"CurrentTemperature\":+%0.1f,\"RelativeHumidity\":%0.1f},\"method\":\"thing.event.property.post\"}", g_temp, g_humid); g_payload_out_len = strlen((char *)g_payload_out); mqtt_publish(g_mqtt_client,DEVICE_PUBLISH,g_payload_out,g_payload_out_len,1,0,mqtt_publish_request_cb,NULL); } vTaskDelay(1000); } }

实验结果：

二、Onenet

主函数：

int main(void) { HAL_Init(); /* 初始化HAL库 */ sys_stm32_clock_init(336, 8, 2, 7); /* 设置时钟,168Mhz */ delay_init(168); /* 延时初始化 */ usart_init(115200); /* 串口初始化为115200 */ usmart_dev.init(84); /* 初始化USMART */ led_init(); /* 初始化LED */ lcd_init(); /* 初始化LCD */ key_init(); /* 初始化按键 */ my_mem_init(SRAMIN); /* 初始化内部SRAM内存池 */ my_mem_init(SRAMCCM); /* 初始化内部SRAMCCM内存池 */ freertos_demo(); /* 创建lwIP的任务函数 */ }
void freertos_demo(void) { /* start_task任务 */ xTaskCreate((TaskFunction_t )start_task, (const char * )"start_task", (uint16_t )START_STK_SIZE, (void * )NULL, (UBaseType_t )START_TASK_PRIO, (TaskHandle_t * )&StartTask_Handler); vTaskStartScheduler(); /* 开启任务调度 */ }
void start_task(void *pvParameters) { pvParameters = pvParameters; g_lwipdev.lwip_display_fn = lwip_test_ui; lwip_test_ui(1); /* 加载后前部分UI */ while (lwip_comm_init() != 0) { lcd_show_string(30, 110, 200, 16, 16, "lwIP Init failed!!", RED); delay_ms(500); lcd_fill(30, 50, 200 + 30, 50 + 16, WHITE); lcd_show_string(30, 110, 200, 16, 16, "Retrying... ", RED); delay_ms(500); LED1_TOGGLE(); } while (!ethernet_read_phy(PHY_SR)) /* 检查MCU与PHY芯片是否通信成功 */ { printf("MCU与PHY芯片通信失败，请检查电路或者源码！！！！\r\n"); } while ((g_lwipdev.dhcpstatus != 2)&&(g_lwipdev.dhcpstatus != 0XFF)) /* 等待DHCP获取成功/超时溢出 */ vTaskDelay(5); taskENTER_CRITICAL(); /* 进入临界区 */ /* 创建lwIP任务 */ xTaskCreate((TaskFunction_t )lwip_demo_task, (const char* )"lwip_demo_task", (uint16_t )LWIP_DMEO_STK_SIZE, (void* )NULL, (UBaseType_t )LWIP_DMEO_TASK_PRIO, (TaskHandle_t* )&LWIP_Task_Handler); /* LED测试任务 */ xTaskCreate((TaskFunction_t )led_task, (const char* )"led_task", (uint16_t )LED_STK_SIZE, (void* )NULL, (UBaseType_t )LED_TASK_PRIO, (TaskHandle_t* )&LEDTask_Handler); vTaskDelete(StartTask_Handler); /* 删除开始任务 */ taskEXIT_CRITICAL(); /* 退出临界区 */ }
void lwip_demo_task(void *pvParameters) { pvParameters = pvParameters; lwip_demo(); while (1) { vTaskDelay(5); } }
void lwip_demo(void) { char pro_id[] = USER_PRODUCT_ID; /* 产品ID */ char access_key[] = USER_ACCESS_KEY; /* 产品密钥 */ char dev_name[] = USER_DEVICE_NAME; /* 设备名称 */ char dev_id[] = USER_DEVICE_ID; /* 产品设备ID */ char key[] = USER_KEY; /* 设备密钥 */ struct hostent *server; static struct mqtt_connect_client_info_t mqtt_client_info; char version[] = "2018-10-31"; unsigned int expiration_time = 1956499200; char authorization_buf[160] = {0}; server = gethostbyname((char *)HOST_NAME); /* 对oneNET服务器地址解析 */ memcpy(&g_mqtt_ip,server->h_addr,server->h_length); /* 把解析好的地址存放在mqtt_ip变量当中 */ /* 把各个参数保存在g_onenet_info结构体的成员变量中 */ memset(g_onenet_info.pro_id, 0, sizeof(g_onenet_info.pro_id)); strcpy(g_onenet_info.pro_id, pro_id); memset(g_onenet_info.access_key, 0, sizeof(g_onenet_info.access_key)); strcpy(g_onenet_info.access_key, access_key); memset(g_onenet_info.dev_name, 0, sizeof(g_onenet_info.dev_name)); strcpy(g_onenet_info.dev_name, dev_name); memset(g_onenet_info.dev_id, 0, sizeof(g_onenet_info.dev_id)); strcpy(g_onenet_info.dev_id, dev_id); memset(g_onenet_info.key, 0, sizeof(g_onenet_info.key)); strcpy(g_onenet_info.key, key); /* 根据这些参数进行解码，当然这个密码可以在token软件下解码 */ onenet_authorization(version, (char *)g_onenet_info.pro_id, expiration_time, (char *)g_onenet_info.key, (char *)g_onenet_info.dev_name, authorization_buf, sizeof(authorization_buf), 0); /* 设置一个空的客户端信息结构 */ memset(&mqtt_client_info, 0, sizeof(mqtt_client_info)); /* 设置客户端的信息量 */ mqtt_client_info.client_id = (char *)g_onenet_info.dev_name; /* 设备名称 */ mqtt_client_info.client_user = (char *)g_onenet_info.pro_id; /* 产品ID */ mqtt_client_info.client_pass = (char *)authorization_buf; /* 计算出来的密码 */ mqtt_client_info.keep_alive = 100; /* 保活时间 */ mqtt_client_info.will_msg = NULL; mqtt_client_info.will_qos = NULL; mqtt_client_info.will_retain = 0; mqtt_client_info.will_topic = 0; /* 创建MQTT客户端控制块 */ g_mqtt_client = mqtt_client_new(); /* 连接服务器 */ mqtt_client_connect(g_mqtt_client, /* 服务器控制块 */ &g_mqtt_ip, MQTT_PORT,/* 服务器IP与端口号 */ mqtt_connection_cb, LWIP_CONST_CAST(void*, &mqtt_client_info),/* 设置服务器连接回调函数 */ &mqtt_client_info); /* MQTT连接信息 */ while(1) { if (g_publish_flag == 1) { g_temp = 30 + rand() % 10 + 1; /* 温度的数据 */ g_humid = 54.8 + rand() % 10 + 1;/* 湿度的数据 */ sprintf((char *)g_payload_out, "{\"id\": 123,\"dp\": { \"temperatrue\": [{\"v\": %0.1f,}],\"power\": [{\"v\": %0.1f,}]}}", g_temp, g_humid); g_payload_out_len = strlen((char *)g_payload_out); mqtt_publish(g_mqtt_client,DEVICE_PUBLISH,g_payload_out,g_payload_out_len,1,0,mqtt_publish_request_cb,NULL); } vTaskDelay(1000); } }

实验结果：

相关新闻

3分钟免费激活IDM完整版：永久解锁极速下载的终极指南

3分钟免费激活IDM完整版：永久解锁极速下载的终极指南

3分钟免费激活IDM完整版：永久解锁极速下载的终极指南 【免费下载链接】IDM-Activation-Script-ZH IDM激活脚本汉化版 项目地址: https://gitcode.com/gh_mirrors/id/IDM-Activation-Script-ZH 还在为Internet Download Manager（IDM）的…

2026/7/3 14:20:08
嵌入式键盘管理系统：硬件去抖动与中断驱动设计

嵌入式键盘管理系统：硬件去抖动与中断驱动设计

1. 项目背景与核心需求在嵌入式系统开发中，键盘输入是最基础的人机交互方式之一。传统方案通常直接连接机械按键到MCU的GPIO引脚，但这种方式存在两个显著问题：一是按键抖动会导致误触发，二是占用宝贵的IO资源。本项目采用74HC32四…

2026/7/3 14:20:08
MC74HC165A与PIC18LF27K40实现高效数字输入扩展方案

MC74HC165A与PIC18LF27K40实现高效数字输入扩展方案

1. 项目背景与核心价值在工业控制和嵌入式系统开发中，我们经常面临一个经典难题：如何用有限的微控制器引脚控制大量外围设备？传统方案要么增加昂贵的IO扩展芯片，要么采用复杂的矩阵扫描电路，这两种方法都会显著提升系统…

2026/7/3 14:20:08

最新新闻

GEO源码真的有用吗

GEO源码真的有用吗

GEO源码的真实价值在于系统化落地能力 据行业统计，GEO源码作为底层技术框架，其核心价值并非单纯代码本身，而是围绕“河南新流量GEO本地引流推广”构建的一套完整系统。AI新流量GEO系统代理的源码版本持续迭代，意味着代理商能实时获…

2026/7/3 15:45:12
如何快速上手.NET权限管理系统：新手避坑完整指南

如何快速上手.NET权限管理系统：新手避坑完整指南

如何快速上手.NET权限管理系统：新手避坑完整指南 【免费下载链接】YiShaAdmin 基于 .NET Core MVC 的权限管理系统，代码易读易懂、界面简洁美观 项目地址: https://gitcode.com/GitHub_Trending/yi/YiShaAdmin .NET权限管理系统YiShaAdmin是一个基…

2026/7/3 15:45:12
WechatAPI 如何突破性能瓶颈？

WechatAPI 如何突破性能瓶颈？

在基于 WechatAPI（个人微信API）构建超大规模社群监控、实时舆情分析或自动化交易系统时，系统的吞吐量往往受到底层进程间通信（IPC）的严格制约。开发者通常习惯采用 WebSocket、HTTP 或 Socket 协议在底层的 Hook 模块&…

2026/7/3 15:45:12
未来展望：ubctl在下一代UB系统中的功能演进与路线图

未来展望：ubctl在下一代UB系统中的功能演进与路线图

未来展望：ubctl在下一代UB系统中的功能演进与路线图 【免费下载链接】ubctl The UB DFX tool supports query for device capabilities, port status, resources, and statistics. 项目地址: https://gitcode.com/openeuler/ubctl 前往项目官网免费下载&…

2026/7/3 15:45:12
STM32与WSEN-ISDS IMU实现高精度姿态测量

STM32与WSEN-ISDS IMU实现高精度姿态测量

1. 项目背景与硬件选型解析 在机器人控制和工业自动化领域，精确的空间运动感知是实现精准控制的基础。WSEN-ISDS（型号2536030320001）是Wrth Elektronik推出的一款6自由度惯性测量单元(IMU)，集成了三轴加速度计和三轴陀螺仪&#x…

2026/7/3 15:45:12
Kiran-Flameshot命令行参数大全：CLI配置和脚本自动化

Kiran-Flameshot命令行参数大全：CLI配置和脚本自动化

Kiran-Flameshot命令行参数大全：CLI配置和脚本自动化 【免费下载链接】kiran-flameshot Powerful and simple to use screenshot software with built-in editor with advanced features. 项目地址: https://gitcode.com/openeuler/kiran-flameshot 前往项目…

2026/7/3 15:44:47

日新闻

JMeter gRPC性能测试插件实战：从原理到CI/CD集成

JMeter gRPC性能测试插件实战：从原理到CI/CD集成

1. 项目概述：为什么我们需要一个gRPC性能测试插件？ 如果你正在处理一个现代化的微服务架构，那么gRPC大概率是你绕不开的通信协议。它基于HTTP/2，支持双向流，序列化效率高，天生就是为微服务间的高性能、低延…

2026/7/3 0:00:03
iOS自动化测试：基于facebook-wda与weditor的稳定元素定位实战

iOS自动化测试：基于facebook-wda与weditor的稳定元素定位实战

1. 项目概述：iOS自动化测试的“定位”之痛做iOS自动化测试的朋友，十有八九都卡在“元素定位”这个环节上。你兴冲冲地写好了测试脚本，结果一运行，要么是找不到元素，要么是找到了但点不动，要么是这次能跑通下…

2026/7/3 0:00:05
MTKClient实战指南：深度解析联发科芯片调试与设备修复方案

MTKClient实战指南：深度解析联发科芯片调试与设备修复方案

MTKClient实战指南：深度解析联发科芯片调试与设备修复方案 【免费下载链接】mtkclient MTK reverse engineering and flash tool 项目地址: https://gitcode.com/gh_mirrors/mt/mtkclient MTKClient是一款专业的联发科芯片调试工具，为技术爱好者和…

2026/7/3 0:00:05

周新闻

Figma中文界面插件终极指南：5分钟快速上手完整教程

Figma中文界面插件终极指南：5分钟快速上手完整教程

Figma中文界面插件终极指南：5分钟快速上手完整教程 【免费下载链接】figmaCN 中文 Figma 插件，设计师人工翻译校验 项目地址: https://gitcode.com/gh_mirrors/fi/figmaCN 还在为Figma的英文界面而困扰吗？FigmaCN中文插件是设计师必备…

2026/7/2 15:30:08
Windows字体自定义终极方案：No!! MeiryoUI完全指南

Windows字体自定义终极方案：No!! MeiryoUI完全指南

Windows字体自定义终极方案：No!! MeiryoUI完全指南 【免费下载链接】noMeiryoUI No!! MeiryoUI is Windows system font setting tool on Windows 8.1/10/11. 项目地址: https://gitcode.com/gh_mirrors/no/noMeiryoUI 还在为Windows系统单调的字体界面感到困…

2026/7/2 15:29:50
WinBtrfs终极实战指南：3种配置方案解锁Windows Btrfs文件系统完整功能

WinBtrfs终极实战指南：3种配置方案解锁Windows Btrfs文件系统完整功能

WinBtrfs终极实战指南：3种配置方案解锁Windows Btrfs文件系统完整功能 【免费下载链接】btrfs WinBtrfs - an open-source btrfs driver for Windows 项目地址: https://gitcode.com/gh_mirrors/bt/btrfs WinBtrfs是一款革命性的开源Windows驱动程序&#xf…

2026/7/2 15:29:51

月新闻

[C++]内存管理：串顺序存储的内存回收

[C++]内存管理：串顺序存储的内存回收

在串（字符串）的顺序存储中，内存回收的方式取决于字符串的存储方式以及所使用的编程语言和相关库。以下以 C 为例进行说明，因为 C 对内存管理有较为直接的控制。 1. 基于 char 数组的串顺序存储 如果使用普通的 char 数组来存储字…

2026/7/2 15:47:40
移动端游戏功耗测试实战：电流、功率、亮度和场景对比

移动端游戏功耗测试实战：电流、功率、亮度和场景对比

移动端游戏功耗测试：先控制变量，再比较优化是否真的省电 摘要：功耗测试最容易犯的错误，是拿两次不同温度、不同亮度、不同场景的平均功率直接比较。本文给出一套可复现的游戏功耗测试方法，覆盖引擎特性验证、版本回归和黑盒体验测试，并说明如何把功耗与帧率、温控、CPU/G…

2026/7/2 15:47:40
足球口袋教练 HarmonyOS 离线应用实战（03/20）：ArkUI 首页仪表盘搭建

足球口袋教练 HarmonyOS 离线应用实战（03/20）：ArkUI 首页仪表盘搭建

本文是“足球口袋教练 HarmonyOS 离线应用实战”系列第 3 篇。示例项目是一个 HarmonyOS / ArkTS / ArkUI 编写的离线足球训练助手，围绕真实页面、真实截图和可复现操作展开。 本篇要解决的问题 训练 App 的首页不能只展示欢迎语，它要解决“我现在该点哪…

2026/7/2 14:14:33