1 个不稳定版本
0.2.0 | 2024年6月4日 |
---|
#980 在 异步
被 3 个开源软件包 使用
13KB
59 代码行
rocketmq-rust
欢迎来到Apache RocketMQ的Rust实现(非官方)。RocketMQ-Rust是Apache RocketMQ消息中间件的Rust语言重实现。该项目旨在为Rust开发者提供高性能且可靠的消息队列服务,充分利用Rust语言的特点。
RocketMQ-Rust特性
- Rust语言优势:利用Rust的优势,如内存安全、零成本抽象和高并发性能,RocketMQ-Rust提供高效可靠的消息中间件。
- 异步和非阻塞设计:RocketMQ-Rust充分利用Rust的异步编程能力,采用非阻塞设计,支持高并发消息处理。
- 生态系统集成:作为Rust生态系统的一部分,RocketMQ-Rust与其他Rust生态系统内的库和框架良好集成,为开发者提供灵活的集成选项。
- 跨平台支持:RocketMQ-Rust支持多个平台,包括Linux、Windows、macOS,使其在不同环境中使用方便。
入门指南
要求
- rust工具链MSRV是1.75。(稳定,夜间)
运行命名服务器
运行以下命令查看用法:
-
Windows平台
cargo run --bin rocketmq-namesrv-rust -- --help RocketMQ Name server(Rust) Usage: rocketmq-namesrv-rust.exe [OPTIONS] Options: -p, --port <PORT> rocketmq name server port [default: 9876] -i, --ip <IP> rocketmq name server ip [default: 127.0.0.1] -h, --help Print help -V, --version Print version
-
Linux平台
$ cargo run --bin rocketmq-namesrv-rust -- --help RocketMQ Name server(Rust) Usage: rocketmq-namesrv-rust [OPTIONS] Options: -p, --port <PORT> rocketmq name server port [default: 9876] -i, --ip <IP> rocketmq name server ip [default: 127.0.0.1] -h, --help Print help -V, --version Print version
运行以下命令启动命名服务器
cargo run --bin rocketmq-namesrv-rust
模块
现有的RocketMQ有以下功能模块
- 命名服务器
- 代理
- 存储(本地存储)
- 控制器(高可用性)
- 客户端(SDK)
- 代理
- 分层存储(分层存储模块)
每个模块的具体功能可以参考官方RocketMQ文档。Rust实现将按以下顺序逐步进行。
命名服务器
特性列表
不支持:💔 ❌
基本支持:❤️ ✅
完全支持:💖 ✅
特性 | 请求代码 | 支持 | 备注 |
---|---|---|---|
放置KV配置 | 100 | 💖 ✅ | |
获取KV配置 | 101 | 💖 ✅ | |
删除KV配置 | 102 | 💖 ✅ | |
按命名空间获取kv列表 | 219 | 💖 ✅ | |
查询数据版本 | 322 | 💖 ✅ | |
注册代理 | 103 | 💖 ✅ | |
注销代理 | 104 | 💖 ✅ | |
代理心跳 | 904 | 💖 ✅ | |
获取代理member_group | 901 | 💖 ✅ | |
获取代理集群信息 | 106 | 💖 ✅ | |
撤销boker的写入权限 | 205 | 💖 ✅ | |
添加boker的写入权限 | 327 | 💖 ✅ | |
从命名服务器获取所有主题列表 | 206 | 💖 ✅ | |
在命名服务器中删除主题 | 216 | 💖 ✅ | |
在命名服务器中注册主题 | 217 | 💖 ✅ | |
按集群获取主题 | 224 | 💖 ✅ | |
从名称服务器获取系统主题列表 | 304 | 💖 ✅ | |
获取单元主题列表 | 311 | 💖 ✅ | |
获取包含单元子主题列表 | 312 | 💖 ✅ | |
获取包含单元子非单元主题列表 | 313 | 💖 ✅ | |
更新名称服务器配置 | 318 | 💔 ❌ | |
获取名称服务器配置 | 318 | 💔 ❌ |
其他模块实现将随后进行,首先从名称服务器的Rust实现开始。目标是实现与Java版本类似的功能。
贡献
欢迎对代码、问题报告和建议的贡献。RocketMQ-Rust的发展依赖于开发者的支持。让我们合作推动Rust在消息中间件领域的应用。
随时间变化的星星数量 | 随时间变化的贡献者数量 |
---|---|
许可证
RocketMQ-Rust采用Apache License 2.0和MIT许可证
依赖项
~2.7–8.5MB
~64K SLoC