第 14 章：实盘交易系统与运维

量化投资的终极目标是实盘获利。从回测到实盘，不仅是代码环境的切换，更是对系统稳定性、执行效率和风险控制的全面考验。本章将介绍 akquant 的实盘架构，并深入探讨订单管理系统 (OMS)、风控系统 (RMS) 以及高可用部署方案。

14.1 实盘架构与接口

14.1.1 回测与实盘的差异

维度	回测 (Backtest)	实盘 (Live Trading)
时间流	历史数据重放 (Replay)	实时数据流 (Stream)
成交机制	假设成交 (Perfect Fill)	真实撮合 (Partial/Reject)
延迟	零延迟 (Zero Latency)	网络延迟 + 内部处理延迟
状态管理	内存状态 (Transient)	持久化状态 (Persistent)

14.1.2 交易接口 (Gateway)

akquant 通过适配器模式支持多种柜台接口：

• CTP (China Trading Platform)：上期技术开发，期货市场标准接口。
• XTP (Xiong'an Trading Platform)：中泰证券开发，股票量化私募首选。
• IB (Interactive Brokers)：盈透证券，连接全球市场。

在实盘模式下，DataFeed 切换为实时行情源，ExecutionClient 切换为柜台交易接口。

14.2 订单管理系统 (Order Management System, OMS)

OMS 是实盘交易的核心，负责维护订单的全生命周期状态。

14.2.1 订单状态机

实盘中的订单状态远比回测复杂：

1. PendingNew：订单已发送，等待交易所确认。
2. New：交易所已确认接收（挂单中）。
3. PartiallyFilled：部分成交。
4. Filled：全部成交。
5. Canceled：已撤单。
6. Rejected：废单（如资金不足、不在交易时间）。

14.2.2 状态同步 (Synchronization)

策略持仓 (Strategy Position) 与柜台持仓 (Broker Position) 可能因网络丢包或人工干预而不一致。

• 定时同步：每隔 N 秒查询柜台持仓，强制覆盖本地状态。
• 事件驱动：依赖 OnRtnOrder 和 OnRtnTrade 推送实时更新状态。

14.3 风险管理系统 (Risk Management System, RMS)

在实盘中，风控前置 (Pre-trade Risk Check) 是防止“乌龙指”的最后一道防线。

14.3.1 核心风控规则

1. 单笔最大委托量 (Max Order Size)：防止代码错误导致的天量下单。
2. 资金使用率限制 (Margin Usage Limit)：防止满仓操作，预留安全垫。
3. 日内撤单次数限制：交易所对频繁撤单有惩罚措施（如上期所 500 次）。
4. 策略级止损：当策略当日亏损超过 N% 时，强制平仓并停止运行。

14.4 算法交易 (Algorithmic Execution)

对于大资金，直接下单会产生巨大的冲击成本 (Market Impact)。算法交易旨在拆解大单，降低成本。

14.4.1 TWAP (Time Weighted Average Price)

时间加权平均价格算法。将大单均匀拆分到一段时间内执行。

• 逻辑：每隔 \(t\) 秒，下单 \(q\) 手。
• 适用：流动性均匀的市场。

14.4.2 VWAP (Volume Weighted Average Price)

成交量加权平均价格算法。根据历史成交量分布，在流动性好的时候多下单，流动性差的时候少下单。

• 目标：成交均价接近市场 VWAP。

14.5 实盘部署与运维

14.5.1 部署环境

• 云服务器 (ECS)：推荐使用靠近交易所机房的节点（如上海、深圳）以降低延迟。
• Docker 容器化：确保实盘环境与测试环境完全一致，避免 "It works on my machine" 问题。

14.5.2 监控与报警

• 心跳监测 (Heartbeat)：确保程序存活。
• 日志 (Logging)：详细记录每一笔 Tick、Signal 和 Order。
• 消息推送：集成钉钉/飞书/邮件机器人，实时推送成交和异常信息。

14.5.3 代码示例：启动实盘

"""
第 11 章：实盘交易系统 (Live Trading).

本示例展示了如何将策略部署到实盘环境。
AKQuant 支持通过 CTP 接口连接期货公司柜台，实现行情接收和自动交易。

注意：
1. 实盘交易涉及真实资金，请务必在模拟盘 (SimNow) 充分测试。
2. 本代码仅为配置演示，无法直接运行，因为需要有效的 CTP 账户信息。
3. 你需要安装 CTP 驱动 (通常只支持 Linux/Windows)。

配置流程：
1. 准备 CTP 账户 (BrokerID, UserID, Password, AuthCode, AppID)。
2. 获取前置机地址 (MD Front, TD Front)。
3. 配置 LiveRunner 并启动。
"""

import akquant as aq
from akquant import Bar, Instrument, Strategy
from akquant.live import LiveRunner  # 导入实盘运行器


# 定义一个简单的策略 (与回测完全一致)
class LiveDemoStrategy(Strategy):
    """实盘演示策略."""

    def on_bar(self, bar: Bar) -> None:
        """收到 Bar 事件的回调."""
        self.log(f"[Live] Received Bar: {bar.symbol} @ {bar.close}")

        # 简单的双均线逻辑
        closes = self.get_history(20, bar.symbol, "close")
        if len(closes) < 20:
            return

        ma5 = closes[-5:].mean()
        ma20 = closes[-20:].mean()

        pos = self.get_position(bar.symbol)

        if ma5 > ma20 and pos == 0:
            self.log("金叉 -> 买入开仓")
            self.buy(bar.symbol, 1)
        elif ma5 < ma20 and pos > 0:
            self.log("死叉 -> 卖出平仓")
            self.close_position(bar.symbol)


if __name__ == "__main__":
    print("正在配置实盘环境...")

    # 1. 定义交易标的
    # 实盘中，合约乘数等信息通常可以从柜台自动查询，但显式配置更安全
    rb2310 = Instrument(
        symbol="rb2310",
        asset_type=aq.AssetType.Futures,
        multiplier=10,
        margin_ratio=0.1,
    )

    # 2. CTP 账户配置 (请替换为你的真实账户或 SimNow 模拟账户)
    CTP_CONFIG = {
        "md_front": "tcp://180.168.146.187:10131",  # SimNow 行情前置
        "td_front": "tcp://180.168.146.187:10130",  # SimNow 交易前置
        "broker_id": "9999",
        "user_id": "YOUR_USER_ID",
        "password": "YOUR_PASSWORD",
        "app_id": "simnow_client_test",
        "auth_code": "0000000000000000",
    }

    # 3. 创建实盘运行器
    try:
        runner = LiveRunner(
            strategy_cls=LiveDemoStrategy,
            instruments=[rb2310],
            md_front=CTP_CONFIG["md_front"],
            td_front=CTP_CONFIG["td_front"],
            broker_id=CTP_CONFIG["broker_id"],
            user_id=CTP_CONFIG["user_id"],
            password=CTP_CONFIG["password"],
            app_id=CTP_CONFIG["app_id"],
            auth_code=CTP_CONFIG["auth_code"],
        )

        # 4. 启动实盘
        # run() 会阻塞主线程，直到手动停止 (Ctrl+C)
        print("启动 CTP 接口...")
        runner.run(cash=500_000)

    except ImportError:
        print(
            "错误: 未找到 CTP 接口库。请确保已安装 akquant[ctp] 或手动配置 "
            "thosttraderapi。"
        )
    except Exception as e:
        print(f"实盘启动失败: {e}")

14.6 高可用架构 (High Availability)

实盘系统最怕的不是亏损，而是宕机。一旦系统崩溃，持仓状态丢失，正在进行的订单无法撤销，后果不堪设想。

14.6.1 主备切换 (Primary-Backup)

构建两套完全相同的系统：

1. 主机 (Master)：负责接收行情、计算信号、发送订单。
2. 备机 (Slave)：实时接收行情和主机状态，但不发单。
3. 心跳 (Heartbeat)：主机每秒向备机发送心跳包。
4. 切换 (Failover)：当备机连续 N 秒未收到心跳，判定主机宕机，自动接管交易权限，并报警通知人工介入。

14.6.2 状态持久化 (Persistence)

内存中的状态（持仓、订单、信号）必须实时落地到数据库（如 Redis AOF 或 SQLite）。

• Crash Recovery：程序重启后，首先读取数据库恢复现场，确保“断点续传”。

14.7 低延迟优化 (Low Latency)

对于高频交易 (HFT)，速度就是利润。

1. 共置 (Co-location)：将服务器托管在交易所机房（如上交所金桥数据中心），光纤直连，物理距离缩短至米级。延迟可从毫秒级 (ms) 降至微秒级 (\(\mu s\))。
2. 内核旁路 (Kernel Bypass)：使用 Solarflare 网卡和 OpenOnload 技术，绕过操作系统内核，直接在用户态处理网络包，减少上下文切换。
3. CPU 亲和性 (CPU Affinity)：将交易进程绑定到特定的 CPU 核心，独占 L1/L2 缓存，避免缓存失效 (Cache Miss)。
4. 无锁编程 (Lock-free)：在 C++ 或 Rust 中使用原子操作 (Atomic) 和无锁队列 (Ring Buffer) 替代互斥锁，避免线程阻塞。

14.8 监控体系 (Monitoring Stack)

仅仅有日志是不够的，我们需要可视化的仪表盘。

1. Prometheus：时序数据库，采集系统指标。
   • strategy_latency: 策略计算耗时。
   • order_latency: 订单往返延时 (RTT)。
   • position_exposure: 当前持仓敞口。
   • pnl_realtime: 实时盈亏。
2. Grafana：可视化展示。配置大屏，实时显示资金曲线、持仓分布、系统负载。
3. AlertManager：报警中心。
   • P0 级报警：程序崩溃、网络断开、资金不足。电话通知。
   • P1 级报警：策略亏损超限、未成交订单过多。短信通知。
   • P2 级报警：延迟抖动、CPU 高负载。邮件通知。

14.9 实盘事故复盘 (Post-Mortem)

前车之鉴，后事之师。

1. 光大乌龙指 (2013)：策略系统错误生成巨量市价单，且缺乏资金校验风控，导致瞬间买入 234 亿元股票，拉升上证指数 5%。
   • 教训：风控系统必须独立于交易系统，且拥有最高权限（“熔断机制”）。
2. 骑士资本 (2012)：由于部署失误，旧代码被错误激活，在 45 分钟内疯狂买卖，亏损 4.4 亿美元，导致公司破产。
   • 教训：灰度发布和自动化部署是生命线。新代码上线前必须在模拟盘 (Paper Trading) 充分验证。

14.10 硬件加速 (Hardware Acceleration)

当通用 CPU 的性能达到瓶颈时，我们需要借助专用硬件。

14.10.1 FPGA (Field-Programmable Gate Array)

FPGA 允许直接在硬件电路层面编程，将网络包处理、行情解析、订单构建等逻辑烧录到芯片中。

• 延迟：亚微秒级 (Sub-microsecond)。从接收行情到发出订单仅需 500ns。
• 应用：做市商 (Market Making)、高频套利。
• 开发成本：极高。需要使用 Verilog/VHDL 语言，调试困难。

14.10.2 GPU (Graphics Processing Unit)

GPU 擅长大规模并行计算。

• 应用：深度学习训练 (Training)、大规模期权定价 (Monte Carlo)。
• 限制：由于 PCIe 总线的延迟，GPU 不适合处理对延迟极度敏感的即时交易逻辑，更适合盘中实时计算复杂的因子或风险指标。

14.11 量化团队协作 (Team Collaboration)

量化交易不再是单打独斗的时代，而是一个工业化的流水线。

1. 基金经理 (PM)：制定顶层投资逻辑，管理投资组合风险，对最终盈亏负责。
2. 量化研究员 (Quant Researcher)：挖掘因子，构建模型，撰写研究报告 (Jupyter Notebook)。
3. 量化开发 (Quant Developer)：
   • 平台开发：维护回测引擎 (akquant)、数据清洗管线。
   • 策略开发：将研究员的 Python 代码重构为高性能的 C++/Rust 实盘代码。
4. 数据工程师 (Data Engineer)：负责大数据的采集、存储和清洗。
5. 运维 (SRE)：负责服务器维护、网络监控、故障排查。

---

全书结语： 恭喜你完成了《量化投资：从理论到实战》的全部课程！ 我们从 Python/Rust 基础出发，构建了高性能回测引擎，探讨了股票、期货、期权等全资产类别的策略，最后落地到实盘交易系统。 量化投资是一场没有终点的马拉松。市场在变，对手在变，唯一不变的是我们要保持对数据的敬畏和对逻辑的执着。

愿 Alpha 与你同在！