update

apps/app01.py

@@ -24,15 +24,15 @@ class App01:
             """Add two integers in App01"""
             return num1 + num2
 
-    async def sse_endpoint(self, request: Request):
-        print("Entering App01 SSE endpoint")
-        try:
-            # 这里可以实现 app01 的 SSE 逻辑
-            yield {"event": "message", "data": "Hello from App01"}
-            await asyncio.sleep(1) # 示例：每秒发送一条消息
-            yield {"event": "message", "data": "Another message from App01"}
-        except Exception as e:
-            print(f"Error in App01 SSE endpoint: {e}")
-            # Optionally yield an error event to the client
-            # yield {"event": "error", "data": str(e)}
-        print("Exiting App01 SSE endpoint")
+    # async def sse_endpoint(self, request: Request):
+    #     print("Entering App01 SSE endpoint")
+    #     try:
+    #         # 这里可以实现 app01 的 SSE 逻辑
+    #         yield {"event": "message", "data": "Hello from App01"}
+    #         await asyncio.sleep(1) # 示例：每秒发送一条消息
+    #         yield {"event": "message", "data": "Another message from App01"}
+    #     except Exception as e:
+    #         print(f"Error in App01 SSE endpoint: {e}")
+    #         # Optionally yield an error event to the client
+    #         # yield {"event": "error", "data": str(e)}
+    #     print("Exiting App01 SSE endpoint")

apps/app02.py

@@ -24,15 +24,15 @@ class App02:
             """Multiply two integers in App02"""
             return num1 * num2
 
-    async def sse_endpoint(self, request: Request):
-        print("Entering App02 SSE endpoint")
-        try:
-            # 这里可以实现 app02 的 SSE 逻辑
-            yield {"event": "message", "data": "Hello from App02"}
-            await asyncio.sleep(2) # 示例：每2秒发送一条消息
-            yield {"event": "message", "data": "Another message from App02"}
-        except Exception as e:
-            print(f"Error in App02 SSE endpoint: {e}")
-            # Optionally yield an error event to the client
-            # yield {"event": "error", "data": str(e)}
-        print("Exiting App02 SSE endpoint")
+    # async def sse_endpoint(self, request: Request):
+    #     print("Entering App02 SSE endpoint")
+    #     try:
+    #         # 这里可以实现 app02 的 SSE 逻辑
+    #         yield {"event": "message", "data": "Hello from App02"}
+    #         await asyncio.sleep(2) # 示例：每2秒发送一条消息
+    #         yield {"event": "message", "data": "Another message from App02"}
+    #     except Exception as e:
+    #         print(f"Error in App02 SSE endpoint: {e}")
+    #         # Optionally yield an error event to the client
+    #         # yield {"event": "error", "data": str(e)}
+    #     print("Exiting App02 SSE endpoint")

博客.md

@@ -5,9 +5,15 @@
 在当前大模型智能体快速发展的背景下，如何有效地管理和调用各种外部工具（Tool）成为了一个关键问题。Model Context Protocol (MCP) 提供了一种标准化的方式来解决这个问题。本项目旨在利用 MCP 的 Python SDK，构建一个**单端口服务，能够加载并管理多个独立的 MCP 应用**。
 
 核心目标如下：
