用途:在 ddd4j-cloud 项目中集成 Spring Cloud Stream,处理消息发布与消费、绑定命名、物理目的地映射、确认与重试死信策略,并统一覆盖 Kafka、RabbitMQ、Pulsar、RocketMQ。
主要能力:使用 StreamBridge 发布消息;按 broker 映射函数名、绑定名与物理目的地;配置消费者 ACK/NACK、重试与死信策略;将 Context/Tenant 写入消息头并在消费端恢复;应用 BindingNamingContributor 命名规则;诊断消息未被消费、重复或重投丢失问题;通过真实 broker 集成测试验证发布/消费、确认/重试、重复与恢复。
使用方式:先确认目标 Cloud 维护线、Boot 父版本与 POM,再定位 stream 扩展、BindingNamingContributor 与 broker 集成测试;定义绑定映射;配置可靠性与上下文透传;对真实 broker 运行集成测试;输出绑定映射(函数→绑定→目的地→broker)、配置键、可靠性设置、测试证据与风险。安装命令:npx skills add full-stack-skills/ddd4j-skills --skill ddd4j-cloud-stream。
适用场景:需要消息集成、绑定与目的地映射、消息确认、死信、Kafka/RabbitMQ/RocketMQ 等场景。不适用:服务间同步请求响应(用 ddd4j-cloud-feign)、无 Cloud 模块的纯 Boot ddd4j(用 ddd4j-boot-mq)、ddd4j 层 broker 选型(用 ddd4j-mq)、Javalin/Quarkus 运行时(用 ddd4j-javalin-mq 或 ddd4j-quarkus-mq)、通用 Spring Cloud Stream 无 ddd4j、数据库写入与事务(用 ddd4j-cloud-data)。
限制:需提供目标 Cloud 线、Boot 父版本与 POM、能力与外部服务及部署要求、当前源码/测试/远程证据;不得将 README 模块名当作已完成能力,不得以配置存在替代外部服务行为;未授权不得发布或执行生产操作;不输出 Nacos/Redis/broker/数据库/私有仓库凭据或真实租户数据。资料未提供具体版本号、价格与平台支持细节。