用STM32G431和塔石NB-IoT模块，5分钟搞定阿里云MQTT设备上云（附完整配置流程）-平芜编程栈

STM32G431与塔石NB-IoT模块快速接入阿里云MQTT实战指南

在物联网项目开发中，设备快速上云往往是验证原型可行性的关键第一步。本文将手把手带您完成STM32G431单片机通过塔石NB-IoT模块连接阿里云物联网平台的完整流程，从硬件准备到云端配置，再到代码调试，每个环节都配有详细说明和避坑指南。

1. 硬件准备与环境搭建

1.1 所需物料清单

确保您已准备好以下硬件和账号资源：

核心硬件：
- STM32G431开发板（兼容STM32F1等系列）
- 塔石NB-IoT模块（型号E33V-DTU带天线）
- Micro SIM卡（已开通NB-IoT服务）
- USB转TTL模块（用于初始配置）
软件工具：
- Keil MDK或STM32CubeIDE开发环境
- 塔石模块配置工具（可从厂商获取）
- 串口调试助手（如SecureCRT、Putty）
云端资源：
- 有效的阿里云账号
- 已实名认证并开通物联网平台服务

1.2 硬件连接示意图

[STM32G431] [塔石NB-IoT模块] | | |--- USART_TX ---> RX | |--- USART_RX <--- TX | |--- GND -------- GND |

提示：初次配置时，建议先用USB转TTL模块将塔石模块直接连接电脑进行参数设置，确认云端通信正常后再接入单片机。

2. 阿里云物联网平台配置

2.1 创建产品与设备

登录阿里云控制台，进入物联网平台服务
选择公共实例>产品>创建产品
填写产品信息：
- 产品名称：自定义（如"MyIoTDevice"）
- 节点类型：直连设备
- 联网方式：蜂窝（2G/3G/4G/5G）
- 数据格式：透传/自定义
创建成功后，进入该产品页面：
- 选择Topic类列表>自定义Topic
- 添加两个Topic：
  - /read（发布权限）
  - /say（订阅权限）
在设备标签页下添加新设备：
- 设备名称：自定义（如"Device01"）
- 设备创建后，记录下三元组信息：
  - ProductKey
  - DeviceName
  - DeviceSecret

2.2 获取MQTT连接参数

在设备详情页，找到MQTT连接参数，这些将用于塔石模块配置：

ClientID:${deviceName}|securemode=3,signmethod=hmacsha1|
Username:${deviceName}&${productKey}
Password: 由DeviceSecret计算得到的加密字符串

注意：阿里云MQTT Broker地址通常为${productKey}.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883

3. 塔石NB-IoT模块配置

3.1 初始参数设置

使用USB转TTL连接塔石模块与PC
打开塔石配置工具，选择对应模块型号
配置基础通信参数：
- 工作模式：MQTT透传
- 运营商APN：根据SIM卡运营商填写（如移动为"CMNET"）
- 频段模式：自动选择

填写MQTT连接信息：

[MQTT参数] Broker地址: ${productKey}.iot-as-mqtt.cn-shanghai.aliyuncs.com 端口: 1883 ClientID: Device01|securemode=3,signmethod=hmacsha1| 用户名: Device01&a1z2b3c4d5 密码: [计算后的加密字符串]

3.2 Topic与设备名替换

在订阅Topic中填入：/say
在发布Topic中填入：/read
关键步骤：将所有${deviceName}替换为实际设备名（如"Device01"）
保存配置并测试连接：
- 点击"进入配置状态"
- "一键配置参数"
- "退出配置状态"
- 观察模块指示灯状态，确认已连接云端

3.3 通信测试验证

在阿里云控制台，进入设备Topic列表
向/sayTopic发布测试消息（如"Hello"）
在塔石配置工具的接收窗口应能看到该消息
通过配置工具发送消息（如"World"）
在阿里云日志服务中查看消息是否成功上传

4. STM32与塔石模块串口集成

4.1 硬件电路连接

将STM32的USART引脚与塔石模块交叉连接：

STM32引脚	塔石模块引脚
PA9 (TX)	RX
PA10 (RX)	TX
GND	GND

提示：确保双方使用相同的波特率（通常为115200）

4.2 基础串口通信代码

// 在STM32CubeMX中启用USART并生成代码 // 添加以下自定义代码： #define MQTT_TOPIC_READ "/read" #define MQTT_TOPIC_SAY "/say" void MQTT_SendMessage(char *message) { char buffer[256]; sprintf(buffer, "PUB:%s:%s\r\n", MQTT_TOPIC_READ, message); HAL_UART_Transmit(&huart1, (uint8_t*)buffer, strlen(buffer), HAL_MAX_DELAY); } void MQTT_ReceiveHandler(void) { static char rxBuffer[256]; static uint8_t index = 0; if(HAL_UART_Receive(&huart1, &rxByte, 1, 50) == HAL_OK) { if(rxByte == '\n') { rxBuffer[index] = '\0'; // 解析接收到的MQTT消息 if(strstr(rxBuffer, MQTT_TOPIC_SAY) != NULL) { char *payload = strchr(rxBuffer, ':') + 1; printf("Received: %s\n", payload); } index = 0; } else { rxBuffer[index++] = rxByte; } } }

4.3 主程序逻辑示例

int main(void) { HAL_Init(); SystemClock_Config(); MX_USART1_UART_Init(); while (1) { // 接收处理云端消息 MQTT_ReceiveHandler(); // 示例：每5秒发送一次数据 static uint32_t lastSend = 0; if(HAL_GetTick() - lastSend > 5000) { MQTT_SendMessage("Hello from STM32"); lastSend = HAL_GetTick(); } } }