使用 Go 构建 MCP Server

一个互联网技术玩家,一个爱聊技术的家伙。在工作和学习中不断思考,把这些思考总结出来,并分享,和大家一起交流进步。

一、MCP 介绍 

1. 基本介绍 

MCP(Model Context Protocol,模型上下文协议)是由 Anthropic 公司(Claude 大模型的创造者)于 2024 年 11 月推出的一种开放标准协议,旨在统一大型语言模型(LLM)与外部数据源和工具之间的通信方式。MCP 的核心目标是解决当前 AI 应用开发中的数据孤岛和碎片化集成问题。

2. 协议特点 

MCP 可以被理解为 AI 大模型的"万能接口",类似于 USB-C 接口在硬件领域的作用,它提供了一种标准化的方法,使 AI 模型能够与不同的数据源和工具进行无缝交互。通过 MCP,开发者可以更轻松地构建复杂的 AI 应用,而无需为每个工具或数据源编写专门的集成代码。

  1. MCP 是一个标准协议,如同电子设备的 Type C 协议(可以充电也可以传输数据),使 AI 模型能够与不同的 API 和数据源无缝交互。

  2. MCP 旨在替换碎片化的 Agent 代码集成,从而使 AI 系统更可靠,更有效。通过建立通用标准,服务商可以基于协议来推出它们自己服务的 AI 能力,从而支持开发者更快的构建更强大的 AI 应用。开发者也不需要重复造轮子,通过开源项目可以建立强大的 AI Agent 生态。

  3. MCP 可以在不同的应用/服务之间保持上下文,从而增强整体自主执行任务的能力。

可以理解为 MCP 是将不同任务进行分层处理,每一层都提供特定的能力、描述和限制。而 MCP Client 端根据不同的任务判断,选择是否需要调用某个能力,然后通过每层的输入和输出,构建一个可以处理复杂、多步对话和统一上下文的 Agent。

3. AI Agent 和 MCP 间的关系 

  1. AI Agent 是一个智能系统,它可以自主运行以实现特定目标。传统的 AI 聊天仅提供建议或者需要手动执行任务,AI Agent 则可以分析具体情况,做出决策,并自行采取行动。

  2. AI Agent 可以利用 MCP 提供的功能描述来理解更多的上下文,并在各种平台/服务自动执行任务。

4. MCP 如何工作 

