fastify-mcp

fastify-mcp

Model Context Protocol サーバーを Fastify アプリに統合します。

Streamable HTTP トランスポート およびレガシーの HTTP+SSE トランスポート をサポートしています。

使い方

まず、MCP サーバーを定義します。

function createServer() {
  const mcpServer = new McpServer({
    name: "...",
    version: "...",
  });

  mcpServer.tool("...");
  mcpServer.resource("...");

  return mcpServer.server;
}

Fastify アプリを作成し、プラグインを登録します。

import { fastify } from "fastify";
import { streamableHttp } from "fastify-mcp";
import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";

const app = fastify();

app.register(streamableHttp, {
  // Set to `true` if you want a stateful server
  stateful: false,
  mcpEndpoint: "/mcp",
  sessions: new Sessions<StreamableHTTPServerTransport>()
  createServer,
});

app.listen({ port: 8080 });

より詳細な例については、examples ディレクトリを参照してください。

インストール

# npm
npm install fastify-mcp

# yarn
yarn add fastify-mcp

セッション管理

公式の MCP TypeScript SDK は、複数のセッションの管理を標準ではサポートしていないため、ホストサーバー側でこれを行う必要があります。

このパッケージは、MCP SDK の例で推奨されているように、アクティブな各セッションをそのセッション ID に紐づけるインメモリのマッピングを使用して、複数のセッションを管理します。

セッションイベント

Sessions クラスは以下のイベントを発行します。

• connected: 新しいセッションが追加されたときに発行されます。
• terminated: セッションが削除されたときに発行されます。
• error: 非同期イベントハンドラーがエラーをスローしたときに発行されます。

const sessions = new Sessions<StreamableHTTPServerTransport>();

sessions.on("connected", (sessionId) => {
  console.log(`Session ${sessionId} connected`);
});

sessions.on("terminated", (sessionId) => {
  console.log(`Session ${sessionId} terminated`);
});

コントリビューション

このパッケージを使用していて問題が発生した場合は、issue を作成してください。新機能やバグ修正のプルリクエストも歓迎します。