#mq #rocket-mq #send-message #notifications #rust

bin+lib rocketmq-broker

Apache RocketMQ 的非官方 Rust 实现

1 个不稳定版本

0.2.0 2024年6月4日

#3#rocket-mq

MIT/Apache 许可协议

1MB
23K SLoC

Apache RocketMQ Broker 的 Rust 实现

概述

此模块主要是 Apache RocketMQ Broker 的实现,包含 Java 版本 Broker 的所有功能。

入门

要求

  1. rust 工具链 MSRV 是 1.75。(稳定版,夜间版)

运行 Broker

运行以下命令查看用法:

  • Windows 平台

    cargo run --bin rocketmq-broker-rust -- --help
    
    RocketMQ Broker Server(Rust)
    
    Usage: rocketmq-broker-rust.exe [OPTIONS]
    
    Options:
      -c, --config-file <FILE>      Broker config properties file
      -m, --print-important-config  Print important config item
      -n, --namesrv-addr <IP>       Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876]
      -p, --print-config-item       Print all config item
      -h, --help                    Print help
      -V, --version                 Print version
    
  • Linux 平台

    $ cargo run --bin rocketmq-broker-rust -- --help
    
    RocketMQ Broker Server(Rust)
    
    Usage: rocketmq-broker-rust [OPTIONS]
    
    Options:
      -c, --config-file <FILE>      Broker config properties file
      -m, --print-important-config  Print important config item
      -n, --namesrv-addr <IP>       Name server address list, eg: '192.168.0.1:9876;192.168.0.2:9876' [default: 127.0.0.1:9876]
      -p, --print-config-item       Print all config item
      -h, --help                    Print help
      -V, --version                 Print version
    

运行以下命令启动命名服务器

cargo run --bin rocketmq-broker-rust

特性

特性列表:

  • 不支持: 💔 ❌
  • 基础支持: ❤️ ✅
  • 完美支持: 💖 ✅
特性 请求代码 支持 备注
主题配置加载 💔 ❌ TopicConfigManager 类函数
主题队列映射加载 💔 ❌ TopicQueueMappingManager 类函数
消费偏移量加载 💔 ❌ ConsumerOffsetManager 类函数
订阅组加载 💔 ❌ SubscriptionGroupManager 类函数
消费过滤器加载 💔 ❌ ConsumerFilterManager 类函数
消费顺序信息加载 💔 ❌ ConsumerOrderInfoManager 类函数
消息存储加载 💔 ❌
定时消息存储加载 💔 ❌
调度消息存储加载 💔 ❌
发送消息钩子 💔 ❌
消费消息钩子 💔 ❌
发送消息 10 ❤️ ✅
发送消息 v2 310 ❤️ ✅
发送批量消息 320 💔 ❌
消费发送消息回执 36 💔 ❌
拉取消息 11 💔 ❌
轻量级拉取消息 361 💔 ❌
查看消息 200052 💔 ❌
弹出消息 200050 💔 ❌
确认消息 200051 💔 ❌
批量确认消息 200151 💔 ❌
更改消息不可见时间 200053 💔 ❌
通知 200054 💔 ❌
轮询信息 200055 💔 ❌
发送回复消息 324 💔 ❌
发送回复消息 v2 325 💔 ❌
查询消息 12 💔 ❌
通过 ID 查看消息 33 💔 ❌
心跳 34 ❤️ ✅
注销客户端 35 ❤️ ✅
检查客户端配置 46 💔 ❌
按组获取消费者列表 38 💔 ❌
更新消费者偏移量 15 💔 ❌
查询消费者偏移量 14 💔 ❌
查询分配 400 💔 ❌
设置消息请求模式 401 💔 ❌
结束事务 37 💔 ❌
默认处理器 💔 ❌ AdminBrokerProcessor 类函数

依赖项

~15–27MB
~402K SLoC