ROS2学习笔记三：话题Topic

目录

前言

1 话题简介

2 常用指令

3 RCLCPP实现实现话题

3.1 创建工作空间

3.2 代码编写

3.2.1 发布端编写

3.2.2 发布端编写

前言

ROS2中的一个重要概念是话题（Topic）。话题是一种通过发布者和订阅者之间进行异步通信的机制。发布者（Publisher）将消息发布到特定的话题上，而订阅者（Subscriber）则可以选择订阅感兴趣的话题，并接收发布者发送的消息。

话题可以用来传递各种类型的消息，例如传感器数据、机器人状态、控制指令等。每个话题有一个唯一的名称，并且可以有多个发布者和订阅者。

ROS2提供了一套API来操作话题。开发者可以使用语言（如C++和Python）来编写发布者和订阅者节点，并在运行时将它们连接到ROS2系统中。

使用话题，开发者可以实现多个节点之间的解耦和灵活性。不同的节点可以以不同的速度发布和接收消息，可以动态地增加或删除节点，而不会影响其他节点的运行。

总结来说，ROS2中的话题机制提供了一种灵活和可扩展的通信方式，可以方便地实现不同节点之间的消息传递和协作。它是ROS2中重要的基础组件之一，为构建机器人应用提供了强大的功能和便利的开发体验。

1 话题简介

支持1对1，1对多，多对1，多对多。

为了方便发送者和接收者进行数据的交换，ROS2帮我们在数据传递时做好了消息的序列化和反序列化，而且ROS2的消息序列化与反序列化通信是可以做到跨编程语言、跨平台和跨设备之间的。

一个节点发布数据到某个话题上，另外一个节点就可以通过订阅话题拿到数据。

2 常用指令

首先运行一个发布节点：

ros2 run demo_nodes_cpp talker

查看上面发布节点的话题信息： 

查看话题列表

ros2 topic list -t 

打印话题

ros2 topic echo /chatter 

 查看topic信息

ros2 topic info  /chatter

查看消息类型

ros2 interface show std_msgs/msg/String

手动发布命令

ros2 topic pub /chatter std_msgs/msg/String 'data: "123"'

图形化查看节点信息

rqt_graph

查看话题频率

ros2 topic hz /chatter

3 RCLCPP实现实现话题

3.1 创建工作空间

cd project/
mkdir -p project/
cd project/
ros2 pkg create cpp_topic --build-type ament_cmake --dependencies rclcpp
touch cpp_topic/src/publisher.cpp

3.2 代码编写

调用Node的成员函数create_publisher并传入对应的参数即可。通过文档可以看出，至少需要传入消息类型（msgT）、话题名称（topic_name）和 服务质量（qos）。
官方rclcpp文档地址：rclcpp: rclcpp: ROS Client Library for C++

消息接口是ROS2通信时必须的一部分，通过消息接口ROS2才能完成消息的序列化和反序列化。ROS2为定义好了常用的消息接口，并生成了相应的C++和Python的依赖文件，通过脚本直接导入。

通过ros2 pkg指令创建的功能包目录结构如下:

$ tree -a

.
└── cpp_topic
    ├── CMakeLists.txt
    ├── include
    │   └── cpp_topic
    ├── package.xml
    └── src
        └── publisher.cpp

3.2.1 发布端编写

publisher.cpp

/*****ros2官方demo*******/
#include <chrono>
#include <functional>
#include <memory>
#include <string>#include "rclcpp/rclcpp.hpp"
#include "std_msgs/msg/string.hpp"using namespace std::chrono_literals;/* This example creates a subclass of Node and uses std::bind() to register a
* member function as a callback from the timer. */class MinimalPublisher : public rclcpp::Node
{public:MinimalPublisher(): Node("minimal_publisher"), count_(0){publisher_ = this->create_publisher<std_msgs::msg::String>("topic", 10);timer_ = this->create_wall_timer(500ms, std::bind(&MinimalPublisher::timer_callback, this));}private:void timer_callback(){auto message = std_msgs::msg::String();message.data = "Hello, world! " + std::to_string(count_++);RCLCPP_INFO(this->get_logger(), "Publishing: '%s'", message.data.c_str());publisher_->publish(message);}rclcpp::TimerBase::SharedPtr timer_;rclcpp::Publisher<std_msgs::msg::String>::SharedPtr publisher_;size_t count_;
};int main(int argc, char * argv[])
{rclcpp::init(argc, argv);rclcpp::spin(std::make_shared<MinimalPublisher>());rclcpp::shutdown();return 0;
}

CMakeLists.txt

