1 个不稳定版本
0.2.0 | 2024年6月4日 |
---|
#3 在 #rocket-mq
1MB
23K SLoC
Apache RocketMQ Broker 的 Rust 实现
概述
此模块主要是 Apache RocketMQ Broker 的实现,包含 Java 版本 Broker 的所有功能。
入门
要求
- 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