Реализация переноса событий сервера (SSE) для протокола контекста модели (MCP) с использованием Bun.

Обзор

Этот пакет обеспечивает Bun-специфическую реализацию SSE-транспорта для MCP-серверов. Он позволяет осуществлять одностороннюю связь в режиме реального времени от сервера к клиенту с использованием протокола SSE, причем связь между клиентом и сервером обрабатывается с помощью запросов HTTP POST.

Ключевые особенности

Создан специально для Bun Runtime

• Внедрение транспортного интерфейса MCP Управляет связями SSE с правильными заголовками Обработка входящих сообщений JSON-RPC Простая интеграция с Bun.serve

Быстрое использование

Как это работает

1 Когда клиент подключается к /sse, сервер создает соединение SSE 2.Сервер отправляет URL конечной точки, где клиент должен размещать сообщения 3.Клиент отправляет сообщения JSON-RPC на URL конечной точки 4.Сервер принимает эти сообщения и передает их на сервер MCP 5. Сервер MCP обрабатывает сообщения и отправляет ответы через соединение SSE

Эта реализация соответствует стандарту MCP, используя возможности потоковой передачи Bun для эффективной связи в реальном времени.

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.