DDS服务发现-北京尧图网络

DDS服务发现概述预制模块SPDPSEDPLiveness参考文档概述DDS的服务发现协议让网络中(同一个domain)的节点能够相互发现。有了服务发现机制各个应用能够快速发现远程的新加入的节点同时也能将自己告知其他节点。DDS服务发现分为两个部分Participant Discovery Protocol (PDP)PDP用于Participant 之间的相互发现Endpoint Discovery Protocol (EDP)EDP用于Endpoint一个reader或者writer都是一个Endpoint之间的相互发现根据DDS的规范各协议栈可以实现自己定义的PDP和EDP但是都必须实现Simple Participant Discovery Protocol (SPDP)和Simple Endpoint Discovery Protocol (SEDP)DDS的服务发现还分为静态服务发现和动态服务发现。其中静态服务发现只用SPDP而动态服务发现会用到SPDP和SEDP本文会结合fastdds官方用例HelloWorldExample和StaticHelloWorldExample的网络报包来进行说明网络包地址https://blog.csdn.net/ouyang035/article/details/147978578。wireshark过滤器((ip.src198.18.7.22 (ip.dst198.18.7.101||ip.dst239.255.0.1))|| (ip.src198.18.7.101 (ip.dst198.18.7.22||ip.dst239.255.0.1)))!ssh!tcp预制模块SPDP和SEDP主要是通过build-in endpoint和build-in topic来进行通信从而实现信息的交换完成相互发现。build-in endpointSPDPbuiltinParticipantWriterSPDPbuiltinParticipantReaderSEDPbuiltinPublicationsWriterSEDPbuiltinPublicationsReaderSEDPbuiltinSubscriptionWriterSEDPbuiltinSubscriptionReaderSEDPbuiltinTopicsWriter抓包中未出该消息SEDPbuiltinTopicsReader抓包中未出该消息BuiltinParticipantMessageReaderBuiltinParticipantMessageWriterbuild-in topic有四个预定义的TopicDCPSParticipantDCPSPublicationDCPSSubscriptionDCPSTopic抓包中未出该消息BuiltinParticipantMessageReader和BuiltinParticipantMessageWriter是实现writer liveliness机制所需要的。每一个participant都可以通过设置使能/禁止wirter liveness机制相应的使能或禁止这两个endpoint。pqos.wire_protocol().builtin.use_WriterLivelinessProtocol false // fastdds 默认是trueSPDPPDP的目的是发现网络上其他的participant的存在及其属性。SPDPbuiltinParticipantWriter是一个RTPS 的Best-EffortStatelessWriter。它会定期像预配置地locators列表发送SPDPdiscoveredParticipantData,通常来说是往组播地址(默认239.255.0.1)发送。它的HistoryCache包含一个SPDPdiscoveredParticipantData类型的数据对象这个数据对象的内容是由participant的属性信息确定例如domain id participant支持什么EDP协议单播和组播地址和端口。SPDPdiscoveredParticipantData的属性SPDPbuiltinParticipantReader的HistoryCache中包含了所有活跃的participants的信息key用来识别每个不同的participant通过participant GUID。每当SPDPbuiltinParticipantReader接收到关于participant的信息时SPDP会检查HistoryCache寻找一个与participant GUID匹配的key的内容。如果没有找到匹配的key的条目就会以参与者的GUID为key添加新的条目。SPDP会周期性检查SPDPbuiltinParticipantReader的historycache寻找旧的条目这些条目被定义为那些超过leaseDuration没有收到消息的条目。然后删除它们。availableBuiltinEndpoints提供了预制endpoints的信息参考下面第三张图片。包括PUBLICATIONS_DETECTORSEDPbuiltinPublicationReaderPUBLICATIONS_ANNOUNCERSEDPbuiltinPublicationWriterSUBSCRIPTIONS_DETECTORSEDPbuiltinSubscriptionReaderSUBSCRIPTIONS_ANNOUNCERSEDPbuiltinSubscriptionWriterTOPICS_DETECTORSEDPbuiltinTopicsReaderTOPICS_ANNOUNCERSEDPbuiltinTopicsWriterPARTICIPANT_MESSAGE_READERBuiltinParticipantMessageReaderPARTICIPANT_MESSAGE_WRITERBuiltinParticipantMessageWriter红框内都是SPDP消息SEDPSEDP协议的目标是Participant间能发现彼此的writer和reader。用于SEDP的built-in Entities的QoS设置成reliable上图是DDSHelloWorldExample_first_pub.cap的消息流其中2个蓝色方框内的是SEDP消息红色线条标识的是A的publication信息发给B的过程绿色色线条标识的是B的subscription信息发给A的过程但是在第一个框框内HelloWorldTopic相关的reader和writer就完成了匹配。A的publication发给B的具体流程如下红色线条A的SEDPbuiltinPublicationsWriter发送heartbeat给B的SEDPbuiltinPublicationsReader告知它的history cache中有sample1firstAvaliableSeqNumber为1lastSeqNumber为1所以最新的sample的sequence number为1B收到heartbeat解析后发现A最新的change是sample1它没有收到过sample 1所以发送acknack 告知丢失了sample1bitmapBase1 numBits1 表示sample 1丢失A发送sample1给B告知它有一个针对HelloWorldTopic的publisher, 到这一步后A的publisher信息已经发送给到了B。由于A已经得到了B的subscriber消息所以A user_writer就可以开始往B发送心跳了。A发送heartbeat 告知最新的change为sample1B发送acknack告知期望sample2bitmapBase2 numBits0 表示sample 2丢失0次那就是说收到的最新的heartbeat的change为sample1 收到的最新的data也是sample1。也就是expecting example2B的subscription发送给B的具体流程如下绿色线条B的SEDPbuiltinSubscriptionWriter发送heartbeat给A的SEDPbuiltinSubscriptionReader告知它的history cache中有sample1firstAvaliableSeqNumber为1lastSeqNumber为1所以最新的sample的sequence number为1A收到heartbeat解析后发现B最新的change是sample1它没有收到过sample 1所以发送acknack 告知丢失了sample1bitmapBase1 numBits1 表示sample 1丢失B发送sample1给A告知它有一个针对HelloWorldTopic的subscriberB发送heartbeat 告知最新的change为sample1A发送acknack告知期望sample2bitmapBase2 numBits0 表示sample 2丢失0次那就是说收到的最新的heartbeat的change为sample1 收到的最新的data也是sample1。也就是expecting example2由于B只有一个用户定义的reader至此B的subscription发现流程完成。LivenessBuiltinParticipantMessageWriter发送的心跳消息如下。其作用暂时不清楚#静态发现采用静态服务发现的话SPDP过程是一样的但是不需要SEDP过程了取而代之的是通过在xml文件来配置对端的节点信息。publisherpqos.name(HelloWorldPublisher);pqos.wire_protocol().builtin.discovery_config.use_SIMPLE_EndpointDiscoveryProtocolfalse;pqos.wire_protocol().builtin.discovery_config.use_STATIC_EndpointDiscoveryProtocoltrue;pqos.wire_protocol().builtin.discovery_config.static_edp_xml_config(file://HelloWorldSubscriber_static_disc.xml);participant_DomainParticipantFactory::get_instance()-create_participant(0,pqos);发送方需要用到配置的接收方的信息如下HelloWorldSubscriber_static_disc.xmlstaticdiscovery participant nameHelloWorldSubscriber/name reader userId3/userId entityId4/entityId topicNameHelloWorldTopic/topicName topicDataTypeHelloWorld/topicDataType topicKindNO_KEY/topicKind reliabilityQosRELIABLE_RELIABILITY_QOS/reliabilityQos /reader /participant /staticdiscovery运行./DDSStaticHelloWorldExample publishersubscriberpqos.name(HelloWorldSubscriber);pqos.wire_protocol().builtin.discovery_config.use_SIMPLE_EndpointDiscoveryProtocolfalse;pqos.wire_protocol().builtin.discovery_config.use_STATIC_EndpointDiscoveryProtocoltrue;pqos.wire_protocol().builtin.discovery_config.static_edp_xml_config(file://HelloWorldPublisher_static_disc.xml);participant_DomainParticipantFactory::get_instance()-create_participant(0,pqos);发送方需要用到配置的接收方的信息如下HelloWorldPublisher_static_disc.xmlstaticdiscovery participant nameHelloWorldPublisher/name writer userId1/userId entityId2/entityId topicNameHelloWorldTopic/topicName topicDataTypeHelloWorld/topicDataType topicKindNO_KEY/topicKind reliabilityQosRELIABLE_RELIABILITY_QOS/reliabilityQos /writer /participant /staticdiscovery运行./DDSStaticHelloWorldExample subscriberwireshark抓包分析没能看到没有SEDP消息了参考文档https://zhuanlan.zhihu.com/p/12663878689