cmake_minimum_required(VERSION 3.8)
project(cpp_topic)if(CMAKE_COMPILER_IS_GNUCXX OR CMAKE_CXX_COMPILER_ID MATCHES "Clang")add_compile_options(-Wall -Wextra -Wpedantic)
endif()# find dependencies
find_package(ament_cmake REQUIRED)
find_package(rclcpp REQUIRED)
find_package(std_msgs REQUIRED)add_executable(pulisher src/publisher.cpp)
ament_target_dependencies(pulisher rclcpp std_msgs)install(TARGETSpulisherDESTINATION lib/${PROJECT_NAME})if(BUILD_TESTING)find_package(ament_lint_auto REQUIRED)# the following line skips the linter which checks for copyrights# comment the line when a copyright and license is added to all source filesset(ament_cmake_copyright_FOUND TRUE)# the following line skips cpplint (only works in a git repo)# comment the line when this package is in a git repo and when# a copyright and license is added to all source filesset(ament_cmake_cpplint_FOUND TRUE)ament_lint_auto_find_test_dependencies()
endif()ament_package()

package.xml

<?xml version="1.0"?>
<?xml-model href="http://download.ros.org/schema/package_format3.xsd" schematypens="http://www.w3.org/2001/XMLSchema"?>
<package format="3"><name>cpp_topic</name><version>0.0.0</version><description>TODO: Package description</description><maintainer email="xxxxx@xxx.com">linux</maintainer><license>TODO: License declaration</license><buildtool_depend>ament_cmake</buildtool_depend><depend>rclcpp</depend><depend>std_msgs</depend><test_depend>ament_lint_auto</test_depend><test_depend>ament_lint_common</test_depend><export><build_type>ament_cmake</build_type></export>
</package>

在project目录运行如下编译指令

colcon build --packages-select cpp_topic

编译完成后目录如下：

运行

source install/setup.bash
ros2 run cpp_topic pulisher

此时可以通过命令订阅该topic

3.2.2 发布端编写

上面过程中是通过ros2自动的命令进行话题的订阅，下面使用c++代码实现话题订阅。

创建订阅节点文件

touch cpp_topic/src/subscriber.cpp

subscriber.cpp：

/*****ros2官方demo*******/
#include <functional>
#include <memory>#include "rclcpp/rclcpp.hpp"
#include "std_msgs/msg/string.hpp"using std::placeholders::_1;class MinimalSubscriber : public rclcpp::Node
{
public:MinimalSubscriber(): Node("minimal_subscriber"){subscription_ = this->create_subscription<std_msgs::msg::String>("topic", 10, std::bind(&MinimalSubscriber::topic_callback, this, _1));}private:void topic_callback(const std_msgs::msg::String & msg) const{RCLCPP_INFO(this->get_logger(), "I heard: '%s'", msg.data.c_str());}rclcpp::Subscription<std_msgs::msg::String>::SharedPtr subscription_;
};int main(int argc, char * argv[])
{rclcpp::init(argc, argv);rclcpp::spin(std::make_shared<MinimalSubscriber>());rclcpp::shutdown();return 0;
}

CMakeLists.txt增加如下代码

add_executable(subscriber src/subscriber.cpp)
ament_target_dependencies(subscriber rclcpp std_msgs)install(TARGETSsubscriberDESTINATION lib/${PROJECT_NAME})

在project目录运行如下编译指令

colcon build --packages-select cpp_topic

在project目录先运行上面的发布节点

source install/setup.bash
ros2 run cpp_topic pulisher

 新开一个终端进入到project目录，运行订阅节点

source install/setup.bash
ros2 run cpp_topic subscriber

 

 

无论你是初学者还是有经验的开发者，希望我的博客能对你的学习之路有所帮助。如果你觉得这篇文章有用，不妨点击点赞、收藏，或者留下你的评论分享你的见解和经验，也欢迎你对我博客的内容提出建议和问题。每一次的点赞、评论、分享和关注都是对我的最大支持，也是对我持续分享和创作的动力。

阅读我的CSDN主页,解锁更多精彩内容:Tech Embedded-CSDN博客

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

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

相关文章

记一次 Redis 数据库迁移

记一次 Redis 数据库迁移

笔者通过一个 Redis 数据库迁移的例子&#xff0c;介绍了迁移脚本的执行思路。 作者&#xff1a;马文斌&#xff0c;MySQL/Redis 爱好者~ 爱可生开源社区出品&#xff0c;原创内容未经授权不得随意使用&#xff0c;转载请联系小编并注明来源。 本文约 500 字&#xff0c;预计阅…
阅读更多...
揭秘HTTP协议：深入了解互联网通信的核心！

揭秘HTTP协议：深入了解互联网通信的核心！

