MCP协议详解：AI与外部数据源交互的开放标准

s := server.NewMCPServer("My Server", "1.0.0")
if err := server.ServeStdio(s); err != nil {
  log.Fatalf("Server error: %v", err)
}

sseServer := server.NewSSEServer(s)
err := sseServer.Start(":8080")

package main

import (
  "context"
  "errors"
  "fmt"
  "os"

  "github.com/mark3labs/mcp-go/mcp"
  "github.com/mark3labs/mcp-go/server"
)

func main() {
  s := server.NewMCPServer("Server Demo", "1.0.0")

  // 添加工具
  calculatorTool := mcp.NewTool("calculate",
    mcp.WithDescription("执行基本的算术运算"),
    mcp.WithString("operation",
      mcp.Required(),
      mcp.Description("运算类型"),
      mcp.Enum("add", "subtract", "multiply", "divide"),
    ),
    mcp.WithNumber("x", mcp.Required(), mcp.Description("第一个数字")),
    mcp.WithNumber("y", mcp.Required(), mcp.Description("第二个数字")),
  )

  s.AddTool(calculatorTool, func(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {
    op := request.Params.Arguments["operation"].(string)
    x := request.Params.Arguments["x"].(float64)
    y := request.Params.Arguments["y"].(float64)

    var result float64
    switch op {
    case "add":      result = x + y
    case "subtract": result = x - y
    case "multiply": result = x * y
    case "divide":
      if y == 0 { return nil, errors.New("不允许除以零") }
      result = x / y
    }
    return mcp.FormatNumberResult(result), nil
  })

  // 添加资源
  resource := mcp.NewResource("docs://readme", "项目说明文档")
  s.AddResource(resource, func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error) {
    content, err := os.ReadFile("README.md")
    if err != nil { return nil, err }
    return []mcp.ResourceContents{
      mcp.TextResourceContents{URI: "docs://readme", Text: string(content)},
    }, nil
  })

  // 启动服务
  if err := server.ServeStdio(s); err != nil {
    fmt.Printf("Server error: %v\n", err)
  }
}

package main

import (
  "context"
  "fmt"
  "time"

  "github.com/mark3labs/mcp-go/client"
  "github.com/mark3labs/mcp-go/mcp"
)

func main() {
  mcpClient, err := client.NewStdioMCPClient("./server", []string{})
  if err != nil { panic(err) }
  defer mcpClient.Close()

  ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
  defer cancel()

  // 初始化
  initResult, err := mcpClient.Initialize(ctx, mcp.InitializeRequest{})
  fmt.Printf("服务器信息: %s %s\n", 
    initResult.ServerInfo.Name, initResult.ServerInfo.Version)

  // 获取工具列表
  tools, _ := mcpClient.ListTools(ctx, mcp.ListToolsRequest{})
  for _, tool := range tools.Tools {
    fmt.Printf("- %s: %s\n", tool.Name, tool.Description)
  }

  // 调用工具
  result, _ := mcpClient.CallTool(ctx, mcp.CallToolRequest{
    Params: mcp.CallToolParams{
      Name: "calculate",
      Arguments: map[string]any{"operation": "add", "x": 1, "y": 1},
    },
  })
  fmt.Println("结果:", result.Content[0].(mcp.TextContent).Text)
}