最近这段时间，AI领域里有一个非常热门的概念——MCP（模型上下文协议）。Anthropic推出的这一开放标准旨在为大型语言模型和AI助手提供统一的接口，使其能够轻松操作外部工具并完成更复杂的任务。
本文将带你速览MCP的核心概念，并以Go语言为例，介绍如何开发MCP服务端和客户端。

为什么MCP如此重要？

在过去，如果想要让AI处理特定的数据，通常只能依赖于预训练数据或者手动上传数据，这既麻烦又低效。即便对于强大的AI模型而言，也存在数据隔离的问题，无法直接访问新的数据源，每次更新数据都需要重新训练或上传。现在，MCP解决了这个问题，它使得AI不再局限于静态知识库，而是能够像人类一样调用搜索引擎、访问本地文件、连接API服务等，极大提升了AI的动态交互能力。

MCP总体架构

MCP的核心是“客户端-服务器”架构，其中MCP客户端可以连接到多个服务器。客户端是指希望通过MCP访问数据的应用程序，如CLI工具、IDE插件或AI应用。

使用mcp-go构建MCP服务端与客户端

要开始使用Go语言构建MCP项目，首先需要安装

1. mcp-go

复制代码

库，这是Go语言实现的Model Context Protocol库，支持LLM应用与外部数据源和工具之间的无缝集成。

1. go get github.com/mark3labs/mcp-go

复制代码

构建MCP服务端

接下来，我们将演示如何使用

1. mcp-go

复制代码

提供的server模块来构建一个通过stdio方式连接的MCP服务器。
创建Server对象

1. s := server.NewMCPServer("My Server", "1.0.0")

复制代码

添加工具（Tools）
例如，我们可以创建一个简单的计算器工具，这次我们实现乘法和除法功能：

1. calculatorTool := mcp.NewTool("calculate",
   
2.     mcp.WithDescription("执行基本的算术运算"),
   
3.     mcp.WithString("operation",
   
4.         mcp.Required(),
   
5.         mcp.Description("要执行的算术运算类型"),
   
6.         mcp.Enum("multiply", "divide"), // 修改为仅支持乘法和除法
   
7.     ),
   
8.     mcp.WithNumber("x",
   
9.         mcp.Required(),
   
10.         mcp.Description("第一个数字"),
    
11.     ),
    
12.     mcp.WithNumber("y",
    
13.         mcp.Required(),
    
14.         mcp.Description("第二个数字"),
    
15.     ),
    
16. )
    
17. 
    
18. s.AddTool(calculatorTool, func(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {
    
19.     op := request.Params.Arguments["operation"].(string)
    
20.     x := request.Params.Arguments["x"].(float64)
    
21.     y := request.Params.Arguments["y"].(float64)
    
22. 
    
23.     var result float64
    
24.     switch op {
    
25.     case "multiply":
    
26.         result = x * y
    
27.     case "divide":
    
28.         if y == 0 {
    
29.             return nil, errors.New("不允许除以零")
    
30.         }
    
31.         result = x / y
    
32.     }
    
33. 
    
34.     return mcp.FormatNumberResult(result), nil
    
35. })

复制代码

• 添加资源（Resources）
  

同样地，我们也可以注册一些静态资源，比如README.md文件的内容：

1. resource := mcp.NewResource(
   
2.     "docs://readme",
   
3.     "项目说明文档",
   
4.     mcp.WithResourceDescription("项目的 README 文件"),
   
5.     mcp.WithMIMEType("text/markdown"),
   
6. )
   
7. 
   
8. s.AddResource(resource, func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error) {
   
9.     content, err := os.ReadFile("README.md")
   
10.     if err != nil {
    
11.         return nil, err
    
12.     }
    
13. 
    
14.     return []mcp.ResourceContents{
    
15.         mcp.TextResourceContents{
    
16.             URI:      "docs://readme",
    
17.             MIMEType: "text/markdown",
    
18.             Text:     string(content),
    
19.         },
    
20.     }, nil
    
21. })

复制代码

• 启动基于stdio传输类型的服务器
  

1. if err := server.ServeStdio(s); err != nil {
   
2.     fmt.Printf("Server error: %v\n", err)
   
3. }

复制代码

以上步骤完成后，我们就成功搭建了一个基础的MCP服务器。

构建MCP客户端

接着，我们将展示如何使用

1. mcp-go

复制代码

提供的client模块构建一个连接至上述MCP服务器的客户端。

• 创建MCP客户端
  

1. mcpClient, err := client.NewStdioMCPClient("./client/server", []string{})
   
2. if err != nil {
   
3.     panic(err)
   
4. }
   
5. defer mcpClient.Close()

复制代码

• 初始化客户端连接
  

1. ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
   
2. defer cancel()
   
3. 
   
4. initRequest := mcp.InitializeRequest{}
   
5. initRequest.Params.ProtocolVersion = mcp.LATEST_PROTOCOL_VERSION
   
6. initRequest.Params.ClientInfo = mcp.Implementation{
   
7.     Name:    "Client Demo",
   
8.     Version: "1.0.0",
   
9. }
   
10. 
    
11. initResult, err := mcpClient.Initialize(ctx, initRequest)
    
12. if err != nil {
    
13.     panic(err)
    
14. }
    
15. fmt.Printf("初始化成功，服务器信息: %s %s\n", initResult.ServerInfo.Name, initResult.ServerInfo.Version)

