RT-Thread串口DMA接收不定长数据，我用消息队列搞定（附完整代码）

RT-Thread串口DMA接收不定长数据的工程实践：消息队列与空闲中断的完美结合

在嵌入式开发中，串口通信是最基础也最常用的外设接口之一。无论是与传感器交互、模块通信还是设备调试，串口都扮演着重要角色。然而，当面对不定长数据接收时，许多开发者都会遇到一个共同的难题：如何确保数据完整接收，同时又不占用过多CPU资源？

1. 为什么需要消息队列+DMA方案

传统的串口数据接收方式主要有两种：轮询和中断。轮询方式需要CPU不断检查串口状态，效率低下；而中断方式虽然提高了效率，但在处理不定长数据时存在明显不足：

• 数据分包问题：高速传输时，单字节中断可能导致数据被分割处理
• 实时性挑战：中断嵌套可能影响系统响应
• 资源占用：频繁中断消耗CPU资源

// 传统中断接收方式示例（存在问题） void USART1_IRQHandler(void) { if(USART_GetITStatus(USART1, USART_IT_RXNE) != RESET) { char ch = USART_ReceiveData(USART1); buffer[index++] = ch; // 简单缓冲，存在临界区问题 } }

相比之下，DMA+空闲中断+消息队列的方案具有显著优势：

2. 核心机制解析：DMA与空闲中断的协同

2.1 DMA接收原理

DMA（Direct Memory Access）是一种无需CPU干预的数据传输机制。在串口接收中配置DMA后：

1. 硬件自动将接收到的数据存入指定缓冲区
2. 仅在传输完成时通知CPU
3. 支持循环缓冲和单次传输两种模式

关键配置参数：

• 接收缓冲区大小
• DMA传输模式（循环/单次）
• 中断触发条件

2.2 串口空闲中断

串口空闲中断（Idle Interrupt）在串口总线保持空闲状态超过一个字节传输时间时触发。结合DMA使用时：

1. 当有新数据到达，DMA自动搬运到缓冲区
2. 数据停止传输后，空闲中断触发
3. 在中断服务程序中获取当前DMA搬运的数据量

// 空闲中断处理逻辑（伪代码） void USART_IRQHandler(void) { if(USART_GetITStatus(USARTx, USART_IT_IDLE) != RESET) { USART_ClearITPendingBit(USARTx, USART_IT_IDLE); size_t received_size = BUFFER_SIZE - DMA_GetCurrDataCounter(DMAy_Streamz); // 通过消息队列通知处理线程 post_message(received_size); } }

2.3 消息队列的异步处理优势

消息队列在此方案中扮演着异步通知桥梁的角色：

1. 中断上下文仅发送消息，不处理数据
2. 应用线程在非实时上下文处理数据
3. 天然解决临界区问题

典型工作流程：

1. 空闲中断触发
2. 发送数据长度信息到消息队列
3. 处理线程被唤醒并读取实际数据
4. 线程安全地处理数据

3. RT-Thread中的完整实现

3.1 硬件配置要点

在RT-Thread中实现该方案需要正确配置以下组件：

1. 串口设备：启用DMA接收模式
2. DMA通道：配置正确的流和通道
3. 空闲中断：在驱动层或应用层启用

# RT-Thread env配置示例 scons --menuconfig # 选择： # Hardware Drivers Config -> On-chip Peripheral Drivers -> Enable UARTx # Enable UARTx DMA RX

3.2 软件架构设计

完整的实现包含三个核心部分：

1. 消息队列：传递数据到达事件
2. 数据处理线程：实际业务逻辑
3. 回调机制：连接硬件中断和软件处理

