STM32F1与EC200U 4G模块：构建工业级物联网数据链的实战指南

在工业物联网和远程监控项目中，将现场采集的传感器数据稳定、可靠地传输到云端平台，是许多硬件工程师面临的核心挑战。传统的Wi-Fi或以太网方案受限于部署环境，而4G通信以其广覆盖、高带宽的特性，成为户外、移动或偏远场景下的首选。STM32F1系列微控制器以其出色的性价比和丰富的生态，搭配移远EC200U这款经典的4G Cat.1通信模块，构成了一个极具竞争力的硬件组合。然而，从硬件连接到数据上云，中间横亘着AT指令调试、网络协议栈适配、数据格式封装等一系列技术门槛。本文将从一个实战项目开发者的视角，深度剖析如何将STM32F1采集的GPS定位、温湿度及模拟量数据，通过EC200U模块，经由MQTT协议安全、高效地发布到EMQX物联网消息服务器。我们不仅会提供经过验证的代码片段，更会分享在调试过程中积累的宝贵经验与避坑指南，旨在为致力于构建可靠物联网数据链的工程师提供一份详尽的实战手册。

1. 硬件系统架构与核心组件选型

在动手连接线缆之前，清晰理解整个系统的硬件架构是成功的第一步。一个典型的基于STM32F1和EC200U的数据采集传输系统，其核心任务可以分解为数据采集、数据处理与协议封装、无线传输三个环节。

STM32F103C8T6（俗称“蓝桥杯最小系统板”核心芯片）在本项目中扮演着“大脑”的角色。它需要完成以下几项关键工作：

• 通过UART串口与EC200U模块进行AT指令交互和数据透传。
• 通过I2C或单总线接口读取数字温湿度传感器（如DHT11、AHT20或SHT30）的数据。
• 通过UART串口连接NMEA-0183协议的GPS模块（如ATGM336H），解析经纬度、时间等信息。
• 通过ADC采集一路或多路模拟信号（如电压、电流、光照强度等）。
• 整合所有数据，按照约定的格式（如JSON）进行封装，并通过MQTT客户端库发布到指定主题。

EC200U LTE Cat.1模块是系统的“通信官”。它内置了完整的TCP/IP协议栈，支持PPP、TCP、UDP、MQTT等网络协议，极大减轻了MCU的负担。工程师只需通过简单的AT指令集，即可指挥模块完成网络注册、建立数据连接、收发数据等复杂操作。其关键特性包括：

• 支持国内三大运营商的4G网络，兼容2G回落。
• 提供UART、USB等多种主机接口，与STM32通信最常用的是UART。
• 内置丰富的网络服务协议栈，直接支持AT+QMTOPEN和AT+QMTPUB等MQTT指令，无需在MCU端实现完整的MQTT协议。

EMQX作为MQTT消息服务器，是系统的“信息枢纽”。它负责接收来自无数个像我们这样的终端设备发布的消息，并将其转发给订阅了相应主题的客户端（如Web后端、数据可视化平台、手机App等）。EMQX的高并发处理能力和丰富的扩展功能（如规则引擎、数据桥接），为物联网应用提供了坚实的中台支撑。

提示：在项目规划初期，务必确认EC200U模块的频段是否覆盖项目部署地的运营商网络。同时，为模块配备一张合适的物联网卡，并确保卡已激活、套餐流量充足。

下表概括了本系统的主要硬件接口连接方案：

组件	接口类型	连接到STM32F1的引脚	备注
EC200U 4G模块	UART (AT指令与数据)	PA9 (USART1_TX), PA10 (USART1_RX)	需连接模块的VCC、GND、RST、PWRKEY等引脚。注意电平匹配（通常为3.3V）。
GPS模块	UART (NMEA数据)	PA2 (USART2_TX), PA3 (USART2_RX)	推荐使用带内置天线或有源天线的模块，确保户外搜星能力。
温湿度传感器	I2C (如AHT20)	PB6 (I2C1_SCL), PB7 (I2C1_SDA)	需接上拉电阻。也可选用单总线DHT11，连接至任一GPIO。
模拟量输入	ADC1	PA0 (ADC1_IN0)	用于采集0-3.3V模拟电压。输入前需确保信号电压在安全范围内。
调试输出	UART (打印信息)	通过USB转TTL连接至PC	用于输出调试日志，至关重要。可使用USART1重定向或另开一个USART。

电源设计是另一个需要高度重视的环节。EC200U模块在发射数据时峰值电流可能超过2A，因此必须为其提供独立、充足且稳定的5V或3.8V电源（具体看模块规格书），避免因电源跌落导致模块重启或通信失败。STM32和传感器可由另一路3.3V LDO供电。

