01
课程导学与背景
事件驱动架构概述 · 策略引擎定义与价值 · 课程目标与学习路径
导学背景
02
核心概念解析
事件 · 事件源 · 事件处理器 · 事件总线
概念基础
03
策略模型设计
策略定义 · 条件(Condition) · 动作(Action) · 优先级与冲突解决
模型设计
04
事件驱动架构模式
发布-订阅 · 事件流 · CQRS与事件溯源简介
模式架构
05
技术选型与对比
消息队列(Kafka/RabbitMQ) · 事件流平台 · 规则引擎对比
选型对比
06
项目初始化与环境搭建
Spring Boot项目 · 依赖(Spring Cloud Stream/Lombok) · YAML配置
环境Spring
07
事件模型定义
通用事件基类 · 业务事件(Order/Payment) · 序列化与反序列化
事件模型
08
事件总线实现
Guava EventBus轻量级 · Kafka分布式 · 事件路由策略
总线实现
09
策略注册中心
注册 · 注销 · 查询 · 动态加载(SPI机制)
注册SPI
10
策略引擎核心
策略匹配引擎 · 条件评估器 · 动作执行器
引擎核心
11
条件表达式引擎
自定义语法 · Aviator/SpEL解析 · 复合条件(AND/OR/NOT)
表达式条件
12
动作执行器设计
内置动作(通知/日志/API) · 自定义动作扩展点
动作扩展
13
事件与策略的关联
事件类型→策略映射 · 动态绑定 · 优先级队列
关联映射
14
策略生命周期管理
启用/禁用 · 版本控制 · 灰度发布
生命周期版本
15
事件处理流程
接收→分类→匹配→评估→执行→回执
流程处理
16
异步处理与并发
线程池 · 异步事件 · 背压(Reactive Streams)
异步并发
17
事务与一致性
原子性 · 最终一致性 · 补偿事务(Saga)
事务一致性
18
监控与可观测性
指标(吞吐/延迟/错误) · 日志聚合 · Jaeger追踪
监控可观测
19
测试策略
单元测试 · 集成测试 · 端到端测试
测试质量
20
性能优化
事件批处理 · 缓存策略 · 无锁编程
优化性能
21
安全与权限
事件过滤 · 策略访问控制 · 数据脱敏
安全权限
22
多租户支持
租户隔离 · 策略隔离 · 事件隔离
多租户隔离
23
扩展性设计
插件化策略 · 自定义事件源 · 自定义动作
扩展插件
24
实战案例一：风控系统
实时交易反欺诈策略引擎
实战风控
25
实战案例二：营销活动
用户行为触发优惠券发放引擎
实战营销
26
实战案例三：IoT设备管理
设备告警与自动修复策略引擎
实战IoT
27
部署与运维
Docker容器化 · Kubernetes · 配置中心(Nacos/Apollo)
部署运维
28
常见问题与避坑
事件丢失 · 重复消费 · 策略风暴 · 条件爆炸
避坑经验
29
架构演进
单体→分布式 · 同步→异步 · 规则引擎→决策引擎
演进架构
30
课程总结与展望
EDA未来趋势 · AI+策略引擎 · 学习资源推荐
总结展望