/* 消息结构体定义 */ struct rx_msg { rt_device_t dev; // 串口设备指针 rt_size_t size; // 本次接收数据长度 }; /* 全局变量 */ static rt_device_t serial; // 串口设备句柄 static struct rt_messagequeue rx_mq; // 消息队列控制块

3.3 关键代码实现

1. 接收回调函数（中断上下文）

static rt_err_t uart_input(rt_device_t dev, rt_size_t size) { struct rx_msg msg; msg.dev = dev; msg.size = size; rt_err_t result = rt_mq_send(&rx_mq, &msg, sizeof(msg)); if (result == -RT_EFULL) { rt_kprintf("Message queue full! Data may lost.\n"); // 可添加队列满时的处理策略 } return result; }

2. 数据处理线程（线程上下文）

static void serial_thread_entry(void *parameter) { struct rx_msg msg; char rx_buffer[256]; // 根据实际需求调整大小 while (1) { // 等待消息到达（线程挂起） if (rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER) == RT_EOK) { // 读取实际数据 rt_size_t rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size); // 业务处理（示例：回显+打印） rx_buffer[rx_length] = '\0'; rt_device_write(serial, 0, rx_buffer, rx_length); rt_kprintf("Received: %s\n", rx_buffer); // 实际项目中这里添加业务逻辑 process_received_data(rx_buffer, rx_length); } } }

3. 初始化代码

static int uart_dma_init(void) { /* 查找串口设备 */ serial = rt_device_find("uart2"); if (!serial) { rt_kprintf("UART device not found!\n"); return -RT_ERROR; } /* 初始化消息队列 */ static char msg_pool[256]; // 消息池大小根据需求调整 rt_mq_init(&rx_mq, "uart_rx_mq", msg_pool, sizeof(struct rx_msg), sizeof(msg_pool), RT_IPC_FLAG_FIFO); /* 打开设备（DMA接收模式） */ rt_device_open(serial, RT_DEVICE_FLAG_DMA_RX); /* 设置接收回调 */ rt_device_set_rx_indicate(serial, uart_input); /* 创建处理线程 */ rt_thread_t thread = rt_thread_create("serial", serial_thread_entry, RT_NULL, 1024, 25, 10); if (thread) { rt_thread_startup(thread); return RT_EOK; } return -RT_ERROR; }

4. 工程实践中的优化技巧

4.1 解决数据分包问题

在实际项目中，可能会遇到数据分包现象，表现为：

• 单次传输被拆分为多个消息
• 数据完整性被破坏

解决方案：

1. 协议层：添加帧头帧尾或校验
2. 超时机制：在一定时间内合并多个包
3. 缓冲区设计：采用环形缓冲区

// 超时合并示例（伪代码） static void serial_thread_entry(void *parameter) { rt_tick_t last_tick = 0; #define MERGE_TIMEOUT 10 // 10个tick while (1) { if (rt_mq_recv(&rx_mq, &msg, sizeof(msg), MERGE_TIMEOUT) == RT_EOK) { if (rt_tick_get() - last_tick > MERGE_TIMEOUT) { // 新数据包开始 reset_buffer(); } last_tick = rt_tick_get(); append_to_buffer(msg.data, msg.size); } else { // 超时，处理完整数据包 process_complete_packet(); } } }

4.2 消息队列满的处理策略

在高负载场景下，消息队列可能满，导致数据丢失。可以考虑以下策略：

1. 动态调整队列大小：根据负载情况自动扩容
2. 重要数据优先：实现优先级队列
3. 流量控制：通知发送方降低速率

// 队列满时的优化处理 if (rt_mq_send(&rx_mq, &msg, sizeof(msg)) == -RT_EFULL) { // 1. 尝试动态扩大队列 if (rx_mq.pool_size < MAX_POOL_SIZE) { rt_mq_resize(&rx_mq, rx_mq.pool_size * 2); rt_mq_send(&rx_mq, &msg, sizeof(msg)); // 重试 } // 2. 记录丢包统计 drop_counter++; }

4.3 性能优化建议

1. DMA缓冲区对齐：提高内存访问效率
2. 双缓冲技术：避免处理过程中的数据覆盖
3. 零拷贝设计：减少内存复制开销

// 双缓冲实现示例 static char dma_buffer[2][256]; static int active_buffer = 0; // 在空闲中断中切换缓冲区 void USART_IRQHandler(void) { if(USART_GetITStatus(USARTx, USART_IT_IDLE)) { size_t size = BUFFER_SIZE - DMA_GetCurrDataCounter(DMAy_Streamz); post_message(dma_buffer[active_buffer], size); active_buffer ^= 1; // 切换缓冲区 // 重新配置DMA到新缓冲区 DMA_Config(DMAy_Streamz, dma_buffer[active_buffer]); } }

5. 实际项目中的应用扩展

5.1 与传感器通信的完整案例

以常见的Modbus RTU温湿度传感器为例：

1. 协议解析层：处理Modbus帧
2. 数据转换层：原始数据转工程值
3. 应用层：显示或上传数据

// Modbus处理线程扩展 static void modbus_thread_entry(void *parameter) { while (1) { struct rx_msg msg; if (rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER) == RT_EOK) { uint8_t frame[256]; rt_size_t len = rt_device_read(msg.dev, 0, frame, msg.size); if (validate_modbus_frame(frame, len)) { float temperature, humidity; parse_modbus_data(frame, &temperature, &humidity); // 更新全局变量或发布事件 update_sensor_data(temperature, humidity); } } } }

5.2 多串口管理方案

当系统需要管理多个串口设备时：

1. 统一消息队列：所有串口共享队列
2. 独立处理线程：每个串口独立线程
3. 设备标识：消息中包含来源信息

struct multi_rx_msg { rt_device_t dev; rt_size_t size; char port_id; // 'A' for UART1, 'B' for UART2 etc. }; // 在回调中设置port_id static rt_err_t uartA_input(rt_device_t dev, rt_size_t size) { struct multi_rx_msg msg = {dev, size, 'A'}; rt_mq_send(&rx_mq, &msg, sizeof(msg)); }

5.3 与RT-Thread其他组件的集成

1. FinSH命令集成：添加调试命令
2. 日志系统：记录通信异常
3. 软件定时器：实现超时检测

# 自定义FinSH命令示例 msh >uart_test uart2 # 输出： # UART2 DMA receiver started # Received: Hello RT-Thread!

在项目开发中，这套方案已经稳定运行在多个工业现场，最长无故障运行时间超过2年。一个特别值得分享的经验是：当通信距离较长时，适当增加空闲检测超时时间（通过修改串口驱动中的IDLE判定条件）可以显著提高通信稳定性。