[ROS 系列学习教程] rosbag C++ API

ROS 系列学习教程(总目录)

本文目录

  • 一、rosbag::Bag
    • 1.1 常用接口
    • 1.2 其他接口
  • 二、rosbag::View
    • 2.1 常用接口
      • 2.1.1 代码示例

rosbag 的 C++ API 主要有两个类,用于写bag文件的Bag类,和用于读bag文件的View类。

一、rosbag::Bag

用于写bag文件。

头文件:bag.h

1.1 常用接口

# 打开bag文件
Bag (std::string const &filename, uint32_t mode=bagmode::Read)# 打开bag文件
void open (std::string const &filename, uint32_t mode=bagmode::Read)# 关闭bag文件
void close()# 写bag文件
template<class T >
void write (std::string const &topic, ros::MessageEvent< T > const &event)template<class T >
void write (std::string const &topic, ros::Time const &time, boost::shared_ptr< T > const &msg, boost::shared_ptr< ros::M_string > connection_header=boost::shared_ptr< ros::M_string >())template<class T >
void write (std::string const &topic, ros::Time const &time, boost::shared_ptr< T const > const &msg, boost::shared_ptr< ros::M_string > connection_header=boost::shared_ptr< ros::M_string >())template<class T >
void write (std::string const &topic, ros::Time const &time, T const &msg, boost::shared_ptr< ros::M_string > connection_header=boost::shared_ptr< ros::M_string >())

示例代码:

#include <ros/ros.h>
#include <rosbag/bag.h>
#include <ros/package.h>
#include <std_msgs/String.h>int main(int argc, char **argv)
{ros::init(argc, argv, "bag_write");std::string packagePath = ros::package::getPath("rosbag_learning");std::string bagsPath = packagePath + "/bags";ros::NodeHandle nh;// 创建bag对象rosbag::Bag bag;// 打开文件bag.open(bagsPath+"/test.bag", rosbag::BagMode::Write);// 写文件std_msgs::String msg;msg.data = "hello world";// 写入4帧for (size_t i = 0; i < 4; i++){bag.write("/chatter", ros::Time::now(), msg);}// 关闭文件bag.close();return 0;
}

编译运行生成 test.bag 文件,查看该文件信息,结果如下:

在这里插入图片描述

可以看到成功写入了4帧数据。

1.2 其他接口

bag文件是否被打开

bool isOpen() const;

获取文件名

std::string getFileName() const;

获取文件的打开模式,枚举如下

BagMode getMode() const; 
enum BagMode
{Write   = 1,Read    = 2,Append  = 4
};

获取文件的主版本号和次版本号
ROS bag格式有很多版本,官方不保证不同版本之间的兼容性
bag文件第一行记录了当前的版本号,格式如:#ROSBAG VX.Y
旧版本使用#ROSRECORD或#ROSLOG前缀
其中,X是主版本号,Y是次版本号

uint32_t getMajorVersion() const;                     
uint32_t getMinorVersion() const;  

获取文件大小

uint64_t getSize() const;    

设置/获取用于写入块的压缩方法,枚举如下

void setCompression(CompressionType compression); 
CompressionType getCompression() const;     
enum CompressionType
{Uncompressed = 0, // 不压缩BZ2          = 1, // BZ2格式LZ4          = 2, // LZ4格式
};

设置/获取 Bag 文件中每个块的最大消息数量
在 ROS Bag 文件中,消息数据被划分为多个“块”(chunks)。每个块可能包含多个消息,并且块的大小是固定的。块的大小决定了 Bag 文件的读写效率和磁盘空间使用。
当向 Bag 文件中写入消息时,ROS 会尝试将消息放入当前的块。如果当前块中的消息数量达到或超过 chunk_threshold,则 ROS 会开始一个新的块来存储后续的消息。
通过调整 chunk_threshold,你可以控制 Bag 文件的读写效率和磁盘空间使用。较小的 chunk_threshold 会导致更多的块,这可能会降低读写效率但可能会节省磁盘空间(因为每个块都有自己的元数据)。而较大的 chunk_threshold 则会提高读写效率,但可能会使用更多的磁盘空间。

