🚀Apache RocketMQ Rust implementation. Faster, safer, and with lower memory usage.
APACHE-2.0 License
Apache Rocketmq非官方的Rust实现。RocketMQ-Rust 是基于 Rust 语言重新实现的 Apache RocketMQ 消息中间件。该项目旨在为 Rust 开发者提供高性能、可靠的消息队列服务,并充分利用 Rust 语言的特性。
运行下面命令查看使用:
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
根据下面的命令运行NameServer
cargo run --bin rocketmq-namesrv-rust
现有的Rocketmq主要有如下几个功能模块:
每个模块的具体作用可以参照Rocketmq的官方说明文档 。Rust的实现会根据下面的顺序逐一来进行实现。
TODO
后续会进行其他的模块实现,首先会对NameServer进行Rust实现,目标是能够达到和Java版本一样的功能。
欢迎贡献代码、报告问题或提出建议。RocketMQ-Rust 的发展离不开开发者的支持,让我们共同推动 Rust 在消息中间件领域的发展。
Stargazers Over Time | Contributors Over Time |
---|---|
RocketMQ-Rust 使用 Apache License 2.0 和 MIT license