MCP Sampling Server 与 Client 实现

两种开发视角Server 与 Client 实现1. MCP Server发起 sampling主动调用 LLMtypescript运行// server 主动向client请求LLM生成 const result await client.request({ method: sampling/createMessage, params: { messages: [{ role: user, content: { type: text, text: 分析日志报错 } }], systemPrompt: 你是运维专家, maxTokens: 800, modelPreferences: { hints: [{ name: gemini-2.0-flash }] } } }); // result 就是标准 SamplingResult console.log(result.content.text, result.stopReason);2. MCP Client注册采样处理器你之前写的代码typescript运行// Client 注册接收 sampling/createMessage 的处理器 mcp.setRequestHandler(CreateMessageRequestSchema, async (request) { // 1. 预处理request.params.messages 所有对话 // 2. 调用本地LLMVercel AI SDK streamText/generateText // 3. 返回标准 SamplingResult 结构 return { role: assistant, model: gemini-2.0-flash, stopReason: endTurn, content: { type: text, text: 模型生成内容 } }; });你写的代码属于Client 侧采样拦截处理器负责接管所有sampling/createMessage请求对接 Gemini 完成生成。为什么负责接管所有 sampling/createMessage 请求因为sampling/createMessage本身就是 MCP 规范中 Server 向 Client 发起请你调用一个 LLM的唯一请求。当你注册mcp.setRequestHandler(CreateMessageRequestSchema, async (request) { ... });实际上是在告诉 MCP Client以后只要任何 MCP Server 发来sampling/createMessage请求都交给这个 handler 处理。所以它看起来像接管所有 sampling/createMessage 请求。MCP 的通信方向很多人第一次看都会觉得奇怪因为平时都是Client | | request v Server但是 Sampling 是反过来的。createMessage Server ---------------------- Client | | 调 LLM | ------------------------------- SamplingResult也就是说Server 不知道怎么调用 GPT、Gemini、Claude。它只知道Client请帮我生成一段文本。为什么不是 Server 自己调用这是 MCP 的设计。Server 负责工具。Client 负责模型。例如VS Code Copilot里面已经登录了 GitHub Copilot。已经有GPT-5ClaudeGemini的权限。MCP Server 根本不知道这些 API Key。于是 Server 发送{ method: sampling/createMessage, params: { messages: [ ... ] } }Client 收到以后哦 让我调用一下 Gemini。然后Gemini API ↓ 得到回复 ↓ 返回给 ServerServer 根本不知道 Gemini 的存在。setRequestHandler为什么能处理所有SDK 内部维护了一张method ↓ handler的映射。类似于handlers { sampling/createMessage: createMessageHandler, roots/listChanged: rootsHandler, logging/setLevel: loggingHandler, }当收到一条请求{ method: sampling/createMessage, ... }SDK 就会const handler handlers[sampling/createMessage]; await handler(request);所以mcp.setRequestHandler( CreateMessageRequestSchema, handler );实际上就是注册sampling/createMessage ↓ handler以后所有这个 Method 的请求都会进入这里。为什么说接管所有因为一个 Client 对于某个 Request Method 通常只能注册一个处理器。例如mcp.setRequestHandler( CreateMessageRequestSchema, handler1 ); mcp.setRequestHandler( CreateMessageRequestSchema, handler2 );通常第二个会覆盖第一个具体行为取决于 SDK 实现但一般不支持多个并行处理器。因此对于sampling/createMessage这一种请求Client 的这一处 handler 就是统一入口。在这里你可以async (request) { // ① 读取所有 messages const messages request.params.messages; // ② 做 Prompt 修改 ... // ③ 选择模型 ... // ④ 调用本地 LLM const result await generateText(...); // ⑤ 返回 SamplingResult return { role: assistant, model: ..., stopReason: endTurn, content: { type: text, text: result.text } }; }无论是哪一个 MCP Server 发起了sampling/createMessage请求只要它们连接到这个 Client都会经过这一入口。因此它不是“接管所有 MCP 请求”而是统一处理所有sampling/createMessage类型的请求。其他请求如tools/call、resources/read、prompts/get等仍然由各自对应的 handler 处理不会经过这个函数。