void setChunkThreshold(uint32_t chunk_threshold); 
uint32_t getChunkThreshold() const;     

使用指定的加密插件加密bag文件

void setEncryptorPlugin(const std::string& plugin_name, const std::string& plugin_param = std::string());

交换当前bag对象与参数bag的内容

void swap(Bag&);

二、rosbag::View

用于读bag文件。

头文件:view.h

2.1 常用接口

创建一个bag文件视图
将bag中的msg存到vector中,按时间升序排序
bag:bag文件
query:查询条件函数
start_time:查询时间范围的开始时间
end_time:查询时间范围的结束时间
reduce_overlap:如果返回多个相同的消息,将它们合并为一条消息

View(bool const& reduce_overlap = false);
View(Bag const& bag, ros::Time const& start_time = ros::TIME_MIN, ros::Time const& end_time = ros::TIME_MAX, bool const& reduce_overlap = false);
View(Bag const& bag, boost::function<bool(ConnectionInfo const*)> query, ros::Time const& start_time = ros::TIME_MIN, ros::Time const& end_time = ros::TIME_MAX, bool const& reduce_overlap = false);

查询时间范围的开始/结束时间

ros::Time getBeginTime();
ros::Time getEndTime();

用于遍历vector中的msg

iterator begin();
iterator end();

获取vector大小(msg个数)

uint32_t size();

添加查询时间范围
bag:bag文件
query:查询条件函数
start_time:查询时间范围的开始时间
end_time:查询时间范围的结束时间

void addQuery(Bag const& bag, ros::Time const& start_time = ros::TIME_MIN, ros::Time const& end_time = ros::TIME_MAX);
void addQuery(Bag const& bag, boost::function<bool(ConnectionInfo const*)> query, ros::Time const& start_time = ros::TIME_MIN, ros::Time const& end_time = ros::TIME_MAX);

获取bag中topic的连接信息,每个topic一个结构体
其中返回结构体定义如下:

std::vector<const ConnectionInfo*> getConnections();
struct ROSBAG_STORAGE_DECL ConnectionInfo
{ConnectionInfo() : id(-1) { }uint32_t    id;        // topic idstd::string topic;     // topic名字std::string datatype;  // topic数据类型,即topic的msgstd::string md5sum;    // topic的MD5值std::string msg_def;   // msg的数据类型boost::shared_ptr<ros::M_string> header;
};

2.1.1 代码示例

#include <ros/ros.h>
#include <rosbag/bag.h>
#include <rosbag/view.h>
#include <std_msgs/String.h>int main(int argc, char **argv)
{ros::init(argc, argv, "bag_read");std::string packagePath = ros::package::getPath("rosbag_learning");std::string bagsPath = packagePath + "/bags";rosbag::Bag bag;bag.open(bagsPath+"/test.bag"); // BagMode is Read by defaultfor (rosbag::MessageInstance const m : rosbag::View(bag)){std_msgs::String::ConstPtr i = m.instantiate<std_msgs::String>();if (i != nullptr){ROS_INFO("%s", i->data.c_str());}}bag.close();return 0;
}

编译运行,读取上文生成的test.bag 文件,结果如下:

在这里插入图片描述

对于 getConnections() 函数,示例如下:

#include <ros/ros.h>
#include <rosbag/bag.h>
#include <rosbag/view.h>int main(int argc, char **argv)
{ros::init(argc, argv, "bag_read");std::string packagePath = ros::package::getPath("rosbag_learning");std::string bagsPath = packagePath + "/bags";rosbag::Bag bag;bag.open(bagsPath+"/test.bag"); // BagMode is Read by defaultrosbag::View view(bag);std::vector<const rosbag::ConnectionInfo*> cInfo = view.getConnections();for (size_t i = 0; i < cInfo.size(); i++){ROS_INFO("id: %d, topic: %s, dataType: %s, md5: %s, msg_def: %s", cInfo[i]->id, cInfo[i]->topic.c_str(), cInfo[i]->datatype.c_str(),cInfo[i]->md5sum.c_str(), cInfo[i]->msg_def.c_str());}bag.close();return 0;
}

