ROS 2边学边练(25)-- 将多个节点组合到一个进程

2024-04-16 10:28

本文主要是介绍ROS 2边学边练(25)-- 将多个节点组合到一个进程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言     

        在ROS 2中,将多个节点(Nodes)组合到一个单独的进程(Process)中通常指的是使用“Composable Nodes”的特性。这个特性允许你定义可复用的组件(Components),然后将这些组件加载到一个或多个ROS 2节点中,而这些节点可以运行在同一个进程中。

这样做有几个好处:

  1. 资源优化:通过将多个节点组合到一个进程中,可以减少进程间通信的开销,并更有效地利用系统资源。

  2. 简化部署:对于需要多个节点协同工作的应用程序,将它们组合到一个进程中可以简化部署和配置。

  3. 代码重用:组件化的设计使得代码重用变得更加容易,因为你可以在不同的节点或应用程序中重用相同的组件。

在ROS 2中实现这一功能,通常涉及以下步骤:

  1. 定义组件:使用ROS 2的组件API定义可复用的组件。每个组件都封装了特定的功能,并且可以在运行时加载到节点中。

  2. 创建节点:创建一个或多个ROS 2节点,这些节点将作为组件的容器。这些节点可以配置为接受组件的加载。

  3. 加载组件:使用ROS 2的组件加载器(Component Loader)将组件加载到节点中。这通常涉及指定组件的类型和参数,并告诉ROS 2在何处找到这些组件的实现。

  4. 运行节点:启动包含组件的节点,这些节点现在将在一个共同的进程中运行,并共享相同的资源。

        需要注意的是,尽管将多个节点组合到一个进程中可以提高效率和简化部署,但这也可能引入额外的复杂性。例如,需要确保进程内的所有节点都能够正确地处理并发操作和资源共享。因此,在决定是否将节点组合到一个进程时,应该仔细考虑应用程序的具体需求和约束。

        简而言之,ROS 2中的“Composable Nodes”特性提供了一种灵活的方式来构建和管理ROS 2应用程序,通过组件化和进程内组合的方式,可以实现更高效、可重用和可配置的机器人和自动化系统。

动动手

运行例子

        这些例子使用了rclcpp_components、ros2component和composition包中的可执行文件,并且可以使用以下命令运行。

发现可用的组件

        想要查看当前工作空间中已注册且能用的组件列表,我们可以利用下面的命令进行查看:

$ros2 component types

返回符合条件的组件列表:

mike@mike-virtual-machine:~/Desktop/ros2_ws$ ros2 component types
examples_rclcpp_wait_setTalkerListener
examples_rclcpp_minimal_subscriberWaitSetSubscriberStaticWaitSetSubscriberTimeTriggeredWaitSetSubscriber
custom_action_cppcustom_action_cpp::FibonacciActionServercustom_action_cpp::FibonacciActionClient
logging_demologging_demo::LoggerConfiglogging_demo::LoggerUsage
compositioncomposition::Talkercomposition::Listenercomposition::NodeLikeListenercomposition::Servercomposition::Client
demo_nodes_cpp_nativedemo_nodes_cpp_native::Talker
robot_state_publisherrobot_state_publisher::RobotStatePublisher
quality_of_service_demo_cppquality_of_service_demo::MessageLostListenerquality_of_service_demo::MessageLostTalkerquality_of_service_demo::QosOverridesListenerquality_of_service_demo::QosOverridesTalker
teleop_twist_joyteleop_twist_joy::TeleopTwistJoy
demo_nodes_cppdemo_nodes_cpp::OneOffTimerNodedemo_nodes_cpp::ReuseTimerNodedemo_nodes_cpp::ServerNodedemo_nodes_cpp::ClientNodedemo_nodes_cpp::IntrospectionServiceNodedemo_nodes_cpp::IntrospectionClientNodedemo_nodes_cpp::ListParametersdemo_nodes_cpp::ParameterBlackboarddemo_nodes_cpp::SetAndGetParametersdemo_nodes_cpp::ParameterEventsAsyncNodedemo_nodes_cpp::EvenParameterNodedemo_nodes_cpp::SetParametersCallbackdemo_nodes_cpp::ContentFilteringPublisherdemo_nodes_cpp::ContentFilteringSubscriberdemo_nodes_cpp::Talkerdemo_nodes_cpp::LoanedMessageTalkerdemo_nodes_cpp::SerializedMessageTalkerdemo_nodes_cpp::Listenerdemo_nodes_cpp::SerializedMessageListenerdemo_nodes_cpp::ListenerBestEffort
tf2_rostf2_ros::StaticTransformBroadcasterNode
action_tutorials_cppaction_tutorials_cpp::FibonacciActionClientaction_tutorials_cpp::FibonacciActionServer
image_toolsimage_tools::Cam2Imageimage_tools::ShowImage
joyjoy::Joyjoy::GameController
depthimage_to_laserscandepthimage_to_laserscan::DepthImageToLaserScanROS
运行时组合示例(ROS的发布者/订阅者)

        应用程序运行时动态加载/卸载组件,灵活性好。

        打开第一个终端,启动组件容器:

