update

.gitignore

@@ -0,0 +1 @@
+**/__pycache__/

app.py

@@ -1,110 +1,7 @@
-import uvicorn
 from fastapi import FastAPI
-from starlette.routing import Mount
-from starlette.requests import Request
-from starlette.responses import StreamingResponse
-import asyncio
-import json
-
-from mcp.server.fastmcp import FastMCP
-from mcp.server.sse import SseServerTransport
-from starlette.applications import Starlette
-from starlette.routing import Mount, Route
-
-def create_sse_server(mcp: FastMCP):
-    """Create a Starlette app that handles SSE connections and message handling"""
-    transport = SseServerTransport("/messages/")
-
-    # Define handler functions
-    async def handle_sse(request):
-        async with transport.connect_sse(
-            request.scope, request.receive, request._send
-        ) as streams:
-            await mcp._mcp_server.run(
-                streams[0], streams[1], mcp._mcp_server.create_initialization_options()
-            )
-
-    # Create Starlette routes for SSE and message handling
-    routes = [
-        Route("/sse/", endpoint=handle_sse),
-        Mount("/messages/", app=transport.handle_post_message),
-    ]
-
-    # Create a Starlette app
-    return Starlette(routes=routes)
-
-# 创建 MCP 应用实例
-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
-
-    async def sse_endpoint(self, request: Request):
-        print("Entering App01 SSE endpoint")
-        try:
-            # 这里可以实现 app01 的 SSE 逻辑
-            yield {"event": "message", "data": "Hello from App01"}
-            import asyncio
-            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")
-
-
-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
-
-    async def sse_endpoint(self, request: Request):
-        print("Entering App02 SSE endpoint")
-        try:
-            # 这里可以实现 app02 的 SSE 逻辑
-            yield {"event": "message", "data": "Hello from App02"}
-            import asyncio
-            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")
 
+from apps.app01 import App01
+from apps.app02 import App02
 
 # 初始化应用
 app01_instance = App01()
@@ -122,6 +19,3 @@ app.mount("/app02", app=app02_instance.mcp.sse_app())
 @app.get("/")
 async def read_root():
     return {"message": "FastAPI is running"}
-
-# if __name__ == "__main__":
-#     uvicorn.run(app, host="0.0.0.0", port=7860)

apps/app01.py

@@ -0,0 +1,38 @@
+import asyncio
+from fastapi import Request
+from mcp.server.fastmcp import FastMCP
+
+# 创建 MCP 应用实例
+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
+
+    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

@@ -0,0 +1,38 @@
+import asyncio
+from fastapi import Request
+from mcp.server.fastmcp import FastMCP
+
+# 创建 MCP 应用实例
+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
+
+    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")