2. 开发环境搭建与基础驱动实现

工欲善其事，必先利其器。一个高效的开发环境能极大提升调试效率。我们选择STM32CubeIDE作为集成开发环境，它集成了STM32CubeMX配置工具和基于Eclipse的IDE，可以一站式完成引脚配置、时钟树设置、中间件初始化以及代码编写、编译和调试。

首先，使用STM32CubeMX创建一个新工程，选择正确的MCU型号（STM32F103C8Tx）。然后进行如下关键配置：

1. 系统核心（SYS）：将Debug设置为Serial Wire，以便使用ST-LINK进行调试和下载。
2. 时钟（RCC）：将HSE设置为Crystal/Ceramic Resonator，为系统提供外部8MHz晶振时钟。
3. 引脚分配与功能配置：
   • USART1: 模式为Asynchronous，用于连接EC200U。波特率建议设置为115200。记得开启中断（NVIC Settings中使能USART1全局中断），用于接收模块返回的数据。
   • USART2: 同样配置为异步模式，波特率9600（这是大多数GPS模块的默认速率），用于接收GPS数据。也需开启接收中断。
   • I2C1: 模式为I2C，用于连接温湿度传感器。保持默认标准模式（100kHz）即可。
   • ADC1: 启用IN0通道（对应PA0）。扫描转换模式（Scan Conversion Mode）选择Disabled，因为我们只采单通道。连续转换模式（Continuous Conversion Mode）选择Enabled，使其自动连续采样。在Parameter Settings中设置采样时间（Sample Time）为239.5 Cycles以获得较高精度。
   • 一个GPIO输出：例如PC13（板载LED），配置为Output Push Pull，用于指示系统状态。

配置完成后，生成代码。CubeMX会自动生成所有外设的初始化代码（HAL库版本），我们只需在生成的工程中填充业务逻辑。

接下来，我们实现几个基础的驱动函数。首先是ADC数据读取，由于我们启用了连续转换模式，读取值非常简单：

// 在main.c的USER CODE BEGIN PV区域定义变量
uint32_t adc_value = 0;
float voltage = 0.0f;

// 在main函数的初始化部分（USER CODE BEGIN 2）启动ADC
HAL_ADC_Start(&hadc1);

// 在需要读取ADC值的循环或函数中
if (HAL_ADC_PollForConversion(&hadc1, 10) == HAL_OK) {
    adc_value = HAL_ADC_GetValue(&hadc1);
    // 将12位ADC值转换为电压 (Vref = 3.3V)
    voltage = (float)adc_value * 3.3f / 4095.0f;
}

对于I2C温湿度传感器（以AHT20为例），我们需要根据其数据手册编写读写函数。这里给出一个读取温湿度的简化流程：

// AHT20 相关定义
#define AHT20_ADDR 0x38 << 1 // 7位地址左移一位

uint8_t read_aht20(float *temperature, float *humidity) {
    uint8_t cmd[3] = {0xAC, 0x33, 0x00}; // 触发测量命令
    uint8_t data[6] = {0};
    uint32_t temp_raw, humi_raw;

    // 1. 发送测量命令
    if (HAL_I2C_Master_Transmit(&hi2c1, AHT20_ADDR, cmd, 3, 100) != HAL_OK)
        return 0;

    // 2. 等待测量完成（约80ms）
    HAL_Delay(80);

    // 3. 读取6字节数据
    if (HAL_I2C_Master_Receive(&hi2c1, AHT20_ADDR, data, 6, 100) != HAL_OK)
        return 0;

    // 4. 检查状态位并计算
    if ((data[0] & 0x80) == 0) { // 判断忙标志位
        humi_raw = ((uint32_t)data[1] << 12) | ((uint32_t)data[2] << 4) | (data[3] >> 4);
        temp_raw = (((uint32_t)data[3] & 0x0F) << 16) | ((uint32_t)data[4] << 8) | data[5];

        *humidity = (float)humi_raw * 100.0f / (1 << 20); // 转换为百分比
        *temperature = (float)temp_raw * 200.0f / (1 << 20) - 50.0f; // 转换为摄氏度
        return 1;
    }
    return 0;
}

GPS数据解析稍微复杂，需要在USART2的中断服务程序中累积数据，并在主循环中查找和解析$GNRMC或$GNGGA语句。这里提供一个简单的框架：

