编写一个简单的发布者和订阅者 (C++)

背景

节点是通过 ROS 2进行通信的可执行进程。在本教程中，节点将通过主题以字符串消息的形式相互传递信息。这里使用的例子是一个简单的“说话者”和“倾听者”系统；一个节点发布数据，另一个节点订阅该主题，以便它可以接收该数据。

任务

1 创建包

打开一个新终端并获取 ROS 2 安装的源代码，以便ros2命令可以运行。

导航到上一教程ros2_ws中创建的目录。

回想一下，包应该在src目录中创建，而不是在工作区的根目录中。因此，导航到ros2_ws/src并运行包创建命令：

ros2 pkg create --build-type ament_cmake cpp_pubsub

cpp_pubsub您的终端将返回一条消息，验证您的包及其所有必需文件和文件夹的创建。

导航到ros2_ws/src/cpp_pubsub/src. 回想一下，这是任何 CMake 包中包含可执行文件的源文件所属的目录。

2 编写发布者节点

输入以下命令来下载示例 talker 代码：

Linux苹果系统视窗 
wget -O publisher_member_function.cpp https://raw.githubusercontent.com/ros2/examples/galactic/rclcpp/topics/minimal_publisher/member_function.cpp

现在将有一个名为 的新文件publisher_member_function.cpp。使用您喜欢的文本编辑器打开文件。

#include <chrono>
#include <functional>
#include <memory>
#include <string>#include "rclcpp/rclcpp.hpp"
#include "std_msgs/msg/string.hpp"using namespace std::chrono_literals;/* This example creates a subclass of Node and uses std::bind() to register a
* member function as a callback from the timer. */class MinimalPublisher : public rclcpp::Node
{public:MinimalPublisher(): Node("minimal_publisher"), count_(0){publisher_ = this->create_publisher<std_msgs::msg::String>("topic", 10);timer_ = this->create_wall_timer(500ms, std::bind(&MinimalPublisher::timer_callback, this));}private:void timer_callback(){auto message = std_msgs::msg::String();message.data = "Hello, world! " + std::to_string(count_++);RCLCPP_INFO(this->get_logger(), "Publishing: '%s'", message.data.c_str());publisher_->publish(message);}rclcpp::TimerBase::SharedPtr timer_;rclcpp::Publisher<std_msgs::msg::String>::SharedPtr publisher_;size_t count_;
};int main(int argc, char * argv[])
{rclcpp::init(argc, argv);rclcpp::spin(std::make_shared<MinimalPublisher>());rclcpp::shutdown();return 0;
}
2.1 检查代码

代码的顶部包含您将使用的标准 C++ 标头。标准 C++ 头文件之后是rclcpp/rclcpp.hpp包含文件，它允许您使用 ROS 2 系统最常见的部分。最后是std_msgs/msg/string.hpp，其中包括您将用于发布数据的内置消息类型。

这些线代表节点的依赖关系。回想一下，必须将依赖项添加到package.xml和CMakeLists.txt，您将在下一节中执行此操作。

#include <chrono>
#include <functional>
#include <memory>
#include <string>#include "rclcpp/rclcpp.hpp"
#include "std_msgs/msg/string.hpp"using namespace std::chrono_literals;

下一行MinimalPublisher通过继承创建节点类rclcpp::Node。代码中的每个都this指的是节点。

class MinimalPublisher : public rclcpp::Node

公共构造函数命名节点minimal_publisher并初始化count_为 0。在构造函数内，发布者使用String消息类型、主题名称topic以及备份时限制消息所需的队列大小进行初始化。接下来，timer_被初始化，这导致该timer_callback函数每秒执行两次。

public:MinimalPublisher(): Node("minimal_publisher"), count_(0){publisher_ = this->create_publisher<std_msgs::msg::String>("topic", 10);timer_ = this->create_wall_timer(500ms, std::bind(&MinimalPublisher::timer_callback, this));}

该timer_callback函数是设置消息数据和实际发布消息的地方。该RCLCPP_INFO宏确保每条发布的消息都打印到控制台。

private:void timer_callback(){auto message = std_msgs::msg::String();message.data = "Hello, world! " + std::to_string(count_++);RCLCPP_INFO(this->get_logger(), "Publishing: '%s'", message.data.c_str());publisher_->publish(message);}

