Ethereal Rust

🚀 MCP-RS

Rustで実装されたMCPサーバー（モデルコンテキストプロトコル）です。これは、元のTypeScript実装こちらのRustポートです。

✨ 主な機能

このRust実装では、すべてのMCPの核心機能を提供しています。

• すべての核心MCPサーバー機能
• 組み込みの認証ハンドラー
• カスタマイズ可能な階層型ミドルウェアのサポート
• 柔軟なトランスポートオプション（標準入出力とSSE）

🚀 クイックスタート

📦 インストール

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

[dependencies]
mcp-rs = "0.1.0"

💻 使用例

基本的な使用法

use mcp_rs::{Emcp, SimpleToolBuilder};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个新的服务器实例
    let server = Emcp::new("my-mcp-server", "1.0.0", None);
    
    // 添加一个工具
    let add_tool = SimpleToolBuilder::new("add", |args| async move {
        let a = args["a"].as_f64().unwrap_or(0.0);
        let b = args["b"].as_f64().unwrap_or(0.0);
        Ok(json!(a + b))
    })
    .description("Add two numbers")
    .input_schema(json!({
        "type": "object",
        "properties": {
            "a": { "type": "number" },
            "b": { "type": "number" }
        },
        "required": ["a", "b"]
    }))
    .build();
    
    server.add_tool(add_tool);
    
    // 启动服务器
    server.start(None).await?;
    
    Ok(())
}

高度な使用法

use mcp_rs::{Emcp, EmcpOptions, SimpleToolBuilder};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建身份验证处理程序
    let auth_handler = Box::new(|request| {
        // 检查认证头、令牌等。
        Box::pin(async { 
            // 返回true表示请求被授权
            true 
        })
    });
    
    // 使用身份验证处理程序创建一个新的服务器
    let server = Emcp::new(
        "mcp-server-with-auth",
        "1.0.0",
        Some(EmcpOptions {
            authentication_handler: Some(auth_handler),
        }),
    );
    
    // 添加工具、资源或提示...
    
    // 启动服务器
    server.start(None).await?;
    
    Ok(())
}

use mcp_rs::{Emcp, SimpleToolBuilder};
use std::time::Instant;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个新的服务器
    let mut server = Emcp::new("mcp-server-with-middleware", "1.0.0", None);
    
    // 添加计时中间件
    server.use_middleware(|request, next| {
        let start_time = Instant::now();
        let method = request.method.clone();
        
        Box::pin(async move {
            // 处理逻辑...
            
            Ok(())
        })
    });
    
    // 启动服务器
    server.start(None).await?;
    
    Ok(())
}

サンプルの実行

リポジトリには、このライブラリの機能をデモするいくつかのサンプルが含まれています。

# 基本サンプルを実行
cargo run --example basic

# 認証サンプルを実行
cargo run --example auth

# ミドルウェアサンプルを実行
cargo run --example middleware

# 標準IOトランスポートサンプルを実行
cargo run --example stdio_transport

📄 ライセンス

MIT