ROS机器人入门第四课:话题通信

文章目录

  • ROS机器人入门第四课:话题通信
    • 一、话题通信概述
      • (一)概念
      • (二)作用
    • 二、话题通信基本操作
      • 需求:
      • 分析:
      • 流程:
      • (一)发布方
        • 解释一些关键的ROS函数和概念:
      • (二)订阅方
      • 关键ROS函数和概念的解释:
      • (三)添加可执行权限
      • (四)配置 CMakeLists.txt
      • (五)执行
      • (六)ROS解耦合

ROS机器人入门第四课:话题通信

一、话题通信概述

话题通信是ROS中使用频率最高的一种通信模式,话题通信是基于发布订阅模式的,也即:一个节点发布消息,另一个节点订阅该消息。话题通信的应用场景也极其广泛,比如下面一个常见场景:

机器人在执行导航功能,使用的传感器是激光雷达,机器人会采集激光雷达感知到的信息并计算,然后生成运动控制信息驱动机器人底盘运动。

在上述场景中,就不止一次使用到了话题通信。

  • 以激光雷达信息的采集处理为例,在 ROS 中有一个节点需要时时的发布当前雷达采集到的数据,导航模块中也有节点会订阅并解析雷达数据。
  • 再以运动消息的发布为例,导航模块会根据传感器采集的数据时时的计算出运动控制信息并发布给底盘,底盘也可以有一个节点订阅运动信息并最终转换成控制电机的脉冲信号。

以此类推,像雷达、摄像头、GPS… 等等一些传感器数据的采集,也都是使用了话题通信,换言之,话题通信适用于不断更新的数据传输相关的应用场景。

(一)概念

以发布订阅的方式实现不同节点之间数据交互的通信模式。

(二)作用

用于不断更新的、少逻辑处理的数据传输场景。

二、话题通信基本操作

需求:

编写发布订阅实现,要求发布方以10HZ(每秒10次)的频率发布文本消息,订阅方订阅消息并将消息内容打印输出。

分析:

在模型实现中,ROS master 不需要实现,而连接的建立也已经被封装了,需要关注的关键点有三个:

  1. 发布方
  2. 接收方
  3. 数据(此处为普通文本)

流程:

  1. 编写发布方实现;
  2. 编写订阅方实现;
  3. 为python文件添加可执行权限;
  4. 编辑配置文件;
  5. 编译并执行。

(一)发布方

这段代码是一个使用ROS(Robot Operating System,机器人操作系统)的Python脚本示例,旨在创建一个名为talker_p的节点,该节点周期性地向名为chatter的话题发送包含字符串的消息。它是一个简单的发布者(Publisher)节点,演示了ROS中发布消息的基本模式。下面对代码进行详细注释,并解释其中使用的关键ROS函数。

#! /usr/bin/env python
# - coding: utf-8 -*-# 导入 rospy 库,rospy 是 ROS 在 Python 中的客户端库,用于使Python代码能与ROS通信。
import rospy
# 从 std_msgs 包中导入 String 消息类型,std_msgs 包含了许多标准的消息类型,String 是其中用于传输文本信息的一个类型。
from std_msgs.msg import String# 判断此脚本是直接被执行而不是被导入到其他文件中时,下面的代码块将被执行。
if __name__ == "__main__":# 初始化ROS节点,命名为 "talker_p"。# 每个ROS节点都必须有一个唯一的名称,这样其他节点就可以与之通信。rospy.init_node("talker_p")# 实例化发布者对象。# 这一步创建了一个发布者对象,它能够向名为 "chatter" 的话题发布 String 类型的消息。# queue_size 参数是发布队列的大小,用于限制未处理消息的数量,防止内存消耗过大。pub = rospy.Publisher("chatter", String, queue_size=10)# 创建一个 String 类型的消息对象。msg = String()# 准备消息的前缀文本。msg_front = "hello 你好"# 初始化计数器,用于生成消息序列。count = 0# 设置消息发布的频率,这里是每秒1次。rate = rospy.Rate(1)# 在 ROS 节点未被关闭的情况下循环。while not rospy.is_shutdown():# 拼接字符串,将前缀和计数器的值合成为最终的消息内容。msg.data = msg_front + str(count)# 发布消息到 "chatter" 话题。pub.publish(msg)# 根据之前设置的频率暂停,确保按照设定的频率发布消息。rate.sleep()# 将发布的消息内容记录到 ROS 日志信息中,便于调试和记录。rospy.loginfo("写出的数据:%s", msg.data)# 更新计数器,为下一条消息准备。count += 1
解释一些关键的ROS函数和概念:
  • rospy.init_node("talker_p"):该函数用于初始化一个ROS节点,这是启动任何ROS节点的第一步。这里的"talker_p"是节点的名称,它必须在ROS系统中唯一。

  • rospy.Publisher("chatter", String, queue_size=10):这个函数创建一个发布者对象,用于向特定的话题(这里是chatter)发布消息。String是消息类型,而queue_size参数用于控制发布者消息队列的大小,有助于处理网络延迟或处理速度慢时消息的积压问题。

  • rospy.Rate(1):这个函数创建一个Rate对象,用于控制循环的速率。这里设置为1Hz,意味着循环每秒运行一次。

  • rospy.is_shutdown():这是一个检查ROS节点是否收到了终止信号(如Ctrl+C)的函数。如果是,则返回True,循环将停止。

  • pub.publish(msg):通过之前创建的发布者对象pub调用publish方法来发布消息。msg是要发布的消息对象。

  • rate.sleep():这个方法使当前循环休眠足够的时间,以保持循环运行在设定的频率上。

  • rospy.loginfo():这个函数用于将信息记录到ROS日志里,类似于Python的print函数,但是它提供了更丰富的日志管理功能。


