ROS：服务通信机制详解

news2024/12/24 8:13:03

目录

  • ROS：通信机制
  • 一、服务通信机制简介
    • 1.1概念
    • 1.2作用
  • 二、服务通信理论模型
  • 三、服务通信自定义srv
    • 3.1目的
    • 3.2流程
      • 3.2.1创建srv文件
      • 3.2.2编辑配置文件
      • 3.2.3.编译
  • 四、服务通信自定义srv调用(C++)
    • 4.1要求
    • 4.2流程
    • 4.3vscode配置
    • 4.4服务端代码
    • 4.5客户端代码
    • 4.6配置 CMakeLists.txt
    • 4.7执行
  • 五、服务通信自定义srv调用(python)
    • 5.1需求
    • 5.2流程
    • 5.3vscode配置
    • 5.4服务端代码
    • 5.5客户端代码
    • 5.6设置权限
    • 5.7配置 CMakeLists.txt
    • 5.8执行

ROS：通信机制

一、服务通信机制简介

服务通信是ROS中一种极其常用的通信模式，服务通信是基于请求响应模式的，是一种应答机制。也即: 一个节点A向另一个节点B发送请求，B接收处理请求并产生响应结果返回给A。比如如下场景:
机器人巡逻过程中，控制系统分析传感器数据发现可疑物体或人… 此时需要拍摄照片并留存。

在上述场景中，就使用到了服务通信。
一个节点需要向相机节点发送拍照请求，相机节点处理请求，并返回处理结果

与上述应用类似的，服务通信更适用于对时时性有要求、具有一定逻辑处理的应用场景。

1.1概念

以请求响应的方式实现不同节点之间数据交互的通信模式。

1.2作用

用于偶然的、对时时性有要求、有一定逻辑处理需求的数据传输场景。

二、服务通信理论模型

服务是一种带有应答的通信机制，与话题的通信相比，其减少了Listener与Talker之间的RPC通信。
服务通信较之于话题通信更简单些，理论模型如下图所示，该模型中涉及到三个角色:

ROS master(管理者)
Server(服务端)
Client(客户端)
ROS Master 负责保管 Server 和 Client 注册的信息，并匹配话题相同的 Server 与 Client ，帮助 Server 与 Client 建立连接，连接建立后，Client 发送请求信息，Server 返回响应信息。

在这里插入图片描述

0、Talker注册
Talker启动，通过1234端口使用RPC向ROS Master注册发布者的信息，包含所提供的服务名;ROS Master会将节点的注册信息加入注册列表中。
1、Listener注册
Listener启动，同样通过RPC向ROS Master注册订阅者的信息，包含需要订阅的服务名。
2、ROS Master进行信息匹配
Master根据Listener的订阅信息从注册列表中进行查找，如果没有找到匹配的服务提供者，则等待该服务的提供者加入：如果找到匹配的服务提供者信息，则通过RPC向Listener发送Talker的TCP地址信息。
4、Listener与Talker建立网络连接
Listener接收到确认信息后，使用TCP尝试与Talker建立网络连接，并且发送服务的请求数据。
5、Talker向Listener发布服务应答数据
Talker接收到服务请求和参数后，开始执行服务功能，执行完成后，向Listener发送应答数据。

三、服务通信自定义srv

3.1目的

服务通信中，客户端提交两个整数至服务端，服务端求和并响应结果到客户端，请创建服务器与客户端通信的数据载体。

3.2流程

srv 文件内的可用数据类型与 msg 文件一致，且定义 srv 实现流程与自定义 msg 实现流程类似:

按照固定格式创建srv文件
编辑配置文件
编译生成中间文件

3.2.1创建srv文件

服务通信中，数据分成两部分，请求与响应，在 srv 文件中请求和响应使用—分割，具体实现如下:
功能包下新建 srv 目录，添加 xxx.srv 文件，内容:

# 客户端请求时发送的两个数字
int32 num1
int32 num2
---
# 服务器响应发送的数据
int32 sum

3.2.2编辑配置文件

package.xml中添加编译依赖与执行依赖

  <build_depend>message_generation</build_depend>
  <exec_depend>message_runtime</exec_depend>
  <!-- 
  exce_depend 以前对应的是 run_depend 现在非法
  -->

CMakeLists.txt编辑 srv 相关配置

find_package(catkin REQUIRED COMPONENTS
  roscpp
  rospy
  std_msgs
  message_generation
)
# 需要加入 message_generation,必须有 std_msgs

add_service_files(
  FILES
  AddInts.srv
)

generate_messages(
  DEPENDENCIES
  std_msgs
)

3.2.3.编译

