ROS2 笔记汇总(2) 通信接口

ROS 系统中,通信接口(Interface) 是节点之间传递信息的标准“语言协议”,确保了不同功能节点之间可以正确理解和使用彼此传送的数据内容。我们可以将其理解为“数据结构+格式定义”,贯穿于话题(Topic)、服务(Service)、动作(Action)等通信机制中。

在软件开发中,“接口”是一种连接关系,它规定了数据如何进出,模块如何对接,只有两边的格式和要求一致,系统才能正常“搭伙做事”。

为了让每个 ROS 节点可以用不同的语言编写,比如一个节点用 C++ 控制硬件,另一个节点用 Python 实现上层逻辑,ROS 把通信接口设计成与编程语言无关的格式

int32 表示 32 位整型

int64 表示 64 位长整型

bool 表示布尔值

还支持数组(如 int32[])、嵌套结构体等复合数据类型

这些接口定义写在 .msg(消息)或 .srv(服务)文件中。
编译时,ROS 会自动生成对应语言(如 C++ 或 Python)里的数据结构文件,供节点直接使用,开发者不需要自己去写解析逻辑。

无论你用什么语言编写节点,只要遵循统一接口,数据就能准确传输、协同工作。

ROS 2 三种通信机制(话题、服务、动作)在接口定义上的格式差异。

在 ROS 2 系统中,通信接口的定义格式因通信机制而异,但都遵循统一的、语言无关的描述方式。

话题(Topic)通信

使用 .msg 文件定义,属于单向异步通信
只需定义每一帧数据的内容格式,如:

int32 x
int32 y
表示消息中包含两个 32 位整型数据,可用于发送二维坐标等。

服务(Service)通信

使用 .srv 文件定义,属于请求-应答式的同步通信
定义由请求部分应答部分组成,中间用 --- 分隔,例如:

int64 a
int64 b
---
int64 sum
客户端发起请求,包含 ab,服务器处理后返回 sum

动作(Action)通信

使用 .action 文件定义,适合描述持续一段时间的过程性任务,如移动、旋转、导航等。

定义包含三部分:

# 目标
bool enable
---
# 结果
bool finish
---
# 反馈
int32 state

目标(Goal):开始任务,如开始转动

结果(Result):任务最终是否完成

反馈(Feedback):周期性返回进度,如当前已转动角度

通信机制接口文件特点数据方向
话题.msg异步、广播单向
服务.srv同步请求客户端 ⇄ 服务端
动作.action可反馈过程客户端 ⇄ 服务端 + 反馈

服务接口的定义与使用

在本案例中,我们以一个获取目标位置的服务为例,全面了解 ROS 2 中服务接口的定义方法及实际应用方式。

learning_interface/srv/GetObjectPosition.srv

bool get     # 请求:是否获取目标位置
---
int32 x      # 响应:目标X坐标
int32 y      # 响应:目标Y坐标

bool get:客户端请求参数,true 表示请求当前目标位置。

---:分隔请求与响应。

int32 x, y:服务端反馈的目标坐标。

