如何利用Golang开发MCP服务器？MCP-K8S实践

发表于 2025-6-5 06:35:42

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

您需要登录才可以下载或查看，没有账号？立即注册

×

我建了一个AI技术交流群，发送关键字”加群“，拉你入群

随着大语言模型(LLM)与开发工具的深度融合，Model Control Protocol (MCP)协议正在成为AI与软件工具交互的重要桥梁。MCP允许LLM以结构化的方式调用工具，使AI可以或许执行具体的利用而不仅仅是天生文本。

本文将详细介绍如何利用Golang和mcp-go[1]这个SDK来开发MCP服务器，并以我的开源项目mcp-k8s[2]为具体案例，讲解如何构建一个与Kubernetes集群交互的MCP服务器。

MCP协议简介

MCP (Model Control Protocol)是一种协议，允许LLM与外部工具进行结构化交互。通过MCP，LLM可以：

1. 获取可用工具及其参数列表
2. 调用这些工具执行利用
3. 获取利用结果并基于结果继续交互

这使得LLM可以或许"控制"外部体系，执行从查询数据库到利用Kubernetes资源等各种任务。

mcp-go SDK概述

mcp-go[3]是一个用Golang实现的MCP协议SDK，它提供了构建MCP服务器所需的焦点组件：

1. 工具注册和管理
2. 协议消息处理
3. 多种传输方式支持（stdio、HTTP SSE等）

利用mcp-go，我们可以快速构建本身的MCP服务器，而无需关心底层协议细节。

开发MCP服务器的基本步骤

利用mcp-go开发MCP服务器通常包罗以下步骤：

1. 设计并定义工具（Tools）
2. 实现工具的具体功能
3. 创建服务器并注册工具
4. 配置并启动服务器

下面我们将详细介绍每一步。

1. 设计并定义工具

在MCP中，工具（Tool）是LLM可以调用的功能单位。每个工具须要定义：

• 名称（Name）：工具的标识符
• 形貌（Description）：工具的功能形貌
• 参数（Parameters）：工具担当的参数及其类型
• 处理函数（Handler）：实现工具功能的函数

以mcp-k8s中的get_api_resources工具为例：

// 定义工具
var getAPIResourcesTool = server.Tool{
Name: "get_api_resources",
Description: "获取集群中所有支持的API资源类型",
Parameters: nil, // 此工具不需要参数
Handler: handleGetAPIResources,
}
// 实现处理函数
func handleGetAPIResources(ctx context.Context, rawParams json.RawMessage) (interface{}, error) {
// 具体实现...
}

复制代码

2. 实现工具的具体功能

工具的Handler函数实现具体的业务逻辑。在mcp-k8s中，这些函数主要与Kubernetes API交互。

例如，获取API资源列表的实现：

func handleGetAPIResources(ctx context.Context, rawParams json.RawMessage) (interface{}, error) {
// 创建k8s discovery客户端
discoveryClient, err := discovery.NewDiscoveryClientForConfig(kubeConfig)
if err != nil {
returnnil, fmt.Errorf("创建discovery客户端失败: %w", err)
}
// 获取服务器上所有API组
apiGroups, err := discoveryClient.ServerGroups()
if err != nil {
returnnil, fmt.Errorf("获取API组失败: %w", err)
}
// 处理结果并返回
result := processAPIGroups(apiGroups)
return result, nil
}

复制代码

3. 创建服务器并注册工具

利用mcp-go创建MCP服务器并注册工具：

func main() {
// 创建MCP服务器
s, err := server.NewServer(
server.WithLogger(log.Default()),
)
if err != nil {
log.Fatalf("创建服务器失败: %v", err)
}
// 注册工具
s.RegisterTool(getAPIResourcesTool)
s.RegisterTool(getResourceTool)
s.RegisterTool(listResourcesTool)
// ... 注册更多工具
// 启动服务器
if err := s.Start(); err != nil {
log.Fatalf("启动服务器失败: %v", err)
}
}

复制代码

4. 配置并启动服务器

mcp-go支持多种传输方式，最常用的是stdio（标准输入/输出）和SSE（Server-Sent Events）。

// stdio模式（默认）
s, err := server.NewServer(
server.WithLogger(log.Default()),
server.WithTransport(server.TransportStdio),
)
// SSE模式
s, err := server.NewServer(
server.WithLogger(log.Default()),
server.WithTransport(server.TransportSSE),
server.WithHost("localhost"),
server.WithPort(8080),
)

复制代码

mcp-k8s: 一个完整的实践案例

mcp-k8s[4]是一个利用mcp-go开发的、用于与Kubernetes集群交互的MCP服务器。它提供了以下工具：

1.资源类型查询工具

