ROS入门-9.订阅者Subscriber的编程实现

2023-05-16

还是通过海龟仿真器去发布数据,要实现一个订阅者来订阅海龟的位置信息等,publisher是海龟仿真器,subcriber即为这次我们要实现的程序
数据传输为从publisher传向subscriber
在这里插入图片描述
一.创建订阅者代码(C++)
在learning_topic里src里创建cpp文件,即c++代码文件
在这里插入图片描述

如何实现一个订阅者
1.初始化ROS节点;
2.订阅需要的话题;
3.循环等待话题消息,接收到消息后进入回调函数(*);
(注意:回调函数处理需要高效,不可以嵌套,不可以太长,防止卡住一个消息,而另一个消息进来仍然无法处理)
4.在回调函数中完成消息处理

/**
 * 该例程将订阅/turtle1/pose话题,话题的消息类型是turtlesim::Pose
 */
 
#include <ros/ros.h>
#include "turtlesim/Pose.h"//首先包含头文件

// 接收到订阅的消息后,会进入消息回调函数
//该函数的输入参数是针对的消息的指针;
//会发现这是在ros里面的固定格式调用,turtlesim::Pose是消息的结构,和/turtle1/pose话题里面发布的消息内容完全一样的,后面调用的是一个长指针msg,故msg进来之后会以一个长指针的形式指向turtlesim::Pose这个姿态信息的所有数据内容,下面可以通过对这个指针里面数据的调用得到这个海龟里面的位置信息(当然,该海龟的位置信息是由turtlesim仿真器发布来的);通过ROS_INFO的打印功能把海龟的位置信息给发布到终端里,我们就可以看到海龟的一个实时的坐标位置
void poseCallback(const turtlesim::Pose::ConstPtr& msg)
{
    // 将接收到的消息打印出来
    ROS_INFO("Turtle pose: x:%0.6f, y:%0.6f", msg->x, msg->y);
}

int main(int argc, char **argv)
{
    // 初始化ROS节点,名字为pose_subscriber;是进到所有节点首先要做的就是初始化
    ros::init(argc, argv, "pose_subscriber");

    // 创建节点句柄,来管理节点里的资源
    ros::NodeHandle n;

    // 创建一个Subscriber,订阅名为/turtle1/pose的topic,注册回调函数poseCallback
    //通过subscriber这样的一个类来创建一个对象pose_sub,该对象的初始化信息包括所要订阅的话题turtle1/pose;第二个参数是订阅的话题的队列长度(同样,要在模型的subscriber一端,没办法判断subscriber的处理能力,因此在这一端也要去创建一个缓冲区或者队列,该队列会不断保存从publisher一端传过来的数据,然后根据subscriber的处理能力依次处理,如果队列长度是10,一样是不断抛弃老的数据保持最新数据);第三个是回调函数,因为订阅者不知道发布者的消息何时进来,一旦有消息进来就需要立刻反映立刻处理,而时间并没有一个同步性,因此我们在这里通过回调函数机制,当订阅者一旦发现有数据进来就会调用该函数去处理
    ros::Subscriber pose_sub = n.subscribe("/turtle1/pose", 10, poseCallback);

    // 循环等待回调函数;spin是ros里一个循环等待的一个死循环,期间会不断查看队列是否有消息进来,有则调用回调函数处理;没有则不断死循环,故而正常情况下不会运行到return 0而一直在死循环
    ros::spin();

    return 0;
}

第二步.配置订阅者代码编译规则
在这里插入图片描述
主目录/工作区间catkin_ws/src/learning_topic/ CMakeLists.txt
打开CMakeLists.txt,在build内,install前内容,在上次添加两句话后继续添加下两句话
add_executable(pose_subscriber src/pose_subscriber.cpp)
target_link_libraries(pose_subscriber ${catkin_LIBRARIES})
在这里插入图片描述
第三步.编译并运行订阅者

