Bun を用いたモデルコンテキストプロトコル (MCP) の Server-Sent イベント (SSE) 輸送の実装。

概要

このパッケージは、MCP サーバーの SSE トランスポートの Bun 固有の実装を提供します。 リアルタイムで、サーバーからのワンウェイの通信をSSEプロトコルを使用してクライアントに、HTTP POSTリクエストによって処理されるクライアント・ツー・サーバーの通信を可能にします。

主な特長

• Bunランタイムのために特に造られる
• MCP トランスポートインターフェイスを実装
• 適切なヘッダーでSSE接続を管理
• JSON-RPC メッセージの処理
• Bun.serve との簡単な統合

速い使用法

使い方

1. クライアントが/sseに接続すると、サーバーはSSE接続を作成します。 2。 サーバは、クライアントがPOSTメッセージが必要なエンドポイントURLを送信します
2. クライアントはエンドポイント URL に JSON-RPC メッセージを送信します
3. サーバはこれらのメッセージを受信し、MCP サーバーに渡します。
4. MCP サーバーは、メッセージの処理とSSE接続による応答の送信

この実装は、Bunのストリーミング機能を活用してリアルタイム通信を効率的に活用しながら、MCP規格に従います.

bun-mcp-sse-transport

A Server-Sent Events (SSE) transport implementation for the Model Context Protocol (MCP) using Bun.

Overview

This package provides a Bun-specific implementation of SSE transport for MCP servers. It enables real-time, one-way communication from server to client using the SSE protocol, with client-to-server communication handled via HTTP POST requests.

Key Features

• Built specifically for Bun runtime
• Implements the MCP transport interface
• Manages SSE connections with proper headers
• Handles incoming JSON-RPC messages
• Simple integration with Bun.serve

Quick Usage

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

How It Works

1. When a client connects to /sse, the server creates an SSE connection
2. The server sends the endpoint URL where the client should POST messages
3. The client sends JSON-RPC messages to the endpoint URL
4. The server receives these messages and passes them to the MCP server
5. The MCP server processes the messages and sends responses via the SSE connection

This implementation follows the MCP standard while leveraging Bun’s streaming capabilities for efficient real-time communication.