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

2024-06-03 00:36
文章标签 串口 rtos env dma gps 解析 接收 数据

本文主要是介绍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;
}

这篇关于RTOS（ENV）串口DMA接收GPS数据并解析的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1025535。

相关文章

解析 XML 和 INI

解析 XML 和 INI

XML 1.TinyXML库 TinyXML是一个C++的XML解析库  使用介绍： https://www.cnblogs.com/mythou/archive/2011/11/27/2265169.html    使用的时候，只要把 tinyxml.h、tinystr.h、tinystr.cpp、tinyxml.cpp、tinyxmlerror.cpp、tinyxmlparser.
阅读更多...
【服务器运维】MySQL数据存储至数据盘

【服务器运维】MySQL数据存储至数据盘

查看磁盘及分区 [root@MySQL tmp]# fdisk -lDisk /dev/sda: 21.5 GB, 21474836480 bytes255 heads, 63 sectors/track, 2610 cylindersUnits = cylinders of 16065 * 512 = 8225280 bytesSector size (logical/physical)
阅读更多...
SQL Server中，查询数据库中有多少个表，以及数据库其余类型数据统计查询

SQL Server中，查询数据库中有多少个表，以及数据库其余类型数据统计查询

sqlserver查询数据库中有多少个表 sql server 数表:select count(1) from sysobjects where xtype='U'数视图:select count(1) from sysobjects where xtype='V'数存储过程select count(1) from sysobjects where xtype='P' SE
阅读更多...
时间服务器中，适用于国内的 NTP 服务器地址，可用于时间同步或 Android 加速 GPS 定位

时间服务器中，适用于国内的 NTP 服务器地址，可用于时间同步或 Android 加速 GPS 定位

NTP 是什么？   NTP 是网络时间协议（Network Time Protocol），它用来同步网络设备【如计算机、手机】的时间的协议。 NTP 实现什么目的？   目的很简单，就是为了提供准确时间。因为我们的手表、设备等，经常会时间跑着跑着就有误差，或快或慢的少几秒，时间长了甚至误差过分钟。 NTP 服务器列表 最常见、熟知的就是 www.pool.ntp.org/zo
阅读更多...
tf.split()函数解析

tf.split()函数解析

API原型（TensorFlow 1.8.0）： tf.split(     value,     num_or_size_splits,     axis=0,     num=None,     name='split' ) 这个函数是用来切割张量的。输入切割的张量和参数，返回切割的结果。  value传入的就是需要切割的张量。  这个函数有两种切割的方式： 以三个维度的张量为例，比如说一
阅读更多...
数据时代的数字企业

数据时代的数字企业

1.写在前面 讨论数据治理在数字企业中的影响和必要性，并介绍数据治理的核心内容和实践方法。作者强调了数据质量、数据安全、数据隐私和数据合规等方面是数据治理的核心内容，并介绍了具体的实践措施和案例分析。企业需要重视这些方面以实现数字化转型和业务增长。 数字化转型行业小伙伴可以加入我的星球，初衷成为各位数字化转型参考库，星球内容每周更新 个人工作经验资料全部放在这里，包含数据治理、数据要
阅读更多...
如何在Java中处理JSON数据？

如何在Java中处理JSON数据？

如何在Java中处理JSON数据？ 大家好，我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编，也是冬天不穿秋裤，天冷也要风度的程序猿！今天我们将探讨在Java中如何处理JSON数据。JSON（JavaScript Object Notation）作为一种轻量级的数据交换格式，在现代应用程序中被广泛使用。Java通过多种库和API提供了处理JSON的能力，我们将深入了解其用法和最佳
阅读更多...
两个基因相关性CPTAC蛋白组数据

两个基因相关性CPTAC蛋白组数据

目录 蛋白数据下载 ①蛋白数据下载 1，TCGA-选择泛癌数据  2，TCGA-TCPA 3，CPTAC(非TCGA) ②蛋白相关性分析 1，数据整理 2，蛋白相关性分析 PCAS在线分析 蛋白数据下载 CPTAC蛋白组学数据库介绍及数据下载分析 – 王进的个人网站 (jingege.wang) ①蛋白数据下载 可以下载泛癌蛋白数据：UCSC Xena (xena
阅读更多...
陀螺仪LSM6DSV16X与AI集成(8)----MotionFX库解析空间坐标

陀螺仪LSM6DSV16X与AI集成(8)----MotionFX库解析空间坐标

陀螺仪LSM6DSV16X与AI集成.8--MotionFX库解析空间坐标 概述视频教学样品申请源码下载开启CRC串口设置开启X-CUBE-MEMS1设置加速度和角速度量程速率选择设置FIFO速率设置FIFO时间戳批处理速率配置过滤链初始化定义MotionFX文件卡尔曼滤波算法主程序执行流程lsm6dsv16x_motion_fx_determin欧拉角简介演示 概述 本文将探讨
阅读更多...
【文末附gpt升级秘笈】腾讯元宝AI搜索解析能力升级：千万字超长文处理的新里程碑

【文末附gpt升级秘笈】腾讯元宝AI搜索解析能力升级：千万字超长文处理的新里程碑

腾讯元宝AI搜索解析能力升级：千万字超长文处理的新里程碑 一、引言 随着人工智能技术的飞速发展，自然语言处理（NLP）和机器学习（ML）在各行各业的应用日益广泛。其中，AI搜索解析能力作为信息检索和知识抽取的核心技术，受到了广泛的关注和研究。腾讯作为互联网行业的领军企业，其在AI领域的探索和创新一直走在前列。近日，腾讯旗下的AI大模型应用——腾讯元宝，迎来了1.1.7版本的升级，新版本在AI搜
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2