MCP 实战:用 Go 语言开发一个查询 IP 信息的 MCP 服务器

简介: 随着 MCP 的快速普及和广泛应用,MCP 服务器也层出不穷。大多数开发者使用的 MCP 服务器开发库是官方提供的 typescript-sdk,而作为 Go 开发者,我们也可以借助优秀的第三方库去开发 MCP 服务器,例如 ThinkInAIXYZ/go-mcp。本文将详细介绍如何在 Go 语言中使用 go-mcp 库来开发一个查询 IP 信息的 MCP 服务器。

作者:陈明勇,一名热爱技术、乐于分享的开发者,同时也是开源爱好者。

我专注于分享 Go 语言相关的技术知识,同时也会深入探讨 AI 领域的前沿技术。

成功的路上并不拥挤,有没有兴趣结个伴?

Go 开源库代表作:go-mongoxgo-optioner

个人网站:https://chenmingyong.cn

文章持续更新,如果本文能让您有所收获,欢迎关注本号。

微信阅读可搜《程序员陈明勇》。

该文章已被 Model Context Protocol(MCP) 中文教程讲解 收录,欢迎 star 收藏。

📝 前言

随着 MCP 的快速普及和广泛应用,MCP 服务器也层出不穷。大多数开发者使用的 MCP 服务器开发库是官方提供的 typescript-sdk,而作为 Go 开发者,我们也可以借助优秀的第三方库去开发 MCP 服务器,例如 ThinkInAIXYZ/go-mcp

本文将详细介绍如何在 Go 语言中使用 go-mcp 库来开发一个查询 IP 信息的 MCP 服务器。

准备好了吗?准备一杯你最喜欢的咖啡或茶,随着本文一探究竟吧。

image.png

🌐 mcp-ip-geo 服务器

mcp-ip-geo 是一个用于查询 IP 信息的 MCP 服务器,项目已开源,仓库地址:mcp-ip-geo

📁 目录结构说明

├─cmd
│  └─mcp-ip-geo
└─internal
    ├─domain
    ├─server
    ├─service
    └─tools
  • cmd/mcp-ip-geo:应用的启动入口目录,包含如 main.go 启动文件。
  • internal/domain:定义项目中的核心数据结构,例如 IP API 的响应体等。
  • internal/serverMCP 服务器的核心逻辑实现。
  • internal/service:对接第三方服务的实现,如调用 IP 解析 API
  • internal/toolsMCP 工具的具体实现,支持灵活扩展和注册。

🔍 查询 IP 信息功能实现

代码位于 service 包中,通过 ip-api.com 提供的接口获取 IP 地理位置信息,具体实现如下:

package service

import (
    "context"
    "fmt"
    "github.com/chenmingyong0423/mcp-ip-geo/internal/domain"
    "net/http"
    "time"

    httpchain "github.com/chenmingyong0423/go-http-chain"
)

func NewIpApiService() *IpApiService {
   
    return &IpApiService{
   
       host: "http://ip-api.com",
       client: httpchain.NewWithClient(&http.Client{
   
          Timeout: time.Second * 10,
       }),
    }
}

type IIpApiService interface {
   
    GetLocation(ctx context.Context, ip string) (*domain.IpApiResponse, error)
}

var _ IIpApiService = (*IpApiService)(nil)

type IpApiService struct {
   
    host   string
    client *httpchain.Client
}

func (s *IpApiService) GetLocation(ctx context.Context, ip string) (*domain.IpApiResponse, error) {
   
    var resp domain.IpApiResponse
    err := s.client.Get(fmt.Sprintf("%s/json/%s", s.host, ip)).DoAndParse(ctx, &resp)
    if err != nil {
   
       return nil, err
    }
    return &resp, nil
}

