用途:该技能用于在实现异步消息、分布式系统与事件驱动架构(EDA)时提供指导,核心思路是通过事件而非直接调用实现松耦合与可扩展。
主要能力:覆盖消息队列、发布/订阅、事件溯源、CQRS、基于 Saga 的分布式事务管理,以及 Kafka 数据流。资料给出了多种实现的代码模式:RabbitMQ(含死信交换机、TTL、重试计数)、AWS SQS(含可见性超时与重投递)、Kafka(kafkajs 生产者/消费者、幂等生产者、消费者组)、NATS(JetStream 持久化流与 durable consumer),以及 PostgreSQL 事件存储(乐观并发校验、事件表结构)与 Aggregate 基类、领域事件接口。
使用方式:资料列出可用代理:senior-software-engineer(Opus)负责架构设计、模式选择与分布式系统设计、事件处理器实现、事件安全与消息加密、消息代理与 Kafka 集群配置;software-engineer(Sonnet)仅用于单元测试、按既有模式编写样板事件处理器,或依据具体方案搭建脚手架。示例连接命令如 brokers: ["localhost:9092"],clientId 按服务命名;订阅需指定 groupId 或 durableName。
适用场景:需要异步解耦、事件溯源、读写分离或跨服务分布式事务的系统。
限制:资料未提供该技能的安装方式、许可、价格或版本信息;文中部分接口实现存在省略(如 Append 中调用的 eventBus 未在类内定义、订阅示例中的 consume 迭代写法可能因驱动版本而异),使用前需按实际运行环境核对。类别归属依据其分布式系统与后端开发用途判定。