•get_api_resources: 获取集群中所有支持的API资源类型

2.资源利用工具
- •get_resource: 获取特定资源的详细信息
- •list_resources: 列出某种资源类型的所有实例
- •create_resource: 创建新资源（可配置禁用）
- •update_resource: 更新现有资源（可配置禁用）
- •delete_resource: 删除资源（可配置禁用）
以下是mcp-k8s的焦点实现：

目录结构
1. mcp-k8s/
2. ├── cmd/
3. │ └── server/
4. │ └── main.go # 主程序入口
5. ├── internal/
6. │ ├── config/ # 配置处理
7. │ ├── k8s/ # Kubernetes客户端
8. │ └── tools/ # MCP工具实现
9. ├── go.mod
10. └── go.sum
复制代码
主程序入口
1. // cmd/server/main.go
2. func main() {
3. // 解析命令行参数
4. kubeconfig := flag.String("kubeconfig", "", "Kubernetes配置文件路径")
5. enableCreate := flag.Bool("enable-create", false, "启用资源创建操作")
6. enableUpdate := flag.Bool("enable-update", false, "启用资源更新操作")
7. enableDelete := flag.Bool("enable-delete", false, "启用资源删除操作")
8. transport := flag.String("transport", "stdio", "传输方式: stdio或sse")
9. host := flag.String("host", "localhost", "SSE模式的主机名")
10. port := flag.Int("port", 8080, "SSE模式的端口")
11. flag.Parse()
13. // 初始化Kubernetes客户端
14. if err := k8s.InitClient(*kubeconfig); err != nil {
15. log.Fatalf("初始化K8s客户端失败: %v", err)
16. }
18. // 创建MCP服务器
19. serverOpts := []server.Option{
20. server.WithLogger(log.Default()),
21. }
23. // 配置传输方式
24. if *transport == "sse" {
25. serverOpts = append(serverOpts,
26. server.WithTransport(server.TransportSSE),
27. server.WithHost(*host),
28. server.WithPort(*port),
29. )
30. } else {
31. serverOpts = append(serverOpts, server.WithTransport(server.TransportStdio))
32. }
34. s, err := server.NewServer(serverOpts...)
35. if err != nil {
36. log.Fatalf("创建服务器失败: %v", err)
37. }
39. // 注册工具
40. tools.RegisterTools(s, &tools.Options{
41. EnableCreate: *enableCreate,
42. EnableUpdate: *enableUpdate,
43. EnableDelete: *enableDelete,
44. })
46. // 启动服务器
47. if err := s.Start(); err != nil {
48. log.Fatalf("启动服务器失败: %v", err)
49. }
50. }
复制代码
工具实现示例

以get_resource工具为例：
1. // internal/tools/get_resource.go
2. var GetResourceTool = server.Tool{
3. Name: "get_resource",
4. Description: "获取特定资源的详细信息",
5. Parameters: []server.Parameter{
6. {
7. Name: "apiVersion",
8. Description: "资源的API版本",
9. Type: "string",
10. Required: true,
11. },
12. {
13. Name: "kind",
14. Description: "资源类型",
15. Type: "string",
16. Required: true,
17. },
18. {
19. Name: "name",
20. Description: "资源名称",
21. Type: "string",
22. Required: true,
23. },
24. {
25. Name: "namespace",
26. Description: "资源所在的命名空间（如适用）",
27. Type: "string",
28. Required: false,
29. },
30. },
31. Handler: handleGetResource,
32. }
34. type GetResourceParams struct {
35. APIVersion string`json:"apiVersion"`
36. Kind string`json:"kind"`
37. Name string`json:"name"`
38. Namespace string`json:"namespace"`
39. }
41. func handleGetResource(ctx context.Context, rawParams json.RawMessage) (interface{}, error) {
42. var params GetResourceParams
43. if err := json.Unmarshal(rawParams, &params); err != nil {
44. returnnil, fmt.Errorf("解析参数失败: %w", err)
45. }
47. // 获取动态客户端
48. dynamicClient, err := k8s.GetDynamicClient()
49. if err != nil {
50. returnnil, err
51. }
53. // 获取资源GVR (Group Version Resource)
54. gvr, namespaced, err := k8s.GetGVR(params.APIVersion, params.Kind)
55. if err != nil {
56. returnnil, err
57. }
59. // 确定是命名空间级别还是集群级别的资源
60. var object *unstructured.Unstructured
61. if namespaced {
62. // 如果是命名空间级别资源但未提供命名空间，使用默认命名空间
63. namespace := params.Namespace
64. if namespace == "" {
65. namespace = "default"
66. }
67. object, err = dynamicClient.Resource(gvr).Namespace(namespace).Get(ctx, params.Name, metav1.GetOptions{})
68. } else {
69. object, err = dynamicClient.Resource(gvr).Get(ctx, params.Name, metav1.GetOptions{})
70. }
72. if err != nil {
73. returnnil, fmt.Errorf("获取资源失败: %w", err)
74. }
76. return object.Object, nil
77. }
复制代码
注册所有工具
1. // internal/tools/tools.go
2. type Options struct {
3. EnableCreate bool
4. EnableUpdate bool
5. EnableDelete bool
6. }
8. func RegisterTools(s *server.Server, opts *Options) {
9. // 注册查询工具（始终启用）
10. s.RegisterTool(GetAPIResourcesTool)
11. s.RegisterTool(GetResourceTool)
12. s.RegisterTool(ListResourcesTool)
14. // 根据配置注册写操作工具
15. if opts.EnableCreate {
16. s.RegisterTool(CreateResourceTool)
17. }
18. if opts.EnableUpdate {
19. s.RegisterTool(UpdateResourceTool)
20. }
21. if opts.EnableDelete {
22. s.RegisterTool(DeleteResourceTool)
23. }
24. }
复制代码
利用方法