$ros2 run rclcpp_components component_container

        打开第二个终端,检查确认组件容器是否正常运行中:

$ros2 component list

如果返回了/ComponentManager,则说明OK。再在此终端中加载talker组件(源码):

$ros2 component load /ComponentManager composition composition::Talker

返回的结果中包含了该组件的名称以及其对应的ID号:

Loaded component 1 into '/ComponentManager' container node as '/talker'

 

现在我们再切换到第一个终端窗口(加载组件容器),看看里面有些什么内容出来:

可以看到,talker组件加载成功并且在不断发布消息。

        我们再在第二个终端加载listener组件(源码),命令类似于talker,如下:

$ros2 component load /ComponentManager composition composition::Listener

也返回了类似的内容,组件名称listener以及ID号码:

Loaded component 2 into '/ComponentManager' container node as '/listener'

 

我们再检查一下当前的组件列表:

$ros2 component list

运行时组合示例(ROS的服务端和客户端)

        同上面的发布者/订阅者例子,先开启一个终端加载组件容器:

$ros2 run rclcpp_components component_container

在第二个终端依次加载服务端组件(源码)和客户端组件(源码):

$ros2 component load /ComponentManager composition composition::Server
$ros2 component load /ComponentManager composition composition::Client

我们看看第一个终端会有什么内容:

编译时组合示例(硬编码)

        编译ROS 2应用程序时,通过硬编码的方式将节点组合在一起,编译时组合通常意味着在源代码中直接定义和实例化节点对象,并将它们组合成一个或多个进程。这种方式的优点包括简单性和确定性——编译后的应用程序结构是固定的,没有运行时的不确定性。然而,它也降低了灵活性,因为一旦应用程序被编译,节点的组合方式就不能轻易改变。

        这个示例显示,可以复用相同的共享库来编译运行多个组件的单个可执行文件,而无需使用ROS接口。可执行文件包含上面的所有四个组件:发送器和侦听器以及服务器和客户端,它们在主函数中进行了硬编码。

        我们可以通过下面的命令调用:

$ros2 run composition manual_composition

我们可以看看终端返回的内容:

编译组合的方式的组件是没法通过ros2 component list命令查看的。

运行时组合示例(使用dlopen)

        在运行时组合示例中,当我们运行组件容器后并启动服务端/客户端时,可以看到在容器的终端输出中有打印出加载对应的so库并且找到对应的类最终实例化。

        这个利用dlopen的示例通过创建一个通用容器进程并显式地传递库以加载而不使用ROS接口,提供了一种运行时组合的替代方案。该进程将打开每个库,并在库中创建每个“rclcpp::Node”类的一个实例(源码),与前面的流程大同小异,只不过不用那么麻烦开启好几个终端而已。

$ros2 run composition dlopen_composition `ros2 pkg prefix composition`/lib/libtalker_component.so `ros2 pkg prefix composition`/lib/liblistener_component.so

  

可以与上面的截图比较一下,是不是差不多。

dlopen-composed组件通过ros2 component list命令也是发现不了的。

launch方式启动组合

        上面的例子都是逐个命令运行组合,可以比较方便地对过程进行调试、诊断,但是我们也可以一条命令启动多个组件(源码):