编译后的中间文件查看:

C++ 需要调用的中间文件(…/工作空间/devel/include/包名/xxx.h)
在这里插入图片描述
Python 需要调用的中间文件(…/工作空间/devel/lib/python3/dist-packages/包名/srv)
在这里插入图片描述
后续调用相关 srv 时，是从这些中间文件调用的

四、服务通信自定义srv调用(C++)

4.1要求

编写服务通信，客户端提交两个整数至服务端，服务端求和并响应结果到客户端。

4.2流程

分析:
在模型实现中，ROS master 不需要实现，而连接的建立也已经被封装了，需要关注的关键点有三个:
服务端
客户端
数据

流程:
编写服务端实现；
编写客户端实现；
编辑配置文件；
编译并执行。

4.3vscode配置

需要像之前自定义 msg 实现一样配置c_cpp_properies.json 文件，如果以前已经配置且没有变更工作空间，可以忽略，如果需要配置，配置方式与之前相同:

{
    "configurations": [
        {
            "browse": {
                "databaseFilename": "",
                "limitSymbolsToIncludedHeaders": true
            },
            "includePath": [
                "/opt/ros/noetic/include/**",
                "/usr/include/**",
                "/xxx/yyy工作空间/devel/include/**" //配置 head 文件的路径 
            ],
            "name": "ROS",
            "intelliSenseMode": "gcc-x64",
            "compilerPath": "/usr/bin/gcc",
            "cStandard": "c11",
            "cppStandard": "c++17"
        }
    ],
    "version": 4
}

4.4服务端代码

#include "ros/ros.h"
#include "plumbing_server_client/AddInts.h"

/*
服务端实现：解析客户端提交的数据，并运算产生响应
1.包含头文件
2.初始化ros节点
3.创建节点句柄
4.创建一个服务对象
5.处理请求并产生响应
6.spin()
*/

bool doNums(plumbing_server_client::AddInts::Request & request,
            plumbing_server_client::AddInts::Response & response)
{
    //1.处理请求
    int num1 = request.num1;
    int num2 = request.num2;
    ROS_INFO("收到的请求数据是:num1=%d,num2=%d",num1,num2);
   
    //2.组织响应
    int sum=num1+num2;
    response.sum = sum;
    ROS_INFO("求和的结果： sum= %d",sum);
    return true;  
}

int main(int argc, char *argv[])
{
    setlocale(LC_ALL,"");
    // 2.初始化ros节点
    ros::init(argc,argv,"heishui");//节点名称需保证唯一
    // 3.创建节点句柄
    ros::NodeHandle nh;
    // 4.创建一个服务对象
    ros::ServiceServer serve = nh.advertiseService("addInts",doNums);
    ROS_INFO("服务端启动");
    // 5.处理请求并产生响应
    // 6.spin()
    ros::spin();



    return 0;
}

4.5客户端代码

#include "ros/ros.h"
#include "plumbing_server_client/AddInts.h"

/*
客户端实现：提交两个整数，并处理响应的结果
1.包含头文件
2.初始化ros节点
3.创建节点句柄
4.创建一个客户端对象
5.请求请求并产生响应，并组织进 request

实现参数的动态提交
1.格式 rosrun xxxx xxxx 12 34
2.节点执行时，需要获取命令中的参数，
*/


int main(int argc, char *argv[])
{
    //获取命令中的参数
    if(argc !=3)
    {
        ROS_INFO("提交的参数个数不对");
        return 1;
    }
    


    setlocale(LC_ALL,"");
    // 2.初始化ros节点
    ros::init(argc,argv,"dabao");//节点名称需保证唯一
    // 3.创建节点句柄
    ros::NodeHandle nh;
    // 4.创建一个客户端对象
    ros::ServiceClient client=nh.serviceClient<plumbing_server_client::AddInts>("addInts");
    ROS_INFO("客户端启动");
    // 5.处理请求并产生响应
    plumbing_server_client::AddInts ai;
    //5.1组织请求
    //规定数字
    // ai.request.num1=100;
    // ai.request.num2=200;
    //获取命令中的参数
    ai.request.num1=atoi(argv[1]);
    ai.request.num2=atoi(argv[2]);

    //5.2处理响应
    //一般操作是先启动服务端，在启动客户端，否则报错
    //可以先将客户端挂起。ros中内置了相关函数，这些函数可以让客户端启动后挂起，等待服务器启动
    //调用判断服务器状态的函数
    //函数1
    //client.waitForExistence();
    //函数2
    ros::service::waitForService("addInts");

    bool flag =client.call(ai);
    if(flag)
    {
        ROS_INFO("响应成功");
        //获取结果
        ROS_INFO("响应结果sum= %d",ai.response.sum);
    }
    else
    {
        ROS_INFO("处理失败");
    }



    return 0;
}

