RTOS（ENV）串口DMA接收GPS数据并解析

RTOS（ENV）配置STM32串口DMA接收模式

环境：

  1. RTOS 4.0.3
  2. Keil5
  3. ENV
  4. STm32l475

ENV配置

  1. 使能串口：

alt text
2. 使能DMA，并设置接收缓冲区大小：

alt text

  1. 创建工程
scons --target=mdk

工程配置

1. 创建串口设备句柄

#define SAMPLE_UART_NAME "uart2" /* 串口设备名称 */
rt_device_t serial; /*句柄*/

2.使用消息队列方式

/* 串口接收消息结构*/
struct rx_msg
{rt_device_t dev;rt_size_t size;
};
/* 串口设备句柄 */
static rt_device_t serial;
/* 消息队列控制块 */
static struct rt_messagequeue rx_mq;

3.打开设备方式

/* 以 DMA 接收及轮询发送方式打开串口设备 */rt_device_open(serial, RT_DEVICE_FLAG_DMA_RX);/* 设置接收回调函数 */rt_device_set_rx_indicate(serial, uart_input);/* 发送字符串 */rt_device_write(serial, 0, str, (sizeof(str) - 1));

注意：

struct serial_configure config = RT_SERIAL_CONFIG_DEFAULT; // 初始化配置
/* 控制串口设备。通过控制接口传入命令控制字，与控制参数 */
rt_device_control(serial, RT_DEVICE_CTRL_CONFIG, &config);
这些步骤是非DMA方式（中断）接收的，使用 rt_device_control函数 会影响DMA共能得使用

4. 串口接收数据

/* 接收数据回调函数 */
static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{struct rx_msg msg;rt_err_t result;msg.dev = dev;msg.size = size;result = rt_mq_send(&rx_mq, &msg, sizeof(msg));if ( result == -RT_EFULL){/* 消息队列满 */rt_kprintf("message queue full！\n");}return result;
}static void serial_thread_entry(void *parameter)
{struct rx_msg msg;rt_err_t result;rt_uint32_t rx_length;static char rx_buffer[RT_SERIAL_RB_BUFSZ + 1];while (1){rt_memset(&msg, 0, sizeof(msg));/* 从消息队列中读取消息*/result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER);if (result == RT_EOK){/* 从串口读取数据*/rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size);rx_buffer[rx_length] = '\0';/* 通过串口设备 serial 输出读取到的消息 */rt_device_write(serial, 0, rx_buffer, rx_length);/* 打印数据 */rt_kprintf("%s\n",rx_buffer);}}
}

源code：

