用途:该技能提供事件驱动架构(EDA)的专业协助,围绕消息代理、发布/订阅拓扑、事件流处理、异步工作流与最终一致性展开,适合将分布式服务通过异步事件而非同步 HTTP 链解耦。
主要能力:涵盖发布/订阅拓扑与扇出、CloudEvents 规范、幂等消费者模式、事务性发件箱(Transactional Outbox)模式、事件代理工具选型(Kafka/Redpanda、RabbitMQ/ActiveMQ、AWS SNS/SQS、Google Cloud Pub/Sub),以及死信队列、事件模式版本化等最佳实践与常见故障排查。
使用方式:资料给出生产者发布与消费者订阅的示例代码,例如 messageBroker.publish("order.created", {...}) 与 messageBroker.subscribe("order.created", async (event) => {...});并给出幂等消费者通过 Redis 记录已处理事件 ID 的写法,以及事务性发件箱的建表与事务写入示例。
适用场景:解耦微服务、高吞吐异步处理(IoT 遥测、分析事件、用户活动日志)、跨服务复杂工作流(订单、库存、通知)、消费者短暂离线时的零停机韧性。
限制与注意:不应使用事件模拟 RPC/请求-响应;避免在事件中广播大型二进制负载;需注意分区键决定顺序、全局顺序不保证;需处理重复投递、乱序与毒丸消息。具体平台、收费与部署细节资料未提供。