4.6配置 CMakeLists.txt

## The recommended prefix ensures that target names across packages don't collide
add_executable(demo01_server src/demo01_server.cpp)
add_executable(demo02_client src/demo02_client.cpp)

## Add cmake target dependencies of the executable
## same as for the library above
add_dependencies(demo01_server ${PROJECT_NAME}_gencpp)
add_dependencies(demo02_client ${PROJECT_NAME}_gencpp)

## Specify libraries to link a library or executable target against
target_link_libraries(demo01_server
  ${catkin_LIBRARIES}
)
target_link_libraries(demo02_client
  ${catkin_LIBRARIES}
)

4.7执行

需要先启动服务:rosrun 包名 服务
然后再调用客户端 :rosrun 包名 客户端 参数1 参数2
结果:
在这里插入图片描述
注意:
如果先启动客户端，那么会导致运行失败
优化:
在客户端发送请求前添加:client.waitForExistence();
或:ros::service::waitForService(“AddInts”);
这是一个阻塞式函数，只有服务启动成功后才会继续执行
此处可以使用 launch 文件优化，但是需要注意 args 传参特点

五、服务通信自定义srv调用(python)

5.1需求

编写服务通信，客户端提交两个整数至服务端，服务端求和并响应结果到客户端。

5.2流程

分析:
在模型实现中，ROS master 不需要实现，而连接的建立也已经被封装了，需要关注的关键点有三个:
服务端
客户端
数据

流程:
编写服务端实现；
编写客户端实现；
为python文件添加可执行权限；
编辑配置文件；
编译并执行。

5.3vscode配置

需要像之前自定义 msg 实现一样配置settings.json 文件，如果以前已经配置且没有变更工作空间，可以忽略，如果需要配置，配置方式与之前相同:

{
    "python.autoComplete.extraPaths": [
        "/opt/ros/noetic/lib/python3/dist-packages",
    ]
}

5.4服务端代码

! /usr/bin/env python

import rospy
# from plumbing_server_client.srv import  AddInts,AddIntsRequest,AddIntsRespones
from plumbing_server_client.srv import *

"""
    服务端：解析客户端请求，产生响应
    1.导包
    2.初始化ros节点s
    3.创建服务端对象
    4.处理逻辑（回调函数）
    5spin()
"""

#参数：封装了请求数据
#返回值：响应数据
def doNum(request):
    #1.解析提交的两个整数
    num1=request.num1
    num2=request.num2
    #2.求和
    sum=num1+num2
    #3.将结果封装进响应
    response = AddIntsResponse()
    response.sum=sum

    rospy.loginfo("服务器解析数据num1= %d, num2= %d,响应的结果:sum= %d",num1,num2,sum)

    return response

if __name__ == "__main__":
    # 2.初始化ros节点
    rospy.init_node("heishui")
    # 3.创建服务端对象
    server = rospy.Service("addInts",AddInts,doNum)
    rospy.loginfo("服务器已经启动")
    # 4.处理逻辑（回调函数）
    # 5spin()
    rospy.spin()

5.5客户端代码

#! /usr/bin/env python

import rospy
# from plumbing_server_client.srv import  AddInts,AddIntsRequest,AddIntsRespones
from plumbing_server_client.srv import *
import sys

"""
    客户端：组织并提交请求，处理服务端响应
    1.导包
    2.初始化ros节点s
    3.创建客户端对象
    4.组织请求数据并发送请求
    5.处理响应
"""


if __name__ == "__main__":
    #判断参数长度
    if len(sys.argv)!=3:
        rospy.logerr("传入参数个数不对")
        sys.exit(1)

    # 2.初始化ros节点
    rospy.init_node("erhei")
    # 3.创建服务端对象
    client = rospy.ServiceProxy("addInts",AddInts)
    rospy.loginfo("客户端已经启动")
    # 4.组织请求数据并发送请求
    #固定数字
    # response=client.call(12,34)
    #捕捉传入的参数
    num1=int(sys.argv[1])
    num2=int(sys.argv[2])

    # 一般操作是先启动服务端，在启动客户端，否则报错
    # 可以先将客户端挂起。ros中内置了相关函数，这些函数可以让客户端启动后挂起，等待服务器启动
    # 调用判断服务器状态的函数
    # 函数1
    # client.wait_for_service()
    #函数2
    rospy.wait_for_service("addInts")

    response=client.call(num1,num2)
    #5.处理响应
    rospy.loginfo("响应的数据：%d",response.sum)

