NexusFIX 开发专家

• GitHub：https://github.com/StratCraftsAI/NexusFIX

适用场景

当用户需要在 C++ 中构建、优化或调试 FIX 协议连接时使用。覆盖会话管理、订单录入、行情数据及低延迟消息解析。

架构设计

NexusFIX 是一个仅含头文件的 C++23 FIX 协议引擎。ExecutionReport 消息的解析延迟低于 250 纳秒，单线程吞吐量超过 400 万条/秒。

关键设计决策：

• 零拷贝解析：使用 std::span 直接引用原始缓冲区，不创建任何中间字符串副本。
• 两阶段 SIMD 解析：先通过 AVX2 / AVX-512 扫描 SOH 分隔符（获取结构索引），再按标签提取字段。其思路类似于 simdjson 处理 JSON 的方式。
• 出站消息采用 Builder 模式：例如 NewOrderSingle::Builder 链式调用字段设置器，最终通过 .build(assembler) 完成序列化。
• 使用 std::expected 进行错误处理：所有解析函数均返回 std::expected；热路径上不抛出异常。
• 定点数运算：价格类型为 FixedPrice（8 位小数），数量类型为 Qty（4 位小数）；价格计算禁用浮点数。
• PMR 内存池：预分配缓冲区，在消息处理过程中避免任何堆内存分配。

约束条件（严格）

生成使用 NexusFIX 的代码时，必须遵守以下规则：

• 仅支持 C++23：使用指定初始化器（designated initializers）、std::expected、concepts、constexpr/consteval 等特性。
• 热路径上禁止任何内存分配：消息处理循环中不得使用 new、delete、std::map、std::unordered_map 或构造 std::string。
• 禁止使用 std::endl，应改用 \n。
• 性能关键代码中禁止使用 virtual 函数。
• 热路径上禁止使用 std::shared_ptr。
• 价格不得使用浮点数；应使用 FixedPrice::from_double() 或 FixedPrice::from_string() 构造。
• 所有可能失败的函数必须返回 std::expected；访问前须检查 .has_value()。
• 热路径函数需标记为 noexcept。
• 所有 API 返回值需添加 [[nodiscard]] 属性。

常见模式

建立连接并发送订单

#include 
using namespace nfx;
using namespace nfx::fix44;

TcpTransport transport;
transport.connect("fix.broker.com", 9876);

SessionConfig config{
    .sender_comp_id = "MY_CLIENT",
    .target_comp_id = "BROKER",
    .heartbeat_interval = 30
};
SessionManager session{transport, config};
session.initiate_logon();

while (!session.is_active()) {
    session.poll();
}

MessageAssembler asm_;
NewOrderSingle::Builder order;
auto msg = order
    .cl_ord_id("ORD001")
    .symbol("AAPL")
    .side(Side::Buy)
    .order_qty(Qty::from_int(100))
    .ord_type(OrdType::Limit)
    .price(FixedPrice::from_double(150.00))
    .build(asm_);
transport.send(msg);

解析 ExecutionReport

void on_message(std::span data) {
    auto result = ExecutionReport::from_buffer(data);
    if (!result) return;

    auto& exec = *result;
    if (exec.is_fill()) {
        // 处理成交
    }
}

消息路由

auto parser = IndexedParser::parse(data);
if (!parser) return;

switch (parser->msg_type()) {
    case '8': on_execution_report(data); break;
    case 'W': on_snapshot(data); break;
    case 'X': on_incremental(data); break;
}

反模式（应避免的写法）

使用 NexusFIX 时，切勿生成如下代码：

// BAD：热路径上发生堆内存分配
std::string field_value(data.begin() + offset, data.begin() + end);

// BAD：使用 std::map 进行字段查找
std::map fields;

// BAD：使用浮点数表示价格
double price = 150.50;

// BAD：用异常控制流程
try { parse(data); } catch (...) { }

// BAD：使用 std::endl
std::cout << "done" << std::endl;

支持的 FIX 消息类型

参考文档

如需完整 API 说明，请执行：skill_view("nexusfix", "references/api-reference.md")。

如需快速上手指南，请执行：skill_view("nexusfix", "references/quick-start.md")。

校验要求

生成 NexusFIX 相关代码后，请确认以下几点：

1. 消息处理逻辑中未出现 new/delete/std::string 构造操作
2. 所有解析结果均通过 std::expected 检查（不得直接返回裸指针）
3. 价格使用 FixedPrice 类型，数量使用 Qty 类型
4. 会话生命周期符合规范：connect → logon → wait active → trade → logout