4. ROS通信机制：话题、服务、动作详解

ROS的通信机制，说白了就是机器人各个模块之间怎么「说话」。我刚开始接触ROS时，最困惑的就是：为什么要有三种通信方式？一个不够用吗？后来在项目中摔过几次跟头，才真正理解了设计者的良苦用心。

4.1 三种通信方式的核心区别

先给你一张总览图，把三种方式的核心逻辑理清楚。我个人习惯在讲具体代码前，先让脑子里有个「地图」。

4.2 话题（Topic）—— 最常用的通信方式

话题是ROS里最基础的通信机制。它的模式是「发布/订阅」，说白了就是：有人往一个频道里发消息，对这个频道感兴趣的人都能收到。

我在项目中遇到过一个问题：激光雷达的数据频率是10Hz，里程计是50Hz，如果都用服务来传，那系统早就卡死了。话题的异步特性正好解决这个问题——发布者只管发，订阅者只管收，互不阻塞。

4.3 服务（Service）—— 有来有往的通信

服务跟话题最大的区别在于：它有「请求-响应」机制。你发一个请求过去，必须等对方处理完返回结果，才能继续往下走。

嗯，这里要注意：服务是同步的。如果你在回调函数里做耗时操作，整个节点都会被卡住。我曾经在调试机器人时，写了一个服务去处理点云数据，结果因为处理时间太长，导致其他模块全部超时——那叫一个惨。

4.4 动作（Action）—— 长时间任务的利器

动作机制是ROS里最复杂的通信方式，但也是最强大的。它专门为「需要一段时间才能完成」的任务设计，比如导航到某个点、机械臂抓取物体。

动作的核心是三个通道：

• 目标（Goal）：客户端告诉服务器要做什么
• 反馈（Feedback）：服务器实时汇报进度
• 结果（Result）：任务完成后的最终输出

你想想看，如果导航用服务来实现，那你在发出「去A点」的指令后，整个程序就卡住了，直到机器人到达或者失败。这显然不合理。动作的异步反馈机制，让你可以在机器人移动的同时，继续做其他事情。

4.5 编写第一个发布/订阅节点

好了，理论说完了，咱们直接上手写代码。我习惯用C++写ROS节点，因为性能更好，尤其在处理激光雷达数据时。

4.5.1 创建功能包

cd ~/catkin_ws/src
catkin_create_pkg ros_basics roscpp rospy std_msgs
cd ~/catkin_ws
catkin_make

4.5.2 发布者节点（talker）

// src/talker.cpp
#include "ros/ros.h"
#include "std_msgs/String.h"
#include <sstream>

int main(int argc, char **argv)
{
    // 初始化ROS节点
    ros::init(argc, argv, "talker");
    ros::NodeHandle nh;

    // 创建一个发布者，话题名为"chatter"，队列大小1000
    ros::Publisher chatter_pub = nh.advertise<std_msgs::String>("chatter", 1000);

    // 设置循环频率为10Hz
    ros::Rate loop_rate(10);

    int count = 0;
    while (ros::ok())
    {
        std_msgs::String msg;
        std::stringstream ss;
        ss << "hello world " << count;
        msg.data = ss.str();

        ROS_INFO("发布消息: %s", msg.data.c_str());
        chatter_pub.publish(msg);

        ros::spinOnce();
        loop_rate.sleep();
        ++count;
    }

    return 0;
}

4.5.3 订阅者节点（listener）

// src/listener.cpp
#include "ros/ros.h"
#include "std_msgs/String.h"

// 回调函数：当收到消息时被调用
void chatterCallback(const std_msgs::String::ConstPtr& msg)
{
    ROS_INFO("收到消息: %s", msg->data.c_str());
}

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

    // 订阅"chatter"话题，队列大小1000，回调函数为chatterCallback
    ros::Subscriber sub = nh.subscribe("chatter", 1000, chatterCallback);

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

    return 0;
}

4.5.4 配置CMakeLists.txt

add_executable(talker src/talker.cpp)
target_link_libraries(talker ${catkin_LIBRARIES})

add_executable(listener src/listener.cpp)
target_link_libraries(listener ${catkin_LIBRARIES})

4.5.5 运行测试

# 启动ROS Master
roscore

# 新终端，运行发布者
rosrun ros_basics talker

# 新终端，运行订阅者
rosrun ros_basics listener

4.6 三种通信方式的选型建议

场景	推荐方式	原因
激光雷达数据（/scan）	话题	连续流式数据，不需要反馈
里程计数据（/odom）	话题	高频更新，异步接收即可
获取当前地图	服务	一次性请求，需要立即返回
生成新地图	动作	耗时操作，需要进度反馈
导航到目标点	动作	长时间任务，可取消、可反馈
设置参数	服务	简单配置，立即生效

说白了，选型就一句话：连续数据用话题，一次性请求用服务，长时间任务用动作。我在实际项目中，90%的通信都用话题，8%用服务，只有2%用动作。但就是这2%的动作，解决了导航、机械臂这些最核心的功能。

---