编译运行,结果如下:

在这里插入图片描述

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

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

相关文章

Spring文件上传下载代码

Spring文件上传下载代码 文件上传 MultipartFile是SpringMVC提供简化上传操作的工具类。 /*** 文件上传接口** param file* return*/PostMapping("/fileUpload")public String fileUpload(RequestParam("file") MultipartFile file) {// 用户鉴权&#x…

集合和数组的相关操作

目录 1.数组转集合(引用类型数组) 2.数组转集合(基础类型数组) 3.集合转数组 4.集合之间是否相交 5.获取两个集合的交集 6.集合转为字符串 1.数组转集合(引用类型数组) (1)Arrays.asList 示例&#xff1a; String[] colArr new String[6];colArr[0] "1";co…

代码随想录刷题笔记 DAY 42 | 最后一块石头的重量 II No.1049 | 目标和 No.494 | 一和零 No.474

文章目录 Day 4301. 最后一块石头的重量 II&#xff08;No. 1049&#xff09;<1> 题目<2> 笔记<3> 代码 02. 目标和&#xff08;No. 494&#xff09;<1> 题目<2> 笔记<3> 代码 03. 一和零&#xff08;No. 474&#xff09;<1> 题目&l…

[C/C++]string类常用接口介绍及模拟实现string类

一&#xff1a;Cstring类的由来 在C语言中&#xff0c;字符串是以\0结尾的一些字符的集合&#xff0c;为了操作方便&#xff0c;C标准库中提供了一些str系列的库函数&#xff0c;但是这些库函数与字符串是分离开的&#xff0c;不太符合OOP的思想&#xff0c;而且底层空间需要用…

字节跳动的 SDXL-LIGHTNING : 体验飞一般的文生图

TikTok 的母公司字节跳动推出了最新的文本到图像生成人工智能模型&#xff0c;名为SDXL-Lightning。顾名思义&#xff0c;这个新模型只需很轻量的推理步骤&#xff08;1&#xff0c;4 或 8 步&#xff09;即可实现极其快速且高质量的文本到图像生成功能。与原始 SDXL 模型相比&…

uniapp开发小程序实现-获取手机号码(二)

一共3篇文章,共同描述,看序号进行寻找。 真机效果图 1.前提 获取手机号码,一定要企业账号,不是企业账号会出现下面提示 所以没有企业账号的,就可以不用看了,申请企业账号去官网申请就行了,申请成功了后,我们接着看。 2.代码 代码参考文章 获取手机号 | 微信开放文…

CodecConfigurationException: Can‘t find a codec for class java.lang.Class.

前言 在使用spring data mongodb的mongoTemplate 更新数据时遇到如下错误 org.bson.codecs.configuration.CodecConfigurationException: Can’t find a codec for class java.lang.Class. 详细的错误信息 org.bson.codecs.configuration.CodecConfigurationException: Cant…

AI PC:重塑未来办公与生活方式的革命性工具

随着科技的飞速发展&#xff0c;人工智能&#xff08;AI&#xff09;已经渗透到我们生活的方方面面。而在PC领域&#xff0c;一场由AI引领的变革也正在悄然发生。从硬件到软件&#xff0c;从云端到终端&#xff0c;AI正在重塑我们的办公和生活方式。 AI工具网 | 人工智能工具推…

【蓝桥杯-单片机】基础模块:矩阵按键

文章目录 【蓝桥杯-单片机】基础模块&#xff1a;矩阵按键 【蓝桥杯-单片机】基础模块&#xff1a;矩阵按键 /** * 函数名 矩阵键盘扫描函数 * 函数功能 返回按下的按键键码值 * 入口参数 无 * 返回值 按键键码值 */ unsigned char Key_Read_Pro() {unsigned char temp 0;P3…

简单银行管理系统(C# winform SQL Server)

一、任务描述 1.使用Asp.NET技术&#xff0c;完成银行管理系统 2.开发工具&#xff1a;VS2010 3.数据库&#xff1a;SQL Server 2008 功能模块&#xff1a;登录、开户、存款、取款、转账、挂失等功能 运行界面&#xff1a; 1.登录界面&#xff08;Login.aspx&#xff09; 在…

YoloV7改进策略:卷积改进|MogaNet——高效的多阶门控聚合网络

文章目录 摘要论文:《MogaNet——高效的多阶门控聚合网络》1、简介2、相关工作2.1、视觉Transformers2.2、ViT时代的卷积网络3、从多阶博弈论交互的角度看表示瓶颈4、方法论4.1、MogaNet概述4.2、多阶门控聚合4.3、通过通道聚合进行多阶特征重新分配4.4、实现细节5、实验5.1、…

Django中的MySQL has gone away

在Django中遇到"Mysql has gone away"的错误,通常是因为MySQL数据库连接断开导致的。这可能是由于多种原因造成的,例如网络问题、数据库服务器的配置问题、数据库连接超时等。 为了解决这个问题,你可以尝试以下几个步骤: 检查数据库连接设置: 确保Django的配置文…

数据分析-Pandas两种分组箱线图比较

数据分析-Pandas两种分组箱线图比较 数据分析和处理中&#xff0c;难免会遇到各种数据&#xff0c;那么数据呈现怎样的规律呢&#xff1f;不管金融数据&#xff0c;风控数据&#xff0c;营销数据等等&#xff0c;莫不如此。如何通过图示展示数据的规律&#xff1f; 数据表&am…

牛客周赛 Round 36

赛况 C题可惜&#xff0c;比赛时模拟没有想明白&#xff0c;只对了一半&#xff0c;赛后看了大佬们的题解后恍然大悟&#xff0c;而F题是压根没思路&#xff0c;况且F题部分分也比较难拿。 题目列表 A-小红的数位删除 思路 将读入的数字整除10做三次后输出即可 参考代码 #inc…

高效管理百万级数据:MySQL备份与恢复实战指南

简介 在当今数字化时代&#xff0c;数据是企业不可或缺的核心资产之一&#xff0c;而MySQL作为一种流行的关系型数据库管理系统&#xff0c;其百万级数据的高效管理显得尤为重要。本实战指南将深入探讨MySQL备份与恢复的关键策略&#xff0c;为您提供全面而实用的解决方案。通…

streamlit学习-如何修改css样式

streamlit学习-如何修改css样式 效果图代码(srv.py)运行 streamlit默认的样式有时并不符合自己的要求。比如手机上的布局太浪费空间,我们希望一屏能放下所有的元素,本文演示了如何操作 效果图 代码(srv.py) import streamlit as st #1.31.1 import cv2 import numpy as np im…

埋点方案设计之感想

埋点方案设计是指在软件开发或者数据分析中&#xff0c;为了跟踪用户行为、收集数据以及进行分析&#xff0c;需要在代码中插入一些埋点&#xff08;Tracking&#xff09;代码&#xff0c;记录用户在应用中的各种操作和行为。下面是一个简单的埋点方案设计流程&#xff1a; 明…

报错:C51/Inc/Atmel/regx52.h(15):error41:syntax error near ‘sfr‘, expected ‘hdata‘

背景 跟着51单片机教程敲代码&#xff0c;在学习模块化编程这块&#xff0c;一会.h&#xff0c;一会.c文件的&#xff0c;文件切来切去&#xff0c;然后编译的时候就出了如题所示的错。 解决过程 看了报错信息&#xff0c;一直以为是regx52.h里的15行附近我手抖改了什么东西…

实验二(二)OSPF路由协议基础实验

1.实验介绍 1.1关于本实验 开放式最短路径优先 OSPF(Open Shortest Path First)是IETF 组织开发的一个基于链路状态的内部网关协议(Interior Gateway Protocol)。目前针对 IPv4 协议使用的是 OSPF Version 2(RFC2328);OSPF 作为基于链路状态的协议&#xff0c;OSPF 具有以下优…

OpenFeign的常规使用

架构: 一.新建module 引入依赖: <!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency> yml配置; server:port: 80spring:applicati…