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 存储会话数据，当客户端连接断开时，自动删除对应的数据。

📄 许可证

文档未提及相关许可证信息。

⚠️ 重要提示

• 状态无服务器实现的限制：所有会话数据仅在内存中临时存储，服务重启后数据丢失
• 水平扩展能力: 适合简单的无状态服务部署场景
• 协议兼容性: 确保客户端和服务器端使用相同的协议版本

💡 使用建议

• 在使用状态无服务器版本时，若需要持久化会话数据，可考虑使用外部存储，如数据库。
• 在进行水平扩展时，需评估内存存储的限制，避免数据丢失。