运行此示例

下面介绍如何使用 Python 运行经典的 HTTP 流式服务器和客户端，以及 MCP 流式服务器和客户端。

概述

你将搭建一个 MCP 服务器，在处理项目时向客户端推送进度通知。
客户端会实时显示每条通知。
本指南涵盖了前提条件、设置、运行和故障排除。

前提条件

Python 3.9 或更高版本
mcp Python 包（通过 pip install mcp 安装）

安装与设置

克隆仓库或下载解决方案文件。

git clone https://github.com/microsoft/mcp-for-beginners

创建并激活虚拟环境（推荐）：

python -m venv venv
.\venv\Scripts\Activate.ps1  # On Windows
# or
source venv/bin/activate      # On Linux/macOS

安装所需依赖：
```
pip install "mcp[cli]"
```

文件

服务器： server.py
客户端： client.py

运行经典 HTTP 流式服务器

进入解决方案目录：

cd 03-GettingStarted/06-http-streaming/solution

启动经典 HTTP 流式服务器：
```
python server.py
```

服务器启动后会显示：

Starting FastAPI server for classic HTTP streaming...
INFO:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)

运行经典 HTTP 流式客户端

打开一个新终端（激活相同的虚拟环境和目录）：

cd 03-GettingStarted/06-http-streaming/solution
python client.py

你会看到按顺序打印的流式消息：

Running classic HTTP streaming client...
Connecting to http://localhost:8000/stream with message: hello
--- Streaming Progress ---
Processing file 1/3...
Processing file 2/3...
Processing file 3/3...
Here's the file content: hello
--- Stream Ended ---

运行 MCP 流式服务器

进入解决方案目录：

cd 03-GettingStarted/06-http-streaming/solution

使用 streamable-http 传输启动 MCP 服务器：
```
python server.py mcp
```

服务器启动后会显示：

Starting MCP server with streamable-http transport...
INFO:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)

运行 MCP 流式客户端

打开一个新终端（激活相同的虚拟环境和目录）：

cd 03-GettingStarted/06-http-streaming/solution
python client.py mcp

你会看到服务器处理每个项目时实时打印的通知：

Running MCP client...
Starting client...
Session ID before init: None
Session ID after init: a30ab7fca9c84f5fa8f5c54fe56c9612
Session initialized, ready to call tools.
Received message: root=LoggingMessageNotification(...)
NOTIFICATION: root=LoggingMessageNotification(...)
...
Tool result: meta=None content=[TextContent(type='text', text='Processed files: file_1.txt, file_2.txt, file_3.txt | Message: hello from client')]

关键实现步骤

使用 FastMCP 创建 MCP 服务器。
定义一个处理列表并通过 ctx.info() 或 ctx.log() 发送通知的工具。
使用 transport="streamable-http" 运行服务器。
实现一个带消息处理器的客户端，实时显示收到的通知。

代码讲解

服务器使用异步函数和 MCP 上下文发送进度更新。
客户端实现异步消息处理器，打印通知和最终结果。

小贴士与故障排除

使用 async/await 实现非阻塞操作。
服务器和客户端都要处理异常，保证健壮性。
通过多个客户端测试，观察实时更新效果。
遇到错误时，检查 Python 版本并确保所有依赖已安装。

免责声明：
本文件使用 AI 翻译服务 Co-op Translator 进行翻译。虽然我们力求准确，但请注意，自动翻译可能包含错误或不准确之处。原始文件的母语版本应被视为权威来源。对于重要信息，建议采用专业人工翻译。对于因使用本翻译而产生的任何误解或误释，我们概不负责。

初学者的模型上下文协议（MCP）课程

运行此示例