MCP Framework

🚀 MCP 框架指南

MCP 框架是一款功能强大的工具，可极大简化实时通信应用的开发工作。它支持 SSE 和 HTTP 流等多种传输协议，还配备了认证、日志记录和错误处理等丰富的功能模块。

🚀 快速开始

📦 安装依赖

npm install mcp-framework

💻 使用示例

基础用法

import { MCPServer } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      port: 3000,
      host: 'localhost'
    }
  }
});

server.start();

运行示例

node index.js

✨ 主要特性

MCP 框架通过中间件机制实现模块化功能。用户能够依据自身需求挑选不同的中间件，进而扩展服务功能。

📚 详细文档

SSE 传输配置

SSE（Server-Sent Events）是一种用于实时通信的协议，适用于需要持续数据流的应用场景。

基本配置

import { MCPServer } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      port: 3000,
      host: 'localhost'
    }
  }
});

server.start();

高级配置

import { MCPServer, SSETransportOptions } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      port: 3000,
      host: 'localhost',
      path: '/events',
      maxReconnectionDelay: 5000
    }
  }
});

server.start();

HTTP 流传输配置

HTTP 流传输适用于需要处理大文件上传和下载的场景。

基本配置

import { MCPServer } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'http-stream',
    options: {
      port: 3000,
      host: 'localhost'
    }
  }
});

server.start();

高级配置

import { MCPServer, HTTPStreamOptions } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'http-stream',
    options: {
      port: 3000,
      host: 'localhost',
      path: '/stream',
      responseMode: 'batch',
      batchTimeout: 30000
    }
  }
});

server.start();

认证

MCP 框架支持多种认证方式，包括 JWT 和 API Key。

JWT 认证配置

import { MCPServer, JWTAuthProvider } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      auth: {
        provider: new JWTAuthProvider({
          secret: process.env.JWT_SECRET,
          algorithms: ['HS256']
        }),
        endpoints: {
          sse: true
        }
      }
    }
  }
});

server.start();

API Key 认证配置

import { MCPServer, APIKeyAuthProvider } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      auth: {
        provider: new APIKeyAuthProvider({
          secret: process.env.API_KEY_SECRET
        })
      }
    }
  }
});

server.start();

日志记录

MCP 框架提供内置日志记录功能，帮助开发者调试和监控服务。

import { MCPServer, Logger } from 'mcp-framework';

const logger = new Logger({
  level: 'info',
  handlers: [
    {
      type: 'file',
      path: './logs/app.log'
    }
  ]
});

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      port: 3000,
      host: 'localhost'
    }
  },
  logger
});

server.start();

错误处理

MCP 框架提供强大的错误处理机制，帮助开发者快速定位和解决问题。

import { MCPServer } from 'mcp-framework';

const server = new MCPServer({
  transport: {
    type: 'sae',
    options: {
      port: 3000,
      host: 'localhost'
    }
  },
  errorHandlers: [
    (error, context) => {
      console.error('Custom error handler:', error);
      context.reply(500, 'Internal Server Error');
    }
  ]
});

server.start();

🔚 总结

MCP 框架通过提供灵活的配置和强大的功能模块，简化了实时通信应用的开发过程。无论是 SSE 还是 HTTP 流传输，用户都可以根据需求选择合适的方案，并通过丰富的中间件扩展服务功能。