文章目录 HTTPHTTP的消息结构HTTP 常用请求方法HTTP 状态码 HTTP HTTP 是超文本传输协议&#xff0c;HTTP是缩写&#xff0c;全称是 HyperText Transfer Protocol 超文本指的是 HTML、css、JavaScript和图片等&#xff0c;HTTP的出现就是为方便接收和发布超HTML页面&#xff0c…
阅读更多...
Django(七)

Django(七)

Django(六) 4.编辑用户 点击编辑&#xff0c;跳转到编辑页面&#xff08;将编辑行的ID携带过去&#xff09;。编辑页面&#xff08;默认数据&#xff0c;根据ID获取并设置到页面中&#xff09;提交&#xff1a; 错误提示数据校验在数据库更新 user_edit.html {% exte…
阅读更多...
代码随想录 Leetcode203. 移除链表元素

代码随想录 Leetcode203. 移除链表元素

题目&#xff1a; 代码(首刷看解析 2024年1月11日&#xff09;&#xff1a; class Solution { public:ListNode* removeElements(ListNode* head, int val) {if(headnullptr) return nullptr;ListNode* BeforeHead new ListNode(0,head);ListNode* temp BeforeHead;while(te…
阅读更多...
Android开发基础（三）

Android开发基础（三）

Android开发基础&#xff08;三&#xff09; 本篇将介绍Android权限管理。 Android权限管理 Android权限管理主要是为了保护用户的隐私和设备的安全性&#xff1b; 在Android系统中&#xff0c;应用在请求权限时必须进行明确的申请&#xff0c;根据权限的保护级别&#xff0…
阅读更多...
打造高性价比小程序，轻松降低成本

打造高性价比小程序，轻松降低成本

随着移动互联网的普及&#xff0c;小程序已经成为一个热门的应用开发方向。然而&#xff0c;对于许多企业和个人而言&#xff0c;制作一个小程序的费用却让人望而却步。那么&#xff0c;如何以最低的成本制作一款高性价比的小程序呢&#xff1f; 答案很简单&#xff0c;只需要找…
阅读更多...
什么是 CAS

什么是 CAS

程序员的公众号&#xff1a;源1024&#xff0c;获取更多资料&#xff0c;无加密无套路&#xff01; 最近整理了一波电子书籍资料&#xff0c;包含《Effective Java中文版 第2版》《深入JAVA虚拟机》&#xff0c;《重构改善既有代码设计》&#xff0c;《MySQL高性能-第3版》&…
阅读更多...
Qt添加资源文件

Qt添加资源文件

ui->setupUi(this);//1. 使用本地文件&#xff1a;ui->actionasdasdas->setIcon(QIcon("本地绝对路径"));ui->actiona1->setIcon(QIcon("C:/Users/满满/Desktop/output/picture/1.jpg"));//2. 使用资源文件&#xff1a;ui->actionasdasd…
阅读更多...
C++内存管理机制（侯捷）笔记4（完结）

C++内存管理机制（侯捷）笔记4（完结）

C内存管理机制&#xff08;侯捷&#xff09; 本文是学习笔记&#xff0c;仅供个人学习使用。如有侵权&#xff0c;请联系删除。 参考链接 Youtube: 侯捷-C内存管理机制 Github课程视频、PPT和源代码: https://github.com/ZachL1/Bilibili-plus 介绍 下面是第四讲和第五讲…
阅读更多...
html+css实现子元素完全居中常见方案

html+css实现子元素完全居中常见方案

详细过程 查看公众号文章 htmlcss实现子元素完全居中常见方案 获取更多内容&#xff0c;请关注微信公众号。搜索“码圈小橙子”&#xff0c;或扫描下方二维码获取关注
阅读更多...
Jarvis步进法（Jarvis March）凸包算法

Jarvis步进法（Jarvis March）凸包算法

Jarvis步进法&#xff08;也称为包裹法&#xff09;&#xff1a; Jarvis步进法是一种逐步选择凸包顶点的算法。从点集中选择一个起始点&#xff0c;然后在每一步中选择下一个顶点&#xff0c;该顶点是当前点集中与当前点形成的线段上&#xff0c;极角最小的点。该算法的时间复杂…
阅读更多...
限流式保护器在户外汽车充装的应用

限流式保护器在户外汽车充装的应用

摘 要&#xff1a;国家标准GB51348-2019中规定储备仓库、电动车充电等场所的末端回路应设置限流式电气防火保护器。电气防火限流式保护器可以有效克服传统断路器、空气开关和监控设备存在的短路电流大、切断短路电流时间长、短路时产生的电弧火花大&#xff0c;以及使用寿命短等…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023