4. 事件驱动架构原理：事件、事件源、事件处理器、事件总线核心概念

在构建回测坏账率监控系统时，传统轮询（Polling）方式存在延迟高、资源浪费、扩展性差等痛点。事件驱动架构（Event-Driven Architecture, EDA）通过将系统组件解耦，以“事件”作为核心通信载体，实现实时、异步、可扩展的数据流处理。本节将深入剖析EDA的四大核心概念：事件、事件源、事件处理器与事件总线，并结合回测坏账率监控场景进行实例化说明。

4.1 事件（Event）

事件是架构中发生的事实记录，代表状态的变化或动作的发生。在回测坏账率监控中，事件是对业务数据变化的封装。

• 不可变性：事件一旦生成，不应被修改，只能被追加或消费。
• 自描述性：事件应包含足够的信息（如事件ID、时间戳、类型、负载数据）供消费者理解。
• 结构化：通常采用JSON、Avro或Protobuf格式。

{
  "eventId": "evt-20250321-001",
  "eventType": "BadDebtThresholdBreached",
  "source": "BacktestEngine",
  "timestamp": "2025-03-21T14:30:00Z",
  "payload": {
    "portfolioId": "PF_001",
    "badDebtRate": 0.085,
    "threshold": 0.05,
    "breachLevel": "CRITICAL"
  }
}

4.2 事件源（Event Source）

事件源是产生事件的实体。在回测坏账率监控系统中，事件源通常是数据采集层或计算引擎。

• 数据采集器：从数据库、消息队列或API实时拉取回测结果。
• 计算引擎：如Apache Flink或Python Pandas脚本，在完成坏账率计算后生成事件。
• 外部系统：如信用评分系统、交易系统，通过Webhook推送状态变更。

4.3 事件处理器（Event Processor）

事件处理器是消费事件并执行业务逻辑的组件。在监控系统中，处理器负责分析、告警、存储或触发补偿动作。

4.4 事件总线（Event Bus）

事件总线是连接事件源与事件处理器的中间层，负责事件的接收、路由、缓冲和分发。它是EDA的“神经系统”。

• 解耦：生产者和消费者无需知道彼此的存在。
• 异步：事件发布后立即返回，处理由消费者异步完成。
• 弹性：通过消息持久化和重试机制，防止事件丢失。
• 扩展性：支持多个消费者并行处理同一类事件。

4.5 四大核心概念协同工作流

在回测坏账率监控的典型场景中，四个核心概念按以下流程协同工作：

1. 事件源（回测引擎）完成一轮回测计算，检测到坏账率超过阈值，生成 BadDebtThresholdBreached 事件。
2. 事件被发布到事件总线（如Kafka Topic: bad-debt-events）。
3. 事件总线根据事件类型或主题，将事件分发给注册的事件处理器。
4. 告警处理器接收事件，触发邮件/短信通知；存储处理器将事件写入数据库；分析处理器更新实时仪表盘。

4.6 核心概念对比总结