1.5 KiB
1.5 KiB
RocketMQ 消息队列架构调整 PRD
- 功能编号：GOV-008
- PRD 版本：0.1
- 状态：approved
- 日期：2026-08-13
问题
项目早期约定 RabbitMQ，但尚未实现消息客户端或业务消息链路。现决定统一采用 RocketMQ，并需要在服务脚手架落地前同步架构、环境契约和部署边界，避免后续同时维护两套消息模型。
目标
- 项目唯一消息队列调整为 RocketMQ 5.x。
- Scheduler 和 Worker 通过
MessageBusAdapter使用版本化消息契约。 - 配置明确区分 NameServer、Broker/Proxy Endpoint、Topic 和 Group。
- 保留本地默认关闭策略，同时允许连接独立运行的本机 RocketMQ。
- 检查当前本机 Docker RocketMQ 的实际连通状态，不夸大验证范围。
非目标
- 本版本不实现 Server、Scheduler、Worker 或 RocketMQ Node 客户端。
- 不替用户创建、删除或重启 Docker 或本机 RocketMQ 进程。
- 不连接生产 RocketMQ，不创建生产 Topic 或 Group。
- NameServer 可达时不宣称消息生产和消费已经可用。
验收标准
- 当前架构、开发规范、部署说明和环境模板只采用 RocketMQ。
- Scheduler 与 Worker 开发/生产模板键集合分别一致，且无 RabbitMQ 变量。
- 文档定义重复投递、幂等、重试、死信和顺序消息边界。
- 本机 NameServer 的版本、端口和启动状态有可复核证据。
- 诊断必须区分 Docker 容器与本机原生进程，并报告 NameServer、Broker、Proxy 的真实状态。