当前位置: 首页 > news >正文

ROS2学习笔记|C++ 实现 ROS 2 订阅与发布功能的完整流程

我使用的是humble版本

创建工作空间和功能包

创建工作空间

打开终端,执行以下命令创建工作空间和 src 目录:

mkdir -p ~/ros2_ws/src
cd ~/ros2_ws
创建功能包

在 src 目录下创建一个新的功能包,这里假设功能包名为 cpp_pubsub,依赖项为 rclcpp 和 std_msgs

cd ~/ros2_ws/src
ros2 pkg create --build-type ament_cmake cpp_pubsub --dependencies rclcpp std_msgs
编写发布者代码
打开发布者代码文件

在 ~/ros2_ws/src/cpp_pubsub/src 目录下创建一个名为 talker.cpp 的文件:

touch ~/ros2_ws/src/cpp_pubsub/src/talker.cpp
编写发布者代码

使用文本编辑器打开 talker.cpp 文件,添加以下代码:

#include <rclcpp/rclcpp.hpp>
#include <std_msgs/msg/string.hpp>using namespace std::chrono_literals;class Talker : public rclcpp::Node
{
public:Talker() : Node("talker"){// 创建发布者,发布 std_msgs::msg::String 类型的消息到 'topic' 话题,队列大小为 10publisher_ = this->create_publisher<std_msgs::msg::String>("topic", 10);// 创建定时器,每 500 毫秒触发一次,调用 timer_callback 函数timer_ = this->create_wall_timer(500ms, std::bind(&Talker::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::Publisher<std_msgs::msg::String>::SharedPtr publisher_;rclcpp::TimerBase::SharedPtr timer_;size_t count_ = 0;
};int main(int argc, char * argv[])
{rclcpp::init(argc, argv);auto node = std::make_shared<Talker>();rclcpp::spin(node);rclcpp::shutdown();return 0;
}

这段代码创建了一个名为 talker 的节点,它会每 500 毫秒发布一条消息到 topic 话题。

编写订阅者代码
打开订阅者代码文件

在 ~/ros2_ws/src/cpp_pubsub/src 目录下创建一个名为 listener.cpp 的文件:

touch ~/ros2_ws/src/cpp_pubsub/src/listener.cpp
编写订阅者代码

使用文本编辑器打开 listener.cpp 文件,添加以下代码:

#include <rclcpp/rclcpp.hpp>
#include <std_msgs/msg/string.hpp>class Listener : public rclcpp::Node
{
public:Listener() : Node("listener"){// 创建订阅者,订阅 'topic' 话题的 std_msgs::msg::String 类型消息,队列大小为 10subscription_ = this->create_subscription<std_msgs::msg::String>("topic", 10, std::bind(&Listener::topic_callback, this, std::placeholders::_1));}private:void topic_callback(const std_msgs::msg::String::SharedPtr 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);auto node = std::make_shared<Listener>();rclcpp::spin(node);rclcpp::shutdown();return 0;
}

这段代码创建了一个名为 listener 的节点,它会订阅 topic 话题,并在接收到消息时打印消息内容。

配置 CMakeLists.txt 文件

打开 ~/ros2_ws/src/cpp_pubsub/CMakeLists.txt 文件,添加以下内容:

add_executable(talker src/talker.cpp)
ament_target_dependencies(talker rclcpp std_msgs)add_executable(listener src/listener.cpp)
ament_target_dependencies(listener rclcpp std_msgs)install(TARGETStalkerlistenerDESTINATION lib/${PROJECT_NAME})

这些配置用于编译 talker.cpp 和 listener.cpp 文件,并将生成的可执行文件安装到指定目录。

再补充一下具体解释

  • 作用
    add_executable(talker src/talker.cpp)
    这行代码是 CMake 指令,其功能是告知 CMake 要把 src/talker.cpp 文件编译成一个可执行文件,并且将这个可执行文件命名为 talker。在 ROS 2 的 C++ 功能包开发里,每个节点的代码一般都要编译成可执行文件,这样才能在 ROS 2 环境中运行。
  • 原因:在 ROS 2 中,节点是运行的基本单元,为了让节点能够运行,需要把节点的源代码编译成可执行文件。add_executable 指令就负责完成这个编译任务。

ament_target_dependencies(talker rclcpp std_msgs)
  • 作用:这是 ament_cmake 提供的指令,它的作用是为 talker 可执行文件添加依赖项。这里的依赖项是 rclcpp 和 std_msgsrclcpp 是 ROS 2 的 C++ 客户端库,节点要与 ROS 2 系统进行交互(像发布和订阅消息)就需要用到它;std_msgs 则是 ROS 2 提供的标准消息类型库,在节点代码里可能会使用到其中定义的消息类型(例如 std_msgs::msg::String)。
  • 原因:在编译节点代码时,编译器需要知道这些依赖库的位置和相关信息,ament_target_dependencies 指令会自动处理这些依赖关系,确保编译器能够找到并正确链接这些库。
install(TARGETStalkerlistenerDESTINATION lib/${PROJECT_NAME})
  • 作用:这行代码是 CMake 的 install 指令,其目的是在编译完成后,将 talker 和 listener 这两个可执行文件安装到指定的目录。DESTINATION lib/${PROJECT_NAME} 表示安装到 lib 目录下以功能包名称命名的子目录中。在 ROS 2 里,这样做可以让这些可执行文件在系统中被正确地找到和运行。
  • 原因:安装可执行文件到指定目录是为了方便管理和使用。当使用 ros2 run 命令来运行节点时,ROS 2 会从指定的安装目录中查找可执行文件。如果不进行安装操作,就无法直接使用 ros2 run 命令来运行节点。

编译工作空间

在 ~/ros2_ws 目录下执行以下命令编译工作空间:

cd ~/ros2_ws
colcon build

运行节点

设置环境变量

注意:每次打开新的终端运行节点前,都需要设置环境变量:

source install/setup.bash
运行发布者节点

打开一个新终端,运行发布者节点:

ros2 run cpp_pubsub talker
运行订阅者节点

再打开一个新终端,运行订阅者节点:

ros2 run cpp_pubsub listener

此时,你会看到发布者节点每隔 500 毫秒发布一条消息,订阅者节点会接收到这些消息并打印出来。

相关文章:

  • 《马小帅的Java闯关记》
  • NV228NV254固态美光颗粒NV255NV263
  • 网络编程,使用select()进行简单服务端与客户端通信
  • 用 PyTorch 轻松实现 MNIST 手写数字识别
  • 【MySQL】索引(重要)
  • [Java]Java的三个阶段
  • C++类_成员函数指针
  • vae笔记
  • 修复笔记:SkyReels-V2项目中的 from_config 警告
  • 学习黑客Linux权限
  • bc 命令
  • 31.软件时序控制方式抗干扰
  • 四年级数学知识边界总结思考-上册
  • FPGA----基于ZYNQ 7020实现EPICS通信系统
  • CATIA高效工作指南——曲面设计篇(一)
  • [GESP202503 四级] 二阶矩阵c++
  • [python]非零基础上手之文件操作
  • 【人工智能学习笔记 二】 MCP 和 Function Calling的区别与联系
  • 动态规划(5)路径问题--剑指offer -珠宝的最大值
  • 【AI论文】Phi-4-reasoning技术报告
  • AI世界的年轻人|横跨教育与产业,他说攻克前沿问题是研究者的使命
  • 经济日报:合力推进民企与毕业生双向奔赴
  • 俄罗斯期望乌克兰在停火期间采取行动缓和局势
  • 我的诗歌阅读史
  • 民族音乐还能这样玩!这场音乐会由AI作曲
  • 国家医保局副局长颜清辉调任人社部副部长