bun-mcp-sse-トランスポート

Bun を使用したモデル コンテキスト プロトコル (MCP) の Server-Sent Events (SSE) トランスポート実装。

概要

このパッケージは、MCPサーバー向けのBun固有のSSEトランスポート実装を提供します。SSEプロトコルを用いたサーバーからクライアントへのリアルタイムの一方向通信を可能にし、クライアントからサーバーへの通信はHTTP POSTリクエストを介して処理されます。

Related MCP server: MCP Server with SSE and Bearer Authentication

主な特徴

• Bunランタイム専用に構築

• MCPトランスポートインターフェースを実装する

• 適切なヘッダーを使用してSSE接続を管理します

• 受信したJSON-RPCメッセージを処理します

• Bun.serveとのシンプルな統合

クイック使用方法

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { BunSSEServerTransport } from "bun-mcp-sse-transport";

// Create SSE transport
const transport = new BunSSEServerTransport("/messages");

// Connect to MCP server
const server = new McpServer({ name: "MyServer", version: "1.0.0" });
server.connect(transport);

// Set up Bun HTTP server
Bun.serve({
  port: 3000,
  routes: {
    "/sse": () => transport.createResponse(),
    "/messages": (req) => transport.handlePostMessage(req)
  }
});

仕組み

1. クライアントが/sseに接続すると、サーバーはSSE接続を作成します。

2. サーバーはクライアントがメッセージをPOSTするエンドポイントURLを送信します。

3. クライアントはエンドポイントURLにJSON-RPCメッセージを送信します。

4. サーバーはこれらのメッセージを受信し、MCPサーバーに渡します。

5. MCPサーバーはメッセージを処理し、SSE接続を介して応答を送信します。

この実装は、MCP 標準に準拠しながら、Bun のストリーミング機能を活用して効率的なリアルタイム通信を実現します。