#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include <drv_lcd.h>
#include <rttlogo.h>#define SAMPLE_UART_NAME       "uart2"/* 串口接收消息结构*/
struct rx_msg
{rt_device_t dev;rt_size_t size;
};
/* 串口设备句柄 */
static rt_device_t serial;
/* 消息队列控制块 */
static struct rt_messagequeue rx_mq;/* 接收数据回调函数 */
static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{struct rx_msg msg;rt_err_t result;msg.dev = dev;msg.size = size;result = rt_mq_send(&rx_mq, &msg, sizeof(msg));if ( result == -RT_EFULL){/* 消息队列满 */rt_kprintf("message queue full！\n");}return result;
}static void serial_thread_entry(void *parameter)
{struct rx_msg msg;rt_err_t result;rt_uint32_t rx_length;static char rx_buffer[RT_SERIAL_RB_BUFSZ + 1];while (1){rt_memset(&msg, 0, sizeof(msg));/* 从消息队列中读取消息*/result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER);if (result == RT_EOK){/* 从串口读取数据*/rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size);rx_buffer[rx_length] = '\0';/* 通过串口设备 serial 输出读取到的消息 */rt_device_write(serial, 0, rx_buffer, rx_length);/* 打印数据 */rt_kprintf("%s\n",rx_buffer);}}
}void main(void)
{static char msg_pool[256];char str[] = "hello RT-Thread!666\r\n";/* 查找串口设备 */serial = rt_device_find(SAMPLE_UART_NAME);if (!serial){rt_kprintf("find %s failed!\n", SAMPLE_UART_NAME);}/* 初始化消息队列 */rt_mq_init(&rx_mq, "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_device_write(serial, 0, str, (sizeof(str) - 1));/* 创建 serial 线程 */rt_thread_t thread = rt_thread_create("serial", serial_thread_entry, RT_NULL, 1024, 25, 10);/* 创建成功则启动线程 */if (thread != RT_NULL){rt_thread_startup(thread);}else{rt_kprintf("Create %s Entry failed!\n", SAMPLE_UART_NAME);}}

附加例题：RT-Thread使用消息邮箱解析GPS数据

使用消息邮箱完成以下任务：
创建2个线程：串口接收和解析线程、LCD显示线程；

  1. 串口线程接收和解析GPS设备通过串口发来的数据（以GPRMC为主），发送给邮箱；

  2. LCD显示线程获取邮箱里的邮件消息，提取相关信息（如 经纬度位置、速度、方向、当前时间等），显示到LCD屏幕上。

  3. 使用PC上位机的串口调试助手发送GPS接收数据，模拟GPS接收机。

参考资料：GPS数据包格式及数据包解析(https://blog.csdn.net/qq_17308321/article/details/80714560)

GPS接收机接收到的数据样例：

$GPRMC,092927.000,A,2235.9058,N,11400.0518,E,0.000,74.11,151216,,D*49 
$GPVTG,74.11,T,,M,0.000,N,0.000,K,D*0B 
$GPGGA,092927.000,2235.9058,N,11400.0518,E,2,9,1.03,53.1,M,-2.4,M,0.0,0*6B
$GPGSA,A,3,29,18,12,25,10,193,32,14,31,,,,1.34,1.03,0.85*31 
$GPGSV,3,1,12,10,77,192,17,25,59,077,42,32,51,359,39,193,49,157,36*48 
$GPGSV,3,2,12,31,47,274,25,50,46,122,37,18,45,158,37,14,36,326,18*70 
$GPGSV,3,3,12,12,24,045,45,26,17,200,18,29,07,128,38,21,02,174,*79

1. 添加GPS数据解析模块

  • 定义数据结构
/*邮箱控股句柄*/
rt_mailbox_t uart_gps_mail;typedef struct GpsData
{char Time[30];char Status[30];char Latitude[30];char N_S[30];char Longitude[30];char E_W[30];char Ground_Speed[30];char Course[30];char Date[30];
} GpsData;
  • 添加GPS数据解析函数
 //解析 NMEA 句子并提取信息的函数
void parseNMEA(const char *sentence)
{char utcTime[12];char status;double latitude, longitude, groundSpeed, course;char utcDate[7];// 使用 sscanf 函数从 NMEA 句子中提取信息sscanf(sentence, "$GPRMC,%[^,],%c,%lf,N,%lf,E,%lf,%lf,%[^,],",utcTime, &status, &latitude, &longitude, &groundSpeed, &course, utcDate);// 提取小时、分钟和秒int hour, minute;double second;sscanf(utcTime, "%2d%2d%lf", &hour, &minute, &second);// 提取日期int year, month, day;sscanf(utcDate, "%2d%2d%2d", &day, &month, &year);// 打印提取的信息sprintf(gpsData.Time, "Time: %02d:%02d:%06.3lf", hour, minute, second);sprintf(gpsData.Status, "Status: %s", (status == 'A') ? "Valid" : "Invalid");sprintf(gpsData.Latitude, "Latitude: %.4f  N", latitude);sprintf(gpsData.Longitude, "Longitude: %.4f  E", longitude);sprintf(gpsData.Ground_Speed, "Speed: %.3f knots", groundSpeed);sprintf(gpsData.Course, "Course: %.2f ", course);sprintf(gpsData.Date, "Date: %02d-%02d-%02d", year, month, day);rt_mb_send(uart_gps_mail, (rt_uint32_t)&gpsData);
}

2. 添加lcd显示线程：

void lcd_show(void *parameter)
{lcd_clear(WHITE);lcd_set_color(WHITE, BLACK);GpsData *gpsData;while (1){rt_mb_recv(uart_gps_mail, (rt_ubase_t *)&gpsData, RT_WAITING_FOREVER);lcd_show_string(10, 10, 16, gpsData->Time);lcd_show_string(10, 40, 16, gpsData->Status);lcd_show_string(10, 70, 16, gpsData->Latitude);lcd_show_string(10, 100, 16, gpsData->Longitude);lcd_show_string(10, 130, 16, gpsData->Ground_Speed);lcd_show_string(10, 160, 16, gpsData->Course);lcd_show_string(10, 190, 16, gpsData->Date);}
}

3. 源code

#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include <drv_lcd.h>
#include <rttlogo.h>
#include <stdio.h>
#include <string.h>#define SAMPLE_UART_NAME "uart2"/* 串口接收消息结构*/
struct rx_msg
{rt_device_t dev;rt_size_t size;
};
/* 串口设备句柄 */
static rt_device_t serial;
/* 消息队列控制块 */
static struct rt_messagequeue rx_mq;
/*邮箱控股句柄*/
rt_mailbox_t uart_gps_mail;typedef struct GpsData
{char Time[30];char Status[30];char Latitude[30];char N_S[30];char Longitude[30];char E_W[30];char Ground_Speed[30];char Course[30];char Date[30];
} GpsData;GpsData gpsData;void lcd_show(void *parameter)
{lcd_clear(WHITE);lcd_set_color(WHITE, BLACK);GpsData *gpsData;while (1){rt_mb_recv(uart_gps_mail, (rt_ubase_t *)&gpsData, RT_WAITING_FOREVER);lcd_show_string(10, 10, 16, gpsData->Time);lcd_show_string(10, 40, 16, gpsData->Status);lcd_show_string(10, 70, 16, gpsData->Latitude);lcd_show_string(10, 100, 16, gpsData->Longitude);lcd_show_string(10, 130, 16, gpsData->Ground_Speed);lcd_show_string(10, 160, 16, gpsData->Course);lcd_show_string(10, 190, 16, gpsData->Date);}
}// 解析 NMEA 句子并提取信息的函数
void parseNMEA(const char *sentence)
{char utcTime[12];char status;double latitude, longitude, groundSpeed, course;char utcDate[7];// 使用 sscanf 函数从 NMEA 句子中提取信息sscanf(sentence, "$GPRMC,%[^,],%c,%lf,N,%lf,E,%lf,%lf,%[^,],",utcTime, &status, &latitude, &longitude, &groundSpeed, &course, utcDate);// 提取小时、分钟和秒int hour, minute;double second;sscanf(utcTime, "%2d%2d%lf", &hour, &minute, &second);// 提取日期int year, month, day;sscanf(utcDate, "%2d%2d%2d", &day, &month, &year);// 打印提取的信息sprintf(gpsData.Time, "Time: %02d:%02d:%06.3lf", hour, minute, second);sprintf(gpsData.Status, "Status: %s", (status == 'A') ? "Valid" : "Invalid");sprintf(gpsData.Latitude, "Latitude: %.4f  N", latitude);sprintf(gpsData.Longitude, "Longitude: %.4f  E", longitude);sprintf(gpsData.Ground_Speed, "Speed: %.3f knots", groundSpeed);sprintf(gpsData.Course, "Course: %.2f ", course);sprintf(gpsData.Date, "Date: %02d-%02d-%02d", year, month, day);rt_mb_send(uart_gps_mail, (rt_uint32_t)&gpsData);
}/* 接收数据回调函数 */
static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{struct rx_msg msg;rt_err_t result;msg.dev = dev;msg.size = size;result = rt_mq_send(&rx_mq, &msg, sizeof(msg));if (result == -RT_EFULL){/* 消息队列满 */rt_kprintf("message queue full！\n");}return result;
}static void serial_thread_entry(void *parameter)
{struct rx_msg msg;rt_err_t result;rt_uint32_t rx_length;static char rx_buffer[RT_SERIAL_RB_BUFSZ + 1];while (1){rt_memset(&msg, 0, sizeof(msg));/* 从消息队列中读取消息*/result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER);if (result == RT_EOK){/* 从串口读取数据*/rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size);rx_buffer[rx_length] = '\0';/* 通过串口设备 serial 输出读取到的消息 */rt_device_write(serial, 0, rx_buffer, rx_length);/* 打印数据 */// rt_kprintf("%s\n",rx_buffer);parseNMEA(rx_buffer);}}
}int main(void)
{static char msg_pool[256];char str[] = "hello RT-Thread!666\r\n";/*动态创建邮箱*/uart_gps_mail = rt_mb_create("uart_gps", 1024, RT_IPC_FLAG_FIFO);/* 查找串口设备 */serial = rt_device_find(SAMPLE_UART_NAME);if (!serial){rt_kprintf("find %s failed!\n", SAMPLE_UART_NAME);}/* 初始化消息队列 */rt_mq_init(&rx_mq, "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_device_write(serial, 0, str, (sizeof(str) - 1));/* 创建 serial 线程 */rt_thread_t thread = rt_thread_create("serial", serial_thread_entry, RT_NULL, 1024, 25, 10);rt_thread_t lcd_th = rt_thread_create("lcd", lcd_show, RT_NULL, 1024, 25, 10);/* 创建成功则启动线程 */if (thread != RT_NULL && lcd_th != RT_NULL){rt_thread_startup(thread);rt_thread_startup(lcd_th);}else{rt_kprintf("Create %s Entry failed!\n", SAMPLE_UART_NAME);}return RT_EOK;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/339223.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

LLaMA-Factory实战推理

LLaMA-Factory实战推理

LLaMA-Factory官网&#xff1a;https://github.com/hiyouga/LLaMA-Factory 安装环境 git clone https://github.com/hiyouga/LLaMA-Factory.git cd LLaMA-Factory/ conda create -n py310 python3.10 conda activate py310按照llama-factory要求的标准格式组织数据集&#xff…
阅读更多...
linux tomcat版本漏洞升级

linux tomcat版本漏洞升级

Tomcat Session 反序列化代码执行漏洞(CVE-2020-9484) Tomcat 安全限制绕过漏洞(CVE-2018-8034) Tomcat远程代码执行漏洞(CVE-2017-12615) 以上均可以升级版本处理&#xff0c;小版本升级方法 tomcat安装请查看https://blog.csdn.net/qq_42250832/article/details/139015573 1、…
阅读更多...
数学建模 —— 人工神经网络（6）

数学建模 —— 人工神经网络（6）

目录 一、人工神经网络 1.1 人工神经网络结构 1.2 神经元/感知器 1.3 激活函数 1.3.1 sign函数 1.3.2 sigmoid函数&#xff08;Logistic函数&#xff09; 1.3.3 tanh双曲正切函数 1.3.4 ReLU函数 1.4 分类 二、BP人工神经网络 2.1 概述 2.2 处理过程 2.3 例题 2.…
阅读更多...
本地安装AI大模型

本地安装AI大模型

使用ollmam安装llmama3等模型 1.打开ollmam下载对应系统的软件&#xff0c;安装即可 官网&#xff1a;Ollama&#xff0c; 安装直接点就就行了&#xff0c;没有其他操作 2.安装模型 在官网找到对于的模型下载命令 记录命令:ollama run llama3 打开一个cmd窗口&#xff0c;输…
阅读更多...
272 基于matlab的形态滤波和局域值分解（LMD）的齿轮故障诊断

272 基于matlab的形态滤波和局域值分解（LMD）的齿轮故障诊断

基于matlab的形态滤波和局域值分解&#xff08;LMD&#xff09;的齿轮故障诊断&#xff0c;GUI交互界面。通过形态滤波对一维信号进行降噪处理&#xff0c;并通过LMD局部均值分解提取故障信号&#xff0c;最后提取处故障频率。程序已调通&#xff0c;可直接运行。 272 形态滤波…
阅读更多...
Thinkphp5响应式进销存仓库管理系统

Thinkphp5响应式进销存仓库管理系统

随着企业规模的不断扩大和市场竞争的日益激烈&#xff0c;进销存管理在企业的运营中扮演着越来越重要的角色。为了提高企业的运营效率&#xff0c;降低库存成本&#xff0c;提升客户满意度&#xff0c;越来越多的企业开始引入进销存仓库管理系统。 进销存仓库管理系统是一种集…
阅读更多...
汽车数据应用构想（二）

汽车数据应用构想（二）

一直说数据价值场景&#xff0c;啥叫有价值&#xff1f;啥样的场景有价值&#xff1f;按互联网的价值观来看&#xff0c;用户的高频需求就是价值。用户也许不会付费&#xff0c;但只要他天天用&#xff0c;那就是流量&#xff0c;就是用户黏性&#xff0c;就是价值&#xff01;…
阅读更多...
夜天之书 #98 Rust 程序库生态合作的例子

夜天之书 #98 Rust 程序库生态合作的例子

近期主要时间都在适应产品市场&#xff08;Product Marketing&#xff09;的新角色&#xff0c;不少想法还在酝酿和斟酌当中&#xff0c;于是文章输出没有太多时间来推敲和选题&#xff0c;只能保持每月发布相关的进展或一些零碎的思考。或许我可以恢复最早的模式&#xff0c;多…
阅读更多...
kotlin1.8.10问题导致gson报错TypeToken type argument must not contain a type variable

kotlin1.8.10问题导致gson报错TypeToken type argument must not contain a type variable

书接上回&#xff0c;https://blog.csdn.net/jzlhll123/article/details/139302991。 之前我发现gson报错后&#xff1a; gson在2.11.0给我的kotlin项目代码报错了。 IllegalArgumentException: TypeToken type argument must not contain a type variable 上次解释原因是因为&…
阅读更多...
String常用操作

String常用操作

String常用方法 构造字符串 常用的构造字符串有3种&#xff1a; 1.直接赋值String s "abcd"; 2.实例化调用构造方法String s new String("abcd"); 3.实例化传字符数组 char[] ch {a,b,c,d}; String s new String(ch);字符串比较 比较 比较的是两个…
阅读更多...
隐马尔可夫链

隐马尔可夫链

1 马尔可夫链 马尔科夫链&#xff08;Markov Chain&#xff09;是一种数学模型&#xff0c;它描述了一系列可能事件的概率&#xff0c;其中每个事件的发生仅依赖于前一个事件的状态。这一特性称为“无记忆性”或“马尔可夫性质”。我将用一个简单的天气预测模型作为例子来解释马…
阅读更多...
Java+SVNCloud+Mysql课程设计

Java+SVNCloud+Mysql课程设计

文章目录 1、主要内容2、所需准备3、与sql访问的中间类&#xff1a;SqlMessage4、窗口界面5、main方法 1、主要内容 课程设计&#xff0c;主要通过Javas wing创建窗口&#xff0c;jdbc连接云端mysql数据库进行基本操作&#xff0c;支持随机生成数据并用动态展示数据结果。 先…
阅读更多...
自学 Java 怎么入门？

自学 Java 怎么入门？

关于自学 Java 如何入门这一重要课题&#xff0c;在此为大家进行详细阐述。 在此之前&#xff0c;如果大家有兴趣的话&#xff0c;可以看看我自己精心整理的嵌入式入门资料&#xff0c;这些资料将全部免费送给大家。其中包含了编程教学内容、详细的视频讲解、实用的数据库资料…
阅读更多...
Vue 实例

Vue 实例

一、页面效果图 二、代码 <!DOCTYPE html> <html><head><meta charset"utf-8"><script src"../vue.js" type"text/javascript"></script><title>vue 实例</title></head><body>&l…
阅读更多...
Linux命令篇（一）：文件管理部分

Linux命令篇（一）：文件管理部分

&#x1f49d;&#x1f49d;&#x1f49d;首先&#xff0c;欢迎各位来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里不仅可以有所收获&#xff0c;同时也能感受到一份轻松欢乐的氛围&#xff0c;祝你生活愉快&#xff01; 文章目录 1、cat命令常用参…
阅读更多...
HALCON-从入门到入门-图像格式的互相转换

HALCON-从入门到入门-图像格式的互相转换

1.废话 上次说到了图片的读取和写入到本地&#xff0c;这次说一下图片的格式相关。 位图和矢量图 photoshop处理出来的图片肯定叫做图片&#xff0c;那么coreDraw处理出来的图片是不是也叫图片。 之间就有区分&#xff0c;一种叫做位图&#xff0c;一种叫做矢量图 位图和矢…
阅读更多...
创建一个支持切换阅读模式和答题模式的Anki问答题模板

创建一个支持切换阅读模式和答题模式的Anki问答题模板

为了备考某个需要默写的科目&#xff0c;做了个问答题笔记模板&#xff0c;如下&#xff1a; 在上图的回答栏填写答案后&#xff0c;点击显示答案按钮转到背面&#xff1a; 只实现上面的功能是很简单的&#xff0c;直接基于Anki自带的问答题模板添加自己需要的字段即可。问题…
阅读更多...
基于卷积-小波神经网络的SAR图像海冰变化检测方法（MATLAB R2018A）

基于卷积-小波神经网络的SAR图像海冰变化检测方法（MATLAB R2018A）

海冰是冰冻圈的重要组成部分&#xff0c;海冰的变化信息对航行安全和自然资源开采等非常重要&#xff0c;许多船舶没有加固防冰设备&#xff0c;因此&#xff0c;必须避开所有的冰区。尤其当冰压很高时&#xff0c;即使破冰船也很难在冰层中前行。为了安全航行&#xff0c;获取…
阅读更多...
自动化办公01 smtplib 邮件⾃动发送

自动化办公01 smtplib 邮件⾃动发送

目录 一、准备需要发送邮件的邮箱账号 二、发送邮箱的基本步骤 1. 登录邮箱 2. 准备数据 3. 发送邮件 三、特殊内容的发送 1. 发送附件 2. 发送图片 3. 发送超文本内容 4.邮件模板内容 SMTP&#xff08;Simple Mail Transfer Protocol&#xff09;即简单邮件传输协议…
阅读更多...
天气数据集-Jena Climate dataset

天气数据集-Jena Climate dataset

天气数据集-Jena Climate dataset 1.数据集基本信息 Dataset Name: mpi_saale_2021b.csv Size: 26495 rows; 1 year (2021), 10 min 气象学、农业、环境科学 开源机构: Max Planck Institute for Biogeochemistry 2.数据特征 2.1 特征简介 数据共有31个特征&#xff0c;…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023