第三章 理解ROS节点与话题：从理论到实战

好，咱们进入第三章。这一章可以说是ROS最核心、最基础的内容了。我经常跟团队里的新人说，搞懂节点和话题，ROS就算入门了一半。剩下的，无非是各种工具和技巧的堆叠。

说实话，我见过太多人一上来就写代码，结果连节点怎么通信都没搞明白。最后调试的时候，消息发不出去，收不回来，急得团团转。咱们今天就把这块彻底讲透。

3.1 节点(Node)：ROS的最小执行单元

节点是什么？说白了，就是一个独立的可执行程序。它负责完成某个具体的功能。比如控制电机、读取激光雷达数据、处理图像等等。

一个机器人系统里，通常有几十甚至上百个节点。每个节点各司其职，互不干扰。这就是ROS的设计哲学——去中心化。

核心要点：每个节点都是一个独立的进程。它们之间通过话题、服务、动作等机制通信。节点之间没有直接的内存共享，只能通过消息传递。

我记得刚入行那会儿，有个项目需要同时控制6个电机。我一开始把所有代码写在一个文件里，结果改一个参数就得重新编译整个项目。后来改用ROS节点，每个电机一个节点，调试起来轻松多了。你想想看，这种模块化的设计，是不是很爽？

3.1.1 节点的命名与唯一性

每个节点在ROS网络中必须有唯一的名称。这个名称就像人的身份证号，不能重复。如果两个节点同名，后启动的那个会强制关闭前一个。

嗯，这里要注意：节点名最好用有意义的英文单词，比如motor_controller、lidar_driver。别用node1、node2这种，时间长了你自己都分不清。

3.1.2 节点的生命周期

一个节点从启动到结束，大致经历这几个阶段：

  • 初始化：注册到ROS Master，获取节点句柄
  • 运行：执行回调函数，处理消息
  • 销毁：释放资源，从Master注销

我个人习惯在节点初始化时，先检查所有硬件是否就绪。如果某个传感器没连上，直接报错退出，而不是让它半死不活地运行。

3.2 话题(Topic)：节点间的通信桥梁

话题是ROS里最常用的通信方式。它是一种发布/订阅模式。一个节点发布消息到某个话题，另一个节点订阅这个话题，就能收到消息。

打个比方：话题就像是一个广播电台。发布者是电台主持人，订阅者是听众。主持人只管播报，不管谁在听。听众只管收听，不管谁在播。这种解耦设计，让系统非常灵活。

我的经验：话题通信是异步的、单向的。如果你需要同步的、双向的通信，比如请求某个服务并等待结果，那就得用ROS的服务(Service)机制。这个话题咱们后面会讲。

3.2.1 话题的命名规则

话题名通常以斜杠开头，比如/cmd_vel、/odom。也可以用相对命名，比如cmd_vel，但绝对命名更清晰，不容易冲突。

我曾经在一个项目里，因为话题名写错了，导致机器人原地转圈。排查了半天才发现，原来是/cmd_vel写成了/cmd_vel/，多了一个斜杠。这种低级错误，说出来都是泪。

3.2.2 话题的数据类型

每个话题都有固定的数据类型，也就是消息类型。ROS内置了很多标准消息，比如：

消息类型 用途 示例
std_msgs/String 字符串 日志信息
geometry_msgs/Twist 速度指令 控制机器人移动
sensor_msgs/LaserScan 激光雷达数据 环境感知
nav_msgs/Odometry 里程计数据 机器人位姿估计

但很多时候，内置消息不够用。比如你要传输一个自定义的传感器数据，就得自己定义消息类型。这就是咱们接下来要讲的——自定义消息。

3.3 自定义消息(msg)定义

自定义消息是ROS里非常强大的功能。它让你可以定义自己的数据结构，满足特定需求。

3.3.1 创建msg文件

在功能包的msg目录下，创建一个.msg文件。比如MotorStatus.msg：

# MotorStatus.msg
# 电机状态消息

int32 motor_id          # 电机ID
float32 current_rpm     # 当前转速
float32 target_rpm      # 目标转速
float32 temperature     # 温度（摄氏度）
bool is_online          # 是否在线
string error_code       # 错误码

你看，消息定义很简单。每行一个字段，格式是类型 名称。支持基本类型、数组、甚至嵌套其他消息。

注意：定义完msg文件后，别忘了修改CMakeLists.txt和package.xml，添加编译依赖。否则编译时会报错。我刚开始学的时候，经常漏掉这一步，编译失败还找不到原因。

