什么是 MCP？

MCP 是一个开放协议，用于标准化 AI 应用与外部工具的连接方式。

简单理解这方面，MCP 就是 AI 调用工具的"USB 接口"。

┌─────────────┐ MCP 协议 ┌─────────────┐│ 大模型 │ ←───────────────→ │ 你的工具 ││ │ │ │└─────────────┘ └─────────────┘

MCP 的三大能力

能力说明示例 Resources提供数据资源天气数据、文档内容 Tools提供可调用的工具查询天气、发送邮件 Prompts提供提示模板分析报告模板

项目结构

MCP_LLM/├── WearMCPServer/│ ├── index.js # MCP 服务主要│ └── mock.js # 模拟天气数据├── MCPServer/│ └── http.js # HTTP 传输层├── MCPClient/│ └── http_client.js # 客户端└── chat.js # 与大模型集成

第一步先这方面，创建 MCP 服务

定义服务能力

工具" this.server.setRequestHandler => );// . 处理工具调用 this.server.setRequestHandler => { if { const location = request.params.arguments?.location，// 这里可以调用真实的天气 API return { content:,};说起来，} throw new Error;})，} getServer { return this.server;}}export default WearServer;

关键点：

• Server 构造时声明 capabilities表示支持哪些能力
• setRequestHandler 注册处理器，响应客户端请求
• ListToolsRequestSchema → 返回工具列表
• CallToolRequestSchema → 执行工具调用

暴露 HTTP 接口

// MCPServer/http.jsimport express from "express";import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";import WearServer from "../WearMCPServer/index.js";const app = express;app.use)，话说回来，const wearServer = new WearServer;// 主要：POST /mcp 处理所有 MCP 请求app.post => { try { const server = wearServer.getServer;// 每个请求创建独立的传输实例 const transport = new StreamableHTTPServerTransport;// 请求结束时清理资源 res.on => { transport.close;server.close;})，按理说，// 连接 MCP 服务器与传输层 await server.connect;老实说，// 处理请求并返回响应 await transport.handleRequest;} catch { res.status.json;}})，app.listen => { console.log;
})，

为什么每次请求都创建新的 transport？

• 隔离性避免并发请求的 ID 冲突
• 无状态适合负载均衡和水平
• 资源清理请求结束自动释放

再看接下来，创建客户端

// MCPClient/http_client.jsimport { Client } from "@modelcontextprotocol/sdk/client/index.js";import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.";说起来，// 创建客户端const client = new Client;// 连接到 MCP 服务const transport = new StreamableHTTPClientTransport,);怎么说呢，await client.connect;// 现在可以调用 MCP 能力了！const tools = await client.listTools;console.log，const result = await client.
callTool;console.
log;export default client;

：与大模型集成

// chat./chat.

async function runConversation {// . 从 MCP 获取可用工具 const mcpTools = await mcpClient. listTools;// . 发送给大模型，让它决定是否调用工具 const response = await zhipuClient. createCompletions;// . 如果大模型决定调用工具 const toolCall = message. tool_calls;// . 执行 MCP 工具调用 const toolResult = await mcpClient. callTool}} );// . 把结果返回给大模型生成最终回答 const finalResponse = await zhipuClient. createCompletions;按理说，console. log;// 输出：北京今天天气晴朗，气温25°C，湿度45%，非常适合出行。})，

完整流程图

使用者："北京天气怎么样？" │ ▼┌───────────────────────────────────────────────────────────┐│ chat./chat.

= client._listTools ——→ 获取 MCP 工具列表 ││ │ │◆◆◆◆◆◆◆◆◆◆◆◆◆◆ ◆ MCPServer/

= POST /mcp ——→ StreamableHTTPServerTransport ▲ ▲ ▼ ▼HTTP POST | 工具结果 | |┌───────────────────────────────────────────────────────────┐ | | | WearMCPServer/

= ListToolsRequestSchema | | CallToolRequestSchema |└───────────────────────────────────────────────────────────┘

运行项目

安装依赖

pnpm install

设置环境变量

# .envZHIPUAI_API_KEY=your_api_key_here

开启服务

# 终端 ：启动 MCP HTTP 服务node MCPServer/http./终端 ：运行对话node main./http.

主要概念

概念服务端客户端 入口类ServerClient 传输层StreamableHTTPServerTransportStreamableHTTPClientTransport 声明能力capabilities:{tools:{}} -注册处理img

---