话题通信基础：ROS2的“神经脉络”

各位同学，今天我们来聊聊ROS2里最核心、最常用的通信方式——话题通信。说白了，话题就是机器人各个部件之间传递消息的“高速公路”。我刚开始接触ROS时，总觉得这玩意儿有点抽象，后来亲手搭了一个激光雷达导航系统，才真正体会到它的设计有多巧妙。

ROS2话题通信原理

话题通信的本质，是一种异步、多对多的数据交换模式。什么意思呢？就是发送方（发布者）只管把数据扔到“话题”这条通道上，接收方（订阅者）按需去取。双方不需要知道对方的存在，也不需要等待回应。

我个人习惯把话题通信比作“电台广播”。发布者就是电台主持人，对着麦克风说话；订阅者就是听众，调准频率就能收听。主持人不知道谁在听，听众也不知道主持人长啥样。但信息就这么传过去了。

核心要点：话题通信是ROS2中最高频使用的通信方式，适用于传感器数据、状态信息等周期性或事件驱动的数据传输。

我在项目中遇到过一个问题：两个节点同时往同一个话题发数据，结果订阅者收到的数据乱序了。后来才发现，ROS2的话题通信默认不保证消息顺序——除非你显式设置QoS策略。嗯，这里要特别注意。

发布者与订阅者模型

这个模型其实就两个角色：

发布者（Publisher）：负责创建话题并发送消息
订阅者（Subscriber）：负责监听话题并接收消息

你想想看，一个话题可以有多个发布者，也可以有多个订阅者。这就是所谓的“多对多”模型。我见过最夸张的项目，一个话题上挂了十几个订阅者，分别做数据记录、可视化、算法处理……各取所需，互不干扰。

下面是一个最简单的发布者代码示例，用Python写的：

import rclpy
from rclpy.node import Node
from std_msgs.msg import String

class SimplePublisher(Node):
    def __init__(self):
        super().__init__('simple_publisher')
        self.publisher_ = self.create_publisher(String, 'topic_example', 10)
        self.timer = self.create_timer(1.0, self.timer_callback)
        self.count = 0

    def timer_callback(self):
        msg = String()
        msg.data = f'Hello, ROS2! Count: {self.count}'
        self.publisher_.publish(msg)
        self.get_logger().info(f'Publishing: "{msg.data}"')
        self.count += 1

def main(args=None):
    rclpy.init(args=args)
    node = SimplePublisher()
    rclpy.spin(node)
    node.destroy_node()
    rclpy.shutdown()

if __name__ == '__main__':
    main()

对应的订阅者代码：

import rclpy
from rclpy.node import Node
from std_msgs.msg import String

class SimpleSubscriber(Node):
    def __init__(self):
        super().__init__('simple_subscriber')
        self.subscription = self.create_subscription(
            String,
            'topic_example',
            self.listener_callback,
            10
        )

    def listener_callback(self, msg):
        self.get_logger().info(f'Received: "{msg.data}"')

def main(args=None):
    rclpy.init(args=args)
    node = SimpleSubscriber()
    rclpy.spin(node)
    node.destroy_node()
    rclpy.shutdown()

if __name__ == '__main__':
    main()

小技巧：代码中的数字“10”是队列大小。我曾经设成1，结果消息全丢了。建议根据数据频率和重要性来设置，传感器数据一般设10~100就够了。

话题与消息的关系

话题和消息的关系，就像“管道”和“水”的关系。话题是管道，消息是管道里流动的水。没有消息，话题就是个空壳；没有话题，消息就无处可去。

每个话题都有固定的消息类型。比如/cmd_vel话题只能发Twist类型的消息，/scan话题只能发LaserScan类型的消息。类型不匹配？编译都过不去。

ROS2内置了很多常用消息类型：

消息类型	所属包	典型用途
String	std_msgs	文本信息、状态日志
Int32 / Float64	std_msgs	数值传感器读数
Twist	geometry_msgs	速度指令（线速度+角速度）
Pose	geometry_msgs	位置与姿态信息
LaserScan	sensor_msgs	激光雷达扫描数据
Image	sensor_msgs	摄像头图像数据
OccupancyGrid	nav_msgs	栅格地图数据

你可能会问：如果内置类型不够用怎么办？自己定义呗。ROS2支持自定义消息类型，通过.msg文件定义字段，编译后自动生成对应的代码。我当年做多传感器融合时，就自己定义了一个FusionData.msg，把IMU、GPS、里程计的数据打包在一起发。

避坑指南：我曾经在自定义消息里塞了一个大数组，结果每次发布都卡顿。后来发现消息体太大，序列化/反序列化耗时严重。建议消息大小控制在几KB以内，大数据量用“零拷贝”或分片传输。

知识体系总览

下面这张图，是我手绘的ROS2话题通信核心逻辑。你看一眼就能明白整个流程：

从这张图可以清楚看到：发布者只管往话题里塞消息，订阅者只管从话题里取消息。中间的话题管道，加上QoS策略，就构成了ROS2通信的基石。

我个人觉得，理解话题通信的关键就三点：

解耦：发布者和订阅者互不知道对方存在
异步：发送和接收是独立的，不会阻塞
类型安全：消息类型在编译时就确定，跑起来不会乱

好了，这一章的内容就到这里。记住，话题通信是ROS2的“神经脉络”，搞懂了它，后面学服务通信、动作通信都会轻松很多。

可可精品资料库

📚 课程目录

话题通信基础：ROS2的“神经脉络”

ROS2话题通信原理

发布者与订阅者模型

话题与消息的关系

知识体系总览