MCP Go Sdk

🚀 MCP Go SDK 翻訳

このSDKは、Go言語で実装されたモデルコンテキストプロトコル（MCP）を提供しています。これにより、クライアントとサーバー間の双方向通信を実現し、ツールの実行、リソースのアクセス、およびプロンプトの処理を行うことができます。

✨ 主な機能

• トランスポート層

  • 複数のトランスポートオプション（標準I/O、SSE、WebSocket）
  • 双方向通信
  • エンドポイントと設定の設定可能

• サーバーの実装

  • ツールの登録と実行
  • リソースのパターンマッチングとアクセス
  • プロンプトテンプレートのレンダリング
  • セッション管理
  • リフレクションベースのハンドラー呼び出し

• コアプロトコルタイプ

  • JSON-RPCメッセージの処理
  • MCP固有のタイプ（ツール、リソース、プロンプト）
  • 機能と初期化設定

📦 インストール

go get github.com/SetiabudiResearch/mcp-go-sdk

🚀 クイックスタート

以下は、MCPサーバーを作成する簡単な例です。

package main

import (
    "context"
    "log"
    "github.com/SetiabudiResearch/mcp-go-sdk/pkg/mcp/server"
    "github.com/SetiabudiResearch/mcp-go-sdk/pkg/mcp/transport"
)

func main() {
    // 创建一个新的服务器
    srv := server.NewServer("Example Server")

    // 添加一个工具
    srv.AddTool("greet", func(name string) string {
        return "Hello, " + name + "!"
    }, "Greet a person")

    // 创建一个会话
    session := server.NewSession(context.Background(), srv)

    // 创建并启动传输
    t := transport.NewStdioTransport(session)
    if err := t.Start(); err != nil {
        log.Fatal(err)
    }
}

💻 使用例

基本的な使用法

サーバーの作成

// 创建一个具有名称的新服务器
srv := server.NewServer("My Server")

// 可选配置服务器功能
srv.WithCapabilities(protocol.ServerCapabilities{
    SupportsAsync: true,
})

ツールの追加

// 添加同步工具
srv.AddTool("myTool", func(arg1 string, arg2 int) (string, error) {
    return fmt.Sprintf("Processed %s with %d", arg1, arg2), nil
}, "Tool description")

// 添加异步工具
srv.AddAsyncTool("longRunningTool", func(params string) error {
    // 长时间运行的操作
    return nil
}, "Async tool description")

リソースの追加

// 添加带模式匹配的资源
srv.AddResource("files/{path}", func(path string) ([]byte, error) {
    return ioutil.ReadFile(path)
}, "Access files")

// 资源模式支持多个参数
srv.AddResource("api/{version}/{endpoint}", func(version, endpoint string) (interface{}, error) {
    return callAPI(version, endpoint)
}, "API access")

プロンプトの追加

// 添加简单的文本提示
srv.AddPrompt("confirm", func(action string) string {
    return fmt.Sprintf("Are you sure you want to %s?", action)
}, "Confirmation prompt")

// 添加多消息提示
srv.AddPrompt("chat", func(context string) []protocol.PromptMessage {
    return []protocol.PromptMessage{
        {
            Role: protocol.RoleAssistant,
            Content: protocol.MessageContent{
                Text: []string{context},
            },
        },
    }
}, "Chat prompt")

トランスポートの設定

// 配置标准 I/O 传输
t := transport.NewStdioTransport(session)
if err := t.Start(); err != nil {
    log.Fatal(err)
}

// 配置 WebSocket 传输
addr := "localhost:8080"
ws := transport.NewWebSocketTransport(addr, session)
if err := ws.Start(); err != nil {
    log.Fatal(err)
}

📄 ライセンス

このSDKは、MITライセンスの下で公開されています。詳細については、LICENSE ファイルを参照してください。