109 lines
4.7 KiB
Markdown
109 lines
4.7 KiB
Markdown
---
|
||
title: "Event-Driven Architecture"
|
||
type: concept
|
||
tags:
|
||
- Architecture
|
||
- Event-Driven
|
||
- Serverless
|
||
- AWS
|
||
sources:
|
||
- public-cloud-learning-sessions-opentext-serverless-computing-20240903-160139-mee
|
||
- public-cloud-learning-sessions-opentext-event-driven-architecture-part-1-2024091
|
||
- public-cloud-learning-sessions-opentext-event-driven-architecture-part-2-2024091
|
||
last_updated: 2026-05-05
|
||
---
|
||
|
||
## Definition
|
||
|
||
Event-Driven Architecture（事件驱动架构）是一种软件设计范式，在该模式下，系统组件通过产生和消费事件（Event）进行异步通信，而非通过直接的函数调用或请求-响应模式。事件是系统中发生的重要动作或状态变化的声明式通知，事件消费者无需知道事件产生者的存在。
|
||
|
||
## Core Principles
|
||
|
||
| 原则 | 描述 |
|
||
|------|------|
|
||
| 异步通信 | 生产者和消费者解耦，无需同步等待响应 |
|
||
| 事件声明 | 事件代表"发生了什么"，而非"该做什么" |
|
||
| 松耦合 | 生产者和消费者之间无直接依赖 |
|
||
| 可扩展 | 新增消费者无需修改生产者代码 |
|
||
|
||
## Event Anatomy
|
||
|
||
典型事件包含：
|
||
|
||
```json
|
||
{
|
||
"event_id": "uuid",
|
||
"event_type": "ORDER_CREATED",
|
||
"source": "order-service",
|
||
"timestamp": "2026-04-14T10:00:00Z",
|
||
"data": { /* 业务相关数据 */ }
|
||
}
|
||
```
|
||
|
||
## AWS Event-Driven Stack
|
||
|
||
| 组件 | 角色 | 说明 |
|
||
|------|------|------|
|
||
| [[Amazon-EventBridge]] | 事件总线 | 接收、过滤、路由事件到目标 |
|
||
| [[AWS-Lambda]] | 事件消费者 | 响应事件执行处理逻辑 |
|
||
| [[Amazon-SNS]] | 事件发布/订阅 | 一对多广播消息 |
|
||
| [[Amazon-SQS]] | 事件队列 | 可靠的事件持久化和顺序处理 |
|
||
| [[Amazon-DynamoDB]] | 事件源 | DynamoDB Streams 触发 Lambda |
|
||
| [[Amazon-S3]] | 事件源 | S3 事件通知触发 Lambda |
|
||
|
||
## Serverless 中的事件驱动
|
||
|
||
[[AWS-Lambda]] 是事件驱动架构的核心执行单元：
|
||
|
||
- **事件即触发器**：Lambda 函数不主动运行，由事件触发
|
||
- **事件源映射**：Lambda 轮询 Kinesis、DynamoDB Stream、SQS 获取事件
|
||
- **状态变化即事件**：S3 对象上传、API Gateway 请求、DynamoDB 写入等均为事件
|
||
|
||
## Event Patterns
|
||
## EDA 三组件与事件代理类型
|
||
|
||
| 组件 | 角色 | 说明 |
|
||
|------|------|------|
|
||
| 事件生产者（Producer） | 产生事件 | 服务检测到状态变化时发布事件 |
|
||
| 事件消费者（Consumer） | 消费事件 | 订阅并处理事件，执行对应业务逻辑 |
|
||
| 事件代理（Broker） | 路由/存储 | 分事件路由器和事件存储两类 |
|
||
|
||
**事件路由器（Event Routers）**——按规则过滤事件并路由到正确消费者：
|
||
- [[Amazon-EventBridge]]：更丰富，支持 Schema 注册、跨服务触发
|
||
- [[Amazon-SNS]]：一对多广播（Fan-out）
|
||
|
||
**事件存储（Event Stores）**——流式持久化事件，消费者自行过滤：
|
||
- [[Amazon-SQS]]：标准队列（乱序/高性能）/ FIFO 队列（有序/Exactly-Once）
|
||
- [[Kinesis-Data-Streams]]：有序事件流，支持重放
|
||
|
||
## 编排模式：Choreography vs Orchestration
|
||
|
||
| 模式 | 特点 | 适用场景 |
|
||
|------|------|---------|
|
||
| Choreography（编排） | 各微服务自主通信，无中央协调者 | 简单、独立的跨服务交互 |
|
||
| Orchestration（编排） | 中央协调者（如 [[AWS-Step-Functions]]）控制工作流步骤 | 复杂业务流程、需要事务保障 |
|
||
|
||
## 生产级最佳实践
|
||
|
||
1. **幂等性（Idempotency）**：同一操作执行一次或多次产生相同结果。[[AWS-Lambda]] 异步调用会自动重试，因此幂等性是处理重复消息的关键——尤其适用于订单、支付等场景。
|
||
|
||
2. **事件排序**：
|
||
- **有序**：SQS FIFO 或 Kinesis Data Streams
|
||
- **乱序可接受**：标准 SQS 或 EventBridge（消费者自行处理乱序）
|
||
|
||
3. **团队独立性**：采用去中心化所有权，平台团队提供基础设防（Cloud CoE），消费者团队自主按需消费事件。
|
||
|
||
## Event Patterns
|
||
1. **Pub/Sub**：SNS 主题广播，多消费者订阅同一事件类型
|
||
2. **Event Streaming**：Kinesis/DynamoDB Stream 持久化事件流，支持重放
|
||
3. **Fan-Out**：SNS 主题或 EventBridge 规则将事件分发到多个消费者
|
||
4. **Competing Consumer**：同一消息同一时间只有一个消费者处理（SQS）
|
||
5. **Dead-Letter Queue（DLQ）**：处理失败事件，防止消息丢失
|
||
6. **Saga Pattern**：通过事件序列协调分布式事务
|
||
7. **Event Sourcing**：完整记录所有状态变化事件作为唯一真相来源
|
||
|
||
## Connections
|
||
- [[Event-Driven-Architecture]] ← is_execution_model_of ← [[Serverless-Computing]]
|
||
- [[Event-Driven-Architecture]] ← uses ← [[Amazon-EventBridge]]
|
||
- [[Event-Driven-Architecture]] ← executed_by ← [[AWS-Lambda]]
|