最后是计时器、发布者和计数器字段的声明。

rclcpp::TimerBase::SharedPtr timer_;
rclcpp::Publisher<std_msgs::msg::String>::SharedPtr publisher_;
size_t count_;

类之后MinimalPublisher是main节点实际执行的地方。 rclcpp::init初始化 ROS 2，并rclcpp::spin开始处理来自节点的数据，包括来自计时器的回调。

int main(int argc, char * argv[])
{rclcpp::init(argc, argv);rclcpp::spin(std::make_shared<MinimalPublisher>());rclcpp::shutdown();return 0;
}
2.2 添加依赖

导航回到已为您创建和文件的ros2_ws/src/cpp_pubsub目录。CMakeLists.txtpackage.xml

package.xml使用文本编辑器打开。

如上一篇教程中所述，请务必填写<description>、<maintainer>和<license>标签：

<description>Examples of minimal publisher/subscriber using rclcpp</description>
<maintainer email="you@email.com">Your Name</maintainer>
<license>Apache License 2.0</license>

在 buildtool 依赖项后添加新行ament_cmake，并粘贴与节点的 include 语句相对应的以下依赖项：

<depend>rclcpp</depend>
<depend>std_msgs</depend>

这声明了包的需求rclcpp以及std_msgs其代码何时执行。

确保保存文件。

2.3 CMakeLists.txt

现在打开CMakeLists.txt文件。在现有依赖项下方，添加以下行：find_package(ament_cmake REQUIRED)

find_package(rclcpp REQUIRED)
find_package(std_msgs REQUIRED)

之后，添加可执行文件并命名它，talker以便您可以使用以下命令运行节点：ros2 run

add_executable(talker src/publisher_member_function.cpp)
ament_target_dependencies(talker rclcpp std_msgs)

最后，添加该install(TARGETS…)部分以便可以找到您的可执行文件：ros2 run

install(TARGETS
  talker
  DESTINATION lib/${PROJECT_NAME})

您可以通过删除一些不必要的部分和注释来清理您的CMakeLists.txt内容，因此它看起来像这样：

cmake_minimum_required(VERSION 3.5)
project(cpp_pubsub)# Default to C++14
if(NOT CMAKE_CXX_STANDARD)
  set(CMAKE_CXX_STANDARD 14)
endif()if(CMAKE_COMPILER_IS_GNUCXX OR CMAKE_CXX_COMPILER_ID MATCHES "Clang")
  add_compile_options(-Wall -Wextra -Wpedantic)
endif()find_package(ament_cmake REQUIRED)
find_package(rclcpp REQUIRED)
find_package(std_msgs REQUIRED)add_executable(talker src/publisher_member_function.cpp)
ament_target_dependencies(talker rclcpp std_msgs)install(TARGETS
  talker
  DESTINATION lib/${PROJECT_NAME})ament_package()

您现在可以构建包，获取本地安装文件并运行它，但我们首先创建订阅者节点，以便您可以看到完整的系统在工作。

3 写入订阅者节点

返回ros2_ws/src/cpp_pubsub/src创建下一个节点。在终端中输入以下代码：

Linux苹果系统视窗 
wget -O subscriber_member_function.cpp https://raw.githubusercontent.com/ros2/examples/galactic/rclcpp/topics/minimal_subscriber/member_function.cpp

ls现在在控制台输入将返回：

publisher_member_function.cpp  subscriber_member_function.cpp

subscriber_member_function.cpp使用文本编辑器打开。

#include <memory>#include "rclcpp/rclcpp.hpp"
#include "std_msgs/msg/string.hpp"
using std::placeholders::_1;class MinimalSubscriber : public rclcpp::Node
{public:MinimalSubscriber(): Node("minimal_subscriber"){subscription_ = this->create_subscription<std_msgs::msg::String>("topic", 10, std::bind(&MinimalSubscriber::topic_callback, this, _1));}private:void topic_callback(const std_msgs::msg::String & msg) const{RCLCPP_INFO(this->get_logger(), "I heard: '%s'", msg.data.c_str());}rclcpp::Subscription<std_msgs::msg::String>::SharedPtr subscription_;
};int main(int argc, char * argv[])
{rclcpp::init(argc, argv);rclcpp::spin(std::make_shared<MinimalSubscriber>());rclcpp::shutdown();return 0;
}
3.1 检查代码

