\n| notifications\/initialized<\/td>\n | \u5ba2\u6237\u7aef\u521d\u59cb\u5316\u5b8c\u6210\u901a\u77e5<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n3.2 \u5b9e\u73b0JSON-RPC\u6d88\u606f\u5904\u7406\u5668<\/h4>\n import json
\nimport sys
\nimport logging
\nfrom typing import Any, Callable<\/p>\n logging.basicConfig(level=logging.INFO, stream=sys.stderr)<\/p>\n class JSONRPCMessage:
\n """JSON-RPC 2.0 \u6d88\u606f\u5c01\u88c5"""<\/p>\n @staticmethod
\n def create_request(id: int, method: str, params: dict = None) -> str:
\n msg = {
\n "jsonrpc": "2.0",
\n "id": id,
\n "method": method
\n }
\n if params is not None:
\n msg["params"] = params
\n return json.dumps(msg)<\/p>\n @staticmethod
\n def create_response(id: int, result: Any) -> str:
\n return json.dumps({
\n "jsonrpc": "2.0",
\n "id": id,
\n "result": result
\n })<\/p>\n @staticmethod
\n def create_error(id: int, code: int, message: str, data: Any = None) -> str:
\n error = {"code": code, "message": message}
\n if data is not None:
\n error["data"] = data
\n return json.dumps({
\n "jsonrpc": "2.0",
\n "id": id,
\n "error": error
\n })<\/p>\n @staticmethod
\n def create_notification(method: str, params: dict = None) -> str:
\n msg = {
\n "jsonrpc": "2.0",
\n "method": method
\n }
\n if params is not None:
\n msg["params"] = params
\n return json.dumps(msg)<\/p>\n 3.3 \u5b9e\u73b0MCP\u670d\u52a1\u5668\u6838\u5fc3<\/h4>\n class MCPServer:
\n """\u4ece\u96f6\u5b9e\u73b0\u7684MCP\u670d\u52a1\u5668"""<\/p>\n def __init__(self, server_name: str = "my-mcp-server", version: str = "1.0.0"):
\n self.server_name = server_name
\n self.version = version
\n self.tools: dict[str, dict] = {}
\n self.tool_handlers: dict[str, Callable] = {}
\n self.resources: dict[str, dict] = {}
\n self.request_id = 0<\/p>\n def register_tool(self, name: str, description: str,
\n input_schema: dict, handler: Callable):
\n """\u6ce8\u518c\u4e00\u4e2aMCP\u5de5\u5177"""
\n self.tools[name] = {
\n "name": name,
\n "description": description,
\n "inputSchema": input_schema
\n }
\n self.tool_handlers[name] = handler<\/p>\n def register_resource(self, uri: str, name: str,
\n description: str, mime_type: str = "text\/plain"):
\n """\u6ce8\u518c\u4e00\u4e2aMCP\u8d44\u6e90"""
\n self.resources[uri] = {
\n "uri": uri,
\n "name": name,
\n "description": description,
\n "mimeType": mime_type
\n }<\/p>\n async def handle_message(self, raw_message: str) -> str | None:
\n """\u5904\u7406\u4e00\u6761JSON-RPC\u6d88\u606f"""
\n try:
\n message = json.loads(raw_message)
\n except json.JSONDecodeError:
\n return JSONRPCMessage.create_error(0, -32700, "Parse error")<\/p>\n method = message.get("method", "")
\n msg_id = message.get("id")
\n params = message.get("params", {})<\/p>\n # \u521d\u59cb\u5316\u9636\u6bb5
\n if method == "initialize":
\n return self._handle_initialize(msg_id, params)<\/p>\n # \u521d\u59cb\u5316\u5b8c\u6210\u901a\u77e5（\u65e0\u54cd\u5e94）
\n if method == "notifications\/initialized":
\n logging.info("Client initialized")
\n return None<\/p>\n # \u5de5\u5177\u5217\u51fa
\n if method == "tools\/list":
\n return JSONRPCMessage.create_response(
\n msg_id, {"tools": list(self.tools.values())}
\n )<\/p>\n # \u5de5\u5177\u8c03\u7528
\n if method == "tools\/call":
\n return await self._handle_tool_call(msg_id, params)<\/p>\n # \u8d44\u6e90\u5217\u51fa
\n if method == "resources\/list":
\n return JSONRPCMessage.create_response(
\n msg_id, {"resources": list(self.resources.values())}
\n )<\/p>\n # \u8d44\u6e90\u8bfb\u53d6
\n if method == "resources\/read":
\n return await self._handle_resource_read(msg_id, params)<\/p>\n # \u672a\u77e5\u65b9\u6cd5
\n return JSONRPCMessage.create_error(
\n msg_id, -32601, f"Method not found: {method}"
\n )<\/p>\n def _handle_initialize(self, msg_id: int, params: dict) -> str:
\n """\u5904\u7406\u521d\u59cb\u5316\u8bf7\u6c42"""
\n protocol_version = params.get("protocolVersion", "2024-11-05")
\n client_name = params.get("clientInfo", {}).get("name", "unknown")
\n logging.info(f"Client connecting: {client_name} (v{protocol_version})")<\/p>\n # \u8fd4\u56de\u670d\u52a1\u5668\u80fd\u529b\u58f0\u660e
\n return JSONRPCMessage.create_response(msg_id, {
\n "protocolVersion": protocol_version,
\n "capabilities": {
\n "tools": {},
\n "resources": {}
\n },
\n "serverInfo": {
\n "name": self.server_name,
\n "version": self.version
\n }
\n })<\/p>\n async def _handle_tool_call(self, msg_id: int, params: dict) -> str:
\n """\u5904\u7406\u5de5\u5177\u8c03\u7528\u8bf7\u6c42"""
\n tool_name = params.get("name", "")
\n arguments = params.get("arguments", {})<\/p>\n if tool_name not in self.tool_handlers:
\n return JSONRPCMessage.create_error(
\n msg_id, -32602, f"Unknown tool: {tool_name}"
\n )<\/p>\n try:
\n handler = self.tool_handlers[tool_name]
\n result = await handler(**arguments)
\n return JSONRPCMessage.create_response(msg_id, {
\n "content": [{"type": "text", "text": str(result)}]
\n })
\n except Exception as e:
\n logging.error(f"Tool execution error: {e}")
\n return JSONRPCMessage.create_error(
\n msg_id, -32603, f"Internal error: {str(e)}"
\n )<\/p>\n async def _handle_resource_read(self, msg_id: int, params: dict) -> str:
\n """\u5904\u7406\u8d44\u6e90\u8bfb\u53d6\u8bf7\u6c42"""
\n uri = params.get("uri", "")
\n if uri not in self.resources:
\n return JSONRPCMessage.create_error(
\n msg_id, -32602, f"Resource not found: {uri}"
\n )
\n # \u8fd4\u56de\u8d44\u6e90\u5185\u5bb9（\u7b80\u5316\u5b9e\u73b0）
\n return JSONRPCMessage.create_response(msg_id, {
\n "contents": [{
\n "uri": uri,
\n "mimeType": self.resources[uri]["mimeType"],
\n "text": f"\u5185\u5bb9\u6765\u81ea\u8d44\u6e90: {uri}"
\n }]
\n })<\/p>\n 3.4 Stdio\u4f20\u8f93\u5c42\u5b9e\u73b0<\/h4>\nMCP\u901a\u8fc7Stdio\u4f20\u8f93\u5c42\u5b9e\u73b0\u8fdb\u7a0b\u95f4\u901a\u4fe1\u3002\u670d\u52a1\u5668\u4ecestdin\u8bfb\u53d6JSON-RPC\u6d88\u606f，\u5c06\u54cd\u5e94\u5199\u5165stdout\u3002<\/p>\n import asyncio<\/p>\n class StdioTransport:
\n """Stdio\u4f20\u8f93\u5c42"""<\/p>\n def __init__(self, server: MCPServer):
\n self.server = server<\/p>\n async def read_line(self) -> str | None:
\n """\u4ecestdin\u8bfb\u53d6\u4e00\u884c"""
\n loop = asyncio.get_event_loop()
\n line = await loop.run_in_executor(None, sys.stdin.readline)
\n return line.strip() if line else None<\/p>\n def write_message(self, message: str):
\n """\u5c06\u6d88\u606f\u5199\u5165stdout"""
\n sys.stdout.write(message + "\\\\n")
\n sys.stdout.flush()<\/p>\n async def run(self):
\n """\u8fd0\u884c\u4e8b\u4ef6\u5faa\u73af"""
\n while True:
\n line = await self.read_line()
\n if not line:
\n break<\/p>\n response = await self.server.handle_message(line)
\n if response:
\n self.write_message(response)<\/p>\n 3.5 \u6ce8\u518c\u5177\u4f53\u5de5\u5177<\/h4>\n\u73b0\u5728，\u8ba9\u6211\u4eec\u4e3a\u670d\u52a1\u5668\u6ce8\u518c\u51e0\u4e2a\u5b9e\u7528\u7684\u5de5\u5177：<\/p>\n import subprocess
\nimport os
\nfrom datetime import datetime<\/p>\n async def calculator(expression: str) -> str:
\n """\u6267\u884c\u6570\u5b66\u8ba1\u7b97"""
\n try:
\n # \u6ce8\u610f: \u751f\u4ea7\u73af\u5883\u5e94\u4f7f\u7528\u66f4\u5b89\u5168\u7684\u65b9\u5f0f
\n result = eval(expression)
\n return f"\u8ba1\u7b97\u7ed3\u679c: {result}"
\n except Exception as e:
\n return f"\u8ba1\u7b97\u9519\u8bef: {str(e)}"<\/p>\n async def get_current_time(timezone: str = "Asia\/Shanghai") -> str:
\n """\u83b7\u53d6\u5f53\u524d\u65f6\u95f4"""
\n now = datetime.now()
\n return f"\u5f53\u524d\u65f6\u95f4: {now.strftime('%Y-%m-%d %H:%M:%S')} (\u65f6\u533a: {timezone})"<\/p>\n async def list_directory(path: str = ".") -> str:
\n """\u5217\u51fa\u76ee\u5f55\u5185\u5bb9"""
\n try:
\n files = os.listdir(path)
\n return "\\\\n".join(files) if files else "(\u7a7a\u76ee\u5f55)"
\n except Exception as e:
\n return f"\u8bfb\u53d6\u76ee\u5f55\u5931\u8d25: {str(e)}"<\/p>\n # \u6784\u5efa\u5b8c\u6574\u7684\u670d\u52a1\u5668
\ndef create_demo_server() -> MCPServer:
\n server = MCPServer("demo-mcp-server", "1.0.0")<\/p>\n server.register_tool(
\n name="calculator",
\n description="\u6267\u884c\u6570\u5b66\u8ba1\u7b97，\u652f\u6301\u56db\u5219\u8fd0\u7b97\u548c\u51fd\u6570",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "expression": {
\n "type": "string",
\n "description": "\u6570\u5b66\u8868\u8fbe\u5f0f，\u5982 '2 + 2' \u6216 'sin(pi\/2)'"
\n }
\n },
\n "required": ["expression"]
\n },
\n handler=calculator
\n )<\/p>\n server.register_tool(
\n name="get_current_time",
\n description="\u83b7\u53d6\u6307\u5b9a\u65f6\u533a\u7684\u5f53\u524d\u65f6\u95f4",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "timezone": {
\n "type": "string",
\n "description": "\u65f6\u533a\u540d\u79f0，\u5982 'Asia\/Shanghai'",
\n "default": "Asia\/Shanghai"
\n }
\n }
\n },
\n handler=get_current_time
\n )<\/p>\n server.register_tool(
\n name="list_directory",
\n description="\u5217\u51fa\u6307\u5b9a\u76ee\u5f55\u7684\u6587\u4ef6\u548c\u6587\u4ef6\u5939",
\n input_schema={
\n "type": "object",
\n "properties": {
\n "path": {
\n "type": "string",
\n "description": "\u76ee\u5f55\u8def\u5f84",
\n "default": "."
\n }
\n }
\n },
\n handler=list_directory
\n )<\/p>\n # \u6ce8\u518c\u8d44\u6e90
\n server.register_resource(
\n uri="server:\/\/info",
\n name="\u670d\u52a1\u5668\u4fe1\u606f",
\n description="MCP\u670d\u52a1\u5668\u7684\u57fa\u672c\u4fe1\u606f"
\n )<\/p>\n return server<\/p>\n 3.6 \u542f\u52a8\u5165\u53e3<\/h4>\n async def main():
\n server = create_demo_server()
\n transport = StdioTransport(server)
\n logging.info(f"Starting MCP server: {server.server_name} v{server.version}")
\n await transport.run()<\/p>\n if __name__ == "__main__":
\n asyncio.run(main())<\/p>\n
\n\u56db\u3001\u4ece\u96f6\u6784\u5efaMCP\u5ba2\u6237\u7aef<\/h3>\n\u6709\u4e86\u670d\u52a1\u5668，\u6211\u4eec\u8fd8\u9700\u8981\u4e00\u4e2a\u5ba2\u6237\u7aef\u6765\u8fde\u63a5\u548c\u4ea4\u4e92\u3002\u540c\u6837，\u6211\u4eec\u4e0d\u4f9d\u8d56\u4efb\u4f55SDK\u3002<\/p>\n import json
\nimport asyncio
\nimport subprocess
\nfrom typing import Any<\/p>\n class MCPClient:
\n """\u4ece\u96f6\u5b9e\u73b0\u7684MCP\u5ba2\u6237\u7aef"""<\/p>\n def __init__(self):
\n self.process: subprocess.Popen | None = None
\n self.request_id = 0
\n self.pending_requests: dict[int, asyncio.Future] = {}<\/p>\n async def connect_stdio(self, command: str, *args: str):
\n """\u901a\u8fc7Stdio\u8fde\u63a5\u5230MCP\u670d\u52a1\u5668"""
\n self.process = await asyncio.create_subprocess_exec(
\n command, *args,
\n stdin=asyncio.subprocess.PIPE,
\n stdout=asyncio.subprocess.PIPE,
\n stderr=asyncio.subprocess.PIPE
\n )<\/p>\n # \u542f\u52a8\u6d88\u606f\u8bfb\u53d6\u5faa\u73af
\n asyncio.create_task(self._read_loop())<\/p>\n async def _read_loop(self):
\n """\u6301\u7eed\u8bfb\u53d6\u670d\u52a1\u5668\u54cd\u5e94"""
\n while self.process and self.process.stdout:
\n line = await self.process.stdout.readline()
\n if not line:
\n break
\n try:
\n response = json.loads(line.decode().strip())
\n msg_id = response.get("id")
\n if msg_id in self.pending_requests:
\n future = self.pending_requests.pop(msg_id)
\n future.set_result(response)
\n except json.JSONDecodeError:
\n continue<\/p>\n async def send_request(self, method: str, params: dict = None) -> dict:
\n """\u53d1\u9001JSON-RPC\u8bf7\u6c42\u5e76\u7b49\u5f85\u54cd\u5e94"""
\n self.request_id += 1
\n request_id = self.request_id<\/p>\n message = {
\n "jsonrpc": "2.0",
\n "id": request_id,
\n "method": method
\n }
\n if params is not None:
\n message["params"] = params<\/p>\n future = asyncio.get_event_loop().create_future()
\n self.pending_requests[request_id] = future<\/p>\n # \u53d1\u9001\u6d88\u606f
\n self.process.stdin.write((json.dumps(message) + "\\\\n").encode())
\n await self.process.stdin.drain()<\/p>\n # \u7b49\u5f85\u54cd\u5e94
\n response = await future<\/p>\n if "error" in response:
\n error = response["error"]
\n raise Exception(f"MCP error [{error['code']}]: {error['message']}")<\/p>\n return response.get("result", {})<\/p>\n async def initialize(self):
\n """\u521d\u59cb\u5316MCP\u8fde\u63a5"""
\n result = await self.send_request("initialize", {
\n "protocolVersion": "2024-11-05",
\n "capabilities": {},
\n "clientInfo": {
\n "name": "my-mcp-client",
\n "version": "1.0.0"
\n }
\n })
\n # \u53d1\u9001\u521d\u59cb\u5316\u5b8c\u6210\u901a\u77e5
\n self.process.stdin.write(
\n (json.dumps({
\n "jsonrpc": "2.0",
\n "method": "notifications\/initialized"
\n }) + "\\\\n").encode()
\n )
\n await self.process.stdin.drain()
\n return result<\/p>\n async def list_tools(self) -> list[dict]:
\n """\u5217\u51fa\u6240\u6709\u53ef\u7528\u5de5\u5177"""
\n result = await self.send_request("tools\/list")
\n return result.get("tools", [])<\/p>\n async def call_tool(self, name: str, arguments: dict = None) -> Any:
\n """\u8c03\u7528\u6307\u5b9a\u5de5\u5177"""
\n params = {"name": name}
\n if arguments:
\n params["arguments"] = arguments
\n result = await self.send_request("tools\/call", params)
\n return result<\/p>\n async def list_resources(self) -> list[dict]:
\n """\u5217\u51fa\u6240\u6709\u53ef\u7528\u8d44\u6e90"""
\n result = await self.send_request("resources\/list")
\n return result.get("resources", [])<\/p>\n async def close(self):
\n """\u5173\u95ed\u8fde\u63a5"""
\n if self.process:
\n self.process.terminate()
\n await self.process.wait()<\/p>\n 4.1 \u4f7f\u7528\u5ba2\u6237\u7aef\u4ea4\u4e92<\/h4>\n async def demo_client_interaction():
\n """\u6f14\u793a\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u7684\u4ea4\u4e92"""<\/p>\n # 1. \u8fde\u63a5\u5230\u670d\u52a1\u5668
\n client = MCPClient()
\n await client.connect_stdio("python", "mcp_server.py")<\/p>\n # 2. \u521d\u59cb\u5316\u8fde\u63a5
\n init_result = await client.initialize()
\n print(f"\u5df2\u8fde\u63a5\u670d\u52a1\u5668: {init_result['serverInfo']['name']}")
\n print(f"\u534f\u8bae\u7248\u672c: {init_result['protocolVersion']}")
\n print(f"\u80fd\u529b: {list(init_result['capabilities'].keys())}")
\n print()<\/p>\n # 3. \u5217\u51fa\u6240\u6709\u5de5\u5177
\n tools = await client.list_tools()
\n print(f"\u53ef\u7528\u5de5\u5177 ({len(tools)}):")
\n for tool in tools:
\n print(f" – {tool['name']}: {tool['description']}")
\n print()<\/p>\n # 4. \u8c03\u7528\u5de5\u5177
\n print("\u8c03\u7528 calculator \u5de5\u5177: 2 + 3 * 4")
\n result = await client.call_tool("calculator", {"expression": "2 + 3 * 4"})
\n print(f"\u7ed3\u679c: {result['content'][0]['text']}")
\n print()<\/p>\n print("\u8c03\u7528 get_current_time \u5de5\u5177")
\n result = await client.call_tool("get_current_time")
\n print(f"\u7ed3\u679c: {result['content'][0]['text']}")
\n print()<\/p>\n # 5. \u5217\u51fa\u8d44\u6e90
\n resources = await client.list_resources()
\n print(f"\u53ef\u7528\u8d44\u6e90 ({len(resources)}):")
\n for res in resources:
\n print(f" – {res['name']} ({res['uri']})")<\/p>\n # 6. \u5173\u95ed\u8fde\u63a5
\n await client.close()<\/p>\n # \u8fd0\u884c\u6f14\u793a
\n# asyncio.run(demo_client_interaction())<\/p>\n
\n\u4e94\u3001\u4f7f\u7528\u5b98\u65b9SDK\u5feb\u901f\u6784\u5efa（\u8fdb\u9636）<\/h3>\n\u7406\u89e3\u5e95\u5c42\u534f\u8bae\u540e，\u5728\u5b9e\u9645\u5f00\u53d1\u4e2d\u6211\u4eec\u901a\u5e38\u4f1a\u4f7f\u7528MCP SDK\u6765\u52a0\u901f\u5f00\u53d1\u3002MCP\u63d0\u4f9b\u4e86Python\u3001TypeScript\u3001Java\u3001Kotlin\u7b49\u591a\u8bed\u8a00SDK\u3002<\/p>\n 5.1 \u5b89\u88c5Python SDK<\/h4>\n pip install "mcp[cli]"<\/p>\n 5.2 \u4f7f\u7528FastMCP\u6784\u5efa\u670d\u52a1\u5668（\u7b80\u5316\u7248）<\/h4>\nMCP SDK\u4ece1.2.0\u7248\u672c\u5f00\u59cb\u63d0\u4f9b\u4e86 FastMCP \u7c7b，\u4f7f\u7528Python\u7c7b\u578b\u63d0\u793a\u548cdocstring\u81ea\u52a8\u751f\u6210\u5de5\u5177\u5b9a\u4e49：<\/p>\n from mcp.server.fastmcp import FastMCP
\nimport httpx
\nimport json<\/p>\n # \u521b\u5efaMCP\u670d\u52a1\u5668\u5b9e\u4f8b
\nmcp = FastMCP("data-analyzer")<\/p>\n @mcp.tool()
\nasync def fetch_json_data(url: str) -> str:
\n """\u83b7\u53d6JSON\u683c\u5f0f\u7684\u8fdc\u7a0b\u6570\u636e<\/p>\n Args:
\n url: \u6570\u636e\u6e90\u7684URL\u5730\u5740
\n """
\n async with httpx.AsyncClient() as client:
\n response = await client.get(url, timeout=30.0)
\n response.raise_for_status()
\n data = response.json()
\n return json.dumps(data, indent=2, ensure_ascii=False)<\/p>\n @mcp.tool()
\nasync def analyze_text(text: str, operation: str = "word_count") -> str:
\n """\u5206\u6790\u6587\u672c\u7684\u57fa\u672c\u7edf\u8ba1\u4fe1\u606f<\/p>\n Args:
\n text: \u5f85\u5206\u6790\u7684\u6587\u672c\u5185\u5bb9
\n operation: \u5206\u6790\u64cd\u4f5c: word_count(\u8bcd\u6570), char_count(\u5b57\u7b26\u6570),
\n line_count(\u884c\u6570), all(\u5168\u90e8)
\n """
\n operations = {
\n "word_count": f"\u8bcd\u6570: {len(text.split())}",
\n "char_count": f"\u5b57\u7b26\u6570: {len(text)}",
\n "line_count": f"\u884c\u6570: {len(text.splitlines())}",
\n "all": (
\n f"\u8bcd\u6570: {len(text.split())}\\\\n"
\n f"\u5b57\u7b26\u6570: {len(text)}\\\\n"
\n f"\u884c\u6570: {len(text.splitlines())}"
\n )
\n }
\n return operations.get(operation, f"\u672a\u77e5\u64cd\u4f5c: {operation}")<\/p>\n @mcp.resource("config:\/\/app\/settings")
\ndef get_settings() -> str:
\n """\u8fd4\u56de\u4e00\u4e2a\u6a21\u62df\u7684\u5e94\u7528\u914d\u7f6e（\u8d44\u6e90\u793a\u4f8b）"""
\n return json.dumps({
\n "app_name": "Data Analyzer",
\n "version": "2.0.0",
\n "max_request_size": "10MB",
\n "enable_logging": True
\n }, indent=2)<\/p>\n if __name__ == "__main__":
\n # \u4f7f\u7528Stdio\u4f20\u8f93\u8fd0\u884c
\n mcp.run(transport="stdio")<\/p>\n \u8fd0\u884c\u65b9\u5f0f：<\/p>\n python data_analyzer_server.py<\/p>\n 5.3 \u4f7f\u7528\u5f02\u6b65\u5ba2\u6237\u7aefSDK<\/h4>\n from mcp import ClientSession, StdioServerParameters
\nfrom mcp.client.stdio import stdio_client
\nimport asyncio<\/p>\n async def main():
\n # \u914d\u7f6e\u670d\u52a1\u5668\u53c2\u6570
\n server_params = StdioServerParameters(
\n command="python",
\n args=["data_analyzer_server.py"]
\n )<\/p>\n async with stdio_client(server_params) as (read, write):
\n async with ClientSession(read, write) as session:
\n # \u521d\u59cb\u5316
\n await session.initialize()<\/p>\n # \u5217\u51fa\u5de5\u5177
\n tools = await session.list_tools()
\n print("\u53ef\u7528\u5de5\u5177:")
\n for tool in tools:
\n print(f" {tool.name}: {tool.description}")<\/p>\n # \u8c03\u7528\u5de5\u5177
\n result = await session.call_tool(
\n "analyze_text",
\n arguments={
\n "text": "Hello MCP! This is a test.",
\n "operation": "all"
\n }
\n )
\n print(f"\\\\n\u5206\u6790\u7ed3\u679c:\\\\n{result.content[0].text}")<\/p>\n # \u8bfb\u53d6\u8d44\u6e90
\n resource = await session.read_resource("config:\/\/app\/settings")
\n print(f"\\\\n\u914d\u7f6e\u4fe1\u606f:\\\\n{resource.contents[0].text}")<\/p>\n asyncio.run(main())<\/p>\n
\n\u516d\u3001MCP\u4e0eDeepSeek\u7684\u6df1\u5ea6\u7ed3\u5408<\/h3>\n\u5230\u76ee\u524d\u4e3a\u6b62，\u6211\u4eec\u6784\u5efa\u7684MCP\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u90fd\u662f\u901a\u7528\u7684\u3002\u63a5\u4e0b\u6765，\u8ba9\u6211\u4eec\u770b\u770b\u5982\u4f55\u5c06MCP\u4e0eDeepSeek\u5927\u6a21\u578b\u7ed3\u5408，\u771f\u6b63\u6253\u9020\u4e00\u4e2a\u53ef\u4ee5\u81ea\u4e3b\u8c03\u7528\u5de5\u5177\u7684AI Agent\u3002<\/p>\n 6.1 \u67b6\u6784\u8bbe\u8ba1<\/h4>\n\u5c06DeepSeek\u4e0eMCP\u7ed3\u5408，\u672c\u8d28\u4e0a\u662f\u6784\u5efa\u4e00\u4e2aReAct（\u63a8\u7406+\u884c\u52a8）\u5faa\u73af\u3002DeepSeek\u5927\u6a21\u578b\u4f5c\u4e3a\u63a8\u7406\u6838\u5fc3，MCP\u4f5c\u4e3a\u884c\u52a8\u63a5\u53e3\u3002<\/p>\n \u7528\u6237\u8f93\u5165 \u2192 DeepSeek\u5927\u6a21\u578b \u2192 MCP\u5ba2\u6237\u7aef \u2192 MCP\u670d\u52a1\u5668 \u2192 \u5916\u90e8\u5de5\u5177
\n \u2191 \u2193
\n \u2514\u2500\u2500\u2500 \u5de5\u5177\u8c03\u7528\u7ed3\u679c \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n \u6838\u5fc3\u6d41\u7a0b\u5206\u4e3a\u4e94\u4e2a\u6b65\u9aa4：<\/p>\n \u7b2c\u4e00\u6b65：\u610f\u56fe\u7406\u89e3\u3002DeepSeek\u63a5\u6536\u7528\u6237\u7684\u81ea\u7136\u8bed\u8a00\u8f93\u5165，\u901a\u8fc7\u5176\u5f3a\u5927\u7684\u8bed\u4e49\u7406\u89e3\u80fd\u529b\u89e3\u6790\u51fa\u7528\u6237\u7684\u771f\u5b9e\u610f\u56fe\u3002\u4f8b\u5982\u7528\u6237\u8bf4"\u5e2e\u6211\u770b\u770b\u4eca\u5929\u7684\u4ee3\u7801\u63d0\u4ea4\u8bb0\u5f55"，DeepSeek\u80fd\u7406\u89e3\u8fd9\u9700\u8981\u8c03\u7528Git\u5de5\u5177\u3002<\/p>\n \u7b2c\u4e8c\u6b65：\u5de5\u5177\u9009\u62e9\u3002\u7ed3\u5408MCP\u5ba2\u6237\u7aef\u63d0\u4f9b\u7684\u5de5\u5177\u5217\u8868（\u901a\u8fc7tools\/list\u83b7\u53d6），DeepSeek\u5224\u65ad\u5e94\u8be5\u4f7f\u7528\u54ea\u4e2a\u6216\u54ea\u4e9b\u5de5\u5177\u6765\u5b8c\u6210\u4efb\u52a1\u3002\u8fd9\u4e2a\u8fc7\u7a0b\u4e0e\u4eba\u7c7b\u9009\u62e9\u5de5\u5177\u7684\u903b\u8f91\u76f8\u4f3c\u2014\u2014"\u6211\u9700\u8981\u67e5\u770bGit\u8bb0\u5f55，\u6240\u4ee5\u9009\u62e9'git_log'\u5de5\u5177"\u3002<\/p>\n \u7b2c\u4e09\u6b65：\u53c2\u6570\u751f\u6210\u3002DeepSeek\u6839\u636e\u7528\u6237\u9700\u6c42\u751f\u6210\u5de5\u5177\u6240\u9700\u7684\u53c2\u6570\u3002\u4f8b\u5982git_log\u5de5\u5177\u53ef\u80fd\u9700\u8981branch（\u5206\u652f\u540d）\u3001since（\u8d77\u59cb\u65e5\u671f）\u7b49\u53c2\u6570\u3002DeepSeek\u7684\u63a8\u7406\u80fd\u529b\u786e\u4fdd\u4e86\u53c2\u6570\u751f\u6210\u7684\u51c6\u786e\u6027\u3002<\/p>\n \u7b2c\u56db\u6b65：\u5de5\u5177\u6267\u884c\u3002DeepSeek\u8f93\u51fa\u7ed3\u6784\u5316\u7684\u51fd\u6570\u8c03\u7528（function call），MCP\u5ba2\u6237\u7aef\u5c06\u5176\u8f6c\u6362\u6210JSON-RPC\u6d88\u606f\u53d1\u9001\u7ed9MCP\u670d\u52a1\u5668\u6267\u884c\u3002\u8fd9\u4e00\u6b65\u5b8c\u5168\u662f\u534f\u8bae\u5c42\u9762\u7684\u901a\u4fe1，DeepSeek\u4e0d\u76f4\u63a5\u53c2\u4e0e\u3002<\/p>\n \u7b2c\u4e94\u6b65：\u7ed3\u679c\u7efc\u5408\u3002MCP\u670d\u52a1\u5668\u8fd4\u56de\u5de5\u5177\u6267\u884c\u7ed3\u679c\u540e，DeepSeek\u5c06\u7ed3\u679c\u4e0e\u7528\u6237\u7684\u95ee\u9898\u4e0a\u4e0b\u6587\u7ed3\u5408，\u751f\u6210\u81ea\u7136\u8bed\u8a00\u7684\u56de\u590d\u3002\u4f8b\u5982\u62ff\u5230Git\u63d0\u4ea4\u8bb0\u5f55\u540e，\u5b83\u4f1a\u6574\u7406\u6210\u6613\u8bfb\u7684\u683c\u5f0f，\u751a\u81f3\u5206\u6790\u63d0\u4ea4\u9891\u7387\u548c\u8d21\u732e\u8005\u7edf\u8ba1\u3002<\/p>\n \u5982\u679c\u4e00\u6b21\u5de5\u5177\u8c03\u7528\u4e0d\u591f，\u6574\u4e2a\u5faa\u73af\u4f1a\u91cd\u590d\u8fdb\u884c，\u76f4\u5230\u4efb\u52a1\u5b8c\u6210\u6216\u8fbe\u5230\u9884\u8bbe\u7684\u6700\u5927\u8f6e\u6b21\u3002\u8fd9\u5c31\u662fReAct\u5faa\u73af\u7684\u6838\u5fc3\u601d\u60f3\u2014\u2014\u63a8\u7406\u3001\u884c\u52a8\u3001\u89c2\u5bdf\u3001\u518d\u63a8\u7406\u3002<\/p>\n 6.2 \u96c6\u6210\u4ee3\u7801\u793a\u4f8b<\/h4>\n from openai import OpenAI
\nimport json<\/p>\n # \u914d\u7f6eDeepSeek API（\u5047\u8bbe\u4f7f\u7528\u517c\u5bb9OpenAI\u63a5\u53e3\u7684DeepSeek API）
\nclient = OpenAI(
\n base_url="https:\/\/api.deepseek.com\/v1",
\n api_key="your-deepseek-api-key"
\n)<\/p>\n class DeepSeekMCPAgent:
\n """\u96c6\u6210DeepSeek\u4e0eMCP\u7684\u667a\u80fd\u4f53"""<\/p>\n def __init__(self, mcp_client: MCPClient, system_prompt: str = None):
\n self.mcp_client = mcp_client
\n self.system_prompt = system_prompt or (
\n "\u4f60\u662f\u4e00\u4e2a\u667a\u80fd\u52a9\u624b，\u53ef\u4ee5\u4f7f\u7528\u5404\u79cd\u5de5\u5177\u6765\u5e2e\u52a9\u7528\u6237\u5b8c\u6210\u4efb\u52a1\u3002"
\n "\u5f53\u4f60\u9700\u8981\u8c03\u7528\u5de5\u5177\u65f6，\u8bf7\u4f7f\u7528\u51fd\u6570\u8c03\u7528\u683c\u5f0f\u3002"
\n )
\n self.tools = []<\/p>\n async def load_tools(self):
\n """\u4eceMCP\u670d\u52a1\u5668\u52a0\u8f7d\u5de5\u5177\u5b9a\u4e49"""
\n mcp_tools = await self.mcp_client.list_tools()
\n self.tools = [
\n {
\n "type": "function",
\n "function": {
\n "name": t["name"],
\n "description": t["description"],
\n "parameters": t["inputSchema"]
\n }
\n }
\n for t in mcp_tools
\n ]<\/p>\n async def chat(self, user_message: str, max_turns: int = 5) -> str:
\n """\u591a\u8f6e\u5bf9\u8bdd，\u652f\u6301\u5de5\u5177\u8c03\u7528"""
\n messages = [
\n {"role": "system", "content": self.system_prompt},
\n {"role": "user", "content": user_message}
\n ]<\/p>\n for turn in range(max_turns):
\n # \u8c03\u7528DeepSeek
\n response = client.chat.completions.create(
\n model="deepseek-chat",
\n messages=messages,
\n tools=self.tools if self.tools else None,
\n tool_choice="auto" if self.tools else None
\n )<\/p>\n msg = response.choices[0].message<\/p>\n # \u5982\u679c\u6a21\u578b\u51b3\u5b9a\u76f4\u63a5\u56de\u590d，\u8fd4\u56de\u7ed3\u679c
\n if not msg.tool_calls:
\n return msg.content<\/p>\n # \u6dfb\u52a0\u6a21\u578b\u54cd\u5e94\u5230\u5bf9\u8bdd
\n messages.append(msg)<\/p>\n # \u5904\u7406\u6bcf\u4e2a\u5de5\u5177\u8c03\u7528
\n for tool_call in msg.tool_calls:
\n function_name = tool_call.function.name
\n function_args = json.loads(tool_call.function.arguments)<\/p>\n # \u901a\u8fc7MCP\u8c03\u7528\u5de5\u5177
\n try:
\n result = await self.mcp_client.call_tool(
\n function_name, function_args
\n )
\n tool_result = result["content"][0]["text"]
\n except Exception as e:
\n tool_result = f"\u5de5\u5177\u8c03\u7528\u5931\u8d25: {str(e)}"<\/p>\n # \u6dfb\u52a0\u5de5\u5177\u8c03\u7528\u7ed3\u679c\u5230\u5bf9\u8bdd
\n messages.append({
\n "role": "tool",
\n "tool_call_id": tool_call.id,
\n "content": tool_result
\n })<\/p>\n return "\u5df2\u8fbe\u5230\u6700\u5927\u5bf9\u8bdd\u8f6e\u6b21"<\/p>\n 6.3 \u6548\u679c\u6f14\u793a<\/h4>\n\u5f53\u7528\u6237\u95ee"\u5e2e\u6211\u8ba1\u7b97\u4e00\u4e0b\u5f53\u524d\u65f6\u95f4\u52a0\u4e0a8\u5c0f\u65f6\u662f\u4ec0\u4e48\u65f6\u5019，\u7136\u540e\u5217\u51fa\u5f53\u524d\u76ee\u5f55\u6709\u54ea\u4e9b\u6587\u4ef6"\u65f6，DeepSeek\u4f1a：<\/p>\n \u8c03\u7528 get_current_time \u5de5\u5177\u83b7\u53d6\u5f53\u524d\u65f6\u95f4<\/li>\n\u6839\u636e\u65f6\u95f4\u7ed3\u679c\u8ba1\u7b97\u52a08\u5c0f\u65f6<\/li>\n\u8c03\u7528 list_directory \u5de5\u5177\u5217\u51fa\u6587\u4ef6<\/li>\n\u7efc\u5408\u6240\u6709\u7ed3\u679c\u56de\u590d\u7528\u6237<\/li>\n\u8fd9\u79cd\u81ea\u4e3b\u8c03\u7528\u5de5\u5177\u7684\u80fd\u529b，\u6b63\u662fMCP\u8d4b\u4e88AI Agent\u7684\u6838\u5fc3\u4ef7\u503c\u3002<\/p>\n
\n\u4e03\u3001MCP\u7684\u9ad8\u7ea7\u7279\u6027<\/h3>\n7.1 \u80fd\u529b\u534f\u5546<\/h4>\nMCP\u7684\u521d\u59cb\u5316\u9636\u6bb5\u5305\u542b\u80fd\u529b\u534f\u5546\u3002\u670d\u52a1\u5668\u58f0\u660e\u81ea\u5df1\u652f\u6301\u54ea\u4e9b\u529f\u80fd（\u5de5\u5177\u3001\u8d44\u6e90\u3001\u63d0\u793a\u6a21\u677f），\u5ba2\u6237\u7aef\u4e5f\u53ef\u4ee5\u58f0\u660e\u81ea\u5df1\u7684\u652f\u6301（\u5982\u91c7\u6837\u80fd\u529b）：<\/p>\n # \u5ba2\u6237\u7aef\u58f0\u660e\u652f\u6301\u91c7\u6837
\nserver_result = await client.send_request("initialize", {
\n "protocolVersion": "2024-11-05",
\n "capabilities": {
\n "sampling": {} # \u652f\u6301\u91c7\u6837\u8bf7\u6c42
\n },
\n "clientInfo": {"name": "advanced-client", "version": "1.0.0"}
\n})<\/p>\n 7.2 \u5b9e\u65f6\u901a\u77e5<\/h4>\n\u5f53\u5de5\u5177\u6216\u8d44\u6e90\u53d1\u751f\u53d8\u5316\u65f6，\u670d\u52a1\u5668\u53ef\u4ee5\u4e3b\u52a8\u53d1\u9001\u901a\u77e5：<\/p>\n # \u670d\u52a1\u5668\u7aef：\u901a\u77e5\u5de5\u5177\u5217\u8868\u5df2\u53d8\u66f4
\ntransport.write_message(
\n JSONRPCMessage.create_notification(
\n "notifications\/tools\/list_changed"
\n )
\n)<\/p>\n 7.3 \u8fdb\u5ea6\u8ffd\u8e2a<\/h4>\n\u5bf9\u4e8e\u957f\u65f6\u95f4\u8fd0\u884c\u7684\u64cd\u4f5c，MCP\u652f\u6301\u8fdb\u5ea6\u8ffd\u8e2a：<\/p>\n {
\n "jsonrpc": "2.0",
\n "method": "notifications\/progress",
\n "params": {
\n "progressToken": "token-001",
\n "progress": 50,
\n "total": 100
\n }
\n}<\/p>\n 7.4 \u4efb\u52a1（Experimental）<\/h4>\nMCP\u7684\u5b9e\u9a8c\u6027\u529f\u80fd\u2014\u2014\u4efb\u52a1，\u63d0\u4f9b\u6301\u4e45\u5316\u7684\u6267\u884c\u5305\u88c5\u5668，\u652f\u6301\u5f02\u6b65\u7ed3\u679c\u68c0\u7d22\u548c\u72b6\u6001\u8ddf\u8e2a：<\/p>\n {
\n "jsonrpc": "2.0",
\n "method": "tasks\/schedule",
\n "params": {
\n "name": "batch-process",
\n "uri": "tasks:\/\/batch\/process-001"
\n }
\n}<\/p>\n
\n\u516b\u3001\u6700\u4f73\u5b9e\u8df5\u4e0e\u751f\u4ea7\u5316\u5efa\u8bae<\/h3>\n8.1 \u5b89\u5168\u6027<\/h4>\n\n- Stdio\u670d\u52a1\u5668：\u7edd\u4e0d\u5411stdout\u8f93\u51fa\u65e5\u5fd7（\u4f1a\u7834\u574fJSON-RPC\u534f\u8bae），\u59cb\u7ec8\u4f7f\u7528stderr\u6216\u6587\u4ef6\u65e5\u5fd7<\/li>\n
- HTTP\u670d\u52a1\u5668：\u4f7f\u7528OAuth 2.0\u8fdb\u884c\u8ba4\u8bc1\u6388\u6743<\/li>\n
- \u8f93\u5165\u9a8c\u8bc1：\u4e25\u683c\u6821\u9a8c\u5de5\u5177\u53c2\u6570，\u907f\u514d\u547d\u4ee4\u6ce8\u5165<\/li>\n
- \u6700\u5c0f\u6743\u9650：MCP\u670d\u52a1\u5668\u53ea\u5f00\u653e\u5fc5\u8981\u7684\u5de5\u5177\u548c\u8d44\u6e90<\/li>\n<\/ul>\n
8.2 \u65e5\u5fd7\u89c4\u8303<\/h4>\n # \u2705 \u6b63\u786e\u7684\u65e5\u5fd7\u65b9\u5f0f（Stdio\u4f20\u8f93）
\nimport sys
\nimport logging
\nlogging.basicConfig(level=logging.INFO, stream=sys.stderr)<\/p>\n # \u2705 \u6216\u8005\u4f7f\u7528print\u91cd\u5b9a\u5411\u5230stderr
\nprint("Server started", file=sys.stderr)<\/p>\n # \u274c \u9519\u8bef\u65b9\u5f0f \u2014\u2014 \u4f1a\u7834\u574f\u534f\u8bae
\nprint("Server started") # \u8f93\u51fa\u5230stdout<\/p>\n 8.3 \u9519\u8bef\u5904\u7406<\/h4>\n |