// 在USART2中断回调中累积数据
void HAL_UART_RxCpltCallback(UART_HandleTypeDef *huart) {
    if (huart->Instance == USART2) {
        static uint8_t gps_buffer[256];
        static int gps_index = 0;
        uint8_t rx_byte;
        HAL_UART_Receive_IT(&huart2, &rx_byte, 1); // 重新开启接收中断

        if (rx_byte == '\n' || gps_index >= 255) {
            gps_buffer[gps_index] = '\0';
            // 将完整的句子传递给解析函数
            gps_parse_sentence((char*)gps_buffer);
            gps_index = 0;
        } else {
            gps_buffer[gps_index++] = rx_byte;
        }
    }
}

// 一个简化的解析函数，仅提取经纬度
void gps_parse_sentence(char* sentence) {
    if (strstr(sentence, "$GNRMC") || strstr(sentence, "$GPRMC")) {
        // 使用strtok或sscanf解析逗号分隔的字段
        // 例如，字段3是纬度，字段4是纬度方向，字段5是经度，字段6是经度方向
        // 解析后将其转换为浮点数格式存储到全局变量中
    }
}

3. EC200U模块的AT指令驱动与网络连接

与EC200U的通信是整个项目的通信基石。我们将封装一套健壮的AT指令驱动，其核心思想是“发送指令-等待响应-解析结果”。为了提高代码的可靠性和可读性，我们将其模块化。

首先，定义一个结构体来管理模块的状态和连接信息：

typedef struct {
    uint8_t is_network_registered; // 网络注册状态
    uint8_t is_mqtt_connected;     // MQTT连接状态
    char imei[16];                 // 设备IMEI
    char ip_addr[16];              // 获取到的IP地址
    // ... 其他状态信息
} ec200u_status_t;

然后，实现核心的发送指令并等待响应的函数。这个函数需要处理响应超时、匹配预期结果等逻辑：

// 向EC200U发送AT指令并等待指定响应
// cmd: 要发送的AT指令字符串（如"AT"）
// expect: 期望在响应中出现的字符串（如"OK"）
// timeout_ms: 超时时间（毫秒）
// 返回: 0-成功，-1-超时，-2-响应不匹配
int8_t ec200u_send_cmd_check(const char* cmd, const char* expect, uint32_t timeout_ms) {
    char response[256] = {0};
    uint32_t start_tick = HAL_GetTick();

    // 清空接收缓冲区
    uart1_rx_clear();

    // 发送指令
    HAL_UART_Transmit(&huart1, (uint8_t*)cmd, strlen(cmd), 1000);
    HAL_UART_Transmit(&huart1, (uint8_t*)"\r\n", 2, 1000); // 发送回车换行

    // 循环读取响应，直到超时或找到预期结果
    while ((HAL_GetTick() - start_tick) < timeout_ms) {
        if (uart1_get_line(response, sizeof(response))) { // 自定义函数，读取一行
            printf("[EC200U RX]: %s\r\n", response); // 打印调试信息
            if (strstr(response, expect) != NULL) {
                return 0; // 成功匹配
            }
            // 有时也需要检查错误响应，如"ERROR"
            if (strstr(response, "ERROR") != NULL) {
                return -2;
            }
        }
        HAL_Delay(10);
    }
    return -1; // 超时
}

基于这个基础函数，我们可以构建模块的初始化流程。这是一个典型的启动序列，建议在系统上电后依次执行：

1. 模块开机与基础检查：拉低PWRKEY引脚一定时间再释放，然后发送AT指令测试通信是否正常。
2. 关闭回显：发送ATE0，避免指令回显干扰响应解析。
3. 获取模块信息：发送AT+CGSN获取IMEI，可用于作为设备唯一标识。
4. 查询网络注册状态：循环发送AT+CGREG?或AT+CEREG?，直到返回+CGREG: 0,1或+CEREG: 0,1，表示已注册到网络。
5. 激活PDP上下文：发送AT+QIACT=1激活数据业务。成功后可以使用AT+QIACT?查询获取到的IP地址。

注意：网络注册和PDP激活可能需要较长时间（几十秒），务必设置足够的等待超时，并加入重试机制。在实际产品中，这部分逻辑最好放在一个独立的任务中，不影响主程序其他功能的运行。

网络连通性测试可以通过Ping一个公网域名（如AT+QPING=1,"www.baidu.com"）来完成。确保这一步成功，再进行MQTT连接。

4. 实现MQTT协议对接与数据上传EMQX

EC200U内置了MQTT客户端功能，我们无需在STM32上实现复杂的MQTT协议栈，只需通过AT指令控制模块进行连接、订阅和发布。这大大降低了开发难度。

