bun-mcp-sse-transport

一个基于Bun实现的Model Context Protocol (MCP)服务器发送事件（SSE）传输实现。

概述

此包为MCP服务器提供了专门针对Bun运行时的SSE传输实现。它使实时、单向从服务器到客户端的通信成为可能，使用SSE协议，并通过HTTP POST请求处理客户端到服务器的通信。

关键特性

• 专为Bun运行时设计
• 实现MCP传输接口
• 管理带有正确标头的SSE连接
• 处理传入的JSON-RPC消息
• 与Bun.serve简单集成

快速使用

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

// 创建SSE传输
const transport = new BunSSEServerTransport("/messages");

// 连接到MCP服务器
const server = new McpServer({ name: "MyServer", version: "1.0.0" });
server.connect(transport);

// 设置Bun HTTP服务器
Bun.serve({
  port: 3000,
  routes: {
    "/sse": () => transport.createResponse(),
    "/messages": (req) => transport.handlePostMessage(req)
  }
});

工作原理

1. 当客户端连接到/sse时，服务器创建一个SSE连接
2. 服务器发送客户端应POST消息的端点URL
3. 客户端将JSON-RPC消息发送到该端点URL
4. 服务器接收这些消息并将其传递给MCP服务器
5. MCP服务器处理消息并将响应通过SSE连接发送

此实现遵循MCP标准，同时利用Bun的流式功能实现高效的实时通信。