Ethereal Rust

🚀 MCP-RS

MCP-RS是一個用Rust實現的MCP（模型上下文協議）服務器。它是原始TypeScript實現此處的Rust端口，為MCP協議提供了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許可證。