-- 使用 Python SDK 实现一个 MCP 服务。
-- 服务运行在 **7860 端口**。
-- 支持通过统一的端口和不同的路径访问不同的 MCP 应用，路径格式为 `http://localhost:7860/app_name/sse`。
+- **构建基于 Python SDK 的 MCP 服务**__**: 项目使用 MCP Python SDK 构建MCP 服务。
+
+- **实现单端口多应用架构**: 核心目标是创建一个可以在单个网络端口上托管多个独立 MCP 应用的服务。通过 FastAPI 和 FastMCP 实现这一架构，服务监听在 7860 端口。
+
+- **支持按应用名称划分路径**: 实现通过不同的 URL 路径（例如 `/app01/sse`, `/app02/sse`）访问不同的 MCP 应用，符合 `http://localhost:7860/{app_name}/sse` 的路径格式要求。
+
+- **集成并托管独立的 MCP 应用**: 创建 `App01` 和 `App02` 两个独立的 MCP 应用类，并将它们拆分到单独的文件中，然后在主 FastAPI 应用中挂载和托管这两个应用。
+
+- **定义和暴露 MCP 工具**: 在每个应用中定义示例 MCP 工具（如 `app01_add_integers` 和 `app02_multiply_integers`），这些工具通过 MCP 协议暴露出来，可供兼容的客户端调用。
 
 ## 2. 技术选型与实现思路
 
@@ -24,77 +30,113 @@
 ## 3. 代码实现示例
 
 以下是 `app.py` 的核心代码示例，展示了如何使用 FastAPI 和 FastMCP 挂载多个应用：
-
+**app.py**
 ```python
-import uvicorn
 from fastapi import FastAPI
-from mcp.server.fastmcp import FastMCP
-import mcp.types as types
 
-# 创建主 FastAPI 应用
-app = FastAPI(
-    title="Multi-App MCP Server",
-    description="A single-port server hosting multiple MCP applications",
-    version="0.1.0",
-)
+from apps.app01 import App01
+from apps.app02 import App02
 
-# 创建第一个 MCP 应用实例 (app01)
-app01 = FastMCP("app01")
-
-# 为 app01 添加一个示例工具
-@app01.tool()
-def app01_add_integers(num1: int, num2: int) -> int:
-    """Adds two integers"""
-    return num1 + num2
-
-# 创建第二个 MCP 应用实例 (app02)
-app02 = FastMCP("app02")
+# 初始化应用
+app01_instance = App01()
+app02_instance = App02()
 
-# 为 app02 添加一个示例工具
-@app02.tool()
-def app02_multiply_integers(num1: int, num2: int) -> int:
-    """Multiplies two integers"""
-    return num1 * num2
+# 创建 FastAPI 应用
+app = FastAPI()
 
-# 将 MCP 应用挂载到主 FastAPI 应用的不同路径下
-app.mount("/app01", app01.app)
-app.mount("/app02", app02.app)
+# 挂载 MCP 应用的 SSE 端点
+# 使用 Mount 来指定路径前缀
+app.mount("/app01", app=app01_instance.mcp.sse_app())
+app.mount("/app02", app=app02_instance.mcp.sse_app())
 
-# 根路径或其他API路由 (可选)
+# 根路径，用于测试 FastAPI 是否正常工作
 @app.get("/")
 async def read_root():
-    return {"message": "Multi-App MCP Server is running"}
+    return {"message": "FastAPI is running"}
+```
+
+# 创建第一个 MCP 应用实例 (app01)
+**app01.py**
+```python
+import asyncio
+from fastapi import Request
+from mcp.server.fastmcp import FastMCP
+
+# 创建 MCP 应用 app01 的类
+class App01:
+    def __init__(self):
+        self.mcp = FastMCP(name="app01", stateless_http=True)
+        self.register_endpoints()
+
+    def register_endpoints(self):
+        @self.mcp.resource("app01://info")
+        def app01_info() -> str:
+            """Information about App01"""
+            return "This is App01"
+
+        @self.mcp.tool()
+        def app01_echo(message: str) -> str:
+            """Echo a message in App01"""
+            return f"App01 Echo: {message}"
+
+        @self.mcp.tool()
+        def app01_add_integers(num1: int, num2: int) -> int:
+            """Add two integers in App01"""
+            return num1 + num2
+```
+
+# 创建第二个 MCP 应用实例 (app02)
+**app02.py**
+```python
+import asyncio
+from fastapi import Request
+from mcp.server.fastmcp import FastMCP
 
-if __name__ == "__main__":
-    # 运行主 FastAPI 应用，监听 7860 端口
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+# 创建 MCP 应用 app02 的类
+class App02:
+    def __init__(self):
+        self.mcp = FastMCP(name="app02", stateless_http=True)
+        self.register_endpoints()
+
+    def register_endpoints(self):
+        @self.mcp.resource("app02://status")
+        def app02_status() -> str:
+            """Status of App02"""
+            return "App02 is running"
+
+        @self.mcp.tool()
+        def app02_process(data: str) -> str:
+            """Process data in App02"""
+            return f"App02 Processing: {data}"
+
+        @self.mcp.tool()
+        def app02_multiply_integers(num1: int, num2: int) -> int:
+            """Multiply two integers in App02"""
+            return num1 * num2
 ```
 
 **代码说明:**