订阅者节点的代码与发布者的代码几乎相同。现在节点已命名minimal_subscriber，构造函数使用节点的create_subscription类来执行回调。

没有计时器，因为订阅者只需在数据发布到topic主题时做出响应。

public:MinimalSubscriber(): Node("minimal_subscriber"){subscription_ = this->create_subscription<std_msgs::msg::String>("topic", 10, std::bind(&MinimalSubscriber::topic_callback, this, _1));}

回想一下主题教程，发布者和订阅者使用的主题名称和消息类型必须匹配才能允许他们进行通信。

该topic_callback函数接收通过主题发布的字符串消息数据，并使用宏将其简单地写入控制台RCLCPP_INFO。

该类中唯一的字段声明是订阅。

private:void topic_callback(const std_msgs::msg::String & msg) const{RCLCPP_INFO(this->get_logger(), "I heard: '%s'", msg.data.c_str());}rclcpp::Subscription<std_msgs::msg::String>::SharedPtr subscription_;

功能main完全相同，只是现在它旋转节点MinimalSubscriber。对于发布者节点来说，旋转意味着启动计时器，但对于订阅者来说，它只是意味着准备好接收消息。

由于该节点与发布者节点具有相同的依赖关系，因此无需添加任何新内容package.xml。

3.2 CMakeLists.txt

重新打开CMakeLists.txt并在发布者条目下方添加订阅者节点的可执行文件和目标。

add_executable(listener src/subscriber_member_function.cpp)
ament_target_dependencies(listener rclcpp std_msgs)install(TARGETStalkerlistenerDESTINATION lib/${PROJECT_NAME})

确保保存文件，然后您的发布/订阅系统就可以使用了。

4 构建并运行

您可能已经安装了rclcpp和std_msgs软件包作为 ROS 2 系统的一部分。在构建之前，最好rosdep在工作区的根目录 ( ros2_ws) 中运行以检查是否缺少依赖项：

Linux苹果系统视窗 
rosdep install -i --from-path src --rosdistro galactic -y

仍在工作区的根目录中ros2_ws，构建新包：

Linux苹果系统视窗 
colcon build --packages-select cpp_pubsub

打开一个新终端，导航到ros2_ws并获取安装文件：

Linux苹果系统视窗 
. install/setup.bash

现在运行 talker 节点：

ros2 run cpp_pubsub talker

终端应开始每 0.5 秒发布一次信息消息，如下所示：

[INFO] [minimal_publisher]: Publishing: "Hello World: 0"
[INFO] [minimal_publisher]: Publishing: "Hello World: 1"
[INFO] [minimal_publisher]: Publishing: "Hello World: 2"
[INFO] [minimal_publisher]: Publishing: "Hello World: 3"
[INFO] [minimal_publisher]: Publishing: "Hello World: 4"

打开另一个终端，再次从内部获取安装文件ros2_ws，然后启动侦听器节点：

ros2 run cpp_pubsub listener

侦听器将开始将消息打印到控制台，从发布者当时的消息计数开始，如下所示：

[INFO] [minimal_subscriber]: I heard: "Hello World: 10"
[INFO] [minimal_subscriber]: I heard: "Hello World: 11"
[INFO] [minimal_subscriber]: I heard: "Hello World: 12"
[INFO] [minimal_subscriber]: I heard: "Hello World: 13"
[INFO] [minimal_subscriber]: I heard: "Hello World: 14"

在每个终端中输入Ctrl+C以停止节点旋转。

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

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

相关文章

2019数据结构----单链表真题

2019数据结构----单链表真题

思路&#xff1a; (1)找到中间节点,将原链表一分为二 (2)后半段链表原地逆置 (3)合并链表 #include <stdio.h> #include <stdlib.h>//定义节点类型 typedef struct LNode {int data;//数据域struct LNode *next;//指针域 } LNode, *LinkList;void tailList(Link…
阅读更多...
阿里云公网带宽出网和入网是什么？上行和下行是什么？

