01
事件驱动交易系统概述
什么是事件驱动架构 · 交易系统中的事件类型 · 系统核心组件概览
架构概念
02
开发环境搭建
Python版本选择 · 虚拟环境配置 · 核心依赖库安装
环境依赖
03
事件模型设计
定义基础事件类 · 事件优先级 · 事件元数据 · 序列化与反序列化
模型序列化
04
事件总线核心
发布-订阅模式实现 · 事件通道设计 · 同步与异步分发
总线模式
05
事件队列实现
基于内存的队列 · 基于Redis的队列 · 持久化策略 · 队列监控
队列Redis
06
消息中间件集成
RabbitMQ基础 · 生产者消费者 · 交换机与路由键 · 消息确认
MQRabbitMQ
07
事件处理器注册
装饰器模式注册 · 处理器优先级排序 · 生命周期管理
处理器装饰器
08
异步编程基础
Python asyncio核心 · 协程与任务 · 事件循环 · 异步上下文管理器
异步asyncio
09
异步事件处理
异步事件循环集成 · 非阻塞分发 · 超时与重试机制
异步超时
10
数据模型设计
订单·持仓·账户·行情模型 · ORM映射与数据库迁移
模型ORM
11
行情数据接入
WebSocket实时行情 · REST API历史数据 · 数据清洗与标准化
行情WebSocket
12
交易指令生成
策略信号解析 · 指令类型定义 · 指令校验 · 指令事件封装
指令策略
13
订单管理模块
订单状态机 · 订单生命周期 · 订单簿维护 · 订单事件处理
订单状态机
14
风控模块设计
资金风控 · 持仓风控 · 频率风控 · 黑白名单 · 风控事件
风控安全
15
策略引擎架构
策略基类设计 · 策略生命周期 · 配置管理 · 事件绑定
策略引擎
16
回测系统搭建
回测事件驱动 · 历史数据回放 · 模拟撮合 · 绩效统计
回测模拟
17
实盘交易接口
交易所API封装 · API限频 · 连接池管理 · 断线重连
实盘API
18
日志与监控
结构化日志 · 日志分级 · 性能指标采集 · 告警事件
日志监控
19
配置管理
YAML解析 · 环境变量覆盖 · 配置热更新 · 配置中心集成
配置YAML
20
系统启动流程
组件初始化顺序 · 依赖注入 · 健康检查 · 优雅关闭
启动生命周期
21
事件追踪与调试
事件ID追踪 · 事件链路日志 · 事件回放 · 调试模式
调试追踪
22
性能优化
事件批处理 · 内存池复用 · 零拷贝技术 · 异步IO优化
性能优化
23
分布式部署
多进程架构 · 进程间通信 · 负载均衡 · 状态同步
分布式部署
24
高可用设计
主备切换 · 事件持久化 · 故障恢复 · 幂等性保证
高可用容错
25
单元测试
事件处理器测试 · 事件总线测试 · 模拟事件源 · 测试覆盖率
测试单元
26
集成测试
端到端事件流测试 · 组件交互测试 · 压力测试 · 混沌工程
集成压力
27
系统监控面板
实时事件流可视化 · 系统仪表盘 · 告警规则 · Grafana集成
监控Grafana
28
安全加固
事件加密传输 · 身份认证 · 权限控制 · 审计日志
安全加密
29
实战案例一：网格交易系统
基于事件驱动的网格交易系统 · 完整实现
实战网格
30
实战案例二：多策略对冲系统
基于事件驱动的多策略对冲系统 · 完整实现
实战对冲