1. ROS2话题通信基础概念
在机器人开发中，不同功能模块之间的数据交换是系统运行的基础。ROS2采用分布式架构，通过话题(Topic)实现节点间的异步通信。这种设计让开发者能够灵活地构建复杂的机器人系统，就像搭积木一样将各个功能模块组合起来。
话题通信的核心是发布-订阅模型。想象一下报纸的发行过程：报社（发布者）定期发布报纸，订阅者（读者）收到报纸后自行阅读。在ROS2中，发布者节点将数据发布到特定话题，订阅该话题的节点会自动接收这些数据。这种机制的最大优势是解耦 - 发布者和订阅者不需要知道对方的存在，只需要约定好话题名称和消息类型即可通信。
ROS2原生支持多种消息类型，从简单的标准数据类型（如std_msgs/String）到复杂的传感器数据（如sensor_msgs/Image）。这些预定义的消息类型覆盖了大多数机器人应用的常见需求。例如，控制指令可以用geometry_msgs/Twist表示，激光雷达数据可以用sensor_msgs/LaserScan传输。
2. 准备工作与环境搭建
在开始实战之前，我们需要准备好开发环境。我推荐使用Ubuntu 22.04 LTS和ROS2 Humble版本，这是目前最稳定的组合。安装完成后，通过以下命令验证ROS2是否安装成功：
source /opt/ros/humble/setup.bash ros2 run demo_nodes_cpp talker在另一个终端中运行：
ros2 run demo_nodes_py listener如果能看到"Hello World"消息的收发，说明环境配置正确。
创建工作空间是ROS2开发的起点。我习惯在home目录下创建专门的开发空间：
mkdir -p ~/ros2_ws/src cd ~/ros2_ws colcon build创建功能包时，C++和Python项目略有不同。对于C++项目：
ros2 pkg create cpp_pubsub --build-type ament_cmake --dependencies rclcpp std_msgs对于Python项目：
ros2 pkg create py_pubsub --build-type ament_python --dependencies rclpy std_msgs3. 原生消息的话题通信实现
3.1 C++实现发布者
让我们从最简单的字符串消息开始。在C++功能包的src目录下创建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"), count_(0) { publisher_ = this->create_publisher<std_msgs::msg::String>("chatter", 10); 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::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<Talker>()); rclcpp::shutdown(); return 0; }修改CMakeLists.txt，添加可执行文件和依赖：
add_executable(talker src/talker.cpp) ament_target_dependencies(talker rclcpp std_msgs) install(TARGETS talker DESTINATION lib/${PROJECT_NAME})3.2 Python实现订阅者
在Python功能包中创建listener.py：
import rclpy from rclpy.node import Node from std_msgs.msg import String class Listener(Node): def __init__(self): super().__init__('listener') self.subscription = self.create_subscription( String, 'chatter', self.listener_callback, 10) def listener_callback(self, msg): self.get_logger().info('I heard: "%s"' % msg.data) def main(args=None): rclpy.init(args=args) listener = Listener() rclpy.spin(listener) listener.destroy_node() rclpy.shutdown() if __name__ == '__main__': main()在setup.py中添加入口点：
entry_points={ 'console_scripts': [ 'listener = py_pubsub.listener:main', ], }编译并运行这两个节点，你应该能看到发布者发送的消息被订阅者接收并打印出来。
4. 自定义接口消息的实现
当标准消息类型不能满足需求时，我们需要自定义消息接口。ROS2支持三种接口文件：msg（简单消息）、srv（服务）和action（动作）。这里我们重点介绍msg文件。
4.1 创建自定义消息
在功能包中创建msg目录和Student.msg文件：
string first_name string last_name uint8 age float32 score修改package.xml，添加构建依赖：
<build_depend>rosidl_default_generators</build_depend> <exec_depend>rosidl_default_runtime</exec_depend> <member_of_group>rosidl_interface_packages</member_of_group>修改CMakeLists.txt：
find_package(rosidl_default_generators REQUIRED) rosidl_generate_interfaces(${PROJECT_NAME} "msg/Student.msg" )4.2 C++实现自定义消息发布者
创建student_publisher.cpp：
#include "rclcpp/rclcpp.hpp" #include "custom_interfaces/msg/student.hpp" using namespace std::chrono_literals; class StudentPublisher : public rclcpp::Node { public: StudentPublisher() : Node("student_publisher"), count_(0) { publisher_ = this->create_publisher<custom_interfaces::msg::Student>("student_topic", 10); timer_ = this->create_wall_timer( 1s, std::bind(&StudentPublisher::timer_callback, this)); } private: void timer_callback() { auto message = custom_interfaces::msg::Student(); message.first_name = "John"; message.last_name = "Doe_" + std::to_string(count_++); message.age = 20 + (count_ % 5); message.score = 85.0 + (count_ % 10); RCLCPP_INFO(this->get_logger(), "Publishing Student: %s %s, Age: %d, Score: %.1f", message.first_name.c_str(), message.last_name.c_str(), message.age, message.score); publisher_->publish(message); } rclcpp::TimerBase::SharedPtr timer_; rclcpp::Publisher<custom_interfaces::msg::Student>::SharedPtr publisher_; size_t count_; }; int main(int argc, char * argv[]) { rclcpp::init(argc, argv); rclcpp::spin(std::make_shared<StudentPublisher>()); rclcpp::shutdown(); return 0; }4.3 Python实现自定义消息订阅者
创建student_subscriber.py：
import rclpy from rclpy.node import Node from custom_interfaces.msg import Student class StudentSubscriber(Node): def __init__(self): super().__init__('student_subscriber') self.subscription = self.create_subscription( Student, 'student_topic', self.listener_callback, 10) def listener_callback(self, msg): self.get_logger().info( f'Received Student: {msg.first_name} {msg.last_name}, ' f'Age: {msg.age}, Score: {msg.score}') def main(args=None): rclpy.init(args=args) subscriber = StudentSubscriber() rclpy.spin(subscriber) subscriber.destroy_node() rclpy.shutdown() if __name__ == '__main__': main()编译并运行这些节点，你将看到包含学生信息的自定义消息在节点间传输。
5. 使用rqt进行可视化调试
rqt是ROS2强大的可视化工具集，其中rqt_graph可以直观展示节点和话题的连接关系。安装rqt：
sudo apt install ros-humble-rqt ros-humble-rqt-common-plugins运行发布者和订阅者节点后，在新终端中启动rqt_graph：
rqt_graph你将看到节点间的连接关系图。对于我们的示例，应该能看到talker和listener通过chatter话题连接，student_publisher和student_subscriber通过student_topic连接。
rqt_console是另一个有用的工具，可以集中查看所有节点的日志输出：
rqt_console在实际调试中，我经常使用rqt_plot来可视化数值数据。例如，要绘制学生成绩的变化：
rqt_plot /student_topic/score6. 实战技巧与常见问题
在实际项目中，我发现以下几个技巧特别有用：
- 话题重映射：当需要临时更改话题名称时，可以使用重映射参数：
ros2 run package_name node_name --ros-args -r old_topic:=new_topic- QoS配置：ROS2允许配置服务质量策略，例如设置可靠性：
auto qos = rclcpp::QoS(rclcpp::KeepLast(10)).reliable(); publisher_ = this->create_publisher<std_msgs::msg::String>("chatter", qos);- 消息时间戳：在处理传感器数据时，记得为消息添加时间戳：
message.header.stamp = this->now();常见问题及解决方案：
消息不接收：检查话题名称和消息类型是否匹配，使用
ros2 topic list -t确认。编译错误：自定义消息后，确保在package.xml和CMakeLists.txt中添加了正确依赖。
性能问题：对于高频数据，考虑使用零拷贝发布或调整QoS策略。
命名冲突：使用命名空间避免节点和话题名称冲突：
auto node = std::make_shared<rclcpp::Node>("node_name", "my_namespace");
