SuperAPI AI 工具集

ddd4j-boot-mq

部署与运维

查看项目

更新于 10-15 21:48

技能介绍

用途:在 ddd4j-boot 服务中集成消息队列适配器,统一处理 Kafka、RabbitMQ、Pulsar、RocketMQ、ActiveMQ、MQTT、NATS、SQS、ONS/TDMQ 及监听器生命周期,而非按 Maven 构件拆分。使用前需通过 ddd4j-boot-version-selection 确认维护线。

主要能力:按投递语义与顺序需求选择 Broker 适配器;在指定 Boot 线(2.3–4.1)上装配 MQ 自动配置、监听器注册器及 topic/tag/group/namespace 设置;区分必需与可选监听器(Broker 宕机是否阻塞启动);配置 ACK、重试与死信策略并验证重复与恢复行为;审计关闭流程,要求生产者/监听器关闭幂等、资源有明确归属并可回滚;诊断消息失败(Bean 已装配但无消费、监听器静默缺失、重试循环未达死信)。

使用方式:先运行 ddd4j-boot-version-selection 固定版本线,定位该线上的 MQ AutoConfiguration、Properties、监听器注册器及对应 ddd4j-mq 模块;再选择 Broker 并确认配置与必需/可选监听器;随后检查条件装配、默认 Bean 与用户覆盖点;最后执行上下文测试与真实 Broker 往返测试(Testcontainers),覆盖发布/消费、ack、nack/重试、重复、Broker 丢失后恢复与优雅关闭。Docker 不可用的套件应标记 BLOCKED 或 SKIPPED,跳过不等于通过。

适用场景:ddd4j-boot 服务的 MQ 选型与装配、配置与生命周期验证、维护线兼容性判断。

限制:不修改 ddd4j 核心公共语义;不适用于 Spring Cloud Stream、Javalin、Quarkus 或未使用 ddd4j 的普通 Spring Boot;不负责 Broker 连接与版本锁定(用 ddd4j-boot-bom)或测试框架搭建(用 ddd4j-boot-testing)。信息缺失时输出 missing 提示并继续只读检查;不得输出凭据、令牌或生产连接串。本技能不访问、不收集、不存储、不传输任何用户数据、凭据或密钥。