这段代码是一个使用 Python 编写的异步客户端程序，它通过 MCP（Model Control Protocol）协议与服务器进行交互。以下是代码的详细解析： ### 代码功能 1. **建立与 MCP 服务器的连接**： - 使用 `SSEClientTransport` 创建流式 HTTP 连接（SSE，Server-Sent Events）。 - 连接地址是 `http://127.0.0.1:8010/mcp`。 2. **初始化会话**： - 使用 `ClientSession` 管理会话。 - 调用 `session.initialize()` 初始化会话，获取服务器支持的功能和版本信息。 3. **获取工具列表**： - 调用 `session.list_tools()` 获取服务器提供的工具列表。 4. **调用工具**： - 使用 `session.call_tool()` 调用名为 `retrieve_context` 的工具，并传入查询参数 `{"query":"张三九的基本信息？"}`。 5. **打印结果**： - 输出服务器支持的功能、工具列表和工具调用结果。 --- ### 代码逐行解析 1. **导入模块** ```python from mcp.client.sse import SSEClientTransport from mcp import ClientSession import asyncio ``` - `SSEClientTransport`：用于创建流式 HTTP 连接。 - `ClientSession`：用于管理客户端与服务器的交互。 - `asyncio`：用于运行异步代码。 2. **定义异步函数 `run()`** ```python async def run(): ``` - `async def` 定义一个异步函数。 3. **创建 SSE 连接** ```python async with streamable_http_client(url="http://127.0.0.1:8010/mcp") as (read_stream, write_stream, get_session_id_callback): ``` - 使用 `streamable_http_client` 创建流式 HTTP 连接。 - `read_stream` 和 `write_stream` 用于与服务器通信。 - `get_session_id_callback` 是获取会话 ID 的回调函数。 4. **创建客户端会话** ```python async with ClientSession(read_stream, write_stream) as session: ``` - 使用 `ClientSession` 管理会话。 - `read_stream` 和 `write_stream` 用于与服务器通信。 5. **初始化会话** ```python capabilities = await session.initialize() print(f"Supported capabilities:{capabilities.capabilities}/n/n") ``` - 调用 `session.initialize()` 初始化会话。 - 打印服务器支持的功能。 6. **获取工具列表** ```python tools = await session.list_tools() print(f"Supported tools:{tools}/n/n") ``` - 调用 `session.list_tools()` 获取工具列表。 - 打印工具列表。 7. **调用工具** ```python result = await session.call_tool("retrieve_context",{"query":"张三九的基本信息？"}) print(f"Supported result:{result}") ``` - 调用 `session.call_tool()` 执行工具 `retrieve_context`。 - 传入参数 `{"query":"张三九的基本信息？"}`。 - 打印工具调用结果。 8. **主程序入口** ```python if __name__ == "__main__": asyncio.run(run()) ``` - 检查是否直接运行脚本。 - 使用 `asyncio.run(run())` 运行异步函数 `run()`。 --- ### 相关问题 1. 什么是 SSE（Server-Sent Events）协议？它与 WebSocket 有什么区别？ 2. 如何在本地运行 MCP 服务器并测试这段代码？ 3. `async with` 和 `with` 在 Python 中有什么区别？ 4. `session.call_tool()` 方法的参数有哪些？如何自定义工具？ 5. 如何处理服务器返回的 JSON 数据？