MCP Server Do

🚀 SSE + MCP 服務器 + Durable Objects

本項目包含三個核心部分，與 @modelcontextprotocol/typescript-sdk 配合使用，為你提供了一個高效的運行環境：

1. 一個 SSE 傳輸層，位於 /src/sse.ts，可與 @modelcontextprotocol/typescript-sdk 協同工作。
2. 一個作為 Durable Object 的 MCP 服務器，位於 /src/mcp-server-do.ts。
3. 提供了端到端的運行步驟，方便你快速上手。

🚀 快速開始

運行步驟

1. 克隆倉庫：將此倉庫克隆到本地。
2. 安裝依賴：在項目根目錄下，運行 npm install 命令，安裝所需的依賴。
3. 啟動 DO：執行 npm start 命令，啟動 Durable Object。啟動後，可通過 http://localhost:8787 訪問。
4. 運行 MCP Inspector：使用 npx @modelcontextprotocol/inspector 命令運行 MCP Inspector。
5. 打開 Inspector：打開 Inspector 後，輸入 http://localhost:8787/sse。

💻 使用示例

基礎用法

我從 這個示例 中獲取靈感，該示例來自 @modelcontextprotocol/typescript-sdk：

import express from "express";
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";

const server = new McpServer({
  name: "example-server",
  version: "1.0.0"
});

// ... 設置服務器資源、工具和提示 ...

const app = express();

app.get("/sse", async (req, res) => {
  const transport = new SSEServerTransport("/messages", res);
  await server.connect(transport);
});

app.post("/messages", async (req, res) => {
  // 注意：要支持多個同時連接，這些消息需要路由到特定的傳輸。由於簡單起見，此處未實現此邏輯。
  await transport.handlePostMessage(req, res);
});

app.listen(3001);

高級用法

參考上述示例，我將其實現為 Durable Objects 中的內容。但首先需要一個在 Workers 上運行的傳輸層。參考 sse.ts 來自 @modelcontextprotocol/typescript-sdk，我實現了一個類似的版本，儘量模仿現有代碼的結構和功能。需要注意的是，SDK 中有一些與 Node.js 的 http 模塊耦合較深的設計假設，這些假設會洩漏到 SSE 傳輸層及其輸入類型中——但其實唯一有意義的接口變化是 handlePostMessage 接受請求並返回響應。看起來有一種巧妙的方法可以將其上游化？

📚 詳細文檔

本項目的靈感來源於 @modelcontextprotocol/typescript-sdk 中的 這個示例。在實現過程中，參考了 sse.ts 來自 @modelcontextprotocol/typescript-sdk，並將其實現為 Durable Objects 中的內容。同時，需要注意 SDK 中與 Node.js 的 http 模塊耦合較深的設計假設對 SSE 傳輸層及其輸入類型的影響。