连接到EMQX服务器是第一步。EMQX支持多种连接方式，我们这里使用TCP直连（非SSL）。需要准备以下连接信息：

• 服务器地址：你的EMQX服务器公网IP或域名。
• 端口号：MQTT默认TCP端口是1883。
• Client ID：客户端标识符，需唯一。可以用IMEI或自定义字符串。
• 用户名/密码：如果EMQX开启了认证，则需要提供。

连接流程的AT指令序列如下：

# 1. 打开一个网络Socket，连接到EMQX的MQTT端口
AT+QMTOPEN=0,"your.emqx.server.ip",1883
# 响应: +QMTOPEN: 0,0 表示成功

# 2. 使用Client ID、用户名、密码连接MQTT服务器
AT+QMTCONN=0,"STM32_Client_001","username","password"
# 响应: +QMTCONN: 0,0,0 表示成功

在代码中，我们需要根据响应判断每一步是否成功，并更新连接状态。

连接成功后，就可以发布数据了。我们需要将传感器数据封装成MQTT消息的有效载荷（Payload）。JSON格式因其良好的可读性和广泛的生态支持，成为物联网数据交换的事实标准。我们将GPS、温湿度和ADC电压数据打包成一个JSON对象：

// 构建JSON格式的MQTT消息
int build_mqtt_payload(char* buffer, int buf_size, float lat, float lon, float temp, float humi, float volt) {
    // 使用snprintf防止缓冲区溢出
    return snprintf(buffer, buf_size,
        "{\"dev_id\":\"%s\",\"timestamp\":%lu,\"gps\":{\"lat\":%.6f,\"lon\":%.6f},\"env\":{\"temp\":%.2f,\"humi\":%.2f},\"adc\":{\"voltage\":%.3f}}",
        g_device_id, // 全局设备ID变量
        HAL_GetTick() / 1000, // 简易时间戳，单位秒
        lat, lon, temp, humi, volt
    );
}

然后，使用AT+QMTPUB指令发布消息到指定主题，例如 device/data/upload：

// 发布MQTT消息的函数
int8_t mqtt_publish_data(const char* topic, const char* payload, int qos) {
    char cmd[128];
    // 设置发布参数：连接ID, 消息ID, QoS, 保留标志, 主题, 消息长度
    snprintf(cmd, sizeof(cmd), "AT+QMTPUB=0,0,%d,0,\"%s\"", qos, topic);
    if (ec200u_send_cmd_check(cmd, ">", 2000) != 0) { // 等待‘>’提示符
        return -1;
    }
    // 发送消息内容
    HAL_UART_Transmit(&huart1, (uint8_t*)payload, strlen(payload), 2000);
    // 发送结束符 Ctrl+Z (0x1A)
    uint8_t end_char = 0x1A;
    HAL_UART_Transmit(&huart1, &end_char, 1, 2000);
    // 等待发布完成响应，如"+QMTPUB: 0,0,0"
    return ec200u_send_cmd_check("", "+QMTPUB: 0,0,0", 5000);
}

在主程序的循环中，我们可以定时（例如每10秒）采集一次所有传感器数据，调用build_mqtt_payload生成JSON字符串，再调用mqtt_publish_data函数将其发布出去。

稳定性与异常处理是工业应用的关键。必须考虑以下情况并编写相应处理代码：

• 网络断开重连：定期检查MQTT连接状态（AT+QMTCONN?），或在发布失败时触发重连流程。
• 指令响应超时：为所有AT指令设置合理的超时时间，超时后应进行重试或错误上报。
• 数据完整性：对于GPS数据，在解析后检查定位是否有效（$GNRMC语句中状态位为‘A’）。
• 流量控制：根据物联网卡套餐，合理设置数据上报频率，避免超额。

最后，在EMQX的Web管理界面或使用MQTT客户端工具（如MQTTX）订阅 device/data/upload 主题，就能实时看到STM32设备上报的JSON格式数据了。你可以进一步配置EMQX的规则引擎，将这些数据写入数据库（如MySQL、TDengine）或转发到其他消息队列（如Kafka），从而构建完整的物联网数据管道。

整个项目的代码结构应该是清晰分层的：底层是HAL库的硬件驱动，中间层是EC200U的AT指令封装和传感器驱动，上层是应用逻辑（数据采集、打包、发布调度）。采用状态机模型来管理EC200U的连接状态（如初始化、联网中、就绪、发布中、错误等），会使程序逻辑更加清晰健壮。在实际部署前，务必进行长时间的稳定性测试，模拟网络波动、电源干扰等真实环境情况，确保你的数据链在任何情况下都能保持坚韧。