1
# ===== 使用MCP官方Python SDK实现 =====
2

3
# 第0步：安装
4
# pip install mcp httpx
5

6
# ===== 第1步：导入MCP SDK核心 =====
7
from mcp.server import Server, NotificationOptions
8
from mcp.server.models import InitializationOptions
9
import mcp.server.stdio
10
import mcp.types as types
11

12
# 解释：MCP Server的核心是暴露工具（Tools）给AI客户端调用
13
# 与Function Calling不同，MCP是标准化的协议层，任何支持的客户端都能用
14

15
# ===== 第2步：创建一个服务器实例 =====
16
server = Server("weather-server")
17

18
# ===== 第3步：定义工具列表（类似Function Calling的Schema） =====
19
@server.list_tools()
20
async def handle_list_tools() -> list[types.Tool]:
21
    """告诉客户端：我这个服务器提供什么工具"""
22
    return [
23
        types.Tool(
24
            name="get_weather",
25
            description="查询指定城市的当前天气",
26
            inputSchema={
27
                "type": "object",
28
                "properties": {
29
                    "city": {
30
                        "type": "string",
31
                        "description": "城市名，例如'北京'、'上海'、'广州'"
32
                    },
33
                    "unit": {
34
                        "type": "string",
35
                        "enum": ["celsius", "fahrenheit"],
36
                        "description": "温度单位，默认为celsius"
37
                    }
38
                },
39
                "required": ["city"]
40
            }
41
        )
42
    ]
43
# 解释：@server.list_tools() 装饰器定义了这个MCP服务器提供了哪些工具
44
# inputSchema和Function Calling的parameters结构几乎一样
45

46
# ===== 第4步：实现工具的执行逻辑 =====
47
@server.call_tool()
48
async def handle_call_tool(
49
    name: str, arguments: dict
50
) -> list[types.TextContent]:
51
    """当客户端调用某个工具时，这个函数会被触发"""
52

53
    if name == "get_weather":
54
        city = arguments.get("city", "北京")
55
        unit = arguments.get("unit", "celsius")
56

57
        # 实际调用天气API（这里用模拟数据）
58
        result = f"{city}的天气：晴天，25°C"
59

60
        # 返回结果（必须用TextContent包装）
61
        return [types.TextContent(type="text", text=result)]
62

63
    # 如果调用了不存在的工具
64
    raise ValueError(f"未知工具: {name}")
65
# 解释：@server.call_tool() 是工具的实际执行入口
66
# name是工具名，arguments是LLM解析出的参数
67
# 必须返回 types.TextContent 列表
68

69
# ===== 第5步：启动服务器 =====
70
async def main():
71
    """使用stdio传输协议运行MCP服务器"""
72
    async with mcp.server.stdio.stdio_server() as (read_stream, write_stream):
73
        await server.run(
74
            read_stream,
75
            write_stream,
76
            InitializationOptions(
77
                server_name="weather-server",
78
                server_version="0.1.0"
79
            )
80
        )
81

82
if __name__ == "__main__":
83
    import asyncio
84
    asyncio.run(main())
85
# 解释：stdio_server表示通过标准输入输出和客户端通信
86
# Claude Desktop等客户端会启动这个进程，通过stdio交互