SuperAPI AI 工具集

ddd4j-mq

通用与其它

查看项目

更新于 10-15 21:48

技能介绍

用途:ddd4j-mq 面向 ddd4j 消息队列的选型、实现与评审。所有 Broker 适配器统一到 MQClient、MQListener、MQEvent、Acknowledgment 四个抽象上,先确定投递与运维语义,再选择具体 Broker。

主要能力:按需求矩阵做 Broker 路由(高吞吐日志/流→Kafka;AMQP 路由→RabbitMQ;多租户流/队列→Pulsar/TDMQ;事务/顺序消息→RocketMQ/ONS;JMS→ActiveMQ/Artemis;IoT→MQTT;轻量 JetStream→NATS;AWS→SQS;Redis 基础设施→Redis Stream;进程内→Disruptor;Spring Cloud 由 Cloud Stream 适配器统一)。支持 ACK/NACK 策略、带退避与上限的重试、死信、基于消息 id/业务键的幂等消费、监听器扫描与生命周期,以及用 Testcontainers 验证真实 publish→consume→ack 往返。

使用方式:先定义投递语义(至多一次/至少一次)与顺序要求,再选 Broker 与适配器,按各 Broker 规则配置 topic/tag/group/namespace,注册监听器并标记 required(失败须阻塞启动)或 optional(可降级就绪),最后验证往返、重试/死信/重复投递与生命周期。安装示例:npx skills add full-stack-skills/ddd4j-skills --skill ddd4j-data(Outbox 场景改用 ddd4j-data)、--skill ddd4j-cache(Redis 缓存场景)、--skill ddd4j-web(HTTP 触发发布场景)。

适用场景:Broker 选型、统一 API 下的生产者/消费者实现、ACK/NACK 与重试死信设计、幂等消费、监听器生命周期评审、Testcontainers 往返验证。

限制:不负责数据库侧事务性 Outbox、Redis 缓存、HTTP 端点;不适用于无 ddd4j 统一的通用 Spring Kafka/RabbitMQ 注解用法;不认可“容器启动即链路成功”或用 mock 证明持久性;不机械统一跨 Broker 的 topic 命名;消息载荷、头与日志不得泄露令牌、PII 或云密钥。资料未提供具体版本、价格与平台支持细节。