SuperAPI AI 工具集

event-driven

编程与开发

查看项目

更新于 10-15 20:28

技能介绍

用途:该技能面向事件驱动架构(EDA),通过事件而非直接调用实现松耦合、可扩展系统,覆盖消息队列、发布/订阅、事件溯源、CQRS、Saga 分布式事务管理以及 Kafka 数据流。

主要能力:提供 RabbitMQ 与 AWS SQS 的消息队列实现(含持久化、死信交换、TTL、重试与可见性超时处理);Kafka 与 NATS 的发布/订阅事件总线(含幂等生产者、消费者组、JetStream 持久化);基于 PostgreSQL 的事件存储与聚合根基类,支持乐观并发校验、版本控制与未提交事件;以及事件安全、授权与消息加密等方向。

使用方式:资料给出 TypeScript 代码示例,包括 RabbitMQClient、SQSQueue、KafkaEventBus、NATSEventBus 与 PostgresEventStore 等类,以及 Order 聚合示例。典型流程为连接 broker、发布事件、订阅并处理事件、确认或重试。

适用场景:异步消息传递、分布式系统、微服务解耦、事件溯源与 CQRS 读写分离、跨服务 Saga 事务、Kafka 数据流处理。

限制:资料未提供安装命令、收费与价格、平台支持范围、性能指标或具体使用步骤;部分代码示例在资料中未完整展示。