如若不写订阅方的代码想直接查看发布方的消息,可以使用如下命令:
rostopic echo 话题
在这里插入图片描述


(二)订阅方

这段代码展示了如何在ROS(Robot Operating System,机器人操作系统)中创建一个订阅者节点,监听并处理来自特定话题(chatter)的消息。下面对代码进行详细注释,并解释其中使用的关键ROS函数。

# 导入 rospy 库,rospy 是 ROS 在 Python 中的客户端库,允许Python代码与ROS通信。
import rospy
# 从 std_msgs 包中导入 String 消息类型,这是一个用于传输文本信息的标准消息类型。
from std_msgs.msg import String# 定义回调函数,这个函数将在节点收到新消息时被调用。
# msg 参数是收到的消息对象。
def doMsg(msg):# 在 ROS 日志中记录信息,这里记录的是收到的消息内容。rospy.loginfo("I heard:%s", msg.data)# 检查这个脚本是否是主程序,而不是被其他文件导入。
if __name__ == "__main__":# 初始化 ROS 节点,节点名为 "listener_p"。# 每个节点必须有一个唯一的名称,以便在 ROS 网络中被识别。rospy.init_node("listener_p")# 实例化订阅者对象。# 这一步创建了一个订阅者对象,它将监听名为 "chatter" 的话题,# 并且每当有新消息时,就会调用 doMsg 函数。# String 指定了话题消息的类型,queue_size 用于限制消息队列的大小。sub = rospy.Subscriber("chatter", String, doMsg, queue_size=10)# 进入循环,等待消息到来。# rospy.spin() 使得Python脚本保持运行状态,并在收到新消息时调用回调函数。# 它是一个阻塞调用,直到节点被明确地关闭或接收到终止信号(例如Ctrl+C)。rospy.spin()

关键ROS函数和概念的解释:

  • rospy.init_node("listener_p"):该函数用于初始化一个ROS节点。这是启动任何ROS节点的必要步骤。这里的"listener_p"是节点的名称,它在ROS网络中必须是唯一的。

  • rospy.Subscriber("chatter", String, doMsg, queue_size=10):这个函数创建了一个订阅者对象,用于订阅特定的话题(这里是chatter)并指定当收到新消息时所调用的回调函数(这里是doMsg)。String参数指定了订阅的消息类型,而queue_size参数用于控制消息队列的大小,有助于处理网络延迟或处理速度慢时消息的积压问题。

  • doMsg(msg):这是一个用户定义的回调函数,每当订阅的话题有新的消息时,这个函数就会被调用。msg参数是收到的消息对象。在这个函数内部,使用rospy.loginfo来记录消息内容。

  • rospy.spin():这个函数会让节点进入等待循环,等待并处理回调函数。它是一个阻塞(blocking)调用,意味着除非节点被关闭,否则程序将停在这里。这是订阅者节点保持激活并响应话题消息的常用方法。

  • rospy.loginfo():这个函数用于在ROS日志中记录信息,对于调试和跟踪节点行为非常有用。


注意: 二者需要设置相同的话题

比如上面的发布方和订阅方都订阅了相同的话题:chatter


(三)添加可执行权限

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

在这里插入图片描述