5.6设置权限

终端下进入 scripts 执行:chmod +x *.py

5.7配置 CMakeLists.txt

catkin_install_python(PROGRAMS
  scripts/AddInts_Server_p.py 
  scripts/AddInts_Client_p.py
  DESTINATION ${CATKIN_PACKAGE_BIN_DESTINATION}
)

5.8执行

需要先启动服务:rosrun 包名 服务
然后再调用客户端 :rosrun 包名 客户端 参数1 参数2

结果：
在这里插入图片描述
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

知识图谱相关概念整理

知识图谱相关概念整理

文章目录 1、概论2、什么是知识图谱&#xff1f;3、知识图谱构建3.1、构建知识图谱的生命周期3.2、Schema定义3.3、知识抽取3.4、知识融合3.5、知识存储3.6、知识推理 4、图谱建设的一些经验 1、概论 知识图谱&#xff08;KnowledgeGraph&#xff09;以结构化的形式描述客观世界…
阅读更多...
C# Winform DataGridView 控件和 DataTable

C# Winform DataGridView 控件和 DataTable

目录 一、概述 二、DataTable 的用法 1.创建表和列 2.添加行 3.取值和赋值 4.删除行 5.遍历 DataTable 6.判断 DataTable 列中是否存在某个值 7.设置主键 8.获取 DataRow 所在的行号 9.DataTable 转换为 List 10.将 List 转 DataTable 三、DataGridView 的用法 1…
阅读更多...
记录好项目D16

记录好项目D16

记录好项目 你好呀&#xff0c;这里是我专门记录一下从某些地方收集起来的项目&#xff0c;对项目修改&#xff0c;进行添砖加瓦&#xff0c;变成自己的闪亮项目。修修补补也可以成为毕设哦 本次的项目是个电影购票系统 一、系统介绍 前台 普通用户注册、登录、注销 用户…
阅读更多...
Redis哨兵——单机安装部署

Redis哨兵——单机安装部署

Redis哨兵——单机安装部署 目录 主从配置&#xff1a; 部署redis哨兵&#xff1a; 结 果 验 证&#xff1a; 主从配置&#xff1a; 1.安装epel源&#xff1a;yum install epel-release -y 2.安装软件&#xff1a;yum install redis -y 3.新建文件夹便于验证&#xff1a;m…
阅读更多...
DAY31：回溯算法（六）：子集+子集Ⅱ+递增子序列（经典子集问题）

DAY31：回溯算法（六）：子集+子集Ⅱ+递增子序列（经典子集问题）

78.子集 给你一个整数数组 nums &#xff0c;数组中的元素 互不相同 。返回该数组所有可能的子集&#xff08;幂集&#xff09;。 解集 不能 包含重复的子集。你可以按 任意顺序 返回解集。 示例1&#xff1a; 输入&#xff1a;nums [1,2,3] 输出&#xff1a;[[],[1],[2],…
阅读更多...
Label，RC，HPA

Label，RC，HPA

上面简单说了一下 pod 的基本知识点&#xff0c;待到后面会使用到 pod 的一些高阶知识点的时候&#xff0c;还可以再细细琢磨底层原理 我们接着继续学习 Lable &#xff0c; RC&#xff0c;HPA 的相关知识点 Label 是什么&#xff1f; label 就是标签&#xff0c;例如之前我们…
阅读更多...
Redis进阶 - Redis哨兵

Redis进阶 - Redis哨兵

原文首更地址&#xff0c;阅读效果更佳&#xff01; Redis进阶 - Redis哨兵 | CoderMast编程桅杆https://www.codermast.com/database/redis/redis-advance-sentinel.html 思考 slave 节点宕机恢复以后可以找 master 节点同步数据&#xff0c;那么 master 节点宕机怎么办&am…
阅读更多...
Vue事件捕获和事件冒泡

Vue事件捕获和事件冒泡

什么是事件&#xff1f; 当一个HTML元素产生一个事件时 该事件会在元素节点与根节点之间的路径传播&#xff0c; 路径所经过的节点都会收到该事件&#xff0c;这个传播的过程叫做DOM事件流 什么是事件捕获&#xff1f;(网景) 事件捕获&#xff1a;事件捕获会从document开始触…
阅读更多...
神经网络如何入门？

神经网络如何入门？

推荐《Python神经网络编程》这本入门书。豆瓣评分9.2。 如果你可以进行加、减、乘、除运算&#xff0c;那么你就可以制作自己的神经网络。我们使用的最困难运算是梯度演算&#xff08;gradient calculus&#xff09;&#xff0c;但是&#xff0c;我们会对这一概念加以说明&…
阅读更多...
基于Java+Springboot+Vue的校园爱心捐赠互助管理系统设计和实现

