01
事件驱动架构基础
什么是事件驱动架构、事件驱动 vs 轮询、在交易系统中的应用场景
架构入门
02
核心概念解析
事件(Event)、事件源(Event Source)、事件处理器(Event Handler)、事件循环(Event Loop)
概念基础
03
事件队列设计
队列数据结构选型、线程安全队列、无锁队列与性能考量
队列性能
04
事件类型与分类
市场数据事件、订单事件、风控事件、系统事件、自定义事件
分类设计
05
事件总线(Event Bus)实现
发布-订阅模式、事件路由、通配符匹配
总线路由
06
事件处理器注册与注销
装饰器模式实现、动态注册、优先级排序
注册优先级
07
异步事件处理
Python asyncio基础、事件循环集成、回调与协程
异步协程
08
事件序列化与反序列化
JSON/Protobuf/Avro对比、性能测试、Schema管理
序列化性能
09
事件持久化
日志存储、回放机制、崩溃恢复
持久化恢复
10
事件时间戳与顺序
逻辑时钟、物理时钟、HLC混合逻辑时钟
时钟顺序
11
事件去重机制
幂等性设计、去重窗口、Bloom Filter应用
去重幂等
12
事件超时与重试
超时检测、重试策略(指数退避)、死信队列
重试死信
13
事件优先级调度
优先级队列实现、饥饿问题解决、多级反馈队列
优先级调度
14
事件过滤与转换
过滤器链、转换器模式、条件路由
过滤转换
15
事件聚合与窗口计算
滑动窗口、滚动窗口、会话窗口
窗口聚合
16
事件溯源(Event Sourcing)
概念、快照、CQRS结合
溯源CQRS
17
事件驱动状态机
状态转换、事件触发、状态持久化
状态机状态
18
多线程事件处理
GIL影响、线程池设计、任务拆分
多线程GIL
19
多进程事件处理
进程间通信、共享内存、ZeroMQ集成
多进程IPC
20
分布式事件系统
Kafka/RabbitMQ对比、分区策略、消费者组
分布式消息队列
21
事件网关设计
WebSocket接入、REST API、FIX协议适配
网关协议
22
事件监控与度量
Prometheus指标、事件延迟统计、吞吐量监控
监控度量
23
事件链路追踪
OpenTelemetry集成、Span上下文传播、可视化
链路追踪
24
事件驱动测试
单元测试、集成测试、混沌工程
测试混沌
25
性能优化
零拷贝、内存池、对象复用、批处理
优化零拷贝
26
内存管理
对象池模式、弱引用、内存泄漏检测
内存泄漏
27
错误处理与容错
优雅降级、断路器模式、舱壁隔离
容错断路器
28
配置管理
动态配置、热加载、配置中心集成
配置热加载
29
实战案例1:行情推送系统
构建一个简单的行情推送系统
实战行情
30
实战案例2:订单执行引擎
构建一个完整的订单执行引擎
实战订单