交易系统行情处理

交易系统行情处理 · 四种方案

导读 · 在交易系统中，行情处理方式直接影响系统性能与稳定性。本文梳理了四种常见方案，从简单直接到高复杂度，各有优劣与适用边界。

在 CTP 回调函数中直接运行策略逻辑，行情数据进入回调后立即处理。

✓ 优点实现简单，无额外开销；延时最低，因为策略在行情内部线程直接执行。

✗ 缺点 ① 阻塞 CTP 内部线程 — 策略处理慢会导致 tick 堆积，最终可能崩溃；② 数据竞争 — 持仓数据被策略与成交回报等多线程同时访问，线程不安全。

行情先推入队列，策略线程通过 POP 获取 tick 处理，实现行情接收与策略线程的解耦。

✓ 优点巧妙解决阻塞与数据竞争；实现简单，可直接用标准库队列或第三方无锁队列（如 boost 无锁队列）。

✗ 缺点引入锁开销与上下文切换，性能受影响。标准库 queue 非线程安全，需要加互斥锁；即使使用无锁队列，仍存在一定开销。

▸ 升级单生产者单消费者场景可用 concurrent queue 或 Boost 无锁队列，性能更高。

生产者向环形缓冲区写入 tick，用原子变量 head 记录写入位置；消费者读取并用 tail 记录读取位置。 tail 追上 head 时消费者等待。

✓ 优点完全无锁，无线程挂起，无上下文切换；时延极快；支持缓存行对齐；固定容量，无动态内存分配，效率与安全兼备。

✗ 缺点实现复杂度高，需理解 C++ 底层内存布局；场景仅限于单生产者与单消费者，通用性受限。

申请公共共享内存区域，映射到各进程虚拟内存。生产者持续写入行情，多个消费者（策略、行情主播等）同时读取。

✓ 优点生产与消费完全解耦；支持多消费者；行情数据可持久化到磁盘（接收线程断线不丢数据）；消费者可随时启停，不丢失行情。

✗ 缺点需要额外外部依赖；实现复杂度高，涉及共享内存管理与进程同步。

核心对比

时延表现无锁 Ring Buffer ≈ 共享内存 > 队列方式 > 直接回调*
*直接回调虽快但不安全，实际可用性低

实现复杂度共享内存 > Ring Buffer > 队列方式 > 直接回调

线程安全队列方式 ✓ · Ring Buffer ✓ · 共享内存 ✓ · 直接回调 ✗

适用规模共享内存 > Ring Buffer > 队列方式 > 直接回调

场景推荐

➀

简单策略 · Demo · 回测直接回调
场景简单，追求快速实现，可容忍一定风险。

➁

实盘简单策略 · 延时要求不高队列方式
需要稳定运行，对性能不极致敏感，开发成本低。

➂

极致低延时交易Ring Buffer
对时延有苛刻要求，单生产者单消费者场景。

➃

多进程架构 · 行情分发共享内存
多个进程需要独立消费行情，要求高可用与数据持久化。

▎ 关键认知

从时延看，无锁 Ring Buffer 与 共享内存 远优于队列方式；直接回调虽快但场景极其有限且不安全。
方案的选择本质是 复杂度、性能、场景 三者的权衡。

总结 · 四种方案各有清晰的适用边界：

从单线程回调到跨进程共享内存，每一步升级都带来更高的性能与更广的适用性，同时也需要付出更多的实现成本。

交易系统行情处理四种方案对比