DDS服务发现

相关推荐

APP逆向实战：从零解析视频流URL获取逻辑与安全协议分析

POLARIS 背后的训练引擎 verl：HybridFlow 架构与 3D-HybridEngine 解析

org-roam-server 三重视界完全指南：数据库网络、缓冲区网络与文件浏览器

更多资讯

51单片机红外遥控计算器：时序解码、状态机与动态扫描

MAI Gateway：制造业AI落地的协议穿透与实时调度中间件

CH340在Ubuntu 22.04下的驱动配置与故障排查全指南

ESP8266/ESP32远程控制实战：blinker库避坑与稳定性优化

Superpowers：给AI编程装上“大脑”，让代码从能跑到可靠

JDK 1.8 + Tomcat 7 外网访问配置全指南

今日更新

微信个人号API开发案例：图片/语音/视频消息怎么下载解析存到本地？

Python股票自动交易系统源码解析：从行情获取到风控的完整链路

视酷酷信IM源码部署指南：Java 17+MySQL 8.0.33实战配置

本周精选

防幻觉智能体架构：电源硬件设计中的大模型编排与工具化实践

OpenGL面试核心考点：渲染管线、矩阵变换与性能排查全解析

全国计算机二级C语言真题PDF高效刷题指南

本月热门

我发现了一个新思路：用 Remotion + Claude Code 像写代码一样自动化生成短视频

Windows下 Codex 中 Chrome 和 Computer Use 插件不可用问题排查及解决参考方式：TaoToken 统一 Key 配置与验证

2026 大模型集体涨价：用 Python 做企业 Token 成本测算与选型避坑（附配置）

读完文章，想聊聊您的网站？