Dravr Tronc

DRAVR-TRONC

用于构建的轻量级Rust运行时 主控程序 具有可选REST API支持的服务器。提供在几分钟内从零到生产就绪的MCP服务器所需的一切——JSON-RPC 2.0协议、stdio和HTTP传输、承载身份验证、健康检查、CLI解析和结构化跟踪。

为什么选择dravr-tronc？

在Rust中构建MCP服务器意味着每次都要编写相同的样板：JSON-RPC 2.0类型、请求调度、传输层、身份验证中间件、CLI args。dravr-tronc将所有这些提取到一个机箱中，因此您只需编写域逻辑。

• 通用超状态 — McpServer 与任何人合作 Send + Sync 状态类型
• 两次运输 --stdio（用于编辑器/CLI集成）和HTTP与SSE（用于web客户端）
• 零配置 --合理的默认设置、环境变量驱动的身份验证、即插即用
• 生产就绪 --恒定时间认证、结构化跟踪、健康检查、76次测试
• 最小依赖性 --axum、tokio、serde、clap、跟踪（无框架锁定）

快速开始

[dependencies]
dravr-tronc = "0.3"

1.定义你的状态和工具

use std::sync::Arc;
use async_trait::async_trait;
use dravr_tronc::mcp::protocol::{CallToolResult, ToolDefinition};
use dravr_tronc::{McpTool, McpServer, ToolRegistry};
use serde_json::{json, Value};
use tokio::sync::RwLock;

struct AppState {
    greeting: String,
}

struct GreetTool;

#[async_trait]
impl McpTool for GreetTool {
    fn definition(&self) -> ToolDefinition {
        ToolDefinition {
            name: "greet".to_owned(),
            description: "Greet someone by name".to_owned(),
            input_schema: json!({
                "type": "object",
                "properties": {
                    "name": { "type": "string" }
                },
                "required": ["name"]
            }),
        }
    }

    async fn execute(&self, state: &Arc>, args: Value) -> CallToolResult {
        let name = args.get("name").and_then(|v| v.as_str()).unwrap_or("world");
        let greeting = state.read().await.greeting.clone();
        CallToolResult::text(format!("{greeting}, {name}!"))
    }
}

2.把它连接起来

#[tokio::main]
async fn main() -> Result> {
    dravr_tronc::server::tracing_init::init("stdio");

    let mut registry = ToolRegistry::new();
    registry.register(Box::new(GreetTool));

    let state = Arc::new(RwLock::new(AppState {
        greeting: "Hello".to_owned(),
    }));
    let server = Arc::new(McpServer::new("my-mcp-server", "0.1.0", registry, state));

    // Serve over stdin/stdout (for Claude Desktop, Cursor, etc.)
    dravr_tronc::mcp::transport::stdio::run(server).await
}

3.或者通过HTTP提供服务

// Serve over HTTP with SSE support
dravr_tronc::mcp::transport::http::serve(server, "127.0.0.1", 3000).await?;

4.合并到现有的Axum应用程序中

use dravr_tronc::mcp::transport::http::mcp_router;

let app = axum::Router::new()
    .route("/health", axum::routing::get(health_handler))
    .route("/api/data", axum::routing::get(data_handler))
    .merge(mcp_router(server))  // adds POST /mcp
    .layer(axum::middleware::from_fn(|req, next| {
        dravr_tronc::server::auth::require_auth("MY_API_KEY", req, next)
    }));

模块

身份验证中间件

从指定的环境变量中读取API键。如果变量未设置，则所有请求都会通过（开发模式）。用途 subtle::ConstantTimeEq 以防止定时攻击。

// Only enforced when MY_API_KEY env var is set
dravr_tronc::server::auth::require_auth("MY_API_KEY", request, next).await

健康检查

use dravr_tronc::server::health::HealthResponse;

let resp = HealthResponse::ok("my-service", "1.0.0")
    .with_detail("database", "connected")
    .with_detail("cache", "warm");
// Returns 200 for "ok", 503 for "degraded"

CLI参数

将共享参数平铺到项目的CLI结构中：

use clap::Parser;
use dravr_tronc::server::cli::McpArgs;

#[derive(Parser)]
struct Cli {
    #[command(flatten)]
    server: McpArgs,  // adds --transport, --host, --port

    #[arg(long)]
    my_custom_flag: bool,
}

推荐项目布局

my-project/
├── src/                          # Core domain library
├── crates/my-project-mcp/        # MCP server (library + binary)
│   ├── src/state.rs              # Your ServerState
│   ├── src/tools/                # Your McpTool implementations
│   └── src/main.rs               # Thin entry point using dravr-tronc
└── crates/my-project-server/     # REST API + MCP unified server (binary)
    ├── src/router.rs             # Axum routes + mcp_router() merge
    └── src/main.rs               # CLI + transport dispatch

许可证

根据以下任一方式获得许可 Apache许可证，版本2.0 或 MIT许可证 由您选择。