cd ~/catkin_ws //回到工作空间根目录下
catkin_make //用该指令去做编译
source devel/setup.bash //设置环境变量,可通过下面方法减去该步骤,跳过
roscore
rosrun turtlesim turtlesim_node
rosrun learning_topic pose_subscriber //运行learning_topic里的一个节点,节点名为pose_subscriber,作用是实时显示海龟位置

回到工作空间, catkin_make编译
在这里插入图片描述
依次打开三个终端输入

roscore
rosrun turtlesim turtlesim_node
rosrun learning_topic pose_subscriber

可见不断在刷显示海龟的位置
在这里插入图片描述
启动键盘控制节点,让海归动起来,再次查看
在这里插入图片描述
对于python代码实现,首先将代码放与
主目录/catkin_ws/src/learning_topic/scripts/
在这里插入图片描述
同样查看权限✔
右击python文件/属性/权限/√允许作为程序执行文件点成
在这里插入图片描述
python文件代码

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# 该例程将订阅/turtle1/pose话题,消息类型turtlesim::Pose

import rospy
from turtlesim.msg import Pose

def poseCallback(msg):  #回调函数显示x,y坐标
    rospy.loginfo("Turtle pose: x:%0.6f, y:%0.6f", msg.x, msg.y)

def pose_subscriber():
	# ROS节点初始化
    rospy.init_node('pose_subscriber', anonymous=True)

	# 创建一个Subscriber,(确定话题名)订阅名为/turtle1/pose的topic,(确定话题的消息内容)Pose,(确定回调函数)注册回调函数poseCallback
    rospy.Subscriber("/turtle1/pose", Pose, poseCallback)

	# 循环等待回调函数   等待数据进入
    rospy.spin()

if __name__ == '__main__':    #main函数,从此处开始
    pose_subscriber()          #调用函数

运行程序rosrun learning_topic pose_subscriber.py

在这里插入图片描述

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