复制代码

• 调用远程工具
  

最后，我们可以通过构造

1. CallToolRequest

复制代码

来调用服务器上的工具，如下所示：

1. toolRequest := mcp.CallToolRequest{
   
2.     Request: mcp.Request{
   
3.         Method: "tools/call",
   
4.     },
   
5. }
   
6. toolRequest.Params.Name = "calculate"
   
7. toolRequest.Params.Arguments = map[string]any{
   
8.     "operation": "multiply", // 调用乘法
   
9.     "x":         2,
   
10.     "y":         3,
    
11. }
    
12. 
    
13. result, err := mcpClient.CallTool(ctx, toolRequest)
    
14. if err != nil {
    
15.     panic(err)
    
16. }
    
17. fmt.Println("调用工具结果:", result.Content[0].(mcp.TextContent).Text)

复制代码

完整代码示例

以下是完整的代码示例，包括服务端和客户端的实现：
服务端代码：

1. package main
   
2. 
   
3. import (
   
4.     "context"
   
5.     "errors"
   
6.     "fmt"
   
7.     "os"
   
8. 
   
9.     "github.com/mark3labs/mcp-go/mcp"
   
10.     "github.com/mark3labs/mcp-go/server"
    
11. )
    
12. 
    
13. func main() {
    
14.     s := server.NewMCPServer("Server Demo", "1.0.0")
    
15. 
    
16.     // 添加工具
    
17.     calculatorTool := mcp.NewTool("calculate",
    
18.         mcp.WithDescription("执行基本的算术运算"),
    
19.         mcp.WithString("operation",
    
20.             mcp.Required(),
    
21.             mcp.Description("要执行的算术运算类型"),
    
22.             mcp.Enum("multiply", "divide"),
    
23.         ),
    
24.         mcp.WithNumber("x",
    
25.             mcp.Required(),
    
26.             mcp.Description("第一个数字"),
    
27.         ),
    
28.         mcp.WithNumber("y",
    
29.             mcp.Required(),
    
30.             mcp.Description("第二个数字"),
    
31.         ),
    
32.     )
    
33. 
    
34.     s.AddTool(calculatorTool, func(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {
    
35.         op := request.Params.Arguments["operation"].(string)
    
36.         x := request.Params.Arguments["x"].(float64)
    
37.         y := request.Params.Arguments["y"].(float64)
    
38. 
    
39.         var result float64
    
40.         switch op {
    
41.         case "multiply":
    
42.             result = x * y
    
43.         case "divide":
    
44.             if y == 0 {
    
45.                 return nil, errors.New("不允许除以零")
    
46.             }
    
47.             result = x / y
    
48.         }
    
49. 
    
50.         return mcp.FormatNumberResult(result), nil
    
51.     })
    
52. 
    
53.     // 启动基于 stdio 的服务器
    
54.     if err := server.ServeStdio(s); err != nil {
    
55.         fmt.Printf("Server error: %v\n", err)
    
56.     }
    
57. }

复制代码

客户端代码：

1. package main
   
2. 
   
3. import (
   
4.     "context"
   
5.     "fmt"
   
6.     "time"
   
7. 
   
8.     "github.com/mark3labs/mcp-go/client"
   
9.     "github.com/mark3labs/mcp-go/mcp"
   
10. )
    
11. 
    
12. func main() {
    
13.     mcpClient, err := client.NewStdioMCPClient("./client/server", []string{})
    
14.     if err != nil {
    
15.         panic(err)
    
16.     }
    
17.     defer mcpClient.Close()
    
18. 
    
19.     ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    
20.     defer cancel()
    
21. 
    
22.     initRequest := mcp.InitializeRequest{}
    
23.     initRequest.Params.ProtocolVersion = mcp.LATEST_PROTOCOL_VERSION
    
24.     initRequest.Params.ClientInfo = mcp.Implementation{
    
25.         Name:    "Client Demo",
    
26.         Version: "1.0.0",
    
27.     }
    
28. 
    
29.     initResult, err := mcpClient.Initialize(ctx, initRequest)
    
30.     if err != nil {
    
31.         panic(err)
    
32.     }
    
33.     fmt.Printf("初始化成功，服务器信息: %s %s\n", initResult.ServerInfo.Name, initResult.ServerInfo.Version)
    
34. 
    
35.     // 调用工具
    
36.     toolRequest := mcp.CallToolRequest{
    
37.         Request: mcp.Request{
    
38.             Method: "tools/call",
    
39.         },
    
40.     }
    
41.     toolRequest.Params.Name = "calculate"
    
42.     toolRequest.Params.Arguments = map[string]any{
    
43.         "operation": "multiply",
    
44.         "x":         2,
    
45.         "y":         3,
    
46.     }
    
47. 
    
48.     result, err := mcpClient.CallTool(ctx, toolRequest)
    
49.     if err != nil {
    
50.         panic(err)
    
51.     }
    
52.     fmt.Println("调用工具结果:", result.Content[0].(mcp.TextContent).Text)
    
53. }

复制代码

希望这篇文章能帮助你快速入门Go语言下的MCP开发！
到此这篇关于一文弄懂用Go实现MCP服务的示例代码的文章就介绍到这了,更多相关Go MCP服务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

来源：互联网
免责声明：如果侵犯了您的权益，请联系站长（1277306191@qq.com），我们会及时删除侵权内容，谢谢合作！