基于Java+Springboot+Vue的校园爱心捐赠互助管理系统设计和实现

博主介绍&#xff1a;擅长Java、微信小程序、Python、Android等&#xff0c;专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;&#x1f3fb; 不然下次找不到哟 Java项目精品实战案例…
阅读更多...
Android Studio 找不到 uploadArchives 入口

Android Studio 找不到 uploadArchives 入口

在4.2之前版本的 Android Studio 中想要module 打包arr&#xff0c;上传Maven 我们只需要 在对应module的build.gradle文件顶部添加 apply plugin: maven然后每一次修改记得要修改版本号&#xff0c;相同版本号提交失败&#xff0c;是不会覆盖的 defaultConfig {......versi…
阅读更多...
GitLab+Jenkins实现持续集成自动化测试

GitLab+Jenkins实现持续集成自动化测试

一、Jenkins和GitLab互相关联 1、在Jenkins设置gitlab的认证。 1)复制gitlab->clone with HTTP 的URL 如果你想学习接口自动化测试&#xff0c;我这边给你推荐一套视频&#xff0c;这个视频可以说是B站播放全网第一的接口自动化测试教程&#xff0c;同时在线人数到达1000人…
阅读更多...
Python3.7源码编译

Python3.7源码编译

1.下载Python3.7.0源码 git clone https://github.com/python/cpython.git git checkout v3.7.0wget https://www.python.org/ftp/python/3.7.0/Python-3.7.0.tar.xz源码目录结构如下所示&#xff1a; &#xff08;1&#xff09;Include目录&#xff1a;包含Python提供的所有…
阅读更多...
反射来命令执行存在的一些问题

反射来命令执行存在的一些问题

一.利用Runtime进行反射 java.lang.Runtime.getRuntime().exec("")若使用该paylaod&#xff0c;比如若依利用点如下&#xff1a; Object bean Class.forName(beanName).newInstance(); invokeMethod(bean, methodName, methodParams)想要通过Class.forName(beanNa…
阅读更多...
2023年软考成绩查询方式有变，成绩快出来了！

2023年软考成绩查询方式有变，成绩快出来了！

2023年软考成绩查询方式有变化&#xff0c;准考证不再作为成绩查询凭证使用。以前的成绩查询方式是考生可以凭准考证或者证件号查询&#xff0c;2023年则取消准考证方式&#xff0c;改为考生必须先登录自己的账号&#xff0c;再凭登录账户的注册证件号查询考试成绩。 那为什么…
阅读更多...
psd 2

psd 2

而 P X ( ω ) P_{X}(\omega) PX​(ω)则是随机信号在该&#xff08;角&#xff09;频率处平均具有的能量
阅读更多...
《论文阅读》DiaASQ：基于会话方面的情感四重分析的基准 ACL2023

《论文阅读》DiaASQ：基于会话方面的情感四重分析的基准 ACL2023

《论文阅读》DiaASQ : A Benchmark of Conversational Aspect-based Sentiment Quadruple Analysis 前言相关知识Aspect-based Sentiment Analysis简介数据集基线模型损失函数总结前言 你是否也对于理解论文存在困惑？ 你是否也像我之前搜索论文解读，得到只是中文翻译的解读…
阅读更多...
C++学习 运算符

C++学习 运算符

运算符 执行代码的运算。 种类 算数运算符 用于四则运算。 #include <iostream> using namespace std; int main() // 除了cout那行代码外&#xff0c;所有C程序都要写那些默认行 -endl进行换行 // 格式化代码 ctrlk ctrlf {int a 11;int b 3;int c 0;double d 9.17…
阅读更多...
绘制原型图xstar简介

绘制原型图xstar简介

文章目录 1. 文章引言2. xstar的安装3. xstar的元件库4. xstar的下载地址 1. 文章引言 最近在学习原型图&#xff0c;针对画原型图的工具&#xff0c;反复对比墨刀、Axure、xiaopiu后&#xff0c;最终选择了Axure。 同时也看到另一款&#xff0c;绘制原型图的工具&#xff0c;…
阅读更多...
自学网安学习心得/路线规划

自学网安学习心得/路线规划

趁着今天下班&#xff0c;我花了几个小时整理了下&#xff0c;非常不易&#xff0c;希望大家可以点赞收藏支持一波&#xff0c;谢谢。 我的经历&#xff1a; 我 19 年毕业&#xff0c;大学专业是物联网工程&#xff0c;我相信很多人在象牙塔里都很迷茫&#xff0c;到了大三大…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023