ROS入门-9.订阅者Subscriber的编程实现 的相关文章

  • 生产企业原材料订购与运输的研究-数据处理课程设计

    目录 摘要1 引言2 规划问题说明3 问题重述3 1 问题分析3 2 数据说明3 3 模型假设3 4 符号说明 4 实验及分析4 1 问题一模型的建立与求解4 2 问题二模型的建立与求解 5 总结5 1 模型的优点5 2 模型的缺点 参考文
  • 信号发生器-电路与电子技术课程设计

    目录 1 设计任务与要求1 1 设计任务1 2 设计要求 2 方案设计与论证2 1 方案设计2 2 论证 3 信号发生器设计与计算3 1 信号发生器设计3 2 方波振荡电路图3 3 三角波振荡电路图3 4 参数计算 4 总原理图及元器件清单
  • 增益可控放大电路-电路与电子技术课程设计

    目录 1 设计任务与要求1 1 设计任务1 2 设计要求 2 方案设计与论证2 1 方案设计2 2 论证 3 放大电路设计与计算3 1 放大电路设计3 2 电子开关切换电路设计3 3 六档控制电路3 4 参数计算 4 总原理图及元器件清单4
  • 超声波测距实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习超声波测距传感器的使用方法 xff0c 了解超声波测距传感器的原理和电路及实际应用 xff0c 了解超声波测距传感器的基本操作
  • 光敏传感器实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习光敏传感器的使用方法 xff0c 了解光敏传感器的基本实验原理和实际应用 xff0c 熟练掌握光敏传感器实验的操作步骤 xff
  • 红外反射传感器实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习红外反射传感器的使用方式 xff0c 了解红外反射传感器的实验原理和实际应用 xff0c 学习并理解Modbus数据格式所代表
  • 酒精传感器实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习酒精传感器MQ 3的使用方法 xff0c 了解酒精传感器的实验原理和实际应用 xff0c 了解酒精传感器的基本操作模式 xff
  • hdoj 1575 Tr A (矩阵快速幂)

    Tr A Time Limit 1000 1000 MS Java Others Memory Limit 32768 32768 K Java Others Total Submission s 4549 Accepted Submiss
  • MapReduce排序过程

    排序是MapReduce框架中最重要的操作之一 MapTask和ReduceTask均会对数据按照key 进行排序 该操作属于Hadoop 的默认行为 xff0c 任何应用程序中的数据均会被排序 xff0c 而不管逻辑上是否需要 默认排序是
  • 温湿度传感器实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习温湿度传感器的使用方法 xff0c 了解温湿度传感器的基本实验原理和实际应用 xff0c 熟练掌握温湿度传感器的基本步骤 xf
  • 烟雾检测传感器实验-传感器原理及应用实验

    目录 一 实验实训主要内容二 实验实训方法 过程步骤三 实验实训结果与分析四 讨论小结 一 实验实训主要内容 学习烟雾检测传感器的原理及检测方式 xff0c 了解烟雾检测传感器的实验原理和技术指标 xff0c 熟练掌握烟雾检测传感器的工作步
  • 4:Servlet-Java Web

    目录 4 1 Servlet简介4 2 HTTP协议4 3 Servlet与JSP4 4 Servlet处理的基本流程4 5 Servlet 容器4 6 Servlet程序实现 4 1 Servlet简介 Servlet是用Java语言编写
  • 5:Servlet程序-Java Web

    目录 5 1 Servlet要求5 2 创建Servlet5 3 第一个Servlet5 4 Servlet编译5 5 Servlet配置 5 1 Servlet要求 如果要开发一个可以处理HTTP请求的Servlet程序 xff0c 首先
  • 6:部署Servlet-Java Web

    目录 6 1 部署Servlet6 2 请求Servlet6 3 找不到servlet包6 4 Servlet映射的细节 6 1 部署Servlet 部署就是把Servlet的字节码文件放在适当的地方 为了在浏览器上访问Servlet xf
  • 7:Servlet表单-Java Web

    目录 7 1 Servlet响应7 2 Servlet获取客户端参数7 3 Servlet接受表单数据 7 1 Servlet响应 通过response对象对用户进行响应 创建输出流对象 PrintWriter out 61 respons
  • 8:Servlet生命周期-Java Web

    目录 8 1 Servlet生命周期8 2 Servlet生命周期对应的方法8 3 Servlet的多线程机制 8 1 Servlet生命周期 Servlet程序是运行在服务器端的一段Java程序 xff0c 其生命周期将受到Web容器的控
  • 9:中文乱码处理-Java Web

    目录 9 1 常见字符集9 2 乱码原因9 3 解决乱码 9 1 常见字符集 ASCII 最原始的一套编码 xff0c 所有编码都是由一个字节的二进制数对应 xff0c 尽管包含8位 xff0c 但是第一位始终是0 xff0c 也就是128
  • 华为云平台零代码搭建物联网可视化大屏体验:疫情防控数据大屏

    目录 一 介绍二 准备三 搭建1 创建疫情防控大屏应用2 组件放置3 组件配置4 应用打包 一 介绍 零代码搭建物联网可视化大屏 xff1a 自定义物联网场景 xff0c 根据个人理解实现基于华为云IoT以及可视化大屏DLV搭建物联网大屏
  • 华为开源自研AI框架昇思MindSpore入门体验:手写数字识别

    目录 一 环境安装1 进入MindSpore官网2 选择安装版本3 确保为Windows系统4 安装MindSpore5 验证安装6 安装依赖 二 模型训练1 下载并处理数据集2 创建模型 本教程是在CPU Ubuntu上安装MindSpo
  • 转型“系统集成商+大数据运营和服务商”,航天信息看好你哟

    毫无疑问 xff0c 人工智能今天已经是一个 风口 抓住这一契机 xff0c 迎风起舞 xff0c 可能是所有厂商的想法 但是每一个新的趋势出现时 xff0c 一定是机遇与挑战并存 对于厂商来说 xff0c 是处变不惊 xff0c 还是急速

随机推荐