Fast DDS (2)

1、结构:

Fast DDS的架构如下图所示,可以看到以下不同环境的层模型:

  • 应用层:利用Fast DDS API 在分布式系统中实现通信的用户应用程序。
  • Fast DDS层:DDS 通信中间件的稳健实现。它允许部署一个或多个 DDS 域,其中同一域内的 DomainParticipants 通过在域主题下发布/订阅来交换消息。
  • RTPS层:实施实时发布-订阅 (RTPS) 协议 ,以实现与 DDS 应用程序的互操作性。该层充当传输层的抽象层。
  • 传输层:快速 DDS可用于各种传输协议,例如不可靠传输协议 (UDP)、可靠传输协议 (TCP) 或共享内存传输协议 (SHM)。
    在这里插入图片描述

2、DDS层:

Fast DDS的 DDS 层定义了通信的几个关键元素。用户将在其应用程序中创建这些元素,从而合并 DDS 应用程序元素并创建以数据为中心的通信系统。 Fast DDS遵循DDS规范,将这些涉及通信的元素定义为实体。DDS实体是支持服务质量配置 (QoS) 并实现侦听器的任何对象。

  • QoS:定义每个实体的行为的机制。
  • Listener:向实体通知应用程序执行期间可能发生的事件的机制。

下面列出了 DDS 实体及其描述和功能:

  • Domain:标识 DDS 域的正整数。每个DomainParticipant都会有一个分配的DDS域,以便同一域中的DomainParticipant可以通信,并隔离DDS域之间的通信。该值必须由应用程序开发人员在创建 DomainParticipants 时给出。
  • DomainParticipant:包含其他 DDS 实体(例如发布者、订阅者、主题和多主题)的对象。它是允许创建其包含的先前实体以及配置其行为的实体。
  • Publisher:发布者使用 DataWriter 发布主题下的数据,DataWriter 将数据写入传输。它是创建和配置其包含的 DataWriter 实体的实体,并且可能包含其中一个或多个。
  • DataWriter:它是负责发布消息的实体。用户在创建该实体时必须提供一个主题,该主题将作为发布数据的主题。发布是通过将数据对象写入 DataWriterHistory 中的更改来完成的。
  • DataWriterHistory:这是数据对象更改的列表。当 DataWriter 继续在特定主题下发布数据时,它实际上会在此数据中创建更改。正是这种变化被记录在历史中。然后,这些更改将发送到订阅该特定主题的 DataReader。
  • Subscriber:订阅者使用 DataReader 订阅主题,DataReader 从传输中读取数据。它是创建和配置其包含的 DataReader 实体的实体,并且可能包含一个或多个 DataReader 实体。
  • DataReader:它是订阅主​​题以接收出版物的实体。用户在创建该实体时必须提供订阅Topic。DataReader 接收其 HistoryDataReader 中发生更改的消息。
  • DataReaderHistory:它包含DataReader 由于订阅某个主题而收到的数据对象的更改。
  • Topic:将发布者的 DataWriter 与订阅者的 DataReader 绑定的实体。

3、RTPS层:

如上所述,Fast DDS中的 RTPS 协议允许从传输层抽象 DDS 应用实体。根据上图,RTPS 层有四个主要Entities。

  • RTPSDomain:它是DDS域对RTPS协议的扩展。
  • RTPSParticipant:包含其他 RTPS 实体的实体。它允许配置和创建它包含的实体。
  • RTPSWriter:消息的来源。它读取 DataWriterHistory 中写入的更改,并将它们传输到之前匹配的所有 RTPSReader。
  • RTPSReader:消息的接收实体。它将 RTPSWriter 报告的更改写入 DataReaderHistory 中。

4、传输层:

Fast DDS支持通过各种传输协议实施应用程序。它们是 UDPv4、UDPv6、TCPv4、TCPv6 和共享内存传输 (SHM)。默认情况下,DomainParticipant 实现 UDPv4 和 SHM 传输协议。

5、并发和多线程:

Fast DDS实现了并发多线程系统。每个 DomainParticipant 都会生成一组线程来处理后台任务,例如日志记录、消息接收和异步通信。这不会影响您使用该库的方式,即Fast DDS API 是线程安全的,因此您可以无所畏惧地从不同线程调用同一 DomainParticipant 上的任何方法。但是,当外部函数访问由库内部运行的线程修改的资源时,必须考虑这种多线程实现。一个示例是实体侦听器回调中修改的资源。
Fast DDS 生成的完整线程集如下所示。仅当使用适当的传输时才会创建与传输相关的线程(标记为 UDP、TCP 和 SHM 类型)。

