{
  "mcpServers": {
    "calculator-server": {
      "command": "node",
      "args": ["mcp-server-example.js"],
      "env": {}
    }
  }
}

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import { z } from "zod";
import * as process from 'process';

/**
 * 定义计算记录的接口
 */
interface CalculationRecord {
  operation: string;
  a: number;
  b: number;
  result: number;
  timestamp: string;
}

/**
 * 1. 创建MCP服务器实例
 */
const server = new McpServer({
  name: "calculator-server",
  version: "1.0.0"
});

/**
 * 存储计算历史记录的数组
 */
const calculationHistory: CalculationRecord[] = [];

/**
 * 2. 定义工具
 * 直接使用tool方法定义工具及其处理逻辑
 */
server.tool(
  "calculate_sum",
  { a: z.number(), b: z.number() },
  async ({ a, b }) => {
    const result = a + b;
    // 记录计算历史
    calculationHistory.push({
      operation: "add",
      a: a,
      b: b,
      result: result,
      timestamp: new Date().toISOString()
    });

    return {
      content: [
        {
          type: "text",
          text: String(result)
        }
      ]
    };
  }
);

/**
 * 添加获取历史记录的工具函数
 */
server.tool(
  "get_calculation_history",
  {},
  async () => {
    if (calculationHistory.length === 0) {
      return {
        content: [
          {
            type: "text",
            text: "暂无计算历史记录"
          }
        ]
      };
    }

    // 格式化历史记录
    const historyText = calculationHistory.map((record, index) => {
      return `${index + 1}. ${record.timestamp}: ${record.a} + ${record.b} = ${record.result}`;
    }).join('\n');

    return {
      content: [
        {
          type: "text",
          text: `计算历史记录:\n${historyText}`
        }
      ]
    };
  }
);

/**
 * 3. 添加历史记录资源
 */
server.resource(
  "calculation_history",
  "calc://history",
  async (uri) => {
    if (calculationHistory.length === 0) {
      return {
        contents: [
          {
            uri: uri.href,
            text: "暂无计算历史记录"
          }
        ]
      };
    }

    // 格式化历史记录
    const historyText = calculationHistory.map((record, index) => {
      return `${index + 1}. ${record.timestamp}: ${record.a} + ${record.b} = ${record.result}`;
    }).join('\n');

    return {
      contents: [
        {
          uri: uri.href,
          text: `计算历史记录:\n${historyText}`
        }
      ]
    };
  }
);

/**
 * 4. 使用stdio传输启动服务器
 */
async function main() {
  const transport = new StdioServerTransport();
  await server.connect(transport);
  console.error("服务器已启动并等待连接...");
}

main().catch((error) => {
  console.error("服务器错误:", error);
  process.exit(1);
});

{
  "mcpServers": {
    "remote-server": {
      "url": "http://localhost:3000/mcp/sse",
      // 除了基础的url，我们可以配置常见的headers属性
      "headers": {
        "Authorization": "Bearer your-token"
      },
      "alwaysAllow": ["tool3"],
      "disabled": false
    }
  }
}

import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
import { z } from 'zod';

/**
 * 定义计算记录的接口
 */
interface CalculationRecord {
  operation: string;
  a: number;
  b: number;
  result: number;
  timestamp: string;
}

/**
 * 存储计算历史记录的数组
 */
const calculationHistory: CalculationRecord[] = [];

/**
 * 创建MCP服务器实例
 */
const server = new McpServer({
  name: "calculator-server",
  version: "1.0.0"
});

/**
 * 定义工具：计算两数之和
 */
server.tool(
  'calculate_sum',
  { a: z.number(), b: z.number() },
  async ({ a, b }) => {
    const result = a + b;
    // 记录计算历史
    calculationHistory.push({
      operation: "add",
      a: a,
      b: b,
      result: result,
      timestamp: new Date().toISOString()
    });

    return {
      content: [
        {
          type: "text",
          text: String(result)
        }
      ]
    };
  },
);

/**
 * 定义工具：获取历史记录
 */
server.tool(
  'get_calculation_history',
  { random_string: z.string() },
  async () => {
    if (calculationHistory.length === 0) {
      return {
        content: [
          {
            type: "text",
            text: "暂无计算历史记录"
          }
        ]
      };
    }

    // 格式化历史记录
    const historyText = calculationHistory.map((record, index) => {
      return `${index + 1}. ${record.timestamp}: ${record.a} + ${record.b} = ${record.result}`;
    }).join('\n');

    return {
      content: [
        {
          type: "text",
          text: `计算历史记录:\n${historyText}`
        }
      ]
    };
  },
);

import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js';
import express from 'express';
// ...

const PORT = process.env.PORT || 3000;
/**
 * 启动SSE传输服务器
 * 参考官方SSEServerTransport实现
 */
const startSseServer = async () => {
  console.log('启动SSE传输服务器...');

  // 创建Express应用
  const app = express();

  // SSE传输实例
  let transport: SSEServerTransport;

  // 设置SSE端点
  app.get('/mcp/sse', async (req, res) => {
    // 创建SSE传输
    transport = new SSEServerTransport('/mcp/messages', res);

    await server.connect(transport);
    return;
  });

  app.listen(PORT, () => {
    console.log(`Server is running on port ${PORT}`);
  });

  return true;
};

  // 设置消息接收端点
  app.post('/messages', async (req, res) => {
    console.log('收到来自客户端的消息');

    await transport.handlePostMessage(req, res);
  });

constructor(_endpoint, res) {
    this._endpoint = _endpoint;
    this.res = res;
    this._sessionId = randomUUID();
}

async start() {
    this.res.writeHead(200, {
        "Content-Type": "text/event-stream",
        "Cache-Control": "no-cache",
        Connection: "keep-alive",
    });
    // 发送端点信息，包含会话ID
    this.res.write(`event: endpoint\ndata: ${encodeURI(this._endpoint)}?sessionId=${this._sessionId}\n\n`);
    this._sseResponse = this.res;
}

// 读取HTTP请求体，处理编码和大小限制
body = await getRawBody(req, {
    limit: MAXIMUM_MESSAGE_SIZE,  // 4MB
    encoding: ct.parameters.charset ?? "utf-8",
});

// 将字符串转换为JSON对象
await this.handleMessage(typeof body === 'string' ? JSON.parse(body) : body);
// ...
// 验证是否符合JSON-RPC 2.0规范
parsedMessage = JSONRPCMessageSchema.parse(message);
// 检查必需字段如jsonrpc、id、method等