import rclpy                                            # ROS2 Python接口库
from rclpy.node   import Node                           # ROS2 节点类
from learning_interface.srv import GetObjectPosition    # 自定义的服务接口class objectClient(Node):def __init__(self, name):super().__init__(name)                          # ROS2节点父类初始化self.client = self.create_client(GetObjectPosition, 'get_target_position')while not self.client.wait_for_service(timeout_sec=1.0):self.get_logger().info('service not available, waiting again...')self.request = GetObjectPosition.Request()def send_request(self):self.request.get = Trueself.future = self.client.call_async(self.request)def main(args=None):rclpy.init(args=args)                             # ROS2 Python接口初始化node = objectClient("service_object_client")      # 创建ROS2节点对象并进行初始化node.send_request()while rclpy.ok():rclpy.spin_once(node)if node.future.done():try:response = node.future.result()except Exception as e:node.get_logger().info('Service call failed %r' % (e,))else:node.get_logger().info('Result of object position:\n x: %d y: %d' %(response.x, response.y))breaknode.destroy_node()                              # 销毁节点对象rclpy.shutdown()                                 # 关闭ROS2 Python接口import rclpy                                           # ROS2 Python接口库
from rclpy.node import Node                            # ROS2 节点类
from sensor_msgs.msg import Image                      # 图像消息类型
import numpy as np                                     # Python数值计算库
from cv_bridge import CvBridge                         # ROS与OpenCV图像转换类
import cv2                                             # Opencv图像处理库
from learning_interface.srv import GetObjectPosition   # 自定义的服务接口lower_red = np.array([0, 90, 128])     # 红色的HSV阈值下限
upper_red = np.array([180, 255, 255])  # 红色的HSV阈值上限class ImageSubscriber(Node):def __init__(self, name):super().__init__(name)                              # ROS2节点父类初始化self.sub = self.create_subscription(Image, 'image_raw', self.listener_callback, 10) # 创建订阅者对象(消息类型、话题名、订阅者回调函数、队列长度)self.cv_bridge = CvBridge()                         # 创建一个图像转换对象,用于OpenCV图像与ROS的图像消息的互相转换self.srv = self.create_service(GetObjectPosition,   # 创建服务器对象(接口类型、服务名、服务器回调函数)'get_target_position',self.object_position_callback)    self.objectX = 0self.objectY = 0                              def object_detect(self, image):hsv_img = cv2.cvtColor(image, cv2.COLOR_BGR2HSV)      # 图像从BGR颜色模型转换为HSV模型mask_red = cv2.inRange(hsv_img, lower_red, upper_red) # 图像二值化contours, hierarchy = cv2.findContours(mask_red, cv2.RETR_LIST, cv2.CHAIN_APPROX_NONE)   # 图像中轮廓检测for cnt in contours:                                  # 去除一些轮廓面积太小的噪声if cnt.shape[0] < 150:continue(x, y, w, h) = cv2.boundingRect(cnt)              # 得到苹果所在轮廓的左上角xy像素坐标及轮廓范围的宽和高cv2.drawContours(image, [cnt], -1, (0, 255, 0), 2)# 将苹果的轮廓勾勒出来cv2.circle(image, (int(x+w/2), int(y+h/2)), 5,(0, 255, 0), -1)                       # 将苹果的图像中心点画出来self.objectX = int(x+w/2)self.objectY = int(y+h/2)cv2.imshow("object", image)                            # 使用OpenCV显示处理后的图像效果cv2.waitKey(50)def listener_callback(self, data):self.get_logger().info('Receiving video frame')        # 输出日志信息,提示已进入回调函数image = self.cv_bridge.imgmsg_to_cv2(data, 'bgr8')     # 将ROS的图像消息转化成OpenCV图像self.object_detect(image)                              # 苹果检测def object_position_callback(self, request, response):     # 创建回调函数,执行收到请求后对数据的处理if request.get == True:response.x = self.objectX                          # 目标物体的XY坐标response.y = self.objectYself.get_logger().info('Object position\nx: %d y: %d' %(response.x, response.y))   # 输出日志信息,提示已经反馈else:response.x = 0response.y = 0self.get_logger().info('Invalid command')          # 输出日志信息,提示已经反馈return responsedef main(args=None):                                 # ROS2节点主入口main函数rclpy.init(args=args)                            # ROS2 Python接口初始化node = ImageSubscriber("service_object_server")  # 创建ROS2节点对象并进行初始化rclpy.spin(node)                                 # 循环等待ROS2退出node.destroy_node()                              # 销毁节点对象rclpy.shutdown()                                 # 关闭ROS2 Python接口

这是一个通过图像识别红色目标物体并通过ROS服务机制获取其当前坐标的系统。

服务器端(服务提供方):接收图像并处理,检测红色物体位置,一旦客户端请求,就返回该位置。

客户端(服务调用方):主动发起“请告诉我目标位置”的请求,获取最新坐标。

在 ROS2 中,通信接口(Interface) 是一种标准格式的“数据结构定义”,用于描述节点间如何传递数据。

对于 服务通信(Service) 来说,接口包括两部分:

请求部分(Request):客户端发送给服务端的数据。

响应部分(Response):服务端返回给客户端的结果。

接口使用 .srv 文件定义,例如你定义的:

定义通信接口文件 .srv

bool get
---
int32 x
int32 y

在服务端创建服务对象,绑定回调

self.srv = self.create_service(
    GetObjectPosition,                   # 使用定义好的接口
    'get_target_position',              # 服务名
    self.object_position_callback       # 处理函数
)

在客户端创建服务请求并发送

self.client = self.create_client(GetObjectPosition, 'get_target_position')
self.request = GetObjectPosition.Request()
self.request.get = True
self.future = self.client.call_async(self.request)

服务端处理请求并返回响应

def object_position_callback(self, request, response):
    if request.get:
        response.x = self.objectX
        response.y = self.objectY
    return response

再次说明,# 文件:learning_interface/srv/GetObjectPosition.srv
bool get
---
int32 x
int32 y

