MCP Sdk Rs

🚀 モデルコンテキストプロトコル（MCP）Rust SDK

AIモデルとその実行環境間のシームレスな通信を実現するためのRust実装のモデルコンテキストプロトコル（MCP）です。

⚠️ 重要注意

このSDKは現在開発中であり、まだ本番環境での使用には適していません。

🚀 クイックスタート

このSDKを使用することで、AIモデルとその実行環境との間の通信を容易に行うことができます。以下に、クライアントとサーバーの使用例を示します。

💻 使用例

基本的な使用法

クライアント側の例

use mcp_sdk_rs::{Client, transport::WebSocketTransport};

#[tokio::main]
async fn main() -> Result<(), Error> {
    // 创建一个传输层实例
    let transport = WebSocketTransport::new(self.url.as_str())
        .await
        .map_err(|_| Error::Internal)?;

    //创建用于客户端和会话之间通信的mpsc通道
    let (request_tx, request_rx): (UnboundedSender<Message>, UnboundedReceiver<Message>) =
        tokio::sync::mpsc::unbounded_channel();
    let (response_tx, response_rx): (UnboundedSender<Message>, UnboundedReceiver<Message>) =
        tokio::sync::mpsc::unbounded_channel();

    // 创建并启动会话
    // 可选地传递一个ClientHandler的实现来处理自定义请求和通知
    let session = Session::new(Arc::new(transport), response_tx, request_rx, None);
    session.start().await.map_err(|_| Error::Internal)?;

    // 创建客户端并发送请求，接收通知等
    let client = Client::new(request_tx, response_rx);
    let response = client.request(
        "tools/call",
        Some(json!({
            "name": "methondName",
            "arguments": json!({})
        })),
    )
    .await?
}

サーバー側の例

use mcp_sdk_rs::{Server, transport::StdioTransport};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个标准输入输出传输层实例
    let (transport, _) = StdioTransport::new();

    // 创建并启动服务器
    let server = Server::new(transport);
    server.start().await?;

    Ok(())
}

✨ 主な機能

• 🚀 MCPプロトコル仕様の完全実装
• 🔄 複数のトランスポート層のサポート（WebSocket、標準入出力）
• ⚡ Tokioを使用した非同期/待機のサポート
• 🛡️ 型安全なメッセージ処理
• 🔍 包括的なエラー処理
• 📦 ゼロコピーのシリアライズ/デシリアライズ

📦 インストール

以下の内容をCargo.tomlに追加してください。

[dependencies]
mcp_sdk_rs = "0.1.0"

📚 ドキュメント

トランスポート層

SDKは複数のトランスポート層をサポートしています。

WebSocketトランスポート層

• ネットワークベースの通信に適しています。
• 安全（WSS）および標準（WS）接続をサポートしています。
• 組み込みの再接続処理機能があります。

標準入出力トランスポート層

• ローカルプロセス間通信に適しています。
• 軽量かつ効率的です。
• コマンドラインツールやローカル開発環境に適しています。

エラー処理

SDKはError型を通じて包括的なエラー処理を提供しています。

use mcp_sdk_rs::Error;

match result {
    Ok(value) => println!("成功: {:?}", value),
    Err(Error::Protocol(code, msg)) => println!("协议错误代码{}：{}", code, msg),
    Err(Error::Transport(e)) => println!("传输错误：{}", e),
    Err(e) => println!("其他错误：{}", e),
}

📄 ライセンス

このプロジェクトはMITライセンスの下でライセンスされています。詳細については、LICENSEファイルを参照してください。

このプロジェクトは最初にhttps://github.com/Derek-X-Wang/mcp-rust-sdkから分岐して作成されました。