(四)配置 CMakeLists.txt

catkin_install_python(PROGRAMSscripts/talker_p.pyscripts/listener_p.pyDESTINATION ${CATKIN_PACKAGE_BIN_DESTINATION}
)

在这里插入图片描述

(五)执行

  1. 启动 roscore;

  2. 启动发布节点;

  • 先启动命令行source ./devel/setup.bash
  • 再启动命令行rosrun 包名 自定义文件名.py
  1. 启动订阅节点。
  • 先启动命令行source ./devel/setup.bash
  • 再启动命令行rosrun 包名 自定义文件名.py

在这里插入图片描述
运行结果如图所示:

在这里插入图片描述


因为发布方是软起动,需要先在master里注册,注册过程中可能就已经把消息发出去了,即使先打开订阅方,再打开发布方也一样会丢失数据,所以我们可以先确保发布方注册完,再发送信息

即在发布方的代码中设置一个休眠函数rospy.sleep(3),我这里是休眠3秒再发送数据

在这里插入图片描述


注意:可以使用 rqt_graph 查看节点关系。

在这里插入图片描述

(六)ROS解耦合

即便你使用不同的语言编写的节点,那么他们之间也是可以实现数据交换

在话题通信中,只要话题一致,C++和python写的代码就可以相互通信

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

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

相关文章

久菜盒子|医学大数据|R|常用安装包及介绍

复习下: library(tibble) library(readxl) library(survival) library(survminer) library(rms) library(forestplot) library(magrittr) library(corrplot) library(car) require(stringdist) library(timeROC) library(tidyverse) library(dplyr) library(tidyr)…

RESTful API 名词解释:查询参数、请求体参数、响应参数、内容类型(Content-Type)、表单

查询参数 RESTful API 设计中的查询参数 在 RESTful API 设计中,查询参数是什么意思? 在RESTful API设计中,查询参数是指当客户端发起GET请求以获取资源时附加在URL末尾的一部分,用来进一步筛选或定制返回资源的内容。查询参数通…

QT+Opencv+yolov5实现监测

功能说明:使用QTOpencvyolov5实现监测 仓库链接:https://gitee.com/wangyoujie11/qt_yolov5.git git本仓库到本地 一、环境配置 1.opencv配置 将OpenCV-MinGW-Build-OpenCV-4.5.2-x64文件夹放在自己的一个目录下,如我的路径: …

Android密钥库(AndroidKeyStore)使用

一、KeyStore描述 在 Android 开发中,KeyStore 是一个用于存储密钥和证书的安全容器。它提供了一种安全的方式来存储敏感信息,如密钥对、数字证书等,以防止它们被未授权的应用或攻击者访问。 KeyStore 通常用于加密数据、数字签名、TLS/SSL…

Spark SQL— Catalyst 优化器

Spark SQL— Catalyst 优化器 1. 目的 本文的目标是描述Spark SQL 优化框架以及它如何允许开发人员用很少的代码行表达复杂的查询转换。我们还将描述Spark SQL如何通过大幅提高其查询优化能力来提高查询的执行时间。在本教程中,我们还将介绍什么是优化、为什么使用…

蓝桥杯练习系统(算法训练)ALGO-967 共线

资源限制 内存限制:256.0MB C/C时间限制:1.0s Java时间限制:3.0s Python时间限制:5.0s 问题描述 给定2维平面上n个整点的坐标,一条直线最多能过几个点? 输入格式 第一行一个整数n表示点的个数   …

【Django】枚举类型数据