$ros2 launch composition composition_demo_launch.py
mike@mike-virtual-machine:~/Desktop/ros2_ws$ ros2 launch composition composition_demo_launch.py
[INFO] [launch]: All log files can be found below /home/mike/.ros/log/2024-04-15-21-18-04-617692-mike-virtual-machine-30402
[INFO] [launch]: Default logging verbosity is set to INFO
[INFO] [component_container-1]: process started with pid [30417]
[component_container-1] [INFO] [1713187085.127445213] [my_container]: Load Library: /opt/ros/iron/lib/libtalker_component.so
[component_container-1] [INFO] [1713187085.128648991] [my_container]: Found class: rclcpp_components::NodeFactoryTemplate<composition::Talker>
[component_container-1] [INFO] [1713187085.128759649] [my_container]: Instantiate class: rclcpp_components::NodeFactoryTemplate<composition::Talker>
[INFO] [launch_ros.actions.load_composable_nodes]: Loaded node '/talker' in container '/my_container'
[component_container-1] [INFO] [1713187085.143832047] [my_container]: Load Library: /opt/ros/iron/lib/liblistener_component.so
[component_container-1] [INFO] [1713187085.144882187] [my_container]: Found class: rclcpp_components::NodeFactoryTemplate<composition::Listener>
[component_container-1] [INFO] [1713187085.144981253] [my_container]: Instantiate class: rclcpp_components::NodeFactoryTemplate<composition::Listener>
[INFO] [launch_ros.actions.load_composable_nodes]: Loaded node '/listener' in container '/my_container'
[component_container-1] [INFO] [1713187086.141280013] [talker]: Publishing: 'Hello World: 1'
[component_container-1] [INFO] [1713187086.141662411] [listener]: I heard: [Hello World: 1]
[component_container-1] [INFO] [1713187087.141013738] [talker]: Publishing: 'Hello World: 2'
[component_container-1] [INFO] [1713187087.141367812] [listener]: I heard: [Hello World: 2]
[component_container-1] [INFO] [1713187088.141100795] [talker]: Publishing: 'Hello World: 3'
[component_container-1] [INFO] [1713187088.141427367] [listener]: I heard: [Hello World: 3]
[component_container-1] [INFO] [1713187089.141335387] [talker]: Publishing: 'Hello World: 4'
[component_container-1] [INFO] [1713187089.141511508] [listener]: I heard: [Hello World: 4]

更多用法

        上面都是关于组合的一些基础用法,下面我们来show几个高级用法。

卸载组件

        再来一遍上面的组合示例,方便用来演示卸载的步骤。

        1.启动组件容器

$ros2 run rclcpp_components component_container

        2.检查确认容器是否正常运行

$ros2 component list

        3.启动talker和listener

$ros2 component load /ComponentManager composition composition::Talker
$ros2 component load /ComponentManager composition composition::Listener

 可以看到每个组件成功加载后都会有一个对应的ID,上面1对应Listener,2对应Talker。

        4.卸载组件

$ros2 component unload /ComponentManager 1 2

 

根据对应的ID来卸载组件,干净明了。

重映射容器及命名空间名字

        我们可以通过下面的命令对组件容器和命名空间的名字进行重映射:

$ros2 run rclcpp_components component_container --ros-args -r __node:=MyContainer -r __ns:=/ns

        第二个终端加载组件:

$ros2 component load /ns/MyContainer composition composition::Listener
重映射组件及命名空间名字

        首先启动组件容器:

$ros2 run rclcpp_components component_container

        我们有几个重映射例子。

        重映射节点名字:

$ros2 component load /ComponentManager composition composition::Talker --node-name talker2

        重映射命名空间:

$ros2 component load /ComponentManager composition composition::Talker --node-namespace /ns

        重映射节点及命名空间:

$ros2 component load /ComponentManager composition composition::Talker --node-name talker3 --node-namespace /ns2

        我们再来检查一下组件列表:

$ros2 component list

将参数值传递到组件

        ros2组件加载命令行支持在构建节点时将任意参数传递给节点。此功能可按如下方式使用:

$ros2 component load /ComponentManager image_tools image_tools::Cam2Image -p burger_mode:=true
将附加参数传递到组件

        ros2组件加载命令行支持将特定选项传递给组件管理器,以便在构建节点时使用。到目前为止,唯一支持的命令行选项是使用进程内通信实例化节点。此功能可按如下方式使用:

$ros2 component load /ComponentManager composition composition::Talker -e use_intra_process_comms:=true

