MCP 服务器

MCP Server with Cloudflare Workers

一个开放标准服务器实现，它使 AI 助手能够通过模型上下文协议直接访问 API 和服务，并使用 Cloudflare Workers 构建以实现可扩展性。

README

基于 Cloudflare Workers 的 MCP 服务器

简介

模型上下文协议 (MCP) 是一种开放标准，它使 AI 代理和助手能够与服务进行交互。通过设置 MCP 服务器，您可以允许 AI 助手直接访问您的 API。

Cloudflare Workers 与 workers-mcp 包相结合，为构建 MCP 服务器提供了一个强大且可扩展的解决方案。

前提条件

在开始之前，请确保您已具备以下条件：

一个 Cloudflare 帐户
已安装 Node.js
已安装 Wrangler CLI (npm install -g wrangler)

入门

步骤 1：创建一个新的 Cloudflare Worker

首先，初始化一个新的 Cloudflare Worker 项目：

npx create-cloudflare@latest my-mcp-worker
cd my-mcp-worker

然后，验证您的 Cloudflare 帐户：

wrangler login

步骤 2：配置 Wrangler

使用正确的帐户详细信息更新您的 wrangler.toml 文件：

name = "my-mcp-worker"
main = "src/index.ts"
compatibility_date = "2025-03-03"
account_id = "your-account-id"

安装 MCP 工具

要启用 MCP 支持，请安装 workers-mcp 包：

npm install workers-mcp

运行 setup 命令来配置 MCP：

npx workers-mcp setup

这将：

添加必要的依赖项
设置用于测试的本地代理
配置 Worker 以符合 MCP 标准

编写 MCP 服务器代码

更新您的 src/index.ts 以定义您的 MCP 服务器：

import { WorkerEntrypoint } from 'cloudflare:workers';
import { ProxyToSelf } from 'workers-mcp';

export default class MyWorker extends WorkerEntrypoint<Env> {
  /**
   * 来自您的 MCP 服务器的友好问候。
   * @param name {string} 用户的姓名。
   * @return {string} 个性化的问候语。
   */
  sayHello(name: string) {
    return `Hello from an MCP Worker, ${name}!`;
  }

  /**
   * @ignore
   */
  async fetch(request: Request): Promise<Response> {
    return new ProxyToSelf(this).fetch(request);
  }
}

关键组件：

WorkerEntrypoint: 管理传入的请求和方法暴露。
ProxyToSelf: 确保 MCP 协议合规性。
sayHello 方法: AI 助手可以调用的示例 MCP 函数。

添加 API 调用

您可以通过与外部 API 集成来扩展您的 MCP 服务器。这是一个获取天气数据的示例：

export default class WeatherWorker extends WorkerEntrypoint<Env> {
  /**
   * 获取给定位置的天气数据。
   * @param location {string} 城市或邮政编码。
   * @return {object} 天气详情。
   */
  async getWeather(location: string) {
    const response = await fetch(`https://api.weather.example/v1/${location}`);
    const data = await response.json();
    return {
      temperature: data.temp,
      conditions: data.conditions,
      forecast: data.forecast
    };
  }

  async fetch(request: Request): Promise<Response> {
    return new ProxyToSelf(this).fetch(request);
  }
}