3.3.2 编译与使用

在CMakeLists.txt中添加：

find_package(catkin REQUIRED COMPONENTS
  message_generation
  std_msgs
)

add_message_files(
  FILES
  MotorStatus.msg
)

generate_messages(
  DEPENDENCIES
  std_msgs
)

然后在package.xml中添加：

<build_depend>message_generation</build_depend>
<exec_depend>message_runtime</exec_depend>

编译后，ROS会自动生成对应的C++或Python代码。你就可以在节点里直接使用这个自定义消息了。

3.4 Publisher与Subscriber实战

理论讲完了，咱们来点实战。我写一个简单的例子：一个节点发布电机状态，另一个节点订阅并显示。

3.4.1 发布者(Publisher)节点

// motor_publisher.cpp
#include "ros/ros.h"
#include "your_package/MotorStatus.h"

int main(int argc, char **argv)
{
    ros::init(argc, argv, "motor_publisher");
    ros::NodeHandle nh;

    // 创建发布者，话题名为"/motor_status"，队列大小为10
    ros::Publisher pub = nh.advertise<your_package::MotorStatus>("/motor_status", 10);

    ros::Rate rate(10); // 10Hz

    while (ros::ok())
    {
        your_package::MotorStatus msg;
        msg.motor_id = 1;
        msg.current_rpm = 1500.0;
        msg.target_rpm = 1500.0;
        msg.temperature = 45.2;
        msg.is_online = true;
        msg.error_code = "OK";

        pub.publish(msg);
        ROS_INFO("Published motor status: ID=%d, RPM=%.1f", msg.motor_id, msg.current_rpm);

        rate.sleep();
    }

    return 0;
}

这段代码很简单。初始化节点，创建发布者，然后循环发布消息。注意那个队列大小参数10，它表示如果订阅者处理不过来，最多缓存10条消息。超过的会被丢弃。

3.4.2 订阅者(Subscriber)节点

// motor_subscriber.cpp
#include "ros/ros.h"
#include "your_package/MotorStatus.h"

void motorCallback(const your_package::MotorStatus::ConstPtr& msg)
{
    ROS_INFO("Received motor status:");
    ROS_INFO("  ID: %d", msg->motor_id);
    ROS_INFO("  Current RPM: %.1f", msg->current_rpm);
    ROS_INFO("  Target RPM: %.1f", msg->target_rpm);
    ROS_INFO("  Temperature: %.1f°C", msg->temperature);
    ROS_INFO("  Online: %s", msg->is_online ? "Yes" : "No");
    ROS_INFO("  Error: %s", msg->error_code.c_str());
}

int main(int argc, char **argv)
{
    ros::init(argc, argv, "motor_subscriber");
    ros::NodeHandle nh;

    // 创建订阅者，订阅"/motor_status"话题，回调函数为motorCallback
    ros::Subscriber sub = nh.subscribe("/motor_status", 10, motorCallback);

    ros::spin(); // 进入循环，等待回调

    return 0;
}

订阅者更简单。创建一个订阅者，绑定回调函数。当有消息到达时，回调函数自动被调用。ros::spin()会一直阻塞，直到节点被关闭。

避坑指南：我曾经在回调函数里做耗时操作，比如写文件、网络请求。结果导致消息处理不及时，系统卡死。记住，回调函数要快进快出。如果需要处理耗时任务，用单独的线程。

3.4.3 运行与测试

启动ROS Master：

roscore

启动发布者：

rosrun your_package motor_publisher

启动订阅者：

rosrun your_package motor_subscriber

你会看到订阅者终端不断打印电机状态信息。用rostopic list可以查看所有话题，用rostopic echo /motor_status可以直接查看消息内容。

嗯，这里有个小技巧：调试时先用rostopic echo确认消息是否正确，再写订阅者代码。这样可以快速定位问题。

3.5 本章小结

这一章咱们讲了节点和话题的核心机制。节点是ROS的最小执行单元，话题是节点间的通信桥梁。自定义消息让你可以定义自己的数据结构，满足特定需求。最后通过一个实战例子，演示了发布者和订阅者的完整流程。

说实话，这些内容看起来简单，但真正用好需要大量实践。我建议你动手写几个小例子，比如发布一个geometry_msgs/Twist消息控制虚拟机器人移动。只有亲手写过，才能真正理解。

下一章，咱们会深入讲解ROS的服务(Service)和参数服务器(Parameter Server)。到时候你会发现，ROS的通信机制远比你想象的强大。

← 上一章 📖 返回目录 下一章 →