251 字
1 分钟
Mymq-rs[消息队列]
本项目计划从零实现一个消息队列,支持消息的生产者-消费者模型。 教程为AI生成,仅用于学习参考。不涉及任何商业用途。
项目代码为手写,不使用AI生成。
项目地址: https://github.com/MrTwoc/Mymq-rs
技术栈预计包括:
- Rust 2024
- tokio(Mutex / Notify / spawn)
Arc<Mutex<Broker>>并发共享- quinn(QUIC + TLS 1.3)
- rcgen 自签名证书
- protobuf + prost 序列化
- build.rs 代码生成
要实现的功能:
- 消息模型与全局 ID
- 广播订阅:一条消息复制给每个订阅者
- 每订阅者独立的 pending / inflight 状态
- dequeue / ack / nack 三操作
- 超时重投巡检
- protobuf 命令协议(Subscribe / Publish / Dequeue / Ack / Nack)
- QUIC 服务端与客户端
- 持久化、topic 路由、HTTP 管理接口
分五个阶段推进,每阶段独立可运行。当前阶段 1 已完成,阶段 2 进行中。
Mymq-rs[消息队列]
https://www.twocblog.site/posts/rust/mymq-rs-1/