Atostek/RustDDS

说明与用途

**项目简介**
Atostek/RustDDS 是用 Rust 实现的 DDS（Data Distribution Service）协议栈，提供高性能、零拷贝的发布/订阅通信，适合在对实时性和安全性有严格要求的系统中使用。

**价值**

• **实时数据分发**：基于 DDS 的 QoS 机制，能够在分布式环境中实现毫秒级甚至微秒级的数据传输。
• **安全可靠**：Rust 的内存安全特性配合 DDS 的可靠传输、持久化和历史数据查询，帮助构建稳健的数据管道。
• **跨语言互操作**：遵循 DDS 标准，可与其他语言（C/C++、Java、Python 等）实现的 DDS 实例无缝对接，便于在混合技术栈中统一数据流。

**典型接入方式**

1. **在 Cargo.toml 中添加依赖**

   [dependencies]
   rustdds = { git = "https://github.com/Atostek/RustDDS.git", tag = "v0.6.0" }

1. **创建 DomainParticipant、Publisher/Subscriber**

   use rustdds::dds::*;
   let domain = DomainParticipant::new(0).unwrap();
   let publisher = domain.create_publisher().unwrap();
   let subscriber = domain.create_subscriber().unwrap();

   // 定义 Topic
   let topic = domain.create_topic::<MyData>("MyTopic", None).unwrap();

   // 创建 DataWriter / DataReader
   let writer = publisher.create_datawriter(&topic, None).unwrap();
   let reader = subscriber.create_datareader(&topic, None).unwrap();

1. **配置 QoS（可选）**

通过 QosPolicy 调整可靠性、历史深度、传输优先级等，以满足具体的实时或带宽需求。

1. **在业务代码中发布/订阅**

   writer.write(&my_data, None).unwrap();   // 发布
   let samples = reader.take().unwrap();    // 拉取

**生产可用性**

• **成熟度**：GitHub 457 ⭐、83 🍴，最近一次提交在 2026‑07‑02，活跃度尚可。
• **适用场景**：原型、内部数据分析管线或对实时性有要求的内部服务，可直接投入使用。
• **风险**：项目文档和集成示例相对有限，元数据中缺少完整的部署指南；在生产环境部署前需要自行验证网络拓扑、QoS 配置以及与现有 DDS 实例的兼容性。
• **建议**：在正式上线前进行一次端到端的功能验证（包括安全、可靠性和性能基准），并制定依赖升级与维护策略。若项目需求长期稳定，考虑在内部维护一个 fork，以便及时修复潜在的安全或兼容性问题。

实际用途

Atostek/RustDDS helps convert raw data into searchable, analyzable, or automated pipelines.

• organize analytics pipelines
• process datasets
• improve reporting workflows

限制与审查说明

Medium: useful for prototypes or internal workflows, with dependency and maintenance checks before production.