-- 我们导入了必要的库：`uvicorn`, `FastAPI`, `FastMCP`, `mcp.types`。
+- 我们导入了必要的库：`FastAPI`, `FastMCP`, `asyncio`, `Request`。
 - 创建了主 `FastAPI` 应用 `app`。
 - 创建了两个 `FastMCP` 实例 `app01` 和 `app02`，分别代表两个独立的 MCP 应用。
-- 使用 `@app01.tool()` 和 `@app02.tool()` 装饰器为各自的应用添加了示例工具。
+- 使用 `@self.mcp.resource()` 和 `@self.mcp.tool()` 装饰器为各自的应用添加了示例资源和工具。
 - 最关键的是使用 `app.mount("/app_name", app_instance.app)` 将每个 `FastMCP` 实例的内部 FastAPI 应用挂载到主应用的 `/app_name` 路径下。
-- 最后，使用 `uvicorn.run()` 启动主应用，监听 7860 端口。
 
-## 4. 项目进展与已完成工作
+## 4. 实现的功能
 
-目前，项目的基础框架已经搭建完成，并成功实现了单端口多应用的架构。
-
-**已完成的工作:**
-- 成功搭建并运行了使用 MCP Python SDK 的单端口多应用 MCP 服务 (端口 7860)。
-- 为 `app01` 应用添加了 `app01_add_integers` 工具，并验证了其功能。
-- 为 `app02` 应用添加了 `app02_multiply_integers` 工具，并验证了其功能。
-- 成功处理了包含加法和乘法的复合数学表达式计算请求，验证了不同应用工具的协同工作。
-
-**当前状态:**
-服务已基本框架搭建完成，并已成功添加并验证了两个应用的示例工具。
+项目的基础框架搭建完成，并成功实现单端口多应用的架构。
+- 搭建并运行使用 MCP Python SDK 的单端口多应用 MCP 服务 (端口 7860)。
+- 将 `App01` 和 `App02` 类独立写入 `apps/app01.py` 和 `apps/app02.py` 文件中，再在 `app.py` 里导入这些类，简化主程序代码。
+- 启动 FastAPI 服务器，在该服务器上托管 `app01` 和 `app02` MCP 应用。
+- 为 `app01` 应用添加 `app01_add_integers` 工具。
+- 为 `app02` 应用添加 `app02_multiply_integers` 工具。
 
 ## 5. 在Cline中测试
 
 在Cline中，我们可以直接调用已连接的MCP服务器提供的工具进行测试。以下是一些测试算例：
 
+**重要说明**: 当前的 MCP 服务使用了 Server-Sent Events (SSE) 作为传输协议。SSE 调用需要一个能够建立 SSE 连接并发送/接收 MCP 消息的客户端（如Cursor、Cline等）。此处使用 Cline 作为客户端进行测试。
+
 **测试1：1+1=？**
 使用 `app01` 的 `app01_add_integers` 工具计算：
 ```xml
@@ -172,7 +214,7 @@ if __name__ == "__main__":
 </use_mcp_tool>
 ```
 结果：4
-然后计算 1+1+4：
+然后计算 1+1：
 ```xml
 <use_mcp_tool>
 <server_name>app01</server_name>