HTTP OAuth Auth0

🚀 プロジェクトドキュメント

本プロジェクトは、2種類のプロトコル（SSE と Streamable HTTP）をサポートする状態レスの MCP サーバーを実装しています。この実装は Model Context Protocol (MCP) に基づいており、AI アプリケーションに高性能かつ低遅延の通信機能を提供することを目的としています。

✨ 主な機能

• プロトコルサポート：SSE（Server-Sent Events）と Streamable HTTP プロトコルの両方をサポートします。
• 状態管理：一時的なメモリストレージを使用して状態レスのサービスを実現し、サーバーレス環境へのデプロイに適しています。
• 水平スケーリング：簡単な水平スケーリングをサポートしますが、メモリストレージの制限による制約があります。
• 低遅延最適化：リアルタイム AI アプリケーション向けに設計され、通信遅延を最小限に抑えます。

🔧 技術詳細

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}`);
});

📦 インストール

プロジェクトには 2 種類のサーバー実装が用意されています。

状態レスバージョン

bun run src/app.stateless.ts

状態ありバージョン

bun run src/app.stateful.ts

💻 使用例

基本的な使用法

この MCP サーバーを実際のアプリケーションに統合するには、以下の手順に従ってください。

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 プロトコルに基づく状態レスの実装ソリューションを提供しており、主にリアルタイム通信機能と軽量なサービス設計が必要な AI アプリケーションのシナリオを対象としています。