C++ 实现 MCP 客户端架构与核心机制解析

通过 dup2() 将标准输入输出'嫁接'到管道，子进程完全感知不到自己在被远程控制——这正是 STDIO 传输的精妙之处。

后台读取线程

连接建立后，主线程启动一个后台线程持续从 stdout_pipe_ 读取数据：

notification_thread_ = std::thread([this]{ processNotificationsStdio(); });

读到完整的 分隔行后，解析 JSON-RPC，判断是响应还是通知，分别处理：

• 响应（有 id 字段）→ 推入 response_queue_，唤醒等待的调用方
• 通知（method == "notifications/message"）→ 调用用户注册的回调

SSE 模式：远程服务通信

SSE（Server-Sent Events）是一种基于 HTTP 的单向推送协议，非常适合服务端主动推送事件流。

整体设计

MCPClient
├── HTTP POST ────────────────→ /message （发送 JSON-RPC 请求）
└── SSE 长连接 ←──────────────── /sse （接收响应和通知）

请求与响应走两条独立通道：

1. 通过 sendRequestSSE() 发一个普通 POST 请求
2. 后台 SSE 监听线程（processNotificationsSSE()）持续接收服务端推送的事件流
3. sseWriteCallback() 解析 data: 行中的 JSON，分发到响应队列或通知回调

CURL 回调机制

size_t MCPClient::sseWriteCallback(char* ptr, size_t size, size_t nmemb, void* userdata) {
    MCPClient* client = static_cast<MCPClient*>(userdata);
    // 追加到缓冲区，寻找 "\n\n" 作为事件分隔符
    // 解析 "data: {...}" 行，提取 JSON 数据
    // 判断是响应还是通知，分别处理
    return size * nmemb;
}

请求 - 响应同步机制

无论哪种传输方式，请求和响应之间的同步都依赖同一套生产者 - 消费者模型：

// 生产者（后台读取线程）
{
    std::lock_guard<std::mutex> lock(queue_mutex_);
    response_queue_.push(response);
    queue_cv_.notify_one(); // 唤醒等待方
}

// 消费者（调用方线程）
std::unique_lock<std::mutex> lock(queue_mutex_);
queue_cv_.wait_for(lock, std::chrono::seconds(30), [this]{
    return !response_queue_.empty();
});
MCPResponse response = response_queue_.front();
response_queue_.pop();

这是经典的 条件变量 + 互斥锁 模式，保证线程安全的同时，避免了忙等（busy-waiting）带来的 CPU 浪费。

JSON-RPC 消息构造

所有请求统一通过 buildJSONRPCRequest() 序列化：

{"jsonrpc":"2.0","method":"tools/call","id":"call_tool_1712345678","params":{"name":"search","arguments":{"query":"MCP protocol"}}}

响应通过 parseJSONRPCResponse() 反序列化，区分成功结果（result 字段）与错误（error.message 字段）。

原子类型的使用

connected_ 和 running_ 均使用原子类型，避免多线程读写时的数据竞争：

std::atomic<bool> connected_{false};
std::atomic<bool> running_{false};

工具调用的完整链路

以调用一个工具为例，梳理完整的数据流：

用户代码
├─→ MCPToolManager::executeTool("search", "{\"query\":\"MCP\"}")
│   │
│   ├─→ MCPClient::callTool()
│   │   │
│   │   ├─→ 构造 MCPRequest {method="tools/call", ...}
│   │   ├─→ sendRequest() → sendRequestStdio() → write(stdin_pipe_)
│   │   │   │
│   │   │   └─→ receiveResponse() ← 阻塞等待（最多 30s）
│   │   │       │
│   │   │       ↑
│   │   │       [后台线程] processNotificationsStdio()
│   │   │           │
│   │   │           read(stdout_pipe_) → parseJSONRPCResponse()
│   │   │           response_queue_.push() + queue_cv_.notify_one()
│   │   │
│   │   └─→ 返回 MCPResponse {result: "搜索结果..."}
│   └─→ 使用工具执行结果

总结

这份 C++ MCP 客户端实现涵盖了以下核心工程要点：

• 进程间通信：fork + pipe + dup2 + execv 构成 STDIO 模式的基础
• HTTP 长连接：libcurl + SSE 事件流实现远程传输
• 线程同步：条件变量 + 互斥锁保证响应的安全传递
• 协议设计：JSON-RPC 2.0 统一请求/响应/通知的消息格式
• 接口抽象：IMCPClient 纯虚接口使传输层可替换、可测试

MCP 协议的魅力在于它把 AI 能力的扩展标准化了——无论是本地脚本还是远程服务，都能通过同一套接口被 AI 模型调用。随着 MCP 生态的成熟，这类客户端实现将成为 AI 应用开发的基础设施之一。