HTTP OAuth Auth0

🚀 項目文檔

本項目實現了一個支持 SSE 和 Streamable HTTP 兩種協議的狀態無服務器 MCP 服務端，基於 Model Context Protocol (MCP)，能為 AI 應用提供高性能、低延遲的通信能力。

🚀 快速開始

本項目提供了兩種不同的服務器實現，可按以下命令運行：

無狀態版本

bun run src/app.stateless.ts

有狀態版本

bun run src/app.stateful.ts

✨ 主要特性

• 協議支持：同時支持 SSE（Server-Sent Events）和 Streamable HTTP 協議
• 狀態管理：使用臨時內存存儲實現無狀態服務，適合服務器less部署
• 水平擴展：支持簡單的水平擴展，但受限於內存存儲的限制
• 低延遲優化：針對即時 AI 應用設計，減少通信時延

📦 安裝指南

項目運行依賴 bun 環境，確保你已經安裝了 bun。若未安裝，可參考 bun 官方文檔 進行安裝。

💻 使用示例

基礎用法

src/app.stateless.ts 實現了一個純粹的狀態無服務器 MCP 服務端：

import { v4 as uuidv4 } from 'uuid';
import type { TextResponse, StreamableHTTPTransport } from '@modelcontextprotocol/sdk/server';

const port = Number(process.env.PORT) || 5050;
const app = express();

// 基於 UUID 的臨時內存存儲
const inMemoryStorage: Map<string, any> = new Map();

app.use(express.json());

app.get('/mcp', async (req, res) => {
    const id = uuidv4();
    inMemoryStorage.set(id, {});

    res.setHeader('Content-Type', 'text/event-stream');
    res.setHeader('Cache-Control', 'no-cache');
    res.setHeader('Connection', 'keep-alive');

    // 監聽客戶端連接斷開事件
    req.on('close', () => {
        inMemoryStorage.delete(id);
    });

    const stream = new ReadableStream({
        async start(controller) {
            while (true) {
                try {
                    const data = await getMCPData();
                    controller.enqueue(data);
                } catch (error) {
                    controller.error(error);
                    break;
                }
            }
        },
    });

    res.end(stream);
});

server.listen(port, () => {
    console.log(`Server running at http://localhost:${port}`);
});

高級用法

配置 MCP 客戶端

使用 mcp-remote 工具連接到 MCP 服務器：

bunx mcp-remote --transport http-first https://some-domain.server.com/mcp

支持的傳輸模式包括：

• http-first: 默認模式，優先使用 HTTP 協議，失敗後回退到 SSE
• sse-first: 優先使用 SSE 協議，失敗後回退到 HTTP
• http-only: 只使用 HTTP 協議連接
• sse-only: 只使用 SSE 協議連接

在 JavaScript/TypeScript 代理中集成

import { createMCPClient } from '@modelcontextprotocol/sdk/client';

const client = createMCPClient({
    serverUrl: 'http://localhost:5050',
    authProvider: new MyAuthProvider(),
});

client.connect().then(() => {
    // 處理連接成功邏輯
}).catch((error) => {
    console.error('連接 MCP 服務器失敗:', error);
});

📚 詳細文檔

為了將此 MCP 服務端集成到實際應用中，可以根據以下方式進行：

配置 MCP 客戶端

使用 mcp-remote 工具連接到 MCP 服務器，支持多種傳輸模式，可根據實際需求選擇。

在 JavaScript/TypeScript 代理中集成

通過 @modelcontextprotocol/sdk/client 中的 createMCPClient 方法創建客戶端實例，並進行連接操作。

🔧 技術細節

本項目基於 Model Context Protocol (MCP) 實現，使用臨時內存存儲實現無狀態服務。在 src/app.stateless.ts 中，通過 Map 存儲會話數據，當客戶端連接斷開時，自動刪除對應的數據。

📄 許可證

文檔未提及相關許可證信息。

⚠️ 重要提示

• 狀態無服務器實現的限制：所有會話數據僅在內存中臨時存儲，服務重啟後數據丟失
• 水平擴展能力: 適合簡單的無狀態服務部署場景
• 協議兼容性: 確保客戶端和服務器端使用相同的協議版本

💡 使用建議

• 在使用狀態無服務器版本時，若需要持久化會話數據，可考慮使用外部存儲，如數據庫。
• 在進行水平擴展時，需評估內存存儲的限制，避免數據丟失。