作为共享库的组合节点

        如果要从包中将可组合节点导出为共享库,并在另一个进行链接时组合的包中使用该节点,请将代码添加到CMake文件中,该文件将导入下游包中的实际目标。然后安装生成的文件并导出生成的文件。一个参考例子:ROS Discourse - Ament best practice for sharing libraries

合成非节点衍生组件

        在ROS 2中,组件允许更有效地使用系统资源,并提供了一个强大的功能,使您能够创建不与特定节点绑定的可重用功能。

        使用组件的一个优点是,它们允许我们将非节点派生的功能创建为独立的可执行文件或共享库,这些可执行文件可根据需要加载到ROS系统中。

  1. 要创建不是从节点派生的组件,我们要遵循以下准则:
  2. 构造函数带const rclcpp::NodeOptions&参数;
  3. 实现get_node_base_interface()方法,该方法应返回NodeBaseInterface::SharedPtr。我们可以使用在构造函数中创建的节点的get_node_base_interface()方法来提供此接口。

        可以参考这个不是从节点派生的组件示例,该组件侦听ROS主题:node_like_listener_component。

        内容有点多,慢慢消化。

本篇完。

这篇关于ROS 2边学边练(25)-- 将多个节点组合到一个进程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/908530

相关文章

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类(常规内部类)局部内部类(方法内部类)匿名内部类二、

基于Flask框架添加多个AI模型的API并进行交互

《基于Flask框架添加多个AI模型的API并进行交互》:本文主要介绍如何基于Flask框架开发AI模型API管理系统,允许用户添加、删除不同AI模型的API密钥,感兴趣的可以了解下... 目录1. 概述2. 后端代码说明2.1 依赖库导入2.2 应用初始化2.3 API 存储字典2.4 路由函数2.5 应

Linux中的进程间通信之匿名管道解读

《Linux中的进程间通信之匿名管道解读》:本文主要介绍Linux中的进程间通信之匿名管道解读,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、基本概念二、管道1、温故知新2、实现方式3、匿名管道(一)管道中的四种情况(二)管道的特性总结一、基本概念我们知道多

Linux进程终止的N种方式详解

《Linux进程终止的N种方式详解》进程终止是操作系统中,进程的一个重要阶段,他标志着进程生命周期的结束,下面小编为大家整理了一些常见的Linux进程终止方式,大家可以根据需求选择... 目录前言一、进程终止的概念二、进程终止的场景三、进程终止的实现3.1 程序退出码3.2 运行完毕结果正常3.3 运行完毕

Python实现合并与拆分多个PDF文档中的指定页

《Python实现合并与拆分多个PDF文档中的指定页》这篇文章主要为大家详细介绍了如何使用Python实现将多个PDF文档中的指定页合并生成新的PDF以及拆分PDF,感兴趣的小伙伴可以参考一下... 安装所需要的库pip install PyPDF2 -i https://pypi.tuna.tsingh

Windows命令之tasklist命令用法详解(Windows查看进程)

《Windows命令之tasklist命令用法详解(Windows查看进程)》tasklist命令显示本地计算机或远程计算机上当前正在运行的进程列表,命令结合筛选器一起使用,可以按照我们的需求进行过滤... 目录命令帮助1、基本使用2、执行原理2.1、tasklist命令无法使用3、筛选器3.1、根据PID

linux本机进程间通信之UDS详解

《linux本机进程间通信之UDS详解》文章介绍了Unix域套接字(UDS)的使用方法,这是一种在同一台主机上不同进程间通信的方式,UDS支持三种套接字类型:SOCK_STREAM、SOCK_DGRA... 目录基础概念本机进程间通信socket实现AF_INET数据收发示意图AF_Unix数据收发流程图A

Python中多线程和多进程的基本用法详解

《Python中多线程和多进程的基本用法详解》这篇文章介绍了Python中多线程和多进程的相关知识,包括并发编程的优势,多线程和多进程的概念、适用场景、示例代码,线程池和进程池的使用,以及如何选择合适... 目录引言一、并发编程的主要优势二、python的多线程(Threading)1. 什么是多线程?2.

Python自动化办公之合并多个Excel

《Python自动化办公之合并多个Excel》在日常的办公自动化工作中,尤其是处理大量数据时,合并多个Excel表格是一个常见且繁琐的任务,下面小编就来为大家介绍一下如何使用Python轻松实现合... 目录为什么选择 python 自动化目标使用 Python 合并多个 Excel 文件安装所需库示例代码

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作