如果你不熟悉 MCP 协议，可以看我之前写的这篇文章：一文掌握 MCP 上下文协议：从理论到实践，如果你想学习如何构建一个 MCP 客户端，可以看这篇文章：用 Go 语言轻松构建 MCP 客户端。
准备好了吗？准备一杯你最喜欢的咖啡或茶，随着本文一探究竟吧。
mcp-go
要构建 MCP 客户端和服务器，我们需要使用 mcp-go 库。
mcp-go 是 Go 语言实现的 Model Context Protocol（MCP）库，通过这个库可以实现 LLM 应用与外部数据源和工具之间的无缝集成。
主要特点
- 快速：高级接口意味着更少的代码和更快的开发速度
- 简单：使用极少的样板代码构建
MCP服务器 - 完整：
MCP Go旨在提供MCP核心规范的完整实现
安装 MCP 库
在 Go 项目根目录下，执行以下命令：
代码语言：Bash
自动换行
AI代码解释
go get github.com/mark3labs/mcp-go
构建 MCP 服务器
接下来，我们使用 mcp-go 提供的 server 模块，构建一个通过 stidio 方式连接的 MCP 服务器。
创建 server 对象
代码语言：JavaScript
代码运行次数：0
自动换行运行
AI代码解释
s := server.NewMCPServer( "Server Demo", "1.0.0", )
创建 server 对象时，我们可以指定 服务器名，版本号 等参数。
添加工具（tools）
以下是一个示例，用于创建并注册一个简单的计算器工具：
代码语言：JavaScript
代码运行次数：2
自动换行运行
AI代码解释
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 })
添加工具的步骤如下：
- 创建工具对象 使用
mcp.NewTool创建一个工具实例。
- 第aly.rouming.net11具名称（必须），例如
"calculate"。 - 其余参数通过函数选项（
functional options）方式传入，例如：
mcp.WithDescription(...)添加工具描述；mcp.WithString(...)或mcp.WithNumber(...)定义参数及其规则（如是否必填、参数说明、枚举限制等）。
- 注册工具到服务器 通过
s.AddTool方法将工具注册到MCP服务中。
- 第一个参数是上一步创建的工具对象；
- 第二个参数是该工具的处理函数（handler），用于实现工具的具体逻辑，如参数解析、运算执行、返回结果等。
添加资源（Resources）
下面的示例展示了如何创建并注册一个静态资源，用于读取并提供 README.md 文件的内容。
代码语言：JavaScript
代码运行次数：0
自动换行运行
AI代码解释
resource := mcp.NewResource( "docs://readme", "项目说明文档", mcp.WithResourceDescription("项目的 README 文件"), mcp.WithMIMEType("text/markdown"), ) 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", MIMEType: "text/markdown", Text: string(content), }, }, nil })
添加资源的步骤如下：
- 创建资源对象使用
mcp.NewResource函数创建资源实例。
- 第一个参数为资源 URI，用于标识资源；
- 第二个参数为资源名称；
- 通过函数选项补充更多信息，例如：
mcp.WithResourceDescription(...)设置资源描述；mcp.WithMIMEType(...)指定资源的 MIME 类型。
- 注册资源处理函数使用
s.AddResource将资源对象注册到服务器，并提供一个处理函数：
- 该处理函数会在资源被访问时执行；
- 返回值是资源内容的数组（例如读取本地文件内容并封装为
TextResourceContents）。
添加提示词（Prompts）
以下示例展示了如何创建并添加一个带参数的简单提示词，用于生成个性化的问候语。
代码语言：JavaScript
代码运行次数：0
自动换行运行
AI代码解释
s.AddPrompt(mcp.NewPrompt("greeting", mcp.WithPromptDescription("一个友好的问候提示"), mcp.WithArgument("name", mcp.ArgumentDescription("要问候的人的名字"), ), ), func(ctx context.Context, request mcp.GetPromptRequest) (*mcp.GetPromptResult, error) { name := request.Params.Arguments["name"] if name == "" { name = "朋友" } return mcp.NewGetPromptResult( "友好的问候", []mcp.PromptMessage{ mcp.NewPromptMessage( mcp.RoleAssistant, mcp.NewTextContent(fmt.Sprintf("你好，%s！今天有什么可以帮您的吗？", name)), ), }, ), nil })
添加提示词的步骤如下：
- 创建提示词对象通过
mcp.NewPrompt创建一个提示词定义。
- 第一个参数是提示词名称；
- 可通过
mcp.WithPromptDescription(...)添加描述； - 使用
mcp.WithArgument(...)定义参数及其说明（如提示词中需要动态插值的内容）。
- 注册提示词处理函数使用
s.AddPrompt将提示词对象注册到服务器，并提供对应的处理逻辑函数：
- 函数接收用户输入参数；
- 返回一个结构化的提示词响应（如构造一个带有用户名字的问候消息）。
启动基于 stdio 传输类型的服务器
代码语言：JavaScript
代码运行次数：0
自动换行运行
AI代码解释
// 启动基于 stdio 的服务器 if err := server.ServeStdio(s); err != nil { fmt.Printf("Server error: %v\n", err) }
使用 server.ServeStdio 方法可以启动一个基于标准输入/输出（stdio）的 MCP 服务器。
这种方式适用于本地集成与命令行工具。
启动基于 sse（Server-Sent Events）传输类型的服务器
如果需要通过 HTTP 的方式提供服务，支持服务端推送数据，可以使用 SSE（Server-Sent Events）传输模式。
代码语言：JavaScript
代码运行次数：0
自动换行运行
AI代码解释
s := server.NewMCPServer( "My Server", // Server 名称 "1.0.0", // 版本号 ) // 创建基于 SSE 的服务器实例 sseServer := server.NewSSEServer(s) // 启动服务器，监听指定端口（如 :8080） err := sseServer.Start(":8080") if err != nil { panic(err) }
与 stdio 不同，sse 模式基于 HTTP 协议，更适合 Web 应用中的长连接场景，支持服务端推送数据。
完整的 stdio 代码示例
代码语言：JavaScript
代码运行次数：11
自动换行运行
AI代码解释
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 }) } // 添加资源 { // 静态资源示例 - 暴露一个 README 文件 resource := mcp.NewResource( "docs://readme", "项目说明文档", mcp.WithResourceDescription("项目的 README 文件"), mcp.WithMIMEType("text/markdown"), ) // 添加资源及其处理函数 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", MIMEType: "text/markdown", Text: string(content), }, }, nil }) } // 添加提示词 { // 简单问候提示 s.AddPrompt(mcp.NewPrompt("greeting", mcp.WithPromptDescription("一个友好的问候提示"), mcp.WithArgument("name", mcp.ArgumentDescription("要问候的人的名字"), ), ), func(ctx context.Context, request mcp.GetPromptRequest) (*mcp.GetPromptResult, error) { name := request.Params.Arguments["name"] if name == "" { name = "朋友" } return mcp.NewGetPromptResult( "友好的问候", []mcp.PromptMessage{ mcp.NewPromptMessage( mcp.RoleAssistant, mcp.NewTextContent(fmt.Sprintf("你好，%s！今天有什么可以帮您的吗？", name)), ), }, ), nil }) } // 启动基于 stdio 的服务器 if err := server.ServeStdio(s); err != nil { fmt.Printf("Server error: %v\n", err) } }
小结
本文介绍了如何构建了一个基于 mcp-go 的服务端，完成了以下内容：
- 创建了
MCP Server实例； - 注册了工具（如计算器）、资源（如 README 文件）和提示词（如问候语）；
- 支持通过
stdio和sse两种方式启动服务，满足不同通信场景。
