R
内存安全核心Rust 语言优势
RocketMQ-Rust 利用 Rust 的所有权模型和零成本抽象实现 Broker、客户端、远程通信和存储,在保持安全性的同时提供可预期的性能。
使用 Rust 构建的高性能分布式消息中间件
RocketMQ-Rust 将 Apache RocketMQ 成熟的消息模型带到 Rust:Producer 发送消息到 Broker,NameServer 提供路由,CommitLog 持久化数据,Consumer 通过异步、类型安全的 API 处理消息。
RocketMQ-Rust 利用 Rust 的所有权模型和零成本抽象实现 Broker、客户端、远程通信和存储,在保持安全性的同时提供可预期的性能。
Producer、Consumer、Remoting 和 Broker 服务围绕异步 I/O 设计,让高并发消息流量不会阻塞工作线程。
可在 Linux、Windows 和 macOS 上运行和开发 RocketMQ-Rust,配合 Cargo、示例和文档融入 Rust 生态。
Producer 和 Consumer 在发送或拉取消息前,通过 NameServer 解析 Broker 路由。
消息写入 CommitLog,并分发到消费队列,支撑可靠投递。
客户端 API 支持 Topic 消息、队列选择、批量发送和事务消息流程。
Consumer 以 Push 或 Pull 模式处理消息,并通过 Offset 维护消费进度。