阿里云公网带宽出网和入网是什么？上行和下行是什么？

什么是阿里云服务器ECS的入网带宽和出网带宽&#xff1f;以云服务器为中心&#xff0c;流入云服务器占用的带宽是入网带宽&#xff0c;流量从云服务器流出的带宽是出网带宽。阿里云服务器网aliyunfuwuqi.com分享入网带宽和出网带宽说明表&#xff1a; 带宽类别说明入网带宽&am…
阅读更多...
Java项目部署文档

Java项目部署文档

Linux安装jdk 默认安装到usr/lib/jvm目录下 yum安装 yum -y list java* # 查找全部jdk版本 yum install -y java-1.8.0-openjdk.x86_64 # 安装jdkapt安装 apt-cache search jdk # 查找全部jdk版本 apt-get install openjdk-8-jdk # 安…
阅读更多...
Rational rose 安装和使用 教程

Rational rose 安装和使用 教程

前言 win10和win11都可以用&#xff0c;亲测了win10 Unified Modeling Language (UML)又称统─建模语言或标准建模语言&#xff0c;是始于1997年一个OMG标准&#xff0c;它是一个支持模型化和软件系统开发的图形化语言&#xff0c;为软件开发的所有阶段提供模型化和可视化支持…
阅读更多...
Spark---RDD算子(单值类型转换算子)

Spark---RDD算子(单值类型转换算子)

文章目录 1.RDD算子介绍2.转换算子2.1 Value类型2.1.1 map2.1.2 mapPartitions2.1.3 mapPartitionsWithIndex2.1.4 flatMap2.1.5 glom2.1.6 groupBy2.1.7 filter2.1.8 sample2.1.9 distinct2.1.10 coalesce2.1.11 repartition2.1.12 sortBy 1.RDD算子介绍 RDD算子是用于对RDD进…
阅读更多...
15K star! 搭建个人PDF工具箱，和广告、泄密说拜拜

15K star! 搭建个人PDF工具箱，和广告、泄密说拜拜

我相信很多人都曾经遇到过这样的麻烦&#xff1a;一大堆PDF文档摆在面前要处理&#xff0c;拆分、标页码、调顺序、加签名。手忙脚乱的在网上找了几个工具&#xff0c;但是要么需要付费&#xff0c;要么各种广告还不好用&#xff0c;更容易出现隐私泄露的问题。 今天我们推荐的…
阅读更多...
轨迹合并 合并轨迹

轨迹合并 合并轨迹

搜索微信小程序 merge gpx
阅读更多...
Leetcode 2999. Count the Number of Powerful Integers

Leetcode 2999. Count the Number of Powerful Integers

Leetcode 2999. Count the Number of Powerful Integers 1. 解题思路2. 代码实现 题目链接&#xff1a;10034. Count the Number of Powerful Integers 1. 解题思路 这一题的话其实还是一个典型的求不大于 N N N的特殊数字个数的问题。 这道题本质上进行一下替换还是要求如…
阅读更多...
测试电脑的公网ip

测试电脑的公网ip

发现ip地址总是变化&#xff0c;想要了解变化规律 操作 反复关闭打开浏览器&#xff0c;查询ip地址&#xff0c;共查询了15次。出现了5种不同的地址&#xff0c;还好&#xff0c;不是无穷的。
阅读更多...
python 各级目录文件读取

python 各级目录文件读取

目录结构 import pytestdef test_01():# 同级文件with open(1.txt, r, encodingutf-8) as file:content file.read()print(content)def test_02():# 同级目录的下的文件with open(rupfile/2.txt, r, encodingutf-8) as file:content file.read()print(content)def test_03():…
阅读更多...
IDEA[Debug]简单说明

IDEA[Debug]简单说明

目录 &#x1f95e;1.打断点 &#x1f32d;2.第一组按钮 &#x1f9c2;3.第二组按钮 &#x1f953;4.参数查看 1.打断点 1.在需要断点处打上断点&#xff0c;然后点击debug运行 2.执行debug&#xff0c;直接执行到断点处 2.第一组按钮 共有8按钮&#xff0c;从左往右依…
阅读更多...
Invalid ToUnicode CMap in font HPDFA++MicrosoftYaHei