系统会自动生成:

一个 GetObjectPosition.Request 类(含 get 字段)

一个 GetObjectPosition.Response 类(含 xy 字段)

所以,你在代码中哪里写了 .get.x.y,就说明用了通信接口定义的字段!

通信接口 .srv 文件是怎么关联上的?

在代码中,首先导入:# 文件:learning_interface/srv/GetObjectPosition.srv

from learning_interface.srv import GetObjectPosition

意思是:你定义的服务接口 GetObjectPosition.srv,位于 ROS功能包 learning_interfacesrv/ 文件夹里

你就可以在你项目的工作空间中查找该文件:cd ~/ros2_ws/src/learning_interface/srv
ls
# 应该能看到 GetObjectPosition.srv

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

微信小程序:将搜索框和表格封装成组件,页面调用组件

一、实现效果 实现搜索框,表格和翻页效果 二、组件实现 1、创建表格组件页面 (1)创建文件 在文件根目录(与pages同级)直接创建components文件夹,并创建表格的页面common-table/index (2)视图层 a、写入表头 循环由主页面传递的columns,数据为字段名label,宽度为设置…

基于贝叶斯学习方法的块稀疏信号压缩感知算法

基于贝叶斯学习方法的块稀疏信号压缩感知算法 BSBL-FM-master/BSBL_BO.m , 15593 BSBL-FM-master/BSBL_FM.m , 12854 BSBL-FM-master/Phi.mat , 131256 BSBL-FM-master/README.md , 3954 BSBL-FM-master/demo.mat , 1610 BSBL-FM-master/demo_fecg.m , 1481 BSBL-FM-master/de…

【Python爬虫】requests知识点讲解

目录 前言1. requests库基础1.1 安装requests1.2 基本导入 2. HTTP请求方法2.1 GET请求2.2 POST请求2.3 其他HTTP方法 3. 请求头设置3.1 User-Agent设置3.2 常用请求头 4. 响应处理4.1 响应内容获取4.2 响应状态码4.3 响应头信息 5. 会话管理5.1 Session对象5.2 Cookie处理 6. …

服务器上安装配置vsftpd

目录 1. 安装vsftpd服务 2、修改配置文件 3. 修改用户白名单 4. 通过ftp客户端命令登录ftp服务器 5. 参考资料 1. 安装vsftpd服务 执行命令安装vsftp服务、和ftp客户端 yum install vsftpd yum install ftp 2、修改配置文件 在服务器上先创建一个系统用户&#xff0c;待…

C#实现图片文字识别

这几年的AI的发展&#xff0c;使得文字识别难度大大降低、精度大大的提高。百度飞浆就是一个非常好的AI框架&#xff0c;而且是开源的。 我们利用百度飞浆就能快速简单的实现文字识别功能&#xff0c;几行代码就可以集成。 其中百度飞浆的PaddleOCR&#xff0c;就是专门针对文…

Android Framework 调用栈

在Android Framework开发中&#xff0c;添加调用栈&#xff08;Call Stack&#xff09;是调试复杂问题&#xff08;如崩溃、死锁或流程追踪&#xff09;的核心手段。 一、Java层调用栈添加 适用于Activity、Service等组件或Framework中的Java代码。 基础方法&#xff1a; 使用…

Ollama安装非系统盘操作方法(2025年6月测试通过)

Ollama是当前部署大模型比较便利的工具&#xff0c;但是默认会将软件和模型都安装到C盘下&#xff0c;导致系统盘爆表&#xff0c;建议将软件和模型都放置在非系统盘。 1. 软件安装在非系统盘 &#xff08;1&#xff09;在D盘下手动创建ollama目录 &#xff08;2&#xff09…

《HTTP权威指南》 第1-2章 HTTP和URL基础

HTTP请求基础 格式化数据块称为HTTP报文 请求报文&#xff1a;从客户端发往服务器的HTTP报文&#xff0c;只有请求起始行请求首部&#xff0c;没有请求主体 响应报文&#xff1a;从服务器发往客户端的报文&#xff0c;包含响应起始行响应首部响应主体 HTTP报文通过传输控制…

9. TypeScript 泛型

TypeScript 中的泛型使开发者能够编写灵活、可重用的代码&#xff0c;同时保持类型安全。它们允许动态定义类型&#xff0c;确保函数、类和接口可以适用于任何数据类型。这有助于避免重复&#xff0c;提高代码的模块化&#xff0c;使其既类型安全又具备适应性。 一、认识泛型 …

