[ROS 系列学习教程] ROS服务(Service)通信：从模型解析到实战进阶

1. ROS服务通信模型解析

第一次接触ROS服务通信时，我误以为它和话题通信差不多。直到在机器人项目中被坑了几次才发现，这完全是两种不同的通信机制。服务通信最核心的特点是请求-响应模型——就像你去餐厅点餐，服务员必须明确回应"菜品已下单"或"今日售罄"。

1.1 核心角色与通信流程

ROS服务通信涉及三个关键角色：

• Master：相当于餐厅的接待台，记录哪些服务可用
• Server：后厨团队，实际处理请求
• Client：顾客，发起服务请求

具体通信流程是这样的（以机器人控制为例）：

1. 服务端注册：就像餐厅开业时在美团上线，/move_robot_service服务会向ROS Master注册自己的位置（IP+端口）和服务菜单（srv格式）
2. 客户端查询：当导航节点需要移动机械臂时，它会询问Master："哪里有机械臂控制服务？"
3. 建立直连：Master把服务端的地址告诉客户端，之后它们就可以绕过Master直接通话
4. 请求响应：客户端发送目标坐标，服务端返回执行结果

# 典型服务定义示例（AddTwoInts.srv） int64 a # 请求参数 int64 b --- # 分隔线 int64 sum # 响应参数

1.2 与话题通信的关键差异

去年做物流机器人时，我曾混淆这两种通信方式，结果导致机械臂失控。这里总结下关键区别：

提示：当需要确保指令被立即处理时（比如紧急停止），一定要用服务通信。我在调试机械臂时曾因错用话题通信导致响应延迟，差点造成碰撞事故。

2. 从零实现Hello World服务

2.1 创建服务包

首先建立工作空间（如果已有可跳过）：

mkdir -p ~/service_ws/src cd ~/service_ws/src catkin_create_pkg service_demo roscpp rospy std_msgs

关键文件结构：

service_demo/ ├── srv/ # 存放服务定义文件 │ └── HelloWorld.srv ├── scripts/ # Python脚本 │ ├── server.py │ └── client.py └── src/ # C++源码 ├── server.cpp └── client.cpp

2.2 定义服务接口

在srv/HelloWorld.srv中定义：

string request # 客户端发送的请求内容 --- string response # 服务端返回的响应

修改CMakeLists.txt添加编译支持：

find_package(catkin REQUIRED COMPONENTS roscpp rospy std_msgs message_generation # 新增 ) add_service_files( FILES HelloWorld.srv ) generate_messages( DEPENDENCIES std_msgs )

2.3 C++实现

服务端src/server.cpp：

#include "ros/ros.h" #include "service_demo/HelloWorld.h" bool handleRequest(service_demo::HelloWorld::Request &req, service_demo::HelloWorld::Response &resp) { ROS_INFO("收到请求: %s", req.request.c_str()); resp.response = "你好，" + req.request; return true; } int main(int argc, char **argv) { ros::init(argc, argv, "hello_server"); ros::NodeHandle nh; ros::ServiceServer service = nh.advertiseService( "/hello_world", handleRequest); ROS_INFO("服务已启动"); ros::spin(); return 0; }

客户端src/client.cpp：

#include "ros/ros.h" #include "service_demo/HelloWorld.h" int main(int argc, char **argv) { ros::init(argc, argv, "hello_client"); if (argc != 2) { ROS_WARN("请传入请求参数"); return 1; } ros::NodeHandle nh; ros::ServiceClient client = nh.serviceClient<service_demo::HelloWorld>( "/hello_world"); service_demo::HelloWorld srv; srv.request.request = argv[1]; if (client.call(srv)) { ROS_INFO("收到响应: %s", srv.response.response.c_str()); } else { ROS_ERROR("服务调用失败"); return 1; } return 0; }

2.4 Python实现

服务端scripts/server.py：

#!/usr/bin/env python import rospy from service_demo.srv import HelloWorld, HelloWorldResponse def handle_request(req): rospy.loginfo("收到请求: %s", req.request) return HelloWorldResponse("你好，" + req.request) if __name__ == "__main__": rospy.init_node('hello_server_py') service = rospy.Service('/hello_world_py', HelloWorld, handle_request) rospy.loginfo("Python服务已启动") rospy.spin()

客户端scripts/client.py：

#!/usr/bin/env python import sys import rospy from service_demo.srv import HelloWorld if __name__ == "__main__": rospy.init_node('hello_client_py') rospy.wait_for_service('/hello_world_py') try: hello_client = rospy.ServiceProxy('/hello_world_py', HelloWorld) resp = hello_client(sys.argv[1]) rospy.loginfo("收到响应: %s", resp.response) except rospy.ServiceException as e: rospy.logerr("服务调用失败: %s", e)

3. 机器人任务调度实战

3.1 场景设计

假设我们要控制一个仓储机器人执行以下任务流程：

1. 客户端发送任务指令（如"取货A03"）
2. 服务端协调底盘和机械臂完成：
   • 底盘移动到目标货架
   • 机械臂执行抓取
   • 返回最终状态

定义任务服务接口RobotTask.srv：

string task_id # 任务ID string destination # 目标位置 --- bool success # 执行结果 string message # 状态信息

3.2 服务端实现关键点

bool executeTask(robot_control::RobotTask::Request &req, robot_control::RobotTask::Response &resp) { // 1. 移动底盘 if(!moveBase(req.destination)) { resp.success = false; resp.message = "移动失败"; return true; } // 2. 控制机械臂 ArmResult arm_res = controlArm(req.task_id); if(!arm_res.success) { resp.success = false; resp.message = "抓取失败: " + arm_res.error_msg; return true; } // 3. 返回结果 resp.success = true; resp.message = "任务完成"; return true; }

3.3 客户端超时处理

实际项目中必须添加超时机制：

try: # 等待服务可用（超时5秒） rospy.wait_for_service('/robot_task', timeout=5) task_client = rospy.ServiceProxy('/robot_task', RobotTask) # 设置调用超时（3秒） resp = task_client("A03", timeout=rospy.Duration(3)) except rospy.ROSException as e: rospy.logerr("任务调度超时: %s", e)

4. 高级技巧与性能优化

4.1 服务复用模式

在机器人多模块协作时，可以采用服务复用策略：

// 在节点初始化时创建服务客户端 ros::ServiceClient arm_client = nh.serviceClient<ArmControl>( "/arm_control"); // 复用同一个客户端 void handleTask1(...) { arm_client.call(req1); } void handleTask2(...) { arm_client.call(req2); }

4.2 异步服务调用

Python中使用多线程实现非阻塞调用：

from threading import Thread def async_call(): try: resp = service_client(arg) print("收到响应:", resp) except Exception as e: print("调用失败:", e) Thread(target=async_call).start() print("主线程继续执行...")

4.3 性能监控技巧

通过rosservice工具分析服务状态：

# 查看服务响应时间 rosservice hz /robot_task # 检查服务连接 rosservice info /robot_task # 模拟调用测试 rosservice call /robot_task "A03"