模型 在模型里主要增加两项内容: 枚举表字段增加choices class Snort(CoreModel):PAGE_TYPE_CHOICES [(1, 失陷主机检测), # 1是保存到数据库里的数据,失陷主机检测是显示在前端的(2, 远程漏洞攻击检测),(3, 可疑流量行为),(4, WEB检测),]page_type…

STM32 使用gcc编译介绍

文章目录 前言1. keil5下的默认编译工具链用的是哪个2. Arm编译工具链和GCC编译工具链有什么区别吗?3. Gcc交叉编译工具链的命名规范4. 怎么下载gcc-arm编译工具链参考资料 前言 我们在STM32上进行开发时,一般都是基于Keil5进行编译下载,Kei…

React中的受控组件与非受控组件

受控组件与非受控组件 受控组件 组件(input, select)的状态与state的值绑定&#xff0c;组件的状态全程响应外部数据 class TestComponent extends React.Component {constructor (props) {super(props);this.state { username: lindaidai };}render () {return <input …

区块链安全之DDoS防护的重要性及其实施策略

随着区块链技术的不断发展和广泛应用&#xff0c;其安全问题也日益凸显。其中&#xff0c;分布式拒绝服务(DDoS)攻击是对区块链网络稳定性和效率构成潜在威胁的重要因素之一。本文旨在深入探讨区块链为何需要采取DDoS高防措施&#xff0c;并提出相应的防护策略。 一、区块链面…

博客系统——3、数据库表设计 - 博客标签表

任务描述 本关任务&#xff1a;在博客数据库中建立博客标签表。 相关知识 多对多关系的建立 每一个博客都可以设置很多个标签&#xff0c;比如一篇讲JavaWeb知识的博客&#xff0c;就可能会涉及到多个标签如&#xff1a;前端、后端、Java、SpringMVC等标签&#xff0c;而一…

碳课堂|什么是碳资产?企业如何进行碳资产管理?

碳资产是绿色资产的重要类别&#xff0c;在全球气候变化日益严峻的背景下备受关注。在“双碳”目标下&#xff0c;碳资产管理是企业层面实现碳减排目标和低碳转型的关键。 一、什么是碳资产&#xff1f; 碳资产是以碳减排为基础的资产&#xff0c;是企业为了积极应对气候变化&…

Kubernetes示例yaml:1. service-deployment.yaml

service-deployment.yaml 示例 apiVersion: apps/v1 kind: Deployment metadata:name: example-plusnamespace: aaaalabels:app: example-prdapp_unit: AAAA-EXAMPLE spec:replicas: 2selector:matchLabels:app: example-prdtemplate:metadata:labels:app: example-prdapp_uni…

js相关的dom方法

查找元素 //获取元素id为box的元素 document.getElementById(box) //获取元素类名为box的元素 document.getElementsByClassName(box) //获取标签名为div的元素 document.getElementsByTagName(div)改变元素 //设置id为box的元素内容 document.getElementById("box"…

常见位运算的总结

目录 一、基础位运算 二、给一个数n&#xff0c;确定它的二进制中的第x位是0还是1 三、将一个数n的二进制表示的第x位修改成1 四、将一个数n的二进制位表示的第x位修改成0 五、位图思想 六、提取一个数(n)二进制表示中最右侧的1(lowbit) 七、干掉一个数n的最右侧的1 八、…

1.5T数据惨遭Lockbit3.0窃取,亚信安全发布《勒索家族和勒索事件监控报告》

本周态势快速感知 本周全球共监测到勒索事件93起&#xff0c;近三周攻击数量呈现持平状态。 本周Lockbit3.0是影响最严重的勒索家族&#xff0c;Blacksuit和Ransomhub恶意家族紧随其后&#xff0c;从整体上看Lockbit3.0依旧是影响最严重的勒索家族&#xff0c;需要注意防范。 …

神经网络代码实现(用手写数字识别数据集实验)

目录 一、前言 二、神经网络架构 三、算法实现 1、导入包 2、实现类 3、训练函数 4、权重参数矩阵初始化 5、参数矩阵变换向量 6、向量变换权重参数矩阵 7、进行梯度下降 7.1、损失函数 7.1.1、前向传播 7.2、反向传播 8、预测函数 四、完整代码 五、手写数字识别 一、前言 …

LVS负载均衡(load balance)

一 LVS LVS&#xff1a;Linux Virtaul Server&#xff0c;该软件的功能是实现 LB&#xff08;load balance&#xff09; 二LVS 的三种工作模式 1.NAT 模式&#xff08;NAT&#xff09; LVS 服务器同时充当一台 NAT 网关&#xff0c;拥有公有 IP &#xff0c;同时负责将针对此…

数据结构——队列(C语言版)

前言&#xff1a; 在学习完数据结构顺序表和链表之后&#xff0c;其实我们就可以做很多事情了&#xff0c;后面的栈和队列&#xff0c;其实就是对前面的顺序表和链表的灵活运用&#xff0c;今天我们就来学习一下队列的原理和应用。 准备工作&#xff1a;本人习惯将文件放在test…

美国大选献金项目数据分析

需求 加载数据查看数据的基本信息指定数据截取&#xff0c;将如下字段的数据进行提取&#xff0c;其他数据舍弃 cand_nm &#xff1a;候选人姓名contbr_nm &#xff1a; 捐赠人姓名contbr_st &#xff1a;捐赠人所在州contbr_employer &#xff1a; 捐赠人所在公司contbr_occu…