代码解释:

  • 服务初始化(NewIpApiService

    • 创建一个新的 IpApiService 实例。
    • 设置了 API 地址为 http://ip-api.com
    • 使用 httpchain 封装的 HTTP 客户端,设置请求超时时间为 10 秒。
  • 接口定义(IIpApiService

    • 定义了服务对外暴露的功能:GetLocation 方法,用于获取 IP 地理位置信息。
    • 使用接口有助于后续做依赖注入、mock 测试等。
    • var _ IIpApiService = (*IpApiService)(nil) 这行代码用于编译时检查,确保 IpApiService 实现了 IIpApiService 接口。
  • 结构体定义(IpApiService

    • 包含两个字段:
    • hostAPI 的基础地址。
    • client:封装的 HTTP 客户端,类型为 *httpchain.Client
  • 核心方法实现(GetLocation

    • 根据传入的 IP 构造请求地址:http://ip-api.com/json/{ip}
    • 使用 httpchain 库发起 GET 请求,并将结果解析到 domain.IpApiResponse 结构体中。

🧰 工具实现

🔧 工具管理

代码位于 tools 包中,用于管理工具,具体实现如下:

package tools

import (
    "github.com/ThinkInAIXYZ/go-mcp/protocol"
    "github.com/ThinkInAIXYZ/go-mcp/server"
)

type ToolFunc func() (tool *protocol.Tool, toolHandler server.ToolHandlerFunc)

func GetToolFuncList() []ToolFunc {
   
    return []ToolFunc{
   
       SingleIpParser,
    }
}

代码解释:

  • ToolFunc 类型定义

    • 定义了一个函数类型 ToolFunc,返回两个值:

      • *protocol.Tool:工具的元信息;
      • server.ToolHandlerFunc:该工具的处理逻辑函数。
    • 用这种方式可以将 工具的定义工具的执行逻辑 一并管理,后续在定义工具时都可以通过实现该函数签名进行表示。

  • GetToolFuncList 函数

    • 返回一个 ToolFunc 列表。
    • 当前只注册了一个工具:SingleIpParser,但这种结构易于扩展,后续只需往列表中添加新的工具函数即可。
    • 通过集中注册,应用在初始化时可以统一加载所有工具。

🌍 查询单个 IP 信息工具的实现

代码位于 tools 包中,用于查询单个 IP 信息,具体实现如下:

package tools

import (
    "context"
    "encoding/json"
    "github.com/ThinkInAIXYZ/go-mcp/protocol"
    "github.com/ThinkInAIXYZ/go-mcp/server"
    "github.com/chenmingyong0423/mcp-ip-geo/internal/service"
)

var singleIpParserTool *protocol.Tool

type ipRequest struct {
   
    Ip string `json:"ip"`
}

func init() {
   
    var err error
    singleIpParserTool, err = protocol.NewTool("ip-details", "a tool that provides IP geolocation information", ipRequest{
   })
    if err != nil {
   
       panic(err)
    }
}

func SingleIpParser() (*protocol.Tool, server.ToolHandlerFunc) {
   
    ipApiService := service.NewIpApiService()

    return singleIpParserTool, func(toolRequest *protocol.CallToolRequest) (*protocol.CallToolResult, error) {
   
       var req ipRequest
       if err := protocol.VerifyAndUnmarshal(toolRequest.RawArguments, &req); err != nil {
   
          return nil, err
       }
       resp, err := ipApiService.GetLocation(context.Background(), req.Ip)
       if err != nil {
   
          return nil, err
       }

       marshal, err := json.Marshal(resp)
       if err != nil {
   
          return nil, err
       }

       return &protocol.CallToolResult{
   
          Content: []protocol.Content{
   
             protocol.TextContent{
   
                Type: "text",
                Text: string(marshal),
             },
          },
       }, nil
    }
}

代码解释:

  • 全局变量声明

    • singleIpParserTool:存储工具元信息的协议工具对象
    • ipRequest:定义工具输入参数结构体,包含 ip 字符串字段
  • 初始化函数(init

    • 在包加载时通过 protocol.NewTool 创建工具元信息
    • 指定工具标识符 ip-details,描述信息和输入参数结构体 ipRequest{}
    • 错误处理采用 panic,确保工具元信息必须正确初始化
  • 工具注册函数(SingleIpParser

    • 创建 IpApiService 服务实例用于 IP 定位查询

    • 返回两个值:

      • 预定义的 singleIpParserTool 元信息对象
      • 工具处理函数
  • 工具处理函数

    • 参数验证与解析

      • 调用 protocol.VerifyAndUnmarshal 验证请求参数有效性
      • 将原始参数反序列化到 ipRequest 结构体
    • 服务调用

      • 使用 ipApiService.GetLocation 获取 IP 地理位置信息
    • 结果处理

      • 将服务响应结果序列化为 JSON 字符串并包装为 protocol.CallToolResult 结构体返回

🚀 服务器的创建与启动

代码位于 server 包中,用于初始化服务并启动服务端,具体实现如下:

package server

import (
    "github.com/ThinkInAIXYZ/go-mcp/server"
    "github.com/ThinkInAIXYZ/go-mcp/transport"
    "github.com/chenmingyong0423/mcp-ip-geo/internal/tools"
)

func Run(address string) error {
   
    var err error

    var ts transport.ServerTransport
    if address == "" {
   
       ts = transport.NewStdioServerTransport()
    } else {
   
       ts, err = transport.NewSSEServerTransport(address)
       if err != nil {
   
          return err
       }
    }

    s, err := server.NewServer(ts)
    if err != nil {
   
       return err
    }

    toolFuncList := tools.GetToolFuncList()
    for _, tool := range toolFuncList {
   
       s.RegisterTool(tool())
    }

    return s.Run()
}

代码解释:

  • 传输层初始化

    • 根据 address 参数判断运行模式:

      • 空地址模式:使用 NewStdioServerTransport 创建标准输入输出传输,适用于命令行工具等场景。
      • 指定地址模式:使用 NewSSEServerTransport 创建 SSE (Server-Sent Events) 传输,适用于 HTTP 长连接服务。
  • 服务实例化

    • 使用 server.NewServer 方法创建服务实例,注入配置好的传输层对象 ts
  • 工具注册

    • 调用 tools.GetToolFuncList 获取所有预定义的工具函数列表。

    • 遍历工具列表,通过 s.RegisterTool(tool()) 注册每个工具:

      • tool() 执行后返回元信息 *protocol.Tool 和处理函数 ToolHandlerFunc
  • 服务启动

    • 调用 s.Run() 启动服务,开始监听请求。

🧩 主程序入口实现

代码位于 main 包中,作为程序启动入口,具体实现如下:

package main

import (
    "flag"
    "github.com/chenmingyong0423/mcp-ip-geo/internal/server"
)

func main() {
   
    addr := flag.String("address", "", "The host and port to run the sse server")
    flag.Parse()

    if err := server.Run(*addr); err != nil {
   
       panic(err)
    }
}

代码解释:

  • 命令行参数解析

    • 定义 address 参数:

      • 参数名称:-address
      • 默认值:空字符串
      • 描述:指定 SSE 服务运行的地址和端口
    • 调用 flag.Parse() 解析命令行参数

  • 服务启动

    • 调用 server.Run(*addr) 启动服务
    • 将解析后的 address 参数值传递给服务启动函数

⚙️ 从源码构建

🛠 本地构建

💻 使用 Go 命令

# 在类 Unix 系统(Linux/macOS)上
go build -o mcp-ip-geo ./cmd/mcp-ip-geo

# 在 Windows 上
go build -o mcp-ip-geo.exe .\cmd\mcp-ip-geo

🐋 使用 Docker

  1. 构建 Docker 镜像:

    docker build -t mcp-ip-geo-server .
    
  2. 运行容器:

    docker run -d --name mcp-ip-geo-server -p 8000:8000 mcp-ip-geo-server
    

📦 安装预编译版本

使用 Go 安装最新版本的服务:

go install github.com/chenmingyong0423/mcp-ip-geo/cmd/mcp-ip-geo@latest

🧩 MCP 集成

你可以通过以下两种方式集成 mcp-ip-geo 服务:

🖥 可执行文件集成(本地运行)

{
  "mcpServers": {
    "mcp-ip-geo": {
      "command": "/path/to/mcp-ip-geo"
    }
  }
}

🌐 HTTP 接口集成(连接到已运行的服务)

{
  "mcpServers": {
    "mcp-ip-geo": {
      "url": "http://host:port/sse"
    }
  }
}

👀 效果演示

企业微信截图_17455811312795.png

✅ 小结

本文将详细介绍 mcp-ip-geo —— 一个用于查询 IP 信息的 MCP 服务器的实现细节。该服务器目前支持两种数据传输方式:stdioSSE(Server-Sent Events)。未来还计划支持 Streamable HTTP 传输方式,并持续扩展更多实用的工具(tools)模块。

目录
相关文章
|
2月前
|
人工智能 JavaScript API
零基础构建MCP服务器:TypeScript/Python双语言实战指南
作为一名深耕技术领域多年的博主摘星,我深刻感受到了MCP(Model Context Protocol)协议在AI生态系统中的革命性意义。MCP作为Anthropic推出的开放标准,正在重新定义AI应用与外部系统的交互方式,它不仅解决了传统API集成的复杂性问题,更为开发者提供了一个统一、安全、高效的连接框架。在过去几个月的实践中,我发现许多开发者对MCP的概念理解透彻,但在实际动手构建MCP服务器时却遇到了各种技术壁垒。从环境配置的细节问题到SDK API的深度理解,从第一个Hello World程序的调试到生产环境的部署优化,每一个环节都可能成为初学者的绊脚石。因此,我决定撰写这篇全面的实
459 67
零基础构建MCP服务器:TypeScript/Python双语言实战指南
|
25天前
|
人工智能 自然语言处理 安全
Python构建MCP服务器:从工具封装到AI集成的全流程实践
MCP协议为AI提供标准化工具调用接口,助力模型高效操作现实世界。
290 1
|
2月前
|
监控 安全 Go
使用Go语言构建网络IP层安全防护
在Go语言中构建网络IP层安全防护是一项需求明确的任务,考虑到高性能、并发和跨平台的优势,Go是构建此类安全系统的合适选择。通过紧密遵循上述步骤并结合最佳实践,可以构建一个强大的网络防护系统,以保障数字环境的安全完整。
72 12
|
2月前
|
人工智能 Nacos 开发者
手把手教你搭建MCP服务器
Model Context Protocol(MCP)正成为AI智能体连接外部工具的主流标准。本文详解两种搭建方案,助你构建专属AI工具扩展引擎,实现工具调用的标准化与高效集成。
|
2月前
|
人工智能 运维 安全
MCP协议深度解析:客户端-服务器架构的技术创新
作为一名长期关注AI技术发展的博主摘星,我深刻感受到了MCP(Model Context Protocol)协议在AI生态系统中的革命性意义。MCP协议作为Anthropic公司推出的开放标准,正在重新定义AI应用与外部系统的交互方式,其基于JSON-RPC 2.0的通信机制为构建可扩展、安全的AI应用提供了坚实的技术基础。在深入研究MCP协议规范的过程中,我发现这一协议不仅解决了传统AI应用在资源访问、工具调用和上下文管理方面的痛点,更通过其独特的三大核心概念——资源(Resources)、工具(Tools)、提示词(Prompts)——构建了一个完整的AI应用生态系统。MCP协议的客户端-
243 0
MCP协议深度解析:客户端-服务器架构的技术创新
|
1月前
|
人工智能 JavaScript 前端开发
用 Go 语言轻松构建 MCP 服务器
本文介绍了使用 Go 语言构建 MCP 服务器的完整过程,涵盖创建服务器实例、注册工具、资源和提示词,以及通过 stdio 和 sse 模式启动服务的方法,帮助开发者快速集成 LLM 应用与外部系统。
|
2月前
|
存储 中间件 网络安全
在Go中构建应用级IP防火墙机制
使用Go构建应用级别的IP防火墙机制不仅能够为你的应用程序增加一层额外的安全性,还能够通过自定义中间件的方式让你有更多控制力,来决定哪些客户端可以或不可以访问你的服务。
72 8
|
3月前
|
C# 图形学 开发者
Unity开发中使用UnityWebRequest从HTTP服务器下载资源。
总之,UnityWebRequest就是游戏开发者手中的万能钓鱼竿,既可以获取文本数据,也能钓上图片资源,甚至是那声音的涟漪。使用UnityWebRequest的时候,你需要精心准备,比如确定URL、配置请求类型和头信息;发起请求;巧妙处理钓获的数据;还需要机智面对网络波澜,处理各种可能出现的错误。按照这样的过程,数据的钓取将会是一次既轻松愉快也效率高效的编程钓鱼之旅。
183 18