事件驱动架构实践

事件驱动基础

核心概念：事件（已发生的事实）、事件生产者（发布事件）、事件消费者（处理事件）、事件通道（传递事件）。优势：松耦合、可扩展、异步处理、审计追踪。适合：微服务通信、实时数据处理、复杂业务编排。

事件设计原则

事件命名：过去式动词（OrderCreated, PaymentCompleted）。事件内容：包含足够信息让消费者独立处理（不需要回查）。事件版本：向后兼容的schema演进。事件大小：避免过大（引用代替内嵌大数据）。

消息队列选择

RabbitMQ：功能丰富、路由灵活、适合企业应用。Kafka：高吞吐、持久化、适合大数据流。Redis Streams：轻量级、低延迟、适合简单场景。云服务：AWS SQS/SNS、阿里云MNS。选择考虑：吞吐量、持久化需求、运维复杂度。

最终一致性处理

分布式系统中强一致性代价高，事件驱动采用最终一致性。处理策略：幂等消费（重复处理不影响结果）、补偿事务（失败时反向操作）、Saga模式（长事务拆分为多步骤+补偿）。监控数据一致性延迟。

在自动化平台中应用

n8n/Make中的事件驱动：Webhook接收事件→路由分发→并行处理→结果聚合。事件存储：记录所有事件用于审计和重放。事件重放：从历史事件恢复状态或重新处理。与传统轮询对比：实时性更好、资源消耗更低。