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

2024-03-11 01:28
文章标签 c++ 教程 api ros rosbag 系列学习

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

相关文章

HTML5 getUserMedia API网页录音实现指南示例小结

HTML5 getUserMedia API网页录音实现指南示例小结

《HTML5getUserMediaAPI网页录音实现指南示例小结》本教程将指导你如何利用这一API，结合WebAudioAPI，实现网页录音功能,从获取音频流到处理和保存录音，整个过程将逐步... 目录1. html5 getUserMedia API简介1.1 API概念与历史1.2 功能与优势1.3
阅读更多...
Windows下C++使用SQLitede的操作过程

Windows下C++使用SQLitede的操作过程

《Windows下C++使用SQLitede的操作过程》本文介绍了Windows下C++使用SQLite的安装配置、CppSQLite库封装优势、核心功能（如数据库连接、事务管理）、跨平台支持及性能优... 目录Windows下C++使用SQLite1、安装2、代码示例CppSQLite：C++轻松操作SQ
阅读更多...
C++中RAII资源获取即初始化

C++中RAII资源获取即初始化

《C++中RAII资源获取即初始化》RAII通过构造/析构自动管理资源生命周期,确保安全释放,本文就来介绍一下C++中的RAII技术及其应用,具有一定的参考价值,感兴趣的可以了解一下... 目录一、核心原理与机制二、标准库中的RAII实现三、自定义RAII类设计原则四、常见应用场景1. 内存管理2. 文件操
阅读更多...
C++中零拷贝的多种实现方式

C++中零拷贝的多种实现方式

《C++中零拷贝的多种实现方式》本文主要介绍了C++中零拷贝的实现示例,旨在在减少数据在内存中的不必要复制,从而提高程序性能、降低内存使用并减少CPU消耗,零拷贝技术通过多种方式实现,下面就来了解一下... 目录一、C++中零拷贝技术的核心概念二、std::string_view 简介三、std::stri
阅读更多...
C++高效内存池实现减少动态分配开销的解决方案

C++高效内存池实现减少动态分配开销的解决方案

《C++高效内存池实现减少动态分配开销的解决方案》C++动态内存分配存在系统调用开销、碎片化和锁竞争等性能问题,内存池通过预分配、分块管理和缓存复用解决这些问题,下面就来了解一下... 目录一、C++内存分配的性能挑战二、内存池技术的核心原理三、主流内存池实现：TCMalloc与Jemalloc1. TCM
阅读更多...
C++ 函数 strftime 和时间格式示例详解

C++ 函数 strftime 和时间格式示例详解

《C++函数strftime和时间格式示例详解》strftime是C/C++标准库中用于格式化日期和时间的函数,定义在ctime头文件中,它将tm结构体中的时间信息转换为指定格式的字符串,是处理... 目录C++ 函数 strftipythonme 详解一、函数原型二、功能描述三、格式字符串说明四、返回值五
阅读更多...
Nexus安装和启动的实现教程

Nexus安装和启动的实现教程

《Nexus安装和启动的实现教程》：本文主要介绍Nexus安装和启动的实现教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、Nexus下载二、Nexus安装和启动三、关闭Nexus总结一、Nexus下载官方下载链接：DownloadWindows系统根
阅读更多...
C++作用域和标识符查找规则详解

C++作用域和标识符查找规则详解

《C++作用域和标识符查找规则详解》在C++中,作用域（Scope）和标识符查找（IdentifierLookup）是理解代码行为的重要概念,本文将详细介绍这些规则,并通过实例来说明它们的工作原理,需... 目录作用域标识符查找规则1. 普通查找（Ordinary Lookup）2. 限定查找（Qualif
阅读更多...
CnPlugin是PL/SQL Developer工具插件使用教程

CnPlugin是PL/SQL Developer工具插件使用教程

《CnPlugin是PL/SQLDeveloper工具插件使用教程》：本文主要介绍CnPlugin是PL/SQLDeveloper工具插件使用教程,具有很好的参考价值,希望对大家有所帮助,如有错... 目录PL/SQL Developer工具插件使用安装拷贝文件配置总结PL/SQL Developer工具插
阅读更多...
Java中的登录技术保姆级详细教程

Java中的登录技术保姆级详细教程

《Java中的登录技术保姆级详细教程》：本文主要介绍Java中登录技术保姆级详细教程的相关资料,在Java中我们可以使用各种技术和框架来实现这些功能,文中通过代码介绍的非常详细,需要的朋友可以参考... 目录1.登录思路2.登录标记1.会话技术2.会话跟踪1.Cookie技术2.Session技术3.令牌技
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2