Danube Messaging

Danube Messaging 是一款用 Rust 构建的开源发布/订阅与流媒体平台，旨在提供可靠的消息传递，同时大幅降低运维复杂度。它采用单一自包含二进制文件，集成了嵌入式 Raft 共识算法，支持独立开发模式、集群扩展以及边缘部署，让您轻松应对各种场景。

核心功能

• 嵌入式 Raft 共识：自动进行领导者选举、故障转移和主题恢复，确保高可用性和数据一致性。
• 内置模式管理：支持 JSON Schema 等模式定义，并提供版本控制，方便数据治理。
• 分层存储架构：采用热、温、冷三级存储策略，优化主题持久化成本与性能。

主要特性

• 零运维负担：单一二进制文件即可运行，无需额外依赖，从开发到生产无缝过渡。
• 灵活部署：支持单机、集群和边缘环境，适应不同规模的需求。
• 高性能：基于 Rust 语言实现，提供低延迟、高吞吐的消息传递能力。
• 自动恢复：节点故障后自动触发领导者选举和主题协调，保证服务连续性。

适用场景

• 微服务通信：作为事件驱动架构中的消息中间件，解耦服务依赖。
• 实时数据流：处理日志、指标或用户行为等流式数据。
• 边缘计算：在资源受限的边缘设备上运行，实现本地消息处理。

无论是构建分布式系统、实时分析管道，还是物联网应用，Danube Messaging 都能以简洁高效的方式满足您的消息需求。