mcp-k8s支持两种通信模式：

  1. Stdio模式（默认）


在stdio模式下，mcp-k8s通过标准输入/输出流与客户端通信。
1. // MCP客户端配置
2. {
3. "mcpServers":{
4. "mcp-k8s":{
5. "command":"/path/to/mcp-k8s",
6. "args":[
7. "-kubeconfig","/path/to/kubeconfig",
8. "-enable-create",
9. "-enable-delete",
10. "-enable-update"
11. ]
12. }
13. }
14. }
复制代码
2. SSE模式

在SSE模式下，mcp-k8s暴露HTTP端点供MCP客户端毗连。
1. # 运行SSE模式服务
2. ./bin/mcp-k8s -kubeconfig=/path/to/kubeconfig -transport=sse -port=8080 -host=localhost -enable-create -enable-delete -enable-update
复制代码
1. // MCP客户端配置
2. {
3. "mcpServers": {
4. "mcp-k8s": {
5. "url": "http://localhost:8080/sse",
6. "args": []
7. }
8. }
9. }
复制代码
MCP服务开发的最佳实践

基于开发mcp-k8s的经验，我总结了以下开发MCP服务的最佳实践：
- 1.工具命名与分类：利用清晰、一致的命名方式，按功能分类工具
- 2.参数设计：参数名称要直观，提供清晰的形貌，明白标记必选参数
- 3.安全控制：对写利用提供独立的开关控制，避免不须要的权限风险
- 4.错误处理：返回详细的错误信息，帮助LLM理解失败原因
- 5.状态管理：MCP服务应保持无状态，所有须要信息通过参数转达
- 6.文档完善：详细记载每个工具的功能、参数和利用示例
  结论


利用Golang和mcp-go SDK开发MCP服务器是一个相对简朴的过程。通过定义和实现工具，我们可以让LLM具备与各种体系交互的能力，从而大大扩展其应用场景。


mcp-k8s项目展示了如何构建一个功能完整的MCP服务器，让LLM可以或许查询、创建、更新和删除Kubernetes资源，为集群管理提供了新的交互方式。


盼望本文可以或许帮助你理解MCP协媾和利用Golang开发MCP服务器的基本方法。更多详情，欢迎访问mcp-k8s[5]项目，或检察mark3labs/mcp-go[6]的文档。

  AI&&MCP交流群


我建了一个AI技术交流群，目的是为了方便各人交流AI相关的知识和共享资源，目前AI变化真的是太快了
- 1.MCP协议规范[7]
- 2.mcp-go SDK[8]
- 3.mcp-k8s项目[9]
- 4.Kubernetes client-go文档[10]
引用链接

[1]mcp-go:https://github.com/mark3labs/mcp-go
[2]mcp-k8s:https://github.com/silenceper/mcp-k8s
[3]mcp-go:https://github.com/mark3labs/mcp-go
[4]mcp-k8s:https://github.com/silenceper/mcp-k8s
[5]mcp-k8s:https://github.com/silenceper/mcp-k8s
[6]mark3labs/mcp-go:https://github.com/mark3labs/mcp-go
[7]MCP协议规范:https://github.com/llm-tools/model-control-protocol
[8]mcp-go SDK:https://github.com/mark3labs/mcp-go
[9]mcp-k8s项目:https://github.com/silenceper/mcp-k8s
[10]Kubernetes client-go文档:https://github.com/kubernetes/client-go

如何利用Golang开发MCP服务器？MCP-K8S实践

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

浏览过的版块