ros2加入话题订阅和回调函数python

### 实现话题订阅及设置回调函数在ROS 2中，为了创建一个节点并订阅特定的话题，可以利用`rclpy`库中的功能。下面是一个简单的例子来展示如何通过Python实现这一过程[^1]。 #### 创建订阅者节点首先导入必要的模块，并初始化ROS客户端库： ```python import rclpy from rclpy.node import Node from std_msgs.msg import String ``` 定义一个新的类继承自Node基类，在构造器内完成节点名称设定以及订阅者的建立工作： ```python class MinimalSubscriber(Node): def __init__(self): super().__init__('minimal_subscriber') self.subscription = self.create_subscription( String, 'topic', self.listener_callback, 10) self.subscription # prevent unused variable warning ``` 上述代码片段展示了如何声明一个名为`'minimal_subscriber'`的新节点实例，并针对指定主题名`'topic'`创建了一个类型为`String`的消息监听器。这里还指定了缓冲区大小参数作为最后一个输入项（此处设为10）。最后注册了当接收到新消息时要调用的方法——即`listener_callback()`方法。 #### 定义回调处理逻辑接下来就是编写实际用于响应传入数据的回调函数部分： ```python def listener_callback(self, msg): self.get_logger().info('I heard: "%s"' % msg.data) ``` 每当有新的字符串消息到达所关注的主题上时，就会触发此回调并将内容打印到控制台日志里去。注意这里的`msg`对象包含了来自发布端发送过来的具体信息字段，比如在这个案例中是`.data`属性表示文本形式的数据。 #### 主程序入口为了让整个应用程序运行起来还需要加上一段标准的启动脚本： ```python def main(args=None): rclpy.init(args=args) minimal_subscriber = MinimalSubscriber() rclpy.spin(minimal_subscriber) # Destroy the node explicitly # (optional - otherwise it will be done automatically # when the garbage collector destroys the node object) minimal_subscriber.destroy_node() rclpy.shutdown() if __name__ == '__main__': main() ``` 这段代码负责初始化环境、构建节点实体、进入循环等待事件发生直至用户终止进程为止；之后清理资源释放内存空间以确保良好的实践习惯。

创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考

下一篇 python 从列表中匹配关键字