Invalid ToUnicode CMap in font HPDFA++MicrosoftYaHei

用pdfbox解析微信支付流水文件提示Invalid ToUnicode CMap in font遇到这个问题 Invalid ToUnicode CMap in font HPDFAMicrosoftYaHei使用最新版本的tabula即可 <dependency><groupId>technology.tabula</groupId><artifactId>tabula</artifactI…
阅读更多...
GCC中常用的内建函数

GCC中常用的内建函数

GCC&#xff08;GNU Compiler Collection&#xff09;是一个包含多个编程语言的编译器集合&#xff0c;而内建函数通常是为了提高代码性能或者实现一些特定功能而在编译器层面提供的函数。以下是一些在GCC中常用的内建函数&#xff1a; 数学函数&#xff1a; __builtin_sin(),…
阅读更多...
Linux实验——页面置换算法模拟

Linux实验——页面置换算法模拟

页面置换算法模拟 【实验目的】 &#xff08;1&#xff09;理解虚拟内存管理的原理和技术。 &#xff08;2&#xff09;掌握请求分页存储管理的思想。 &#xff08;3&#xff09;理解常用页面置换算法的思想。 【实验原理/实验基础知识】 存储器是计算机系统的重要资源之…
阅读更多...
java8新特性-日期类

java8新特性-日期类

在JDK 8之前&#xff0c;其实有不少的API都存在着一些问题&#xff0c;功能上也并不强大&#xff0c;日期时间等相关类同样如此。所以从JDK 8开始&#xff0c;Java做了较大的改动&#xff0c;出现了很多新特性。其中&#xff0c;java.time包中了就提供了不少强大的日期和时间AP…
阅读更多...
可怜的小猪

可怜的小猪

题目 有 buckets 桶液体&#xff0c;其中 正好有一桶 含有毒药&#xff0c;其余装的都是水。它们从外观看起来都一样。为了弄清楚哪只水桶含有毒药&#xff0c;你可以喂一些猪喝&#xff0c;通过观察猪是否会死进行判断。不幸的是&#xff0c;你只有 minutesToTest 分钟时间来…
阅读更多...
msvcp140.dll丢失的解决方法，从两个方向解决msvcp140.dll丢失

msvcp140.dll丢失的解决方法，从两个方向解决msvcp140.dll丢失

在Windows操作系统上&#xff0c;msvcp140.dll是Visual C Redistributable for Visual Studio 2015的一部分&#xff0c;如果msvcp140.dll文件丢失&#xff0c;可能在尝试启动使用C运行时库的程序时遇到错误&#xff0c;应用程序可能也会相应的无法打开&#xff0c;那么有什么m…
阅读更多...
「HDLBits题解」Vector1

「HDLBits题解」Vector1

本专栏的目的是分享可以通过HDLBits仿真的Verilog代码 以提供参考 各位可同时参考我的代码和官方题解代码 或许会有所收益 题目链接&#xff1a;Vector1 - HDLBits default_nettype none // Disable implicit nets. Reduces some types of bugs. module top_module( input…
阅读更多...
Qt/C++摄像头采集/二维码解析/同时采集多路/图片传输/分辨率帧率可调/自动重连

Qt/C++摄像头采集/二维码解析/同时采集多路/图片传输/分辨率帧率可调/自动重连

一、前言 本地摄像头的采集可以有多种方式&#xff0c;一般本地摄像头会通过USB的方式连接&#xff0c;在嵌入式上可能大部分是CMOS之类的软带的接口&#xff0c;这些都统称本地摄像头&#xff0c;和网络摄像头最大区别就是一个是通过网络来通信&#xff0c;一个是直接本地通信…
阅读更多...
浅谈顺序表基本操作

浅谈顺序表基本操作

&#x1f937;‍♀️&#x1f937;‍♀️&#x1f937;‍♀️ 今天给大家带来的是数据结构——顺序表的实现(增删查改)。 清风的CSDN博客主页 &#x1f389;欢迎&#x1f44d;点赞✍评论❤️收藏 &#x1f61b;&#x1f61b;&#x1f61b;希望我的文章能对你有所帮助&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023