Apache Iceberg与Hive集成:分区表篇

一、Iceberg分区表核心概念与Hive集成原理 1.1 分区表在大数据场景的价值 在大规模数据分析中&#xff0c;分区表通过将数据按特定维度&#xff08;如时间、地域、业务类型&#xff09;划分存储&#xff0c;可显著提升查询效率。Apache Iceberg的分区表设计融合了Hive的分区理…

SAST + IAST + DAST 全链路防护体系构建方案

&#x1f525;「炎码工坊」技术弹药已装填&#xff01; 点击关注 → 解锁工业级干货【工具实测|项目避坑|源码燃烧指南】 1. 生命周期分层嵌入&#xff08;防御纵深&#xff09; 阶段工具防护重点集成触发点编码阶段SAST源码漏洞&#xff08;硬编码密钥、SQL注入模式&#x…

pnpm link如何不踩坑

前提一&#xff1a;我有一个source-project源码库&#xff0c;有一个develop-project项目库。想使用pnpm link对source-project进行本地调试。 前提二&#xff1a;source-project源码库已打包 本地调试详细步骤如下&#xff1a; 1、检查是否配置了系统环境变量&#xff0c;P…

vue3 javascript 多字段求和技巧

在 Vue 3 中&#xff0c;如果你需要在一个组件中处理多个字段的求和&#xff0c;你可以通过计算属性&#xff08;computed properties&#xff09;或者方法&#xff08;methods&#xff09;来实现。这里我将展示两种主要的方法&#xff1a; 方法 1&#xff1a;使用计算属性&am…

【LeetCode】每日一题 —— No.3405

LeetCode 3405 统计恰好有 K 个相等相邻元素的数组数目&#xff08;DP 构造型&#xff09; 题目概述 我们需要统计长度为 n 的数组 arr 满足如下条件的方案数&#xff1a; 每个元素在区间 [1, m] 之间恰好存在 k 个位置 i (1 ≤ i < n) 满足 arr[i] arr[i - 1] 也就是说…

Elsa Workflows: .NET 的开源工作流引擎简介

文章目录 Elsa Workflows&#xff1a; .NET 的开源工作流引擎核心定位与理念关键特性与优势当前 (Elsa 3) 的已知限制/待完善项总结 Elsa Workflows&#xff1a; .NET 的开源工作流引擎 Elsa Workflows 是一个开源的、模块化的 .NET 库集合&#xff0c;旨在为 .NET 应用程序提…

linux虚拟机yum命令报错解决方案

问题 假如出现了这样的问题&#xff0c;可能是虚拟机yum库存在问题 解决方法 1、打开cmd&#xff0c;输入ssh root地址&#xff0c;比如ssh root192.168.222..111&#xff0c;选yes&#xff0c;输入虚拟机密码 2、使用yum repolist,查看仓库状态&#xff0c;status下面如果是…

C++ 第一阶段 基本语法 - 第一节:变量与数据类型详解

目录 一、变量与数据类型概述 1.1 什么是变量&#xff1f; 1.2 数据类型分类 二、基本数据类型详解 2.1 整型&#xff08;int, short, long&#xff09; 2.1.1 常见整型类型 2.1.2 代码示例 2.1.3 注意事项 2.2 浮点型&#xff08;float, double&#xff09; 2.2.1 浮…

CppCon 2017 学习:CNL: A Compositional Numeric Library

你说的这段关于浮点数的问题总结得很精准&#xff0c;我帮你整理一下&#xff0c;让理解更清晰&#xff1a; The Problem with Floating-Point&#xff08;浮点数的问题&#xff09; 复杂的表示结构 浮点数由符号位 &#xff0c;有效数&#xff08;significand/mantissa&…

linux基础重定向及组合重定向

一、基础重定向操作符 ‌类别‌ ‌操作符‌ ‌含义‌ ‌示例‌ ‌备注‌ ‌标准输出‌ > 覆盖写入 stdout 到文件 ls > file.txt 文件不存在则创建&#xff0c;存在则清空内容 >> 追加 stdout 到文件末尾 date >> log.txt 保留原有内容 ‌标准…

佰力博科技与您探讨铁电分析仪适用场景

铁电分析仪是一种用于测试和研究铁电材料性能的精密仪器&#xff0c;其适用场景非常广泛&#xff0c;涵盖了材料科学、物理学、电子工程等多个领域。 1、材料科学与工程 铁电分析仪广泛应用于铁电材料的研究&#xff0c;包括薄膜、厚膜、块体材料以及电子陶瓷等。它能够测试材料…