#消息队列 #RocketMQ #MQ #内存安全 #Rust

rocketmq-runtime

Apache RocketMQ的非官方Rust实现

1 个不稳定版本

0.2.0 2024年6月4日

#980异步


3 个开源软件包 使用

MIT/Apache

13KB
59 代码行

rocketmq-rust

GitHub last commit Crates.io Docs.rs CI CodeCov GitHub contributors Crates.io License GitHub repo size Static Badge

欢迎来到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,使其在不同环境中使用方便。

入门指南

要求

  1. 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在消息中间件领域的应用。

Alt

随时间变化的星星数量 随时间变化的贡献者数量
Stargazers over time GitHub Contributor Over Time

许可证

RocketMQ-Rust采用Apache License 2.0MIT许可证

依赖项

~2.7–8.5MB
~64K SLoC