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

2024-03-11 01:28

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

编译运行,结果如下:

在这里插入图片描述

这篇关于[ROS 系列学习教程] rosbag C++ API的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/796155

相关文章

windos server2022的配置故障转移服务的图文教程

《windosserver2022的配置故障转移服务的图文教程》本文主要介绍了windosserver2022的配置故障转移服务的图文教程,以确保服务和应用程序的连续性和可用性,文中通过图文介绍的非... 目录准备环境:步骤故障转移群集是 Windows Server 2022 中提供的一种功能,用于在多个

龙蜥操作系统Anolis OS-23.x安装配置图解教程(保姆级)

《龙蜥操作系统AnolisOS-23.x安装配置图解教程(保姆级)》:本文主要介绍了安装和配置AnolisOS23.2系统,包括分区、软件选择、设置root密码、网络配置、主机名设置和禁用SELinux的步骤,详细内容请阅读本文,希望能对你有所帮助... ‌AnolisOS‌是由阿里云推出的开源操作系统,旨

PyTorch使用教程之Tensor包详解

《PyTorch使用教程之Tensor包详解》这篇文章介绍了PyTorch中的张量(Tensor)数据结构,包括张量的数据类型、初始化、常用操作、属性等,张量是PyTorch框架中的核心数据结构,支持... 目录1、张量Tensor2、数据类型3、初始化(构造张量)4、常用操作5、常用属性5.1 存储(st

C++中实现调试日志输出

《C++中实现调试日志输出》在C++编程中,调试日志对于定位问题和优化代码至关重要,本文将介绍几种常用的调试日志输出方法,并教你如何在日志中添加时间戳,希望对大家有所帮助... 目录1. 使用 #ifdef _DEBUG 宏2. 加入时间戳:精确到毫秒3.Windows 和 MFC 中的调试日志方法MFC

Java操作PDF文件实现签订电子合同详细教程

《Java操作PDF文件实现签订电子合同详细教程》:本文主要介绍如何在PDF中加入电子签章与电子签名的过程,包括编写Word文件、生成PDF、为PDF格式做表单、为表单赋值、生成文档以及上传到OB... 目录前言:先看效果:1.编写word文件1.2然后生成PDF格式进行保存1.3我这里是将文件保存到本地后

windows系统下shutdown重启关机命令超详细教程

《windows系统下shutdown重启关机命令超详细教程》shutdown命令是一个强大的工具,允许你通过命令行快速完成关机、重启或注销操作,本文将为你详细解析shutdown命令的使用方法,并提... 目录一、shutdown 命令简介二、shutdown 命令的基本用法三、远程关机与重启四、实际应用

python库fire使用教程

《python库fire使用教程》本文主要介绍了python库fire使用教程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1.简介2. fire安装3. fire使用示例1.简介目前python命令行解析库用过的有:ar

LinuxMint怎么安装? Linux Mint22下载安装图文教程

《LinuxMint怎么安装?LinuxMint22下载安装图文教程》LinuxMint22发布以后,有很多新功能,很多朋友想要下载并安装,该怎么操作呢?下面我们就来看看详细安装指南... linux Mint 是一款基于 Ubuntu 的流行发行版,凭借其现代、精致、易于使用的特性,深受小伙伴们所喜爱。对

使用SpringBoot创建一个RESTful API的详细步骤

《使用SpringBoot创建一个RESTfulAPI的详细步骤》使用Java的SpringBoot创建RESTfulAPI可以满足多种开发场景,它提供了快速开发、易于配置、可扩展、可维护的优点,尤... 目录一、创建 Spring Boot 项目二、创建控制器类(Controller Class)三、运行

深入理解C++ 空类大小

《深入理解C++空类大小》本文主要介绍了C++空类大小,规定空类大小为1字节,主要是为了保证对象的唯一性和可区分性,满足数组元素地址连续的要求,下面就来了解一下... 目录1. 保证对象的唯一性和可区分性2. 满足数组元素地址连续的要求3. 与C++的对象模型和内存管理机制相适配查看类对象内存在C++中,规