MCP 采用客户端-服务器架构,MCP 架构主要包含以下核心组件:

    MCP 的基本工作流程如下:

    1. 用户向 AI 模型(MCP 客户端)发送请求

    2. AI 模型分析请求,确定需要调用的外部工具或数据

    3. AI 模型通过 MCP 协议向相应的 MCP 服务器发送请求

    4. MCP 服务器处理请求并返回结果

    5. AI 模型整合结果,生成最终回复给用户

    二、cline 配置本地模型 

    我做测试使用的客户端是 vscode+cline,cline 在 vscode 的插件市场中直接安装即可。cline 对 MCP 的支持也是非常好的。因为要使用到大模型,所以这里还要给 cline 配置一个大模型。

    外网开放的免费模型一般都不太好用,所以我一般都是配置本地模型来测试,这里也介绍一下 cline 如何配置本地模型。

    我这里配置了 ollama 启动的 qwen2.5:14b 模型。如下图配置即可,这个配置过程比较简单。

    三、MCP 服务开发 

    1. 典型应用场景 

    1. 实时数据分析:LLM 通过 MCP 直接查询数据库生成动态报告(如销售数据可视化)。

    2. 跨平台自动化:结合本地文件读写和 API 调用,实现“读取文档 → 生成会议摘要 → 发送邮件”全流程自动化。

    3. 隐私敏感任务:医疗数据存储在本地 Server,模型处理时不外传,符合 GDPR 合规要求。

    4. 工具增强生成:例如代码编辑器中集成 MCP Server,根据用户需求调用图像生成工具自动插入图片。

    2. 案例开发 

    这部分代码参考了这篇文章:https://mp.weixin.qq.com/s/JmPxMBRZa8UhsIOQVgupLw ,这篇文章主要是一个按照时区获取时间的工具,我在测试 ok 之后扩展了一个天气获取的工具。

    天气接口使用的是腾讯云的接口,大家可以直接使用免费额度,代码也是直接从腾讯云 api 的介绍中拷贝过来的,这里做了简单的封装调用。

    下面的代码直接拷贝过去就可以使用,不过天气 api 的 key要替换成你自己的。

    package main
    import (	"context"	"crypto/hmac"	"crypto/sha1"	"encoding/base64"	"fmt"	"io"	"io/ioutil"	"net/http"	gourl "net/url"	"strings"	"time""github.com/mark3labs/mcp-go/mcp"	"github.com/mark3labs/mcp-go/server")
    func main() {	// GetWeaher("北京")	// Create MCP server	s := server.NewMCPServer("MCPDemo", "1.0.0")	// Add Get time tool	timetool := mcp.NewTool("current_time",		mcp.WithDescription("Get current time with timezone, Asia/Shanghai is default"),		mcp.WithString("timezone", mcp.Required(), mcp.Description("current time timezone")))	// Add tool handler	s.AddTool(timetool, currentTimeHandler)// add weather tool	weathertool := mcp.NewTool("current_weather",		mcp.WithDescription("Get current weather with city name, 北京 is default, 需要输入中文"),		mcp.WithString("city", mcp.Required(), mcp.Description("city name")))	// Add tool handler	s.AddTool(weathertool, weatherHandler)	// Start the stdio server	if err := server.ServeStdio(s); err != nil {		fmt.Printf("Server error: %v\n", err)	}}
    func currentTimeHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {	timezone, ok := request.Params.Arguments["timezone"].(string)	if !ok {		return mcp.NewToolResultError("timezone must be a string"), nil	}	loc, err := time.LoadLocation(timezone)	if err != nil {		return mcp.NewToolResultError(fmt.Sprintf("parse timezone with error: %v", err)), nil	}	return mcp.NewToolResultText(fmt.Sprintf(`current time is %s`, time.Now().In(loc))), nil}
    func weatherHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error) {	city, ok := request.Params.Arguments["city"].(string)	if !ok {		return mcp.NewToolResultError("city must be a string"), nil	} 	body, err := GetWeaher(city)	if err != nil {		return mcp.NewToolResultError(fmt.Sprintf("read response body with error: %v", err)), nil	}	return mcp.NewToolResultText(string(body)), nil}
    func calcAuthorization(source string, secretId string, secretKey string) (auth string, datetime string, err error) {	timeLocation, _ := time.LoadLocation("Etc/GMT")	datetime = time.Now().In(timeLocation).Format("Mon, 02 Jan 2006 15:04:05 GMT")	signStr := fmt.Sprintf("x-date: %s\nx-source: %s", datetime, source)// hmac-sha1	mac := hmac.New(sha1.New, []byte(secretKey))	mac.Write([]byte(signStr))	sign := base64.StdEncoding.EncodeToString(mac.Sum(nil))auth = fmt.Sprintf("hmac id=\"%s\", algorithm=\"hmac-sha1\", headers=\"x-date x-source\", signature=\"%s\"",		secretId, sign)return auth, datetime, nil}
    func urlencode(params map[string]string) string {	var p = gourl.Values{}	for k, v := range params {		p.Add(k, v)	}	return p.Encode()}
    func GetWeaher(city string) (ret string, err error) {	// 云市场分配的密钥Id	secretId := "xxx"	// 云市场分配的密钥Key	secretKey := "xxx"	source := "usagePlan-xxx"// 签名	auth, datetime, _ := calcAuthorization(source, secretId, secretKey)// 请求方法	method := "GET"	// 请求头	headers := map[string]string{"X-Source": source, "X-Date": datetime, "Authorization": auth}// 查询参数	queryParams := make(map[string]string)	queryParams["areaCn"] = city	queryParams["areaCode"] = ""	queryParams["ip"] = ""	queryParams["lat"] = ""	queryParams["lng"] = ""	queryParams["need1hour"] = ""	queryParams["need3hour"] = ""	queryParams["needIndex"] = ""	queryParams["needObserve"] = ""	queryParams["needalarm"] = ""	// body参数	bodyParams := make(map[string]string)// url参数拼接	url := "https://service-6drgk6su-1258850945.gz.apigw.tencentcs.com/release/lundear/weather1d"	if len(queryParams) > 0 {		url = fmt.Sprintf("%s?%s", url, urlencode(queryParams))	}bodyMethods := map[string]bool{"POST": true, "PUT": true, "PATCH": true}	var body io.Reader = nil	if bodyMethods[method] {		body = strings.NewReader(urlencode(bodyParams))		headers["Content-Type"] = "application/x-www-form-urlencoded"	}client := &http.Client{		Timeout: 5 * time.Second,	}	request, err := http.NewRequest(method, url, body)	if err != nil {		panic(err)	}	for k, v := range headers {		request.Header.Set(k, v)	}	response, err := client.Do(request)	if err != nil {		panic(err)	}	defer response.Body.Close()bodyBytes, err := ioutil.ReadAll(response.Body)	if err != nil {		panic(err)	}	fmt.Println(string(bodyBytes))	return string(bodyBytes), nil}

    四、Cline 上配置自己开发的 MCP 服务 

    在 Cline 上添加 MCP 服务点击右上角“+”号旁边的 4 个小方块按钮即可进入。

    里面有默认的服务市场和已经安装,我们在已经安装这个 tab 中选择 “Configure MCP Servers”,打开配置文件编辑,填写以下内容:

    {  "mcpServers": {    "helight-mcpServers": {      "command": "/Users/helightxu/aillm/mcpgolangtest/mcp-server",      "args": [],      "env": {},      "disabled": false,      "autoApprove": [        "current_weather",        "current_time"      ]    }  }}

    主要就是MCP 服务的名称,里面服务二进制地址等配置。这里还有一个“autoApprove”配置项,这个是在执行命令的时候是否需要人工二次确认还是自动确认。配置之后就可以看到下图的内容了。

    这里还可以点击下面的“Restart Server”,对服务进行重启,重启之后也会获取最新的服务工具信息。在你重新编译 MCP 服务之后,这里一般需要点击重启一下。

    五、案例测试 

    1. 时间获取案例 

    这里输入“当前东京的时间是多少”,执行过程如下,就会在大模型解析之后去调用我们的工具进行执行获取结果,并且会对工具返回的结果使用大模型进行再次组织。

    2. 天气获取案例 

    天气这里也是,提问:“深圳的天气怎么样”,在大模型分析之后就会调用我们的天气获取工具进行天气信息获取,获取之后再使用大模型进行信息组织和展示。

    这里是对信息的再次组织

    五、MCP 的优势和典型应用场景 

    1. MCP 的核心优势 

    从系统集成和开放集成的角度来看,我认为 MCP会带来以下的突破。

    1. 打破数据孤岛:通过统一协议连接异构系统(如本地文档、云服务),减少大量的适配代码开发量。

    2. 双向动态交互:支持实时请求-响应和主动通知(如 WebSocket),相比传统 API 的静态交互更灵活。

    3. 隐私与安全:

      1. 数据隔离:敏感操作(如医疗数据处理)在本地 Server 完成,无需向 LLM 提供商暴露密钥。

      2. 权限控制:Server 可自主定义访问范围,防止越权操作。

    4. 开发效率提升: 开发者只需关注业务逻辑,无需重复实现通信层,例如通过 Python SDK 快速构建天气查询服务。

    2. MCP 目前比较典型的应用场景 

    我认为目前 MCP 的一些典型应用场景会在以下几个方面,不过这个应该发展会很快,未来也许会有更为复杂的应用场景出现。

    1. 智能助手增强

    MCP 可以显著增强智能助手的能力,使其能够:

    • 访问实时信息(如天气、新闻、股票价格等)

    • 执行复杂计算

    • 查询和操作数据库

    • 控制外部设备和系统

    2. 企业知识管理

    在企业环境中,MCP 可以帮助:

    • 构建智能知识库

    • 实现跨部门数据共享

    • 自动化文档处理和分析

    • 提供个性化的员工支持

    六、总结 

    我认为这种模式应该是 AI 应用的趋势,不做大模型,而是做大模型、内容信息和工具之间的一种胶水层,是一种思考模式的实现。感觉未来大厂的这些工具都会向这个方向发展。在特定的领域之内,结合大模型、具体场景信息和相关工具,思考组织执行方式和流程,最终完成一个自动化大规模计算的复杂任务。比如复杂的 k8s 集群运维,复杂大规模的数据分析。

    多智能体协作系统应该是未来的大趋势。而 MCP 在多智能体系统中的应用是其最强大的特性之一。通过 MCP,多个 AI 智能体可以协同工作,各自负责不同的任务,并通过标准化的接口进行通信。

    多智能体可能的一个架构:

    多智能体系统
    多智能体系统├── 协调者智能体(Coordinator Agent)├── 专家智能体 1(Expert Agent 1)├── 专家智能体 2(Expert Agent 2)├── ...└── 专家智能体 N(Expert Agent N)

    六、参考 

    1. https://mp.weixin.qq.com/s/JmPxMBRZa8UhsIOQVgupLw
    2. https://guangzhengli.com/blog/zh/model-context-protocol/

    本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/39662.html

    如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

    相关文章

    Python----计算机视觉处理(Opencv:模板匹配)

    一、 概念 模板匹配就是用模板图(通常是一个小图)在目标图像(通常是一个比模板图大的图片)中不断的滑动 比较,通过某种比较方法来判断是否匹配成功。 二、应用场景 1. 目标检测与识别:在计算机视觉领域&am…

    【stm32】用从模式控制器 完成PWM的测量

    🌞学习视频还是来自于 铁头山羊 🌿主要是回顾一下他讲的这一章的定时器的部分,具体的话 还是看一下具体铁头山羊的视频,讲的很清楚~~ 整体流程是这样的,首先通过定时器的输出比较功能,配置好PA6产生一个特定…

    【C#】CS学习之Modbus通讯

    摘要 本文详细描述了如何在在C#的Winform应用程序中使用NModbus库实现Modbus通讯,包括读取保持寄存器、以及相应的UI界面设计和事件处理。 前言 ​应用场景 Modbus 从站广泛应用于工业自动化领域: 1、传感器数据采集(如温度、压力等&#xf…

    Pycharm社区版创建Flask项目详解

    一、创建工程项目 二、配置工程目录 新建的空项目下创建目录。 1、新建app.py文件 2、app.py代码如下: from flask import Flask, render_templateapp Flask(__name__)app.route("/") def root():"""主页:return: Index.html"&qu…

    Linux 基础入门操作 第十二章 TINY Web 服务器

    1 服务器基础架构 1.1 背景知识 Web 服务器使用 HTTP 协议与客户端(即浏览器)通信,而 HTTP 协议又基于 TCP/IP 协议。因此我们要做的工作就是利用 Linux 系统提供的 TCP 通信接口来实现 HTTP 协议。 而 Linux 为我们提供了哪些网络编程接口…

    RAG优化:python从零实现[吃一堑长一智]循环反馈Feedback

    本文将介绍一种有反馈循环机制的RAG系统,让当AI学会"吃一堑长一智",给传统RAG装了个"后悔"系统,让AI能记住哪些回答被用户点赞/拍砖,从此告别金鱼记忆: 每次回答都像在玩roguelike:失败结局会强化下次冒险悄悄把优质问答变成新知识卡牌,实现"以…

    基于SpringBoot的名著阅读网站

    作者:计算机学姐 开发技术:SpringBoot、SSM、Vue、MySQL、JSP、ElementUI、Python、小程序等,“文末源码”。 专栏推荐:前后端分离项目源码、SpringBoot项目源码、Vue项目源码、SSM项目源码、微信小程序源码 精品专栏:…

    [AI建模] 使用Pinokio本地化部署混元2D到3D AI建模服务

    近年来,AI驱动的2D转3D建模技术发展迅猛,而Pinokio作为一个强大的AI模型管理与部署平台,使得在本地部署这些复杂的AI模型变得更加简单高效。本文将介绍如何使用Pinokio在本地部署混元2D到3D AI建模服务,并快速生成带或不带Texture的3D模型。 1. 在Pinokio Discover页面找到…

    Qt 导入TagLib库

    文章目录 0. 前言和环境介绍1. 下载TagLib2. 下载zlib3. 修改.pro文件4. 测试代码 0. 前言和环境介绍 最近在使用Qt写一个播放器,需要解析mp3文件,于是研究了一下如何导入TagLib库 Qt构建套件:Desktop Qt6.8.2 MinGW64-bit Qt Creator安装目录: D:\bit…

    【前端面试题】计算机网络相关

    总结面试前端过程可能会问到的计算机网络相关知识点 1.HTTP和HTTPS的区别 (1)HTTPS HTTP 安全加密 HTTPS 是 HTTP 的 加密版,通过 SSL/TLS 保障数据安全,防止窃听和篡改。 (2)HTTPS 如何保护数据&…

    【RabbitMQ高级特性】消息确认机制、持久化、发送方确认、TTL和死信队列

    🔥个人主页: 中草药 🔥专栏:【中间件】企业级中间件剖析 一、消息确认机制 消费者确认机制确保消息被正确处理后才从队列中删除。如果消费者处理失败(如业务异常或宕机),Broker 会重新投递消息…

    调用百度api实现语音识别(python)

    该代码实现了一个企业级的语音识别解决方案,通过调用百度语音识别API,实现实时录音识别和对已有音频语音识别功能。 百度智能云:请自行访问百度智能云,开通免费的语音识别功能,获取API_KEY和SECRET_KEY。操作按照百度流程即可,可免费申请。 首先,配置下百度API和描述下错…

    Python实现小红书app版爬虫

    简介:由于数据需求的日益增大,小红书网页版已经不能满足我们日常工作的需求,为此,小编特地开发了小红书手机版算法,方便大家获取更多的数据,提升工作效率。 手机版接口主要包括:搜素&#xff0…

    【AndroidRTC-11】如何理解webrtc的Source、TrackSink

    Android-RTC系列软重启,改变以往细读源代码的方式 改为 带上实际问题分析代码。增加实用性,方便形成肌肉记忆。同时不分种类、不分难易程度,在线征集问题切入点。 问题1:如何理解VideoSource、VideoTrack&VideoSink三者的关系…

    Windows安装Rust环境(详细教程)

    一、 安装mingw64(C语言环境) Rust默认使用的C语言依赖Visual Studio,但该工具占用空间大安装也较为麻烦,可以选用轻便的mingw64包。 1.1 安装地址 (1) 下载地址1-GitHub:Releases niXman/mingw-builds-binaries GitHub (2) 下载地址2-W…

    英伟达黄仁勋谈人工智能趋势,首提代理式AI,后续机器人将登场

    近日,英伟达 GTC 2025 大会主题演讲中,英伟达 CEO 黄仁勋再次身穿皮衣登场。黄仁勋一上来就提到了 AI 发展的未来,现在我们处于生成式 AI(Generative AI)阶段,但根据黄仁勋的路线图,我们将迈向一…

    LCR 187. 破冰游戏(python3解法)

    难度:简单 社团共有 num 位成员参与破冰游戏,编号为 0 ~ num-1。成员们按照编号顺序围绕圆桌而坐。社长抽取一个数字 target,从 0 号成员起开始计数,排在第 target 位的成员离开圆桌,且成员离开后从下一个成员开始计数…

    水星(MERCURY)监控初始化的恢复和转码方法

    水星(MERCURY)的安防监控恢复了很多,其嵌入式文件系统也一直迭代更新。做为数据恢复从业者每天处理最多的就是恢复数据,但是有的时候业务的需要我们不仅仅恢复出数据,还需要能够转码成通用的MP4类文件并要求画面和声音实现“同步”。 故障存…

    基于SpringBoot的实现的客户关系管理系统(CRM)(源码+数据库)

    464客户关系管理系统(CRM),主要功能如下 【后台功能】 权限管理模块: 包括系统的登录与注册功能 用户管理模块: 基于RBAC的权限模型设计, 实现分配角色的功能功能 客户管理模块: 对客户信息进行新增 修改 删除 查看 联络信息管理模块: 对联络…

    关于网络的一点知识(持续更新)

    1、IP地址和子网掩码、端口号: IP地址是设备在网络上的地址,相当于一栋房子的门牌号。子网掩码相当于房子所在的街道。同一条街道的房子间是通过街道直通的,主人可以互相拜访。 举个例子,如下图所示。 说明:将两台设备的IP和子网掩码转化为二进制,然后将各自的IP地址和…