CycloneDDS 0.10.5 Python拆分发布订阅脚本后订阅失败排查求助

1. 数据类型定义不一致 #

拆分文件时最容易踩的坑就是HelloWorld数据类型定义不统一。原示例里类型在同一个文件中定义，拆分后如果两个文件各自写类型定义，哪怕是字段名大小写、注释差异，都会导致DDS无法识别为同一主题。

• 解决：把类型定义单独抽成helloworld_type.py，在publisher.py和subscriber.py中统一导入。示例类型代码：

  from cyclonedds.idl import IdlStruct
  
  class HelloWorld(IdlStruct):
      msg: str
      count: int
  

2. 主题名称或QoS不匹配 #

• 检查两个文件中主题名称是否完全一致，DDS主题名称大小写敏感，哪怕差一个字符都不行。
• 确认QoS配置一致：原示例用默认QoS，拆分后如果某一方修改了可靠性、持久性等参数，会导致订阅匹配失败。
  解决：两个文件都使用默认QoS，或显式配置相同参数，比如：

  from cyclonedds.qos import Qos, Reliability
  qos = Qos(Reliability.Reliable)
  participant = DomainParticipant(0, qos=qos)
  topic = Topic(participant, "HelloWorldTopic", HelloWorld, qos=qos)
  

3. Domain ID不匹配 #

DDS通过Domain ID隔离通信域，默认是0。如果拆分后某一方把DomainParticipant的第一个参数改成了其他值（比如1），两个进程就不在同一域，无法通信。

• 解决：检查两个文件中DomainParticipant的Domain ID参数是否完全相同。

4. Windows防火墙或网络配置问题 #

Windows防火墙可能拦截CycloneDDS的UDP通信，导致跨进程消息无法传递。

• 解决：
  • 临时关闭防火墙测试，若恢复正常，给CycloneDDS进程添加防火墙允许规则。
  • 在cyclonedds.xml中指定正确的网络接口，避免程序绑定到错误的网卡：

    <CycloneDDS>
      <Domain id="0">
        <General>
          <NetworkInterfaceAddress>你的网卡IP或名称</NetworkInterfaceAddress>
        </General>
      </Domain>
    </CycloneDDS>
    

5. 进程启动顺序与持久性配置 #

如果先启动发布者发消息，再启动订阅者，默认QoS下订阅者收不到历史消息——原示例是单进程顺序执行，所以没这个问题。

• 解决：若需要接收历史消息，把Durability QoS设为TransientLocal：

  from cyclonedds.qos import Durability
  qos = Qos(Durability.TransientLocal, Reliability.Reliable)
  

内容的提问来源于stack exchange，提问作者yanzhang.guo