NameTypeCardinalityDescription
EventGeneral每个域参与者一个处理周期性和触发时间事件
Discovery Server EventGeneral每个域参与者一个同步对 Discovery Server数据库的访问
Asynchronous WriterGeneral每个启用的异步流量控制器一个最少 1。管理异步写入。即使对于同步写入器,某些形式的通信也必须在后台启动。
Datasharing ListenerGeneral每个数据读取器一个处理通过数据共享接收到的消息的侦听器线程
ReceptionUDP每个端口一个处理传入UDP 消息的侦听器线程
ReceptionTCP每个端口一个处理传入TCP 消息的侦听器线程
Keep AliveTCP每个端口一个保持 TCP 连接的活动线程。
ReceptionSHM每个端口一个通过 SHM 段处理传入消息的侦听器线程
LoggingSHM每个 SHM 描述符一个将传输的数据包存储并转储到文件中。
WatchdogSHM监视打开的共享内存段的运行状况。
General LoggingLog累积并写入适当的消费者日志条目。
Security LoggingLog每个域参与者一个累积并写入安全日志条目。
WatchdogFilewatch跟踪监视文件的修改状态
CallbackFilewatch当监视的文件更改时运行注册的回调

其中一些线程仅在满足某些条件时才会产生:

  • 仅当使用数据共享时才会创建数据共享侦听器线程。
  • 仅当 DomainParticipant 配置为 Discovery Server SERVER 时,才会创建 Discovery Server 事件线程。
  • TCP 保活线程要求保活周期配置为大于零的值。
  • 安全日志记录和共享内存数据包日志记录线程都需要启用某些配置选项。
  • 仅当使用FASTDDS_ENVIRONMENT_FILE时才会生成文件监视线程。

关于传输线程,Fast DDS 默认使用 UDP 和共享内存传输。可以配置端口配置以满足部署的特定需求,但默认配置是始终使用元流量端口和单播用户流量端口。这适用于 UDP 和共享内存,因为 TCP 不支持多播。

6、发现协议:

发现协议定义了在给定主题下发布的 DataWriter 和订阅同一主题的 DataReader 进行匹配的机制,以便它们可以开始共享数据。这适用于沟通过程中的任何时刻。 Fast DDS提供以下发现机制:

  • 简单的发现:这是默认的发现机制,在RTPS 标准中定义 ,并提供与其他 DDS 实现的兼容性。这里,DomainParticipants 在早期阶段被单独发现,以便随后匹配它们实现的 DataWriter 和 DataReader。
  • 发现服务器:这种发现机制使用集中式发现架构,其中服务器充当元流量发现的中心。
  • 静态发现:这实现了 DomainParticipant 之间的发现,但如果远程 DomainParticipant 事先知道这些实体,则可以跳过每个 DomainParticipant (DataReader/DataWriter) 中包含的实体的发现。
  • 手动发现:该机制仅与RTPS层兼容。它允许用户使用其选择的任何外部元信息通道手动匹配和取消匹配 RTPSParticipants、RTPSWriters 和 RTPSReaders。

7、安全:

Fast DDS可配置为通过在三个级别实现可插拔安全性来提供安全通信:

  • 远程域参与者的身份验证:DDS :Auth:PKI-DH插件使用受信任的证书颁发机构 (CA) 和 ECDSA 数字签名算法提供身份验证来执行相互身份验证。它还使用椭圆曲线 Diffie-Hellman (ECDH) 密钥协商协议建立共享密钥。
  • 实体的访问控制:DDS :Access:Permissions插件在 DDS 域和主题级别提供对 DomainParticipants 的访问控制。
  • 数据加密:DDS :Crypto:AES-GCM-GMAC插件使用伽罗瓦计数器模式 (AES-GCM) 中的高级加密标准 (AES) 提供经过身份验证的加密。

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

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

相关文章

leetcode303. 区域和检索 - 数组不可变(java)

前缀和数组的应用 区域和检索 - 数组不可变题目描述前缀和数组代码演示 区域和检索 - 数组不可变 难度 - 简单 原题链接 - 区域和检索 - 数组不可变 题目描述 给定一个整数数组 nums,处理以下类型的多个查询: 计算索引 left 和 right (包含 left 和 righ…

Python支持下最新Noah-MP陆面模式站点、区域模拟及可视化分析技术教程

详情点击公众号链接:Python支持下最新Noah-MP陆面模式站点、区域模拟及可视化分析技术教程 Noah-MP 5.0模型&模型所需环境的搭建 陆面过程的主要研究内容(陆表能量平衡、水循环、碳循环等),陆面过程研究的重要性。 图 1 陆面…

MySQL语法及常用数据类型

一、SQL语言概述 对数据库进行查询和修改操作的语言叫做SQL。SQL的含义就是结构化查询语言(Structured Query Language)。SQL包含以下4个部分: 1、数据定义语言(DDL):DROP、CREATE、ALTER等语句&#xff…

jenkins 日志输出显示时间戳的方式

网上很多方式比较片面,最新版插件直接使用即可无需更多操作。 使用方式如下: 1.安装插件 Timestamper 2.更新全局设置 系统设置-找到 Timestamper 勾选 Enabled for all Pipeline builds 也可修改时间戳格式。 帮助信息中显示 When checked, timesta…

ARM--day5(C语言点灯实验、总线、串口通信信息、串口通讯协议)

函数分装实现点灯 gpio.c: #include "gpio.h" //函数功能:GPIO引脚初始化操作 //参数1:GPIO组号 //参数2:引脚编号 //参数3:初始化内容 void hal_gpio_init(volatile gpio_t*gpiox,unsigned int pin,gpio_init_t* ini…

rabbitmq的死信队列

目录 成为死信的条件 消息TTL过期 队列达到最大长度 消息被拒 延迟队列 延迟队列使用场景 消息设置 TTL 队列设置 TTL 两者区别 producer 将消息投递到 broker 或者直接到 queue 里了, consumer 从 queue 取出消息 进行消费,但某些时候由…

最新Win10离线安装.NET Framework 3.5的方法(附离线包2022/3/22)

win10系统安装软件时,可能需要.net framework3.5的运行环境,当我们安装某些软件的时候会提示“你的电脑上的应用需要使用以下Windows功能:.NET Framework 3.5(包括.NET 2.0和3.0)。如果系统默认的是4.0以上的版本,当软件需要.net framework3.…

LVS+Keepalived集群

keepalived Keepalived及其工作原理 Keepalived 是一个基于VRRP协议来实现的LVS服务高可用方案,可以解决静态路由出现的单点故障问题 在一个LVS服务集群中通常有主服务器(MASTER)和备份服务器(BACKUP)两种角色的服务…

提升管班小诀窍

在传统教育中,将考试结果告知家长一直是一项相对麻烦的任务。老师们不得不一个一个的打电话或发短信,耗费大量时间和精力。然而,现在有了易查分,老师们可以轻松地创建自己的成绩查询系统,大大简化了这项任务。 好消息&…

【STM32】高效开发工具CubeMonitor快速上手

工欲善其事必先利其器。拥有一个辅助测试工具,能极大提高开发项目的效率。STM32CubeMonitor系列工具能够实时读取和呈现其变量,从而在运行时帮助微调和诊断STM32应用,类似于一个简单的示波器。它是一款基于流程的图形化编程工具,类…

LeetCode--HOT100题(35)

目录 题目描述:23. 合并 K 个升序链表(困难)题目接口解题思路1代码解题思路2代码 PS: 题目描述:23. 合并 K 个升序链表(困难) 给你一个链表数组,每个链表都已经按升序排列。 请你将所有链表合…

视频汇聚/视频云存储/视频监控管理平台EasyCVR提升网络稳定小tips来啦!

安防视频监控/视频集中存储/云存储/磁盘阵列EasyCVR平台可拓展性强、视频能力灵活、部署轻快,可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等,以及支持厂家私有协议与SDK接入,包括海康Ehome、海大宇等设备的SDK等。平台既具备传统安…

HummingBird 基于 Go 开源超轻量级 IoT 物联网平台

蜂鸟(HummingBird) 是 Go 语言实现的超轻量级物联网开发平台,包含设备接入、产品管理、物模型、告警中心、规则引擎等丰富功能模块。系统采用GoLang编写,占用内存极低, 单物理机可实现百设备的连接。 在数据存储上&…

系统架构师---软件重用、基于架构的软件设计、软件模型

目录 软件重用 构件技术 基于架构的软件设计 ABSD方法与生命周期 抽象功能需求 用例 抽象的质量和业务需求 架构选项 质量场景 约束 基于架构的软件开发模型 架构需求 需求获取 标识构件 需求评审 架构设计 架构文档 架构复审 架构实现 架构演化 前言&…

Spring项目使用Redis限制用户登录失败的次数以及暂时锁定用户登录权限

文章目录 背景环境代码实现0. 项目结构图(供参考)1. 数据库中的表(供参考)2. 依赖(pom.xml)3. 配置文件(application.yml)4. 配置文件(application-dev.yml)5…

ChatGPT和Claude的能力全测评

创造性思维/语言 提示:“写一首 4 行诗,每行只有 3 个词,描写重庆” ChatGPT写诗👇 Claude写诗👇 仁者见仁,您怎么看谁更强? 提示: "如果你随机选择这个问题的答案,…

【高危】企业微信私有化2.5-2.6.93版本后台API未授权访问漏洞

漏洞描述 企业微信私有化2.5.x版本及2.6.930000版本以下后台中存在接口未授权访问漏洞,攻击者通过访问/cgi-bin/gateway/agentinfo接口可获得Secret,从而利用开放API获取企业通讯录等敏感信息及企业微信内应用权限。 漏洞名称企业微信私有化2.5-2.6.93…

Unity C# 引用池 ReferencePool

Unity C# 引用池 ReferencePool 1.目的 对于多次创建的数据使用new 关键字是十分消耗性能的,使用完成后由GC去自动释放,当一个类型的数据频繁创建可以使用引用池进行管理。 2.实现 项目目录 IReference 接口 要放入引用池的数据只需要继承这个接口…

如何提升城市空气质量?一招教会你

空气质量监控,作为保障人类健康和维护环境可持续的关键手段,在现代社会发挥着重要作用。通过实时监测、数据采集和分析,我们能够深入了解空气中各种污染物的浓度以及气象参数的变化,从而评估空气质量的状况。 空气质量监控通过科学…

开放网关架构演进

作者:庄文弘(弘智) 淘宝开放平台是阿里与外部生态互联互通的重要开放途径,通过开放的产品技术把阿里经济体一系列基础服务,像水、电、煤一样输送给我们的商家、开发者、社区媒体以及其他合作伙伴,推动行业的…