\n- STDIO：\u901a\u8fc7\u6807\u51c6\u8f93\u5165\/\u8f93\u51fa\u901a\u4fe1，\u9002\u5408\u672c\u5730\u5b50\u8fdb\u7a0b\u6a21\u5f0f<\/li>\n
- SSE（Server-Sent Events）：\u901a\u8fc7 HTTP \u957f\u8fde\u63a5\u901a\u4fe1，\u9002\u5408\u8fdc\u7a0b\u6a21\u5f0f<\/li>\n<\/ul>\n
\u672c\u6587\u5148\u7528 STDIO \u5b9e\u73b0\u6838\u5fc3\u903b\u8f91，\u518d\u6269\u5c55\u5230 SSE\u3002<\/p>\n
\n2. JSON-RPC \u57fa\u7840<\/h3>\n
MCP \u4f7f\u7528 JSON-RPC 2.0 \u4f5c\u4e3a\u6d88\u606f\u683c\u5f0f\u3002\u6bcf\u6761\u6d88\u606f\u90fd\u662f\u4e00\u4e2a JSON \u5bf9\u8c61：<\/p>\n
\u8bf7\u6c42(Request)：<\/p>\n
{
\n "jsonrpc": "2.0",
\n "id": 1,
\n "method": "tools\/list",
\n "params": {}
\n}<\/p>\n
\u6210\u529f\u54cd\u5e94(Success Response)：<\/p>\n
{
\n "jsonrpc": "2.0",
\n "id": 1,
\n "result": {
\n "tools": […]
\n }
\n}<\/p>\n
\u9519\u8bef\u54cd\u5e94(Error Response)：<\/p>\n
{
\n "jsonrpc": "2.0",
\n "id": 1,
\n "error": {
\n "code": -32601,
\n "message": "Method not found"
\n }
\n}<\/p>\n
\u901a\u77e5(Notification)： \u6ca1\u6709 id \u7684\u6d88\u606f，Server \u4e0d\u9700\u8981\u56de\u590d\u3002<\/p>\n
{
\n "jsonrpc": "2.0",
\n "method": "notifications\/initialized",
\n "params": {}
\n}<\/p>\n
\u5148\u5199\u4e00\u4e2a\u57fa\u7840\u7684 JSON-RPC \u6d88\u606f\u5904\u7406\u7c7b：<\/p>\n
import json
\nimport sys
\nimport uuid
\nfrom typing import Any, Callable, Dict, Optional
\nfrom dataclasses import dataclass, field<\/p>\n
class JSONRPCError(Exception):
\n """JSON-RPC \u9519\u8bef\u57fa\u7c7b"""
\n def __init__(self, code: int, message: str, data: Any = None):
\n self.code = code
\n self.message = message
\n self.data = data
\n super().__init__(message)<\/p>\n
class MethodNotFound(JSONRPCError):
\n def __init__(self, method: str):
\n super().__init__(-32601, f"Method not found: {method}")<\/p>\n
class InvalidParams(JSONRPCError):
\n def __init__(self, message: str):
\n super().__init__(-32602, message)<\/p>\n
class InternalError(JSONRPCError):
\n def __init__(self, message: str):
\n super().__init__(-32603, message)<\/p>\n
def make_request(method: str, params: dict = None, request_id: int = None) -> dict:
\n """\u6784\u9020 JSON-RPC \u8bf7\u6c42"""
\n if request_id is None:
\n request_id = uuid.uuid4().int & (1 << 31) – 1
\n msg = {
\n "jsonrpc": "2.0",
\n "id": request_id,
\n "method": method,
\n }
\n if params is not None:
\n msg["params"] = params
\n return msg<\/p>\n
def make_notification(method: str, params: dict = None) -> dict:
\n """\u6784\u9020\u901a\u77e5\u6d88\u606f（\u65e0 id）"""
\n msg = {"jsonrpc": "2.0", "method": method}
\n if params is not None:
\n msg["params"] = params
\n return msg<\/p>\n
def make_success_response(request_id: int, result: Any) -> dict:
\n """\u6784\u9020\u6210\u529f\u54cd\u5e94"""
\n return {"jsonrpc": "2.0", "id": request_id, "result": result}<\/p>\n
def make_error_response(request_id: int, error: JSONRPCError) -> dict:
\n """\u6784\u9020\u9519\u8bef\u54cd\u5e94"""
\n resp = {"jsonrpc": "2.0", "id": request_id, "error": {"code": error.code, "message": error.message}}
\n if error.data is not None:
\n resp["error"]["data"] = error.data
\n return resp<\/p>\n
\u8fd9\u6bb5\u4ee3\u7801\u53ea\u6709 60 \u884c，\u4f46\u5df2\u7ecf\u8986\u76d6\u4e86 JSON-RPC \u7684\u5168\u90e8\u6838\u5fc3\u7c7b\u578b：\u8bf7\u6c42\u3001\u901a\u77e5\u3001\u6210\u529f\/\u9519\u8bef\u54cd\u5e94\u3002\u4e4b\u540e\u6240\u6709\u7684 MCP \u901a\u4fe1\u90fd\u57fa\u4e8e\u8fd9\u4e2a\u5e95\u5c42\u3002<\/p>\n
\n3. \u624b\u5199 MCP Server<\/h3>\n
\u6709\u4e86 JSON-RPC \u57fa\u7840，\u63a5\u4e0b\u6765\u5b9e\u73b0 Server \u7aef\u3002<\/p>\n
\u4e00\u4e2a MCP Server \u7684\u751f\u547d\u5468\u671f\u5206\u4e3a\u4e09\u4e2a\u9636\u6bb5： 1. \u521d\u59cb\u5316\u9636\u6bb5：\u63a5\u6536 Client \u7684 initialize \u8bf7\u6c42，\u8fd4\u56de\u80fd\u529b\u58f0\u660e（\u63d0\u4f9b\u4e86\u54ea\u4e9b\u5de5\u5177\u3001\u8d44\u6e90） 2. \u5c31\u7eea\u9636\u6bb5：\u63a5\u6536 Client \u7684 notifications\/initialized \u901a\u77e5，\u786e\u8ba4\u63e1\u624b\u5b8c\u6210 3. \u8fd0\u884c\u9636\u6bb5：\u6301\u7eed\u5904\u7406\u5de5\u5177\u8c03\u7528\u3001\u8d44\u6e90\u8bfb\u53d6\u7b49\u8bf7\u6c42<\/p>\n
\u8fd9\u4e2a\u6d41\u7a0b\u548c TCP \u7684\u4e09\u6b21\u63e1\u624b\u6709\u5f02\u66f2\u540c\u5de5\u4e4b\u5904\u2014\u2014\u5148\u534f\u5546\u80fd\u529b，\u518d\u5f00\u59cb\u6b63\u5f0f\u901a\u4fe1\u3002<\/p>\n
3.1 \u5b9a\u4e49\u5de5\u5177\u6a21\u578b<\/h4>\n
MCP \u7684\u5de5\u5177（Tool）\u662f\u4e00\u4e2a\u5305\u542b\u63cf\u8ff0\u548c\u53c2\u6570 schema \u7684\u53ef\u8c03\u7528\u51fd\u6570\u3002\u6211\u4eec\u5148\u5b9a\u4e49\u6570\u636e\u6a21\u578b：<\/p>\n
@dataclass
\nclass Tool:
\n """MCP \u5de5\u5177\u5b9a\u4e49"""
\n name: str
\n description: str
\n input_schema: dict # JSON Schema
\n handler: Callable # \u5b9e\u9645\u7684 Python \u51fd\u6570<\/p>\n
@dataclass
\nclass Resource:
\n """MCP \u8d44\u6e90\u5b9a\u4e49"""
\n uri: str
\n name: str
\n description: str = ""
\n mime_type: str = "text\/plain"<\/p>\n
@dataclass
\nclass Prompt:
\n """MCP \u63d0\u793a\u6a21\u677f"""
\n name: str
\n description: str = ""
\n arguments: list = field(default_factory=list)<\/p>\n
3.2 \u5b9e\u73b0 Server \u6838\u5fc3<\/h4>\n
Server \u7684\u6838\u5fc3\u804c\u8d23： 1. \u6ce8\u518c\u5de5\u5177\u3001\u8d44\u6e90\u3001\u63d0\u793a 2. \u901a\u8fc7 STDIO \u8bfb\u53d6 JSON-RPC \u8bf7\u6c42 3. \u5206\u53d1\u8bf7\u6c42\u5230\u5bf9\u5e94\u7684\u65b9\u6cd5\u5904\u7406\u5668 4. \u8fd4\u56de JSON-RPC \u54cd\u5e94<\/p>\n
import sys
\nimport json
\nimport threading
\nfrom typing import Optional<\/p>\n
class MCPServer:
\n """
\n \u7eaf\u624b\u5199 MCP Server，\u57fa\u4e8e STDIO \u4f20\u8f93
\n \u4e0d\u4f9d\u8d56\u4efb\u4f55 MCP SDK
\n """<\/p>\n
def __init__(self, server_name: str = "mcp-server", version: str = "1.0.0"):
\n self.server_name = server_name
\n self.version = version
\n self._tools: Dict[str, Tool] = {}
\n self._resources: Dict[str, Resource] = {}
\n self._prompts: Dict[str, Prompt] = {}
\n self._initialized = False
\n self._request_handlers: Dict[str, Callable] = {}
\n self._running = False<\/p>\n
# \u6ce8\u518c\u5185\u7f6e\u65b9\u6cd5
\n self._request_handlers = {
\n "initialize": self._handle_initialize,
\n "initialized": self._handle_initialized,
\n "tools\/list": self._handle_tools_list,
\n "tools\/call": self._handle_tools_call,
\n "resources\/list": self._handle_resources_list,
\n "resources\/read": self._handle_resources_read,
\n "prompts\/list": self._handle_prompts_list,
\n }<\/p>\n
def register_tool(self, tool: Tool):
\n """\u6ce8\u518c\u4e00\u4e2a\u5de5\u5177"""
\n if tool.name in self._tools:
\n raise ValueError(f"Tool already registered: {tool.name}")
\n self._tools[tool.name] = tool<\/p>\n
def tool(self, name: str, description: str = "", input_schema: dict = None):
\n """\u88c5\u9970\u5668\u65b9\u5f0f\u6ce8\u518c\u5de5\u5177"""
\n def decorator(func):
\n schema = input_schema or {
\n "type": "object",
\n "properties": {},
\n "required": []
\n }
\n t = Tool(
\n name=name,
\n description=description or func.__doc__ or "",
\n input_schema=schema,
\n handler=func
\n )
\n self.register_tool(t)
\n return func
\n return decorator<\/p>\n
def register_resource(self, resource: Resource):
\n self._resources[resource.uri] = resource<\/p>\n
def register_prompt(self, prompt: Prompt):
\n self._prompts[prompt.name] = prompt<\/p>\n
# —- \u534f\u8bae\u65b9\u6cd5\u5904\u7406 —-<\/p>\n
def _handle_initialize(self, params: dict) -> dict:
\n """\u5904\u7406\u521d\u59cb\u5316\u8bf7\u6c42，\u8fd4\u56de Server \u80fd\u529b\u58f0\u660e"""
\n protocol_version = params.get("protocolVersion", "2025-03-26")
\n self._initialized = True<\/p>\n
# \u6536\u96c6 Server \u652f\u6301\u7684\u80fd\u529b
\n capabilities = {
\n "tools": {} if self._tools else None,
\n "resources": {} if self._resources else None,
\n "prompts": {} if self._prompts else None,
\n }
\n # \u79fb\u9664 None \u7684\u80fd\u529b
\n capabilities = {k: v for k, v in capabilities.items() if v is not None}<\/p>\n
return {
\n "protocolVersion": protocol_version,
\n "serverInfo": {
\n "name": self.server_name,
\n "version": self.version,
\n },
\n "capabilities": capabilities,
\n }<\/p>\n
def _handle_initialized(self, params: dict):
\n """\u5904\u7406\u521d\u59cb\u5316\u901a\u77e5（Client \u786e\u8ba4\u521d\u59cb\u5316\u5b8c\u6210）"""
\n # \u65e0\u8fd4\u56de\u503c（\u901a\u77e5\u4e0d\u9700\u8981\u54cd\u5e94）
\n return None<\/p>\n
def _handle_tools_list(self, params: dict) -> dict:
\n """\u8fd4\u56de\u6240\u6709\u5df2\u6ce8\u518c\u7684\u5de5\u5177"""
\n tools_list = []
\n for t in self._tools.values():
\n tools_list.append({
\n "name": t.name,
\n "description": t.description,
\n "inputSchema": t.input_schema,
\n })
\n return {"tools": tools_list}<\/p>\n
def _handle_tools_call(self, params: dict) -> dict:
\n """\u8c03\u7528\u6307\u5b9a\u7684\u5de5\u5177"""
\n name = params.get("name")
\n arguments = params.get("arguments", {})<\/p>\n
if name not in self._tools:
\n raise MethodNotFound(f"Tool not found: {name}")<\/p>\n
tool = self._tools[name]
\n try:
\n result = tool.handler(**arguments)<\/p>\n
# MCP \u5de5\u5177\u8c03\u7528\u7684\u6807\u51c6\u7ed3\u679c\u683c\u5f0f
\n if isinstance(result, str):
\n content = [{"type": "text", "text": result}]
\n elif isinstance(result, (dict, list)):
\n content = [{"type": "text", "text": json.dumps(result, ensure_ascii=False)}]
\n else:
\n content = [{"type": "text", "text": str(result)}]<\/p>\n
return {"content": content}
\n except Exception as e:
\n raise InternalError(str(e))<\/p>\n
def _handle_resources_list(self, params: dict) -> dict:
\n resources_list = []
\n for r in self._resources.values():
\n resources_list.append({
\n "uri": r.uri,
\n "name": r.name,
\n "description": r.description,
\n "mimeType": r.mime_type,
\n })
\n return {"resources": resources_list}<\/p>\n
def _handle_resources_read(self, params: dict) -> dict:
\n uri = params.get("uri")
\n if uri not in self._resources:
\n raise MethodNotFound(f"Resource not found: {uri}")
\n return {"contents": []} # \u5b9e\u9645\u60c5\u51b5\u4f1a\u8fd4\u56de\u8d44\u6e90\u5185\u5bb9<\/p>\n
def _handle_prompts_list(self, params: dict) -> dict:
\n prompts_list = []
\n for p in self._prompts.values():
\n prompts_list.append({
\n "name": p.name,
\n "description": p.description,
\n "arguments": p.arguments,
\n })
\n return {"prompts": prompts_list}<\/p>\n
# —- \u6d88\u606f\u5206\u53d1 —-<\/p>\n
def _process_message(self, raw: str) -> Optional[str]:
\n """\u5904\u7406\u4e00\u6761 JSON-RPC \u6d88\u606f，\u8fd4\u56de\u54cd\u5e94\u6d88\u606f（\u5982\u679c\u6709）"""
\n try:
\n msg = json.loads(raw)
\n except json.JSONDecodeError:
\n return None # \u9759\u9ed8\u4e22\u5f03\u65e0\u6548 JSON<\/p>\n
method = msg.get("method")
\n params = msg.get("params", {})
\n msg_id = msg.get("id")<\/p>\n
# \u901a\u77e5：\u6ca1\u6709 id，\u65e0\u9700\u54cd\u5e94
\n if msg_id is None:
\n handler = self._request_handlers.get(method)
\n if handler:
\n try:
\n handler(params)
\n except Exception:
\n pass # \u901a\u77e5\u5904\u7406\u5931\u8d25\u65e0\u9700\u901a\u77e5\u8c03\u7528\u65b9
\n return None<\/p>\n
# \u8bf7\u6c42：\u6709 id，\u9700\u8981\u54cd\u5e94
\n handler = self._request_handlers.get(method)
\n if handler is None:
\n return json.dumps(make_error_response(msg_id, MethodNotFound(method)))<\/p>\n
try:
\n result = handler(params)
\n if result is None:
\n # handler \u8fd4\u56de None \u8868\u793a\u4e0d\u9700\u8981\u54cd\u5e94（\u4f8b\u5982 initialized \u901a\u77e5\u7684\u54cd\u5e94）
\n return None
\n return json.dumps(make_success_response(msg_id, result))
\n except JSONRPCError as e:
\n return json.dumps(make_error_response(msg_id, e))
\n except Exception as e:
\n return json.dumps(make_error_response(msg_id, InternalError(str(e))))<\/p>\n
def run_stdio(self):
\n """\u901a\u8fc7 STDIO \u8fd0\u884c Server（\u4e3b\u5faa\u73af）"""
\n self._running = True<\/p>\n
# \u7b2c\u4e00\u884c\u8f93\u51fa Server \u6807\u8bc6（MCP \u534f\u8bae\u7ea6\u5b9a）
\n # \u5b9e\u9645\u751f\u4ea7\u73af\u5883\u4e2d\u4f7f\u7528 Line-delimited JSON
\n for line in sys.stdin:
\n line = line.strip()
\n if not line:
\n continue<\/p>\n
response = self._process_message(line)
\n if response:
\n sys.stdout.write(response + "\\\\n")
\n sys.stdout.flush()<\/p>\n
def run(self):
\n """\u542f\u52a8 Server"""
\n self.run_stdio()<\/p>\n
\u4e0d\u5230 200 \u884c\u7684\u4ee3\u7801，\u4e00\u4e2a\u53ef\u4ee5\u8fd0\u884c\u7684 MCP Server \u5c31\u5b8c\u6210\u4e86\u3002\u6838\u5fc3\u6d41\u7a0b：<\/p>\n
- \u6ce8\u518c\u5de5\u5177\u5230 _tools \u5b57\u5178<\/li>\n
- \u6bcf\u6536\u5230\u4e00\u884c JSON，\u89e3\u6790\u540e\u627e\u5230\u5bf9\u5e94\u65b9\u6cd5\u5904\u7406<\/li>\n
- \u8fd4\u56de JSON-RPC \u54cd\u5e94<\/li>\n
3.3 \u5b9a\u4e49\u5b9e\u9645\u5de5\u5177<\/h4>\n
\u73b0\u5728\u7528\u6211\u4eec\u7684 MCP Server \u6ce8\u518c\u51e0\u4e2a\u771f\u5b9e\u53ef\u7528\u7684\u5de5\u5177：<\/p>\n
# \u521b\u5efa\u4e00\u4e2a\u5b9e\u9645\u53ef\u7528\u7684 MCP Server
\nimport datetime
\nimport random<\/p>\n
def create_demo_server() -> MCPServer:
\n server = MCPServer(
\n server_name="demo-server",
\n version="1.0.0"
\n )<\/p>\n
@server.tool(
\n name="get_weather",
\n description="\u83b7\u53d6\u6307\u5b9a\u57ce\u5e02\u7684\u5b9e\u65f6\u5929\u6c14\u4fe1\u606f",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "city": {
\n "type": "string",
\n "description": "\u57ce\u5e02\u540d\u79f0，\u5982 \u5317\u4eac\u3001\u4e0a\u6d77\u3001\u6df1\u5733"
\n }
\n },
\n "required": ["city"]
\n }
\n )
\n def get_weather(city: str) -> str:
\n """\u6a21\u62df\u83b7\u53d6\u5929\u6c14\u6570\u636e"""
\n weathers = ["\u2600\ufe0f \u6674", "\u26c5 \u591a\u4e91", "🌧\ufe0f \u5c0f\u96e8", "🌩\ufe0f \u96f7\u9635\u96e8", "🌫\ufe0f \u96fe"]
\n temps = {city: random.randint(15, 35) for city in ["\u5317\u4eac", "\u4e0a\u6d77", "\u6df1\u5733", "\u5e7f\u5dde", "\u676d\u5dde"]}
\n temp = temps.get(city, random.randint(10, 30))
\n weather = random.choice(weathers)
\n return f"{city} \u5f53\u524d\u5929\u6c14：{weather}，\u6e29\u5ea6 {temp}\u00b0C，\u6e7f\u5ea6 {random.randint(40, 80)}%"<\/p>\n
@server.tool(
\n name="calculate",
\n description="\u6267\u884c\u6570\u5b66\u8ba1\u7b97",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "expression": {
\n "type": "string",
\n "description": "\u6570\u5b66\u8868\u8fbe\u5f0f，\u5982 2 + 3 * 4"
\n }
\n },
\n "required": ["expression"]
\n }
\n )
\n def calculate(expression: str) -> str:
\n """\u5b89\u5168\u6267\u884c\u6570\u5b66\u8868\u8fbe\u5f0f\u8ba1\u7b97"""
\n # \u6ce8\u610f：\u751f\u4ea7\u73af\u5883\u5e94\u4f7f\u7528 ast \u6216\u8005 safer \u7684\u8868\u8fbe\u5f0f\u5f15\u64ce
\n # \u8fd9\u91cc\u6f14\u793a\u7528 eval \u4f46\u53ea\u5141\u8bb8\u6570\u5b57\u548c\u8fd0\u7b97\u7b26
\n allowed = set("0123456789.+-*\/()% ")
\n if not all(c in allowed for c in expression):
\n return "\u9519\u8bef：\u8868\u8fbe\u5f0f\u5305\u542b\u4e0d\u5141\u8bb8\u7684\u5b57\u7b26"
\n try:
\n result = eval(expression, {"__builtins__": {}}, {})
\n return f"{expression} = {result}"
\n except Exception as e:
\n return f"\u8ba1\u7b97\u9519\u8bef：{str(e)}"<\/p>\n
@server.tool(
\n name="get_current_time",
\n description="\u83b7\u53d6\u5f53\u524d\u65e5\u671f\u548c\u65f6\u95f4",
\n input_schema={
\n "type": "object",
\n "properties": {},
\n "required": []
\n }
\n )
\n def get_current_time() -> str:
\n now = datetime.datetime.now()
\n return f"\u5f53\u524d\u65f6\u95f4：{now.strftime('%Y\u5e74%m\u6708%d\u65e5 %H:%M:%S')} \u661f\u671f{['\u4e00','\u4e8c','\u4e09','\u56db','\u4e94','\u516d','\u65e5'][now.weekday()]}"<\/p>\n
@server.tool(
\n name="search_knowledge",
\n description="\u641c\u7d22\u672c\u5730\u77e5\u8bc6\u5e93（\u6a21\u62df）",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "query": {
\n "type": "string",
\n "description": "\u641c\u7d22\u5173\u952e\u8bcd"
\n },
\n "limit": {
\n "type": "integer",
\n "description": "\u8fd4\u56de\u7ed3\u679c\u6570\u91cf",
\n "default": 3
\n }
\n },
\n "required": ["query"]
\n }
\n )
\n def search_knowledge(query: str, limit: int = 3) -> str:
\n """\u6a21\u62df\u77e5\u8bc6\u5e93\u641c\u7d22"""
\n # \u6a21\u62df\u77e5\u8bc6\u5e93
\n knowledge_base = {
\n "python": [
\n "Python \u662f\u4e00\u79cd\u89e3\u91ca\u578b\u3001\u9762\u5411\u5bf9\u8c61\u7684\u9ad8\u7ea7\u7f16\u7a0b\u8bed\u8a00\u3002",
\n "Python 3.13 \u5f15\u5165\u4e86 JIT \u7f16\u8bd1\u5668\u548c\u81ea\u7531\u7ebf\u7a0b\u6a21\u5f0f\u3002",
\n "Python \u7684 asyncio \u5e93\u652f\u6301\u5f02\u6b65\u7f16\u7a0b\u3002",
\n ],
\n "mcp": [
\n "MCP（Model Context Protocol）\u662f Anthropic \u63d0\u51fa\u7684\u5f00\u653e\u534f\u8bae\u3002",
\n "MCP \u5b9a\u4e49\u4e86 AI \u6a21\u578b\u4e0e\u5916\u90e8\u5de5\u5177\/\u6570\u636e\u6e90\u7684\u6807\u51c6\u901a\u4fe1\u65b9\u5f0f\u3002",
\n "MCP \u652f\u6301 STDIO \u548c SSE \u4e24\u79cd\u4f20\u8f93\u65b9\u5f0f\u3002",
\n ],
\n "ai": [
\n "AI Agent \u662f\u5177\u5907\u81ea\u4e3b\u51b3\u7b56\u80fd\u529b\u7684\u5927\u6a21\u578b\u5e94\u7528\u5f62\u6001\u3002",
\n "ReAct \u6a21\u5f0f\u8ba9 Agent \u901a\u8fc7\u601d\u8003-\u884c\u52a8-\u89c2\u5bdf\u5faa\u73af\u5b8c\u6210\u4efb\u52a1\u3002",
\n "Function Calling \u8ba9\u5927\u6a21\u578b\u80fd\u591f\u8c03\u7528\u5916\u90e8\u5de5\u5177\u548c API\u3002",
\n ]
\n }<\/p>\n
results = []
\n for keyword, articles in knowledge_base.items():
\n if query.lower() in keyword.lower():
\n results.extend(articles)<\/p>\n
for articles in knowledge_base.values():
\n for article in articles:
\n if query.lower() in article.lower():
\n results.append(article)<\/p>\n
if not results:
\n return f"\u672a\u627e\u5230\u4e0e\u300c{query}\u300d\u76f8\u5173\u7684\u77e5\u8bc6\u6761\u76ee\u3002"<\/p>\n
results = results[:limit]
\n output = f"\u627e\u5230 {len(results)} \u6761\u76f8\u5173\u7ed3\u679c：\\\\n\\\\n"
\n for i, r in enumerate(results, 1):
\n output += f"{i}. {r}\\\\n"
\n return output<\/p>\n
return server<\/p>\n
\u8fd9\u56db\u4e2a\u5de5\u5177\u8986\u76d6\u4e86\u4e0d\u540c\u7684\u8f93\u5165\u8f93\u51fa\u6a21\u5f0f： – get_weather：\u5fc5\u586b\u53c2\u6570，\u8fd4\u56de\u683c\u5f0f\u5316\u6587\u672c – calculate：\u5e26\u5b89\u5168\u6821\u9a8c\u7684\u53c2\u6570 – get_current_time：\u65e0\u53c2\u6570 – search_knowledge：\u5e26\u9ed8\u8ba4\u503c\u7684\u53c2\u6570<\/p>\n
\u8fd9\u91cc\u6709\u51e0\u4e2a\u5173\u952e\u8bbe\u8ba1\u8981\u70b9\u503c\u5f97\u6ce8\u610f：<\/p>\n
1. \u65b9\u6cd5\u5206\u53d1\u5668\u7684\u8bbe\u8ba1\u6a21\u5f0f<\/p>\n
_request_handlers \u5b57\u5178\u5b9e\u73b0\u4e86\u4e00\u4e2a\u7b80\u5355\u7684\u8def\u7531\u5206\u53d1\u5668，\u5c06\u65b9\u6cd5\u540d\u6620\u5c04\u5230\u5bf9\u5e94\u7684\u5904\u7406\u51fd\u6570\u3002\u8fd9\u79cd\u6a21\u5f0f\u7684\u597d\u5904\u662f： – \u65b0\u589e\u65b9\u6cd5\u53ea\u9700\u8981\u6dfb\u52a0\u4e00\u4e2a\u952e\u503c\u5bf9 – \u6bcf\u4e2a\u65b9\u6cd5\u72ec\u7acb\u5b9e\u73b0，\u804c\u8d23\u6e05\u6670 – \u53ef\u4ee5\u7075\u6d3b\u5730\u91cd\u5199\u6216\u6269\u5c55<\/p>\n
2. \u80fd\u529b\u58f0\u660e\u7684\u534f\u5546\u673a\u5236<\/p>\n
\u5728 _handle_initialize \u4e2d，Server \u4f1a\u6839\u636e\u5b9e\u9645\u6ce8\u518c\u7684\u5185\u5bb9\u52a8\u6001\u6784\u5efa\u80fd\u529b\u58f0\u660e\u3002\u5982\u679c\u4e00\u4e2a Server \u53ea\u6ce8\u518c\u4e86\u5de5\u5177\u800c\u6ca1\u6709\u6ce8\u518c\u8d44\u6e90，resources \u80fd\u529b\u5c31\u4e0d\u4f1a\u51fa\u73b0\u5728\u58f0\u660e\u4e2d\u3002\u8fd9\u79cd\u8bbe\u8ba1\u8ba9 Client \u53ef\u4ee5\u7cbe\u786e\u77e5\u9053 Server \u652f\u6301\u4ec0\u4e48\u3002<\/p>\n
3. \u9519\u8bef\u5904\u7406\u7684\u5206\u5c42\u8bbe\u8ba1<\/p>\n
JSONRPCError \u7684\u7ee7\u627f\u4f53\u7cfb\u8ba9\u9519\u8bef\u5904\u7406\u975e\u5e38\u6709\u5c42\u6b21： – MethodNotFound：\u65b9\u6cd5\u540d\u9519\u8bef（\u534f\u8bae\u5c42\u9519\u8bef） – InvalidParams：\u53c2\u6570\u6821\u9a8c\u5931\u8d25（\u4e1a\u52a1\u5c42\u9519\u8bef） – InternalError：\u5185\u90e8\u6267\u884c\u5f02\u5e38（\u5b9e\u73b0\u5c42\u9519\u8bef）<\/p>\n
3.4 \u542f\u52a8 Server<\/h4>\n
if __name__ == "__main__":
\n server = create_demo_server()
\n print("🧩 MCP Demo Server \u5df2\u542f\u52a8", file=sys.stderr)
\n print(f"📦 \u5df2\u6ce8\u518c {len(server._tools)} \u4e2a\u5de5\u5177", file=sys.stderr)
\n server.run()<\/p>\n
\u7528\u4e00\u884c\u547d\u4ee4\u6d4b\u8bd5：<\/p>\n
# \u53d1\u9001\u521d\u59cb\u5316\u8bf7\u6c42
\necho '{"jsonrpc":"2.0","id":1,"method":"initialize","params":{"protocolVersion":"2025-03-26"}}' | python mcp_server.py<\/p>\n
# \u5217\u51fa\u5de5\u5177
\necho '{"jsonrpc":"2.0","id":2,"method":"tools\/list","params":{}}' | python mcp_server.py<\/p>\n
\n4. \u624b\u5199 MCP Client<\/h3>\n
Server \u5199\u597d\u4e86，\u73b0\u5728\u5199\u4e00\u4e2a Client \u6765\u4f7f\u7528\u5b83\u3002Client \u7684\u6838\u5fc3\u804c\u8d23：<\/p>\n
- \u4e0e Server \u5efa\u7acb\u8fde\u63a5（STDIO \u6216 SSE）<\/li>\n
- \u53d1\u9001\u521d\u59cb\u5316\u63e1\u624b<\/li>\n
- \u53d1\u73b0 Server \u63d0\u4f9b\u7684\u5de5\u5177<\/li>\n
- \u8c03\u7528\u5de5\u5177\u5e76\u83b7\u53d6\u7ed3\u679c<\/li>\n
- \u5c01\u88c5\u6210\u53cb\u597d\u7684\u8c03\u7528\u63a5\u53e3<\/li>\n
import subprocess
\nimport json
\nimport threading
\nfrom typing import Optional<\/p>\n
class MCPClient:
\n """
\n \u7eaf\u624b\u5199 MCP Client，\u8fde\u63a5 STDIO \u6a21\u5f0f\u7684 Server
\n \u4e0d\u4f9d\u8d56\u4efb\u4f55 MCP SDK
\n """<\/p>\n
def __init__(self, server_command: list[str]):
\n """
\n Args:
\n server_command: \u542f\u52a8 Server \u7684\u547d\u4ee4，\u5982 ["python", "server.py"]
\n """
\n self._server_command = server_command
\n self._process: Optional[subprocess.Popen] = None
\n self._request_id = 0
\n self._pending: Dict[int, threading.Event] = {}
\n self._results: Dict[int, dict] = {}
\n self._lock = threading.Lock()
\n self._reader_thread: Optional[threading.Thread] = None
\n self._server_info = None
\n self._capabilities = None<\/p>\n
def connect(self):
\n """\u542f\u52a8 Server \u8fdb\u7a0b\u5e76\u8fde\u63a5"""
\n self._process = subprocess.Popen(
\n self._server_command,
\n stdin=subprocess.PIPE,
\n stdout=subprocess.PIPE,
\n stderr=subprocess.PIPE,
\n text=True,
\n bufsize=1, # \u884c\u7f13\u51b2
\n )<\/p>\n
# \u542f\u52a8\u8bfb\u53d6\u7ebf\u7a0b
\n self._reader_thread = threading.Thread(
\n target=self._read_loop,
\n daemon=True
\n )
\n self._reader_thread.start()<\/p>\n
def _read_loop(self):
\n """\u540e\u53f0\u7ebf\u7a0b：\u6301\u7eed\u8bfb\u53d6 Server \u8f93\u51fa"""
\n while self._process and self._process.poll() is None:
\n line = self._process.stdout.readline()
\n if not line:
\n break
\n line = line.strip()
\n if not line:
\n continue<\/p>\n
try:
\n response = json.loads(line)
\n msg_id = response.get("id")<\/p>\n
if msg_id is not None and msg_id in self._pending:
\n with self._lock:
\n self._results[msg_id] = response
\n self._pending[msg_id].set()
\n except json.JSONDecodeError:
\n pass # \u5ffd\u7565\u65e0\u6548\u884c<\/p>\n
def _send_request(self, method: str, params: dict = None) -> dict:
\n """\u53d1\u9001\u8bf7\u6c42\u5e76\u7b49\u5f85\u54cd\u5e94（\u540c\u6b65\u8c03\u7528）"""
\n with self._lock:
\n self._request_id += 1
\n req_id = self._request_id
\n event = threading.Event()
\n self._pending[req_id] = event<\/p>\n
request = make_request(method, params, req_id)
\n request_str = json.dumps(request) + "\\\\n"<\/p>\n
self._process.stdin.write(request_str)
\n self._process.stdin.flush()<\/p>\n
# \u7b49\u5f85\u54cd\u5e94（\u6700\u591a 30 \u79d2）
\n if not event.wait(timeout=30):
\n raise TimeoutError(f"Request timed out: {method}")<\/p>\n
with self._lock:
\n response = self._results.pop(req_id)
\n self._pending.pop(req_id)<\/p>\n
if "error" in response:
\n err = response["error"]
\n raise JSONRPCError(err.get("code", 0), err.get("message", "Unknown error"))<\/p>\n
return response.get("result", {})<\/p>\n
def initialize(self):
\n """\u53d1\u9001\u521d\u59cb\u5316\u8bf7\u6c42，\u5b8c\u6210\u63e1\u624b"""
\n result = self._send_request("initialize", {
\n "protocolVersion": "2025-03-26",
\n "capabilities": {},
\n "clientInfo": {
\n "name": "mcp-client-demo",
\n "version": "1.0.0"
\n }
\n })<\/p>\n
self._server_info = result.get("serverInfo", {})
\n self._capabilities = result.get("capabilities", {})<\/p>\n
# \u53d1\u9001 initialized \u901a\u77e5
\n notif = make_notification("notifications\/initialized")
\n self._process.stdin.write(json.dumps(notif) + "\\\\n")
\n self._process.stdin.flush()<\/p>\n
return result<\/p>\n
def list_tools(self) -> list:
\n """\u83b7\u53d6 Server \u63d0\u4f9b\u7684\u5de5\u5177\u5217\u8868"""
\n result = self._send_request("tools\/list")
\n return result.get("tools", [])<\/p>\n
def call_tool(self, name: str, arguments: dict = None) -> dict:
\n """\u8c03\u7528\u6307\u5b9a\u5de5\u5177"""
\n params = {"name": name}
\n if arguments:
\n params["arguments"] = arguments
\n return self._send_request("tools\/call", params)<\/p>\n
def close(self):
\n """\u5173\u95ed\u8fde\u63a5"""
\n if self._process:
\n self._process.terminate()
\n self._process.wait(timeout=5)
\n self._process = None<\/p>\n
4.1 \u540c\u6b65\u8c03\u7528\u673a\u5236\u7684\u5b9e\u73b0\u7ec6\u8282<\/h4>\n
\u4e0a\u9762\u7684 Client \u4e2d，_send_request \u662f\u6838\u5fc3\u65b9\u6cd5\u3002\u5b83\u7684\u5de5\u4f5c\u6d41\u7a0b\u503c\u5f97\u4ed4\u7ec6\u63e3\u6469：<\/p>\n
\u53d1\u9001\u8bf7\u6c42\u524d：
\n 1. \u751f\u6210\u81ea\u589e request_id
\n 2. \u521b\u5efa threading.Event \u5e76\u653e\u5165 _pending \u5b57\u5178
\n 3. \u901a\u8fc7 STDIN \u53d1\u9001 JSON \u6d88\u606f<\/p>\n
\u7b49\u5f85\u54cd\u5e94：
\n 4. \u540e\u53f0 _read_loop \u7ebf\u7a0b\u6301\u7eed\u8bfb\u53d6 STDOUT
\n 5. \u6536\u5230\u54cd\u5e94\u65f6，\u6839\u636e id \u627e\u5230\u5bf9\u5e94\u7684 Event
\n 6. \u8bbe\u7f6e Event，\u5524\u9192\u7b49\u5f85\u7684\u7ebf\u7a0b<\/p>\n
\u83b7\u53d6\u7ed3\u679c：
\n 7. \u4ece _results \u5b57\u5178\u53d6\u51fa\u54cd\u5e94\u6570\u636e
\n 8. \u68c0\u67e5\u662f\u5426\u6709 error \u5b57\u6bb5
\n 9. \u8fd4\u56de result \u90e8\u5206<\/p>\n
\u8fd9\u79cd\u8bbe\u8ba1\u7684\u5173\u952e\u5728\u4e8e\u89e3\u8026\u53d1\u9001\u548c\u63a5\u6536： – \u53d1\u9001\u7ebf\u7a0b\u4e0d\u963b\u585e STDIO \u7684\u8bfb\u53d6 – \u540e\u53f0\u8bfb\u53d6\u7ebf\u7a0b\u72ec\u7acb\u8fd0\u884c，\u4fdd\u8bc1\u4efb\u4f55\u65f6\u523b\u90fd\u80fd\u6536\u5230 Server \u7684\u6d88\u606f – Event \u673a\u5236\u8ba9\u591a\u4e2a\u5e76\u53d1\u8bf7\u6c42\u53ef\u4ee5\u72ec\u7acb\u7b49\u5f85\u5404\u81ea\u7684\u54cd\u5e94<\/p>\n
threading.Event \u5728\u8fd9\u91cc\u8d77\u5230\u4e86\u4fe1\u53f7\u91cf\u7684\u4f5c\u7528\u2014\u2014\u53d1\u9001\u7ebf\u7a0b\u53d1\u8d77\u8bf7\u6c42\u540e\u6302\u8d77\u7b49\u5f85，\u8bfb\u53d6\u7ebf\u7a0b\u6536\u5230\u54cd\u5e94\u540e\u901a\u8fc7 Event \u901a\u77e5\u53d1\u9001\u7ebf\u7a0b\u7ee7\u7eed\u6267\u884c\u3002\u8fd9\u79cd\u6a21\u5f0f\u5728\u5f02\u6b65\u7f16\u7a0b\u4e2d\u975e\u5e38\u5e38\u89c1，\u53ea\u662f\u8fd9\u91cc\u6211\u4eec\u5728\u540c\u6b65\u7684\u7ebf\u7a0b\u6a21\u578b\u4e2d\u5b9e\u73b0\u4e86\u5b83\u3002<\/p>\n
4.2 \u6d4b\u8bd5 Client<\/h4>\n
def test_client():
\n """\u6d4b\u8bd5 MCP Client \u4e0e Server \u7684\u4ea4\u4e92"""<\/p>\n
client = MCPClient(["python", "mcp_server.py"])<\/p>\n
try:
\n # \u7b2c\u4e00\u6b65：\u8fde\u63a5
\n print("🔄 \u8fde\u63a5 Server…")
\n client.connect()<\/p>\n
# \u7b2c\u4e8c\u6b65：\u521d\u59cb\u5316\u63e1\u624b
\n print("🔄 \u521d\u59cb\u5316\u63e1\u624b…")
\n info = client.initialize()
\n print(f"\u2705 \u5df2\u8fde\u63a5: {info['serverInfo']['name']} v{info['serverInfo']['version']}")
\n print(f"📊 \u80fd\u529b: {', '.join(info['capabilities'].keys())}\\\\n")<\/p>\n
# \u7b2c\u4e09\u6b65：\u5217\u51fa\u5de5\u5177
\n print("🔧 \u53ef\u7528\u5de5\u5177:")
\n tools = client.list_tools()
\n for t in tools:
\n required = t['inputSchema'].get('required', [])
\n params_desc = ', '.join(t['inputSchema']['properties'].keys()) if t['inputSchema']['properties'] else '\u65e0'
\n print(f" 📌 {t['name']}: {t['description']}")
\n print(f" \u53c2\u6570: {params_desc}")
\n print()<\/p>\n
# \u7b2c\u56db\u6b65：\u8c03\u7528\u5de5\u5177
\n print("🚀 \u8c03\u7528\u5de5\u5177:\\\\n")<\/p>\n
# \u8c03\u7528 get_current_time
\n print("— get_current_time —")
\n result = client.call_tool("get_current_time")
\n print(result['content'][0]['text'])
\n print()<\/p>\n
# \u8c03\u7528 calculate
\n print("— calculate —")
\n result = client.call_tool("calculate", {"expression": "2 ** 10 + 42"})
\n print(result['content'][0]['text'])
\n print()<\/p>\n
# \u8c03\u7528 search_knowledge
\n print("— search_knowledge —")
\n result = client.call_tool("search_knowledge", {"query": "MCP", "limit": 2})
\n print(result['content'][0]['text'])<\/p>\n
finally:
\n client.close()<\/p>\n
if __name__ == "__main__":
\n test_client()<\/p>\n
\u8fd0\u884c\u8f93\u51fa\u793a\u4f8b：<\/p>\n
🔄 \u8fde\u63a5 Server…
\n🔄 \u521d\u59cb\u5316\u63e1\u624b…
\n\u2705 \u5df2\u8fde\u63a5: demo-server v1.0.0
\n📊 \u80fd\u529b: tools<\/p>\n
🔧 \u53ef\u7528\u5de5\u5177:
\n 📌 get_weather: \u83b7\u53d6\u6307\u5b9a\u57ce\u5e02\u7684\u5b9e\u65f6\u5929\u6c14\u4fe1\u606f
\n \u53c2\u6570: city
\n 📌 calculate: \u6267\u884c\u6570\u5b66\u8ba1\u7b97
\n \u53c2\u6570: expression
\n 📌 get_current_time: \u83b7\u53d6\u5f53\u524d\u65e5\u671f\u548c\u65f6\u95f4
\n \u53c2\u6570: \u65e0
\n 📌 search_knowledge: \u641c\u7d22\u672c\u5730\u77e5\u8bc6\u5e93（\u6a21\u62df）
\n \u53c2\u6570: query, limit<\/p>\n
🚀 \u8c03\u7528\u5de5\u5177:<\/p>\n
— get_current_time —
\n\u5f53\u524d\u65f6\u95f4：2026\u5e7404\u670827\u65e5 21:00:00 \u661f\u671f\u4e00<\/p>\n
— calculate —
\n2 ** 10 + 42 = 1066<\/p>\n
— search_knowledge —
\n\u627e\u5230 3 \u6761\u76f8\u5173\u7ed3\u679c：<\/p>\n
1. MCP（Model Context Protocol）\u662f Anthropic \u63d0\u51fa\u7684\u5f00\u653e\u534f\u8bae\u3002
\n2. MCP \u5b9a\u4e49\u4e86 AI \u6a21\u578b\u4e0e\u5916\u90e8\u5de5\u5177\/\u6570\u636e\u6e90\u7684\u6807\u51c6\u901a\u4fe1\u65b9\u5f0f\u3002
\n3. MCP \u652f\u6301 STDIO \u548c SSE \u4e24\u79cd\u4f20\u8f93\u65b9\u5f0f\u3002<\/p>\n
\n5. \u4e0e LLM \u96c6\u6210：\u8ba9 AI \u7528\u4f60\u7684\u5de5\u5177<\/h3>\n
MCP \u7684\u6700\u5927\u4ef7\u503c\u5728\u4e8e：\u8ba9\u5927\u6a21\u578b\u81ea\u52a8\u53d1\u73b0\u5e76\u4f7f\u7528\u5de5\u5177\u3002\u6211\u4eec\u628a MCP Client \u548c LLM \u7ed3\u5408\u8d77\u6765\u3002<\/p>\n
import requests
\nfrom typing import List<\/p>\n
class MCPAgent:
\n """
\n \u5c06 MCP Client \u4e0e LLM \u96c6\u6210
\n AI \u81ea\u52a8\u53d1\u73b0\u3001\u8c03\u7528 MCP Server \u4e0a\u7684\u5de5\u5177
\n """<\/p>\n
def __init__(self,
\n mcp_client: MCPClient,
\n llm_api_url: str = "https:\/\/api.openai.com\/v1\/chat\/completions",
\n llm_api_key: str = None,
\n model: str = "gpt-4o"):
\n self.mcp = mcp_client
\n self.api_url = llm_api_url
\n self.api_key = llm_api_key
\n self.model = model
\n self._tools = []<\/p>\n
def connect_mcp(self):
\n """\u8fde\u63a5 MCP Server \u5e76\u540c\u6b65\u5de5\u5177"""
\n self.mcp.connect()
\n self.mcp.initialize()
\n self._tools = self.mcp.list_tools()
\n print(f"\u2705 \u5df2\u540c\u6b65 {len(self._tools)} \u4e2a MCP \u5de5\u5177")<\/p>\n
def _convert_tool_to_openai(self, mcp_tool: dict) -> dict:
\n """\u5c06 MCP \u5de5\u5177\u683c\u5f0f\u8f6c\u6362\u4e3a OpenAI Function Calling \u683c\u5f0f"""
\n return {
\n "type": "function",
\n "function": {
\n "name": mcp_tool["name"],
\n "description": mcp_tool["description"],
\n "parameters": mcp_tool.get("inputSchema", {
\n "type": "object",
\n "properties": {}
\n })
\n }
\n }<\/p>\n
def _call_llm(self, messages: list) -> dict:
\n """\u8c03\u7528 LLM API"""
\n headers = {
\n "Authorization": f"Bearer {self.api_key}",
\n "Content-Type": "application\/json"
\n }<\/p>\n
payload = {
\n "model": self.model,
\n "messages": messages,
\n "tools": [self._convert_tool_to_openai(t) for t in self._tools],
\n "tool_choice": "auto"
\n }<\/p>\n
resp = requests.post(self.api_url, headers=headers, json=payload, timeout=60)
\n resp.raise_for_status()
\n return resp.json()<\/p>\n
def chat(self, user_message: str, max_turns: int = 10) -> str:
\n """
\n \u4e0e AI \u5bf9\u8bdd，AI \u81ea\u52a8\u8c03\u7528 MCP \u5de5\u5177
\n \u4f7f\u7528 ReAct \u6a21\u5f0f：\u601d\u8003 \u2192 \u8c03\u7528 \u2192 \u89c2\u5bdf \u2192 \u7ee7\u7eed\u601d\u8003
\n """
\n messages = [
\n {"role": "system", "content": "\u4f60\u662f\u4e00\u4e2a\u4f7f\u7528 MCP \u5de5\u5177\u7684 AI \u52a9\u624b\u3002\u8c03\u7528\u5de5\u5177\u65f6，\u4f7f\u7528\u8fd4\u56de\u7ed3\u679c\u56de\u7b54\u95ee\u9898\u3002"},
\n {"role": "user", "content": user_message}
\n ]<\/p>\n
for turn in range(max_turns):
\n response = self._call_llm(messages)
\n choice = response["choices"][0]
\n msg = choice["message"]<\/p>\n
# \u5982\u679c AI \u6ca1\u6709\u8c03\u7528\u5de5\u5177，\u76f4\u63a5\u8fd4\u56de
\n if not msg.get("tool_calls"):
\n return msg["content"]<\/p>\n
# AI \u8bf7\u6c42\u8c03\u7528\u5de5\u5177
\n messages.append(msg)<\/p>\n
for tool_call in msg["tool_calls"]:
\n func_name = tool_call["function"]["name"]
\n func_args = json.loads(tool_call["function"]["arguments"])<\/p>\n
# \u901a\u8fc7 MCP \u8c03\u7528\u5de5\u5177
\n try:
\n result = self.mcp.call_tool(func_name, func_args)
\n tool_result = result["content"][0]["text"]
\n except Exception as e:
\n tool_result = f"Error: {str(e)}"<\/p>\n
# \u5c06\u5de5\u5177\u7ed3\u679c\u8fd4\u56de\u7ed9 AI
\n messages.append({
\n "role": "tool",
\n "tool_call_id": tool_call["id"],
\n "content": tool_result
\n })<\/p>\n
# \u7ee7\u7eed\u5faa\u73af，\u8ba9 AI \u6839\u636e\u5de5\u5177\u7ed3\u679c\u51b3\u5b9a\u4e0b\u4e00\u6b65<\/p>\n
return "\u5df2\u8fbe\u5230\u6700\u5927\u5bf9\u8bdd\u8f6e\u6b21\u3002"<\/p>\n
def close(self):
\n self.mcp.close()<\/p>\n
5.1 \u5b8c\u6574\u6d41\u7a0b\u6f14\u793a<\/h4>\n
def demo():
\n """MCP + LLM \u5b8c\u6574\u6f14\u793a"""<\/p>\n
# \u521b\u5efa MCP Client（\u8fde\u63a5 Server）
\n client = MCPClient(["python", "mcp_server.py"])<\/p>\n
# \u521b\u5efa MCP Agent（\u96c6\u6210 LLM）
\n agent = MCPAgent(
\n mcp_client=client,
\n llm_api_url="https:\/\/api.deepseek.com\/v1\/chat\/completions",
\n llm_api_key="your-api-key-here",
\n model="deepseek-chat"
\n )<\/p>\n
# \u8fde\u63a5 MCP，\u81ea\u52a8\u540c\u6b65\u5de5\u5177
\n agent.connect_mcp()<\/p>\n
try:
\n # \u7528\u6237\u63d0\u95ee
\n questions = [
\n "\u73b0\u5728\u51e0\u70b9\u4e86？\u5e2e\u6211\u7b97\u4e00\u4e0b 2^16 \u662f\u591a\u5c11",
\n "\u641c\u7d22\u4e00\u4e0b\u5173\u4e8e Python \u5f02\u6b65\u7f16\u7a0b\u7684\u77e5\u8bc6",
\n "\u5317\u4eac\u7684\u5929\u6c14\u600e\u4e48\u6837？\u987a\u4fbf\u8bf4\u4e00\u4e0b\u4eca\u5929\u65e5\u671f",
\n ]<\/p>\n
for q in questions:
\n print(f"\\\\n👤 \u7528\u6237: {q}")
\n print("🤖 AI: ", end="", flush=True)
\n answer = agent.chat(q)
\n print(answer)<\/p>\n
finally:
\n agent.close()<\/p>\n
\u5f53\u7528\u6237\u95ee"\u5317\u4eac\u7684\u5929\u6c14\u600e\u4e48\u6837？\u987a\u4fbf\u8bf4\u4e00\u4e0b\u4eca\u5929\u65e5\u671f"\u65f6，AI \u5185\u90e8\u6d41\u7a0b\u5982\u4e0b：<\/p>\n
1. AI \u601d\u8003：\u9700\u8981\u8c03 get_current_time \u83b7\u53d6\u65e5\u671f
\n2. AI \u8c03\u7528 \u2192 get_current_time()
\n3. Server \u8fd4\u56de：\u5f53\u524d\u65f6\u95f4…
\n4. AI \u601d\u8003：\u8fd8\u9700\u8981\u8c03 get_weather \u83b7\u53d6\u5317\u4eac\u5929\u6c14
\n5. AI \u8c03\u7528 \u2192 get_weather(city="\u5317\u4eac")
\n6. Server \u8fd4\u56de：\u5317\u4eac\u5929\u6c14…
\n7. AI \u7efc\u5408\u56de\u7b54<\/p>\n
\u8fd9\u5c31\u662f MCP \u7684\u6838\u5fc3\u4ef7\u503c\u2014\u2014AI \u81ea\u5df1\u51b3\u5b9a\u7528\u4ec0\u4e48\u5de5\u5177\u3001\u4ec0\u4e48\u65f6\u5019\u7528，\u4e0d\u9700\u8981\u5f00\u53d1\u8005\u786c\u7f16\u7801\u8c03\u7528\u94fe\u3002<\/p>\n
\n6. \u6269\u5c55：SSE \u4f20\u8f93\u5b9e\u73b0<\/h3>\n
STDIO \u9002\u5408\u672c\u5730\u5b50\u8fdb\u7a0b\u6a21\u5f0f，\u4f46\u5b9e\u9645\u90e8\u7f72\u4e2d\u66f4\u591a\u9700\u8981\u8fdc\u7a0b\u8bbf\u95ee\u3002MCP \u652f\u6301 SSE（Server-Sent Events）\u4f5c\u4e3a HTTP \u4f20\u8f93\u5c42\u3002<\/p>\n
6.1 SSE Server<\/h4>\n
from http.server import HTTPServer, BaseHTTPRequestHandler
\nimport urllib.parse<\/p>\n
class SSEMCPServer(MCPServer):
\n """
\n \u57fa\u4e8e SSE \u7684 MCP Server
\n \u652f\u6301 HTTP \u8fdc\u7a0b\u8bbf\u95ee
\n """<\/p>\n
def __init__(self, host="0.0.0.0", port=8000, **kwargs):
\n super().__init__(**kwargs)
\n self.host = host
\n self.port = port
\n self._clients = []<\/p>\n
def _handle_sse_connection(self, client_id: str):
\n """\u5904\u7406 SSE \u8fde\u63a5"""
\n # SSE \u4f7f\u7528\u957f\u8fde\u63a5，Server \u53ef\u4ee5\u4e3b\u52a8\u63a8\u9001\u6d88\u606f
\n pass<\/p>\n
def _handle_message_post(self, client_id: str, body: str):
\n """\u5904\u7406 Client \u901a\u8fc7 POST \u53d1\u9001\u7684\u6d88\u606f"""
\n return self._process_message(body)<\/p>\n
def run(self):
\n """\u542f\u52a8 HTTP Server"""
\n server = HTTPServer((self.host, self.port), self._create_handler())
\n print(f"🌐 MCP SSE Server \u8fd0\u884c\u5728 http:\/\/{self.host}:{self.port}", file=sys.stderr)
\n server.serve_forever()<\/p>\n
def _create_handler(self):
\n server_ref = self<\/p>\n
class Handler(BaseHTTPRequestHandler):
\n def do_GET(self):
\n if self.path == "\/sse":
\n # SSE \u7aef\u70b9
\n self.send_response(200)
\n self.send_header("Content-Type", "text\/event-stream")
\n self.send_header("Cache-Control", "no-cache")
\n self.send_header("Connection", "keep-alive")
\n self.send_header("Access-Control-Allow-Origin", "*")
\n self.end_headers()<\/p>\n
# \u53d1\u9001 endpoint \u4e8b\u4ef6，\u544a\u77e5 Client \u6d88\u606f POST \u5730\u5740
\n self.wfile.write(f"event: endpoint\\\\ndata: \/messages\/{id(self)}\\\\n\\\\n".encode())
\n self.wfile.flush()<\/p>\n
# \u4fdd\u6301\u8fde\u63a5（\u6301\u7eed\u53d1\u9001\u5fc3\u8df3）
\n while server_ref._running:
\n try:
\n self.wfile.write(": heartbeat\\\\n\\\\n".encode())
\n self.wfile.flush()
\n import time
\n time.sleep(15)
\n except BrokenPipeError:
\n break
\n else:
\n self.send_error(404)<\/p>\n
def do_POST(self):
\n if self.path.startswith("\/messages\/"):
\n content_length = int(self.headers["Content-Length"])
\n body = self.rfile.read(content_length).decode()<\/p>\n
response = server_ref._process_message(body)
\n if response:
\n self.send_response(200)
\n self.send_header("Content-Type", "application\/json")
\n self.send_header("Access-Control-Allow-Origin", "*")
\n self.end_headers()
\n self.wfile.write(response.encode())
\n else:
\n self.send_response(202) # Accepted（\u901a\u77e5\u7c7b\u6d88\u606f）
\n self.end_headers()
\n else:
\n self.send_error(404)<\/p>\n
def log_message(self, format, *args):
\n pass # \u5b89\u9759\u6a21\u5f0f<\/p>\n
return Handler<\/p>\n
6.2 SSE Client<\/h4>\n
import requests
\nimport sseclient # pip install sseclient-py<\/p>\n
class SSEMCPClient(MCPClient):
\n """\u57fa\u4e8e SSE \u7684 MCP Client"""<\/p>\n
def __init__(self, server_url: str):
\n self.server_url = server_url.rstrip("\/")
\n self._session = requests.Session()
\n self._message_url = None
\n self._request_id = 0
\n self._pending = {}<\/p>\n
def connect(self):
\n """\u5efa\u7acb SSE \u8fde\u63a5，\u83b7\u53d6\u6d88\u606f POST \u5730\u5740"""
\n resp = self._session.get(
\n f"{self.server_url}\/sse",
\n stream=True,
\n headers={"Accept": "text\/event-stream"}
\n )
\n resp.raise_for_status()<\/p>\n
client = sseclient.SSEClient(resp)
\n for event in client.events():
\n if event.event == "endpoint":
\n self._message_url = f"{self.server_url}{event.data}"
\n break<\/p>\n
def _send_request(self, method: str, params: dict = None) -> dict:
\n with self._lock:
\n self._request_id += 1
\n req_id = self._request_id
\n event = threading.Event()
\n self._pending[req_id] = event<\/p>\n
request = make_request(method, params, req_id)<\/p>\n
resp = self._session.post(
\n self._message_url,
\n json=request,
\n headers={"Content-Type": "application\/json"}
\n )
\n resp.raise_for_status()<\/p>\n
# HTTP 200 \u8868\u793a\u6709\u54cd\u5e94，202 \u8868\u793a\u901a\u77e5\u5df2\u63a5\u53d7
\n if resp.status_code == 200:
\n return resp.json().get("result", {})<\/p>\n
event.wait(timeout=30)
\n return self._results.pop(req_id, {})<\/p>\n
SSE \u6a21\u5f0f\u7684\u6838\u5fc3\u533a\u522b：<\/p>\n
\n- Server \u7ef4\u62a4\u957f\u8fde\u63a5，\u53ef\u4ee5\u4e3b\u52a8\u63a8\u9001\u4e8b\u4ef6<\/li>\n
- Client \u901a\u8fc7 POST \u53d1\u9001\u8bf7\u6c42\u5230 \/messages\/{id}<\/li>\n
- Server \u901a\u8fc7 SSE \u8fde\u63a5\u63a8\u9001\u54cd\u5e94\u548c\u4e8b\u4ef6<\/li>\n<\/ul>\n
\n7. \u5b8c\u6574\u9879\u76ee\u7ed3\u6784<\/h3>\n
\u4ee5\u4e0a\u4ee3\u7801\u867d\u7136\u662f\u4ece\u96f6\u624b\u5199，\u4f46\u5df2\u7ecf\u8986\u76d6\u4e86\u751f\u4ea7\u7ea7 MCP \u9700\u8981\u7684\u6838\u5fc3\u80fd\u529b\u3002\u5b8c\u6574\u9879\u76ee\u7ed3\u6784\u5982\u4e0b：<\/p>\n
mcp-demo\/
\n\u251c\u2500\u2500 mcp_core.py # JSON-RPC \u57fa\u7840（130\u884c）
\n\u251c\u2500\u2500 mcp_server.py # MCP Server \u5b9e\u73b0（200\u884c）
\n\u251c\u2500\u2500 mcp_client.py # MCP Client \u5b9e\u73b0（150\u884c）
\n\u251c\u2500\u2500 mcp_agent.py # MCP + LLM \u96c6\u6210（100\u884c）
\n\u251c\u2500\u2500 sse_server.py # SSE \u6269\u5c55（80\u884c）
\n\u251c\u2500\u2500 demo.py # \u793a\u4f8b\u5de5\u5177\u548c\u6f14\u793a（100\u884c）
\n\u2514\u2500\u2500 test.py # \u6d4b\u8bd5\u811a\u672c（50\u884c）<\/p>\n
\u603b\u4ee3\u7801\u91cf\u4e0d\u5230 1000 \u884c，\u5c31\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684 MCP \u534f\u8bae\u6808\u3002\u8fd9\u5c31\u662f MCP \u7684\u8bbe\u8ba1\u4e4b\u7f8e\u2014\u2014\u534f\u8bae\u672c\u8eab\u975e\u5e38\u7b80\u6d01，\u6838\u5fc3\u662f JSON-RPC + \u6807\u51c6\u5316\u7684\u6570\u636e\u6a21\u578b\u3002<\/p>\n
\n8. \u5728 AI Agent \u4e2d\u843d\u5730 MCP<\/h3>\n
\u7406\u89e3\u4e86\u539f\u7406，\u6211\u4eec\u6765\u804a\u804a MCP \u5728\u5b9e\u9645\u9879\u76ee\u4e2d\u7684\u6700\u4f73\u5b9e\u8df5\u3002<\/p>\n
8.1 \u4ec0\u4e48\u65f6\u5019\u7528 STDIO，\u4ec0\u4e48\u65f6\u5019\u7528 SSE？<\/h4>\n
\n\u573a\u666f\u63a8\u8350\u65b9\u5f0f\u539f\u56e0<\/tr>\n
\n\n| \u672c\u5730\u5f00\u53d1\/\u6d4b\u8bd5<\/td>\n | STDIO<\/td>\n | \u96f6\u4f9d\u8d56，\u542f\u52a8\u5feb<\/td>\n<\/tr>\n |
\n| \u5355\u673a Agent \u8fdb\u7a0b<\/td>\n | STDIO<\/td>\n | \u5b50\u8fdb\u7a0b\u901a\u4fe1，\u9694\u79bb\u6027\u597d<\/td>\n<\/tr>\n |
\n| \u5fae\u670d\u52a1\/\u5bb9\u5668\u90e8\u7f72<\/td>\n | SSE<\/td>\n | \u652f\u6301\u8fdc\u7a0b\u8c03\u7528\u548c\u6c34\u5e73\u6269\u5c55<\/td>\n<\/tr>\n |
\n| \u8de8\u8bed\u8a00\u534f\u4f5c<\/td>\n | SSE<\/td>\n | HTTP \u534f\u8bae\u901a\u7528\u517c\u5bb9<\/td>\n<\/tr>\n |
\n| \u9700\u8981 Server \u63a8\u9001<\/td>\n | SSE<\/td>\n | \u4e8b\u4ef6\u6d41\u5929\u7136\u652f\u6301<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n8.2 \u5e38\u89c1\u7684 MCP \u5e94\u7528\u6a21\u5f0f<\/h4>\n\u6a21\u5f0f\u4e00：\u672c\u5730\u5de5\u5177\u589e\u5f3a<\/p>\n LLM \u8fd0\u884c\u5728\u672c\u5730，MCP Server \u63d0\u4f9b\u6587\u4ef6\u7cfb\u7edf\u3001Shell\u3001\u8ba1\u7b97\u7b49\u5de5\u5177\u3002<\/p>\n \u7528\u6237 \u2194 LLM \u2194 MCP Server(\u672c\u5730\u5de5\u5177)<\/p>\n \u6a21\u5f0f\u4e8c：\u5fae\u670d\u52a1\u7f51\u5173<\/p>\n \u6bcf\u4e2a\u540e\u7aef\u670d\u52a1\u542f\u52a8\u4e00\u4e2a MCP Server，AI \u7f51\u5173\u7edf\u4e00\u53d1\u73b0\u548c\u8def\u7531\u3002<\/p>\n \u7528\u6237 \u2194 AI\u7f51\u5173 \u2194 MCP Server(\u641c\u7d22\u670d\u52a1)
\n \u2194 MCP Server(\u6570\u636e\u5e93\u670d\u52a1)
\n \u2194 MCP Server(\u4ee3\u7801\u670d\u52a1)<\/p>\n \u6a21\u5f0f\u4e09：\u4e2d\u95f4\u4ef6\u4ee3\u7406<\/p>\n MCP \u4f5c\u4e3a AI \u4e0e\u73b0\u6709\u7cfb\u7edf\u7684\u9002\u914d\u5c42，\u5c01\u88c5\u65e7\u7cfb\u7edf\u7684 API\u3002<\/p>\n \u7528\u6237 \u2194 LLM \u2194 MCP Proxy \u2194 \u9057\u7559\u7cfb\u7edf REST\/SOAP API<\/p>\n 8.3 \u5e38\u89c1\u9677\u9631\u4e0e\u8c03\u8bd5\u6280\u5de7<\/h4>\n\u5728\u5b9e\u9645\u5f00\u53d1 MCP Server \u65f6，\u6709\u51e0\u4e2a\u5bb9\u6613\u8e29\u7684\u5751：<\/p>\n \u9677\u9631\u4e00：\u4f7f\u7528 print \u8f93\u51fa Python \u7684 print() \u9ed8\u8ba4\u8f93\u51fa\u5230 STDOUT，\u4f46\u5728 MCP \u7684 STDIO \u6a21\u5f0f\u4e0b，STDOUT \u7528\u6765\u4f20\u8f93 JSON-RPC \u6d88\u606f\u3002\u5982\u679c\u4f60\u5728\u5de5\u5177\u51fd\u6570\u91cc\u7528\u4e86 print() \u8c03\u8bd5，Client \u7aef\u4f1a\u6536\u5230\u4e00\u884c\u65e0\u6cd5\u89e3\u6790\u7684\u6587\u672c，\u5bfc\u81f4 JSON \u89e3\u6790\u5931\u8d25\u3002<\/p>\n \u2705 \u6b63\u786e\u505a\u6cd5：\u7528 sys.stderr \u8f93\u51fa\u65e5\u5fd7<\/p>\n print("\u8c03\u8bd5\u4fe1\u606f", file=sys.stderr, flush=True)<\/p>\n \u9677\u9631\u4e8c：\u5fd8\u8bb0 flush MCP \u7684\u884c\u534f\u8bae\u8981\u6c42\u6bcf\u6b21\u5199\u5165\u540e\u7acb\u5373\u5237\u65b0\u7f13\u51b2\u533a\u3002\u5982\u679c\u5fd8\u8bb0 flush()，Client \u53ef\u80fd\u6c38\u8fdc\u6536\u4e0d\u5230\u54cd\u5e94\u3002<\/p>\n \u2705 \u6b63\u786e\u505a\u6cd5：\u6bcf\u6b21 write() \u540e\u8c03\u7528 flush()<\/p>\n sys.stdout.write(response + "\\\\n")
\nsys.stdout.flush() # \u4e00\u5b9a\u8981\u5237\u65b0！<\/p>\n \u9677\u9631\u4e09：\u901a\u77e5\u4e0d\u9700\u8981\u54cd\u5e94 \u521d\u6b21\u5b9e\u73b0\u65f6\u5bb9\u6613\u628a\u901a\u77e5（notifications\/initialized）\u4e5f\u8fd4\u56de {"id": null} \u683c\u5f0f\u7684\u54cd\u5e94\u2014\u2014\u4f46\u5b9e\u9645\u4e0a\u901a\u77e5\u6839\u672c\u4e0d\u9700\u8981\u54cd\u5e94\u3002\u533a\u5206\u6807\u51c6\u5f88\u7b80\u5355：\u6d88\u606f\u91cc\u6ca1\u6709 id \u5b57\u6bb5\u5c31\u662f\u901a\u77e5\u3002<\/p>\n \u9677\u9631\u56db：\u5de5\u5177\u8fd4\u56de\u503c\u683c\u5f0f MCP \u89c4\u5b9a\u7684\u5de5\u5177\u8fd4\u56de\u503c\u683c\u5f0f\u662f {"content": [{"type": "text", "text": "…"}]}，\u4e0d\u662f\u76f4\u63a5\u8fd4\u56de\u5b57\u7b26\u4e32\u3002\u5982\u679c\u683c\u5f0f\u4e0d\u5bf9，\u867d\u7136 Client \u80fd\u6536\u5230\u6570\u636e，\u4f46\u4e0d\u7b26\u5408\u534f\u8bae\u7684\u8bed\u4e49\u6807\u51c6\u3002<\/p>\n 8.4 \u5b89\u5168\u6027\u6ce8\u610f\u4e8b\u9879<\/h4>\nMCP \u672c\u8eab\u4e0d\u52a0\u5bc6\u4f20\u8f93\u2014\u2014STDIO \u662f\u672c\u5730 IPC，SSE \u9700\u8981\u914d\u5408 HTTPS：<\/p>\n - \u8f93\u5165\u9a8c\u8bc1：calculate \u5de5\u5177\u4e2d\u7684\u767d\u540d\u5355\u6a21\u5f0f\u5fc5\u987b\u4e25\u683c\u6267\u884c<\/li>\n
- \u6743\u9650\u63a7\u5236：\u4e0d\u8981\u628a\u6240\u6709\u7cfb\u7edf\u80fd\u529b\u66b4\u9732\u4e3a MCP \u5de5\u5177<\/li>\n
- \u901f\u7387\u9650\u5236：\u7ed9\u6bcf\u4e2a\u5de5\u5177\u8c03\u7528\u52a0\u9650\u6d41，\u9632\u6b62\u6ee5\u7528<\/li>\n
- \u64cd\u4f5c\u786e\u8ba4：\u5371\u9669\u64cd\u4f5c（\u5220\u9664\u6587\u4ef6\u3001\u4fee\u6539\u6570\u636e）\u52a0\u5165\u4e8c\u6b21\u786e\u8ba4<\/li>\n
- \u5ba1\u8ba1\u65e5\u5fd7：\u8bb0\u5f55\u6240\u6709\u5de5\u5177\u8c03\u7528\u8be6\u60c5<\/li>\n
\n9. \u603b\u7ed3<\/h3>\n\u4ece\u96f6\u624b\u5199 MCP，\u6211\u6562\u5199\u4f60\u4e5f\u6562\u5b66\u3002\u6838\u5fc3\u8981\u70b9：<\/p>\n \n\u5c42\u7ea7\u5185\u5bb9\u4ee3\u7801\u91cf<\/tr>\n \n\n| JSON-RPC \u534f\u8bae<\/td>\n | \u6d88\u606f\u683c\u5f0f\u3001\u8bf7\u6c42\/\u54cd\u5e94\/\u901a\u77e5<\/td>\n | 60\u884c<\/td>\n<\/tr>\n | \n| Server \u5b9e\u73b0<\/td>\n | \u5de5\u5177\u6ce8\u518c\u3001\u65b9\u6cd5\u5206\u53d1\u3001\u80fd\u529b\u58f0\u660e<\/td>\n | 200\u884c<\/td>\n<\/tr>\n | \n| Client \u5b9e\u73b0<\/td>\n | \u8fdb\u7a0b\u901a\u4fe1\u3001\u8bf7\u6c42\u54cd\u5e94\u540c\u6b65<\/td>\n | 150\u884c<\/td>\n<\/tr>\n | \n| LLM \u96c6\u6210<\/td>\n | \u5de5\u5177\u81ea\u52a8\u53d1\u73b0\u3001Function Calling<\/td>\n | 100\u884c<\/td>\n<\/tr>\n | \n| SSE \u6269\u5c55<\/td>\n | HTTP \u957f\u8fde\u63a5\u3001\u8fdc\u7a0b\u8bbf\u95ee<\/td>\n | 80\u884c<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n MCP \u4e0d\u662f\u9ed1\u9b54\u6cd5\u2014\u2014\u5b83\u5c31\u662f\u4e00\u4e2a\u8bbe\u8ba1\u826f\u597d\u7684 JSON-RPC \u534f\u8bae，\u52a0\u4e0a\u6807\u51c6\u5316\u7684\u5de5\u5177\u5b9a\u4e49\u548c\u53d1\u73b0\u673a\u5236\u3002\u7406\u89e3\u4e86\u8fd9\u4e2a\u672c\u8d28，\u4e0d\u7ba1\u662f\u8bfb\u5b98\u65b9 SDK \u6e90\u7801\u3001\u81ea\u5df1\u5199\u6269\u5c55\u3001\u8fd8\u662f\u8c03\u8bd5\u751f\u4ea7\u95ee\u9898，\u90fd\u6e38\u5203\u6709\u4f59\u3002<\/p>\n \u6700\u540e\u9001\u4e0a\u4e00\u53e5\u8bdd： MCP \u89e3\u51b3\u7684\u4ece\u6765\u4e0d\u662f"\u80fd\u4e0d\u80fd\u8c03\u5de5\u5177"\u7684\u95ee\u9898，\u800c\u662f"AI \u5982\u4f55\u53d1\u73b0\u548c\u9009\u62e9\u5de5\u5177"\u7684\u95ee\u9898\u2014\u2014\u8fd9\u624d\u662f Agent \u65f6\u4ee3\u7684\u6838\u5fc3\u547d\u9898\u3002<\/p>\n
\n\u672c\u6587\u6240\u6709\u4ee3\u7801\u53ef\u5728 GitHub \u627e\u5230\u5b8c\u6574\u5b9e\u73b0：github.com\/your-repo\/mcp-from-scratch<\/p>\n \u6b22\u8fce\u5728\u8bc4\u8bba\u533a\u8ba8\u8bba\u4f60\u7684 MCP \u5b9e\u8df5\u5fc3\u5f97！<\/p>\n","protected":false},"excerpt":{"rendered":" \u524d\u8a002025\u5e74\u5e95，Anthropic \u63d0\u51fa Model Context Protocol（MCP），\u8fc5\u901f\u6210\u4e3a AI Agent \u751f\u6001\u4e2d\u6700\u6709\u5f71\u54cd\u529b\u7684\u5f00\u653e\u534f\u8bae\u4e4b\u4e00\u3002\u52302026\u5e74，MCP \u5df2\u7ecf\u4ece\\”\u65b0\u6982\u5ff5\\”\u53d8\u6210\u4e86\u5b9e\u9645\u751f\u4ea7\u529b\u2014\u2014\u5404\u5927\u6a21\u578b\u5e73\u53f0\u3001\u5f00\u53d1\u5de5\u5177\u3001\u6570\u636e\u4e2d\u95f4\u4ef6\u7eb7\u7eb7\u539f\u751f\u652f\u6301 MCP \u534f\u8bae\u3002\u4f46 MCP \u5230\u5e95\u662f\u4ec0\u4e48？\u5b83\u548c\u4f20\u7edf\u7684 API \u8c03\u7528\u6709\u4ec0\u4e48\u533a\u522b？\u4e3a\u4ec0\u4e48\u8bf4\u5b83\u662f\\”AI \u65f6\u4ee3\u7684 USB-C\\”&<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[218,43,44],"topic":[],"class_list":["post-82271","post","type-post","status-publish","format-standard","hentry","category-server","tag-qt","tag-43","tag-44"],"yoast_head":"\n \u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/82271.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u524d\u8a002025\u5e74\u5e95，Anthropic \u63d0\u51fa Model Context Protocol（MCP），\u8fc5\u901f\u6210\u4e3a AI Agent \u751f\u6001\u4e2d\u6700\u6709\u5f71\u54cd\u529b\u7684\u5f00\u653e\u534f\u8bae\u4e4b\u4e00\u3002\u52302026\u5e74，MCP \u5df2\u7ecf\u4ece"\u65b0\u6982\u5ff5"\u53d8\u6210\u4e86\u5b9e\u9645\u751f\u4ea7\u529b\u2014\u2014\u5404\u5927\u6a21\u578b\u5e73\u53f0\u3001\u5f00\u53d1\u5de5\u5177\u3001\u6570\u636e\u4e2d\u95f4\u4ef6\u7eb7\u7eb7\u539f\u751f\u652f\u6301 MCP \u534f\u8bae\u3002\u4f46 MCP \u5230\u5e95\u662f\u4ec0\u4e48？\u5b83\u548c\u4f20\u7edf\u7684 API \u8c03\u7528\u6709\u4ec0\u4e48\u533a\u522b？\u4e3a\u4ec0\u4e48\u8bf4\u5b83\u662f"AI \u65f6\u4ee3\u7684 USB-C"&\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/82271.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-07-24T23:43:13+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"18 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/82271.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/82271.html\",\"name\":\"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-07-24T23:43:13+00:00\",\"dateModified\":\"2026-07-24T23:43:13+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/82271.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/82271.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/82271.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/82271.html","og_locale":"zh_CN","og_type":"article","og_title":"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u524d\u8a002025\u5e74\u5e95，Anthropic \u63d0\u51fa Model Context Protocol（MCP），\u8fc5\u901f\u6210\u4e3a AI Agent \u751f\u6001\u4e2d\u6700\u6709\u5f71\u54cd\u529b\u7684\u5f00\u653e\u534f\u8bae\u4e4b\u4e00\u3002\u52302026\u5e74，MCP \u5df2\u7ecf\u4ece\"\u65b0\u6982\u5ff5\"\u53d8\u6210\u4e86\u5b9e\u9645\u751f\u4ea7\u529b\u2014\u2014\u5404\u5927\u6a21\u578b\u5e73\u53f0\u3001\u5f00\u53d1\u5de5\u5177\u3001\u6570\u636e\u4e2d\u95f4\u4ef6\u7eb7\u7eb7\u539f\u751f\u652f\u6301 MCP \u534f\u8bae\u3002\u4f46 MCP \u5230\u5e95\u662f\u4ec0\u4e48？\u5b83\u548c\u4f20\u7edf\u7684 API \u8c03\u7528\u6709\u4ec0\u4e48\u533a\u522b？\u4e3a\u4ec0\u4e48\u8bf4\u5b83\u662f\"AI \u65f6\u4ee3\u7684 USB-C\"&","og_url":"https:\/\/www.wsisp.com\/helps\/82271.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-07-24T23:43:13+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"18 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/82271.html","url":"https:\/\/www.wsisp.com\/helps\/82271.html","name":"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-07-24T23:43:13+00:00","dateModified":"2026-07-24T23:43:13+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/82271.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/82271.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/82271.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u624b\u5199 MCP\uff1a\u4ece\u96f6\u5b9e\u73b0 Model Context Protocol \u670d\u52a1\u5668\u4e0e\u5ba2\u6237\u7aef"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/82271","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=82271"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/82271\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=82271"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=82271"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=82271"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=82271"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}} | |