Struct SimpleMcpServer 

pub struct SimpleMcpServer { /* private fields */ }

Implementations

impl SimpleMcpServer

pub fn new() -> Self

Examples found in repository

examples/mcp_ping_example.rs (line 10)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("开始 MCP Ping 示例");
    
    // 创建 MCP 服务器
    let server = SimpleMcpServer::new();
    
    // 启动服务器
    let server_address = "127.0.0.1:6000";
    server.start(server_address).await?;
    
    // 等待服务器启动
    tokio::time::sleep(Duration::from_millis(100)).await;
    
    // 创建 MCP 客户端
    let mut client = SimpleMcpClient::new(format!("http://{}", server_address));
    
    // 连接到服务器 - 修复URL格式
    client.connect(&format!("http://{}", server_address)).await?;
    client.set_server_connected(true);
    
    // 执行多次 ping 测试
    for i in 1..=3 {
        let start_time = std::time::Instant::now();
        
        match client.ping().await {
            Ok(_) => {
                let elapsed = start_time.elapsed();
                println!("Ping {} 成功，响应时间: {:?}", i, elapsed);
            }
            Err(e) => {
                println!("Ping {} 失败: {}", i, e);
            }
        }
        
        // 等待 1 秒再进行下一次 ping
        tokio::time::sleep(Duration::from_secs(1)).await;
    }
    
    // 停止服务器
    server.stop().await?;
    
    println!("MCP Ping 示例完成");
    
    Ok(())
}

examples/mcp_server_complete_example.rs (line 195)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Rust Agent Complete MCP Server Example ===");
    
    // 创建MCP服务器实例
    let server = rust_agent::SimpleMcpServer::new().with_address("127.0.0.1:6000".to_string());
    
    // 创建实际的工具实现
    let weather_tool = WeatherTool::new();
    let calculator_tool = CalculatorTool::new();
    
    // 注册工具
    server.register_tool(Arc::new(weather_tool))?;
    server.register_tool(Arc::new(calculator_tool))?;
    
    // 启动服务器
    server.start("127.0.0.1:6000").await?;
    
    println!("MCP服务器已启动，地址: 127.0.0.1:6000");
    println!("MCP Server端工具:");
    println!("  1. get_weather: Get the weather information for a specified city. For example: 'What's the weather like in Beijing?'");
    println!("  2. simple_calculate: Perform simple mathematical calculations. Input should be a mathematical expression with numbers and operators (+, -, *, /). For example: '15.5 + 24.3'");
    println!("服务器正在运行中，按 Ctrl+C 停止服务器");
    
    // 保持服务器持续运行
    // tokio::time::sleep(tokio::time::Duration::from_secs(30)).await;
    // 这里我们使用 tokio::signal 来等待 Ctrl+C 信号
    #[cfg(unix)]
    let terminate = async {
        tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())
            .unwrap()
            .recv()
            .await;
    };
    
    #[cfg(not(unix))]
    let terminate = std::future::pending::<()>();
    
    tokio::select! {
        _ = tokio::signal::ctrl_c() => {
            println!("收到 Ctrl+C 信号，正在停止服务器...");
        },
        _ = terminate => {
            println!("收到终止信号，正在停止服务器...");
        },
    }
    
    // 停止服务器
    // server.stop().await?;
    println!("MCP服务器已停止");
    
    Ok(())
}

pub fn with_address(self, address: String) -> Self

Examples found in repository

examples/mcp_server_complete_example.rs (line 195)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Rust Agent Complete MCP Server Example ===");
    
    // 创建MCP服务器实例
    let server = rust_agent::SimpleMcpServer::new().with_address("127.0.0.1:6000".to_string());
    
    // 创建实际的工具实现
    let weather_tool = WeatherTool::new();
    let calculator_tool = CalculatorTool::new();
    
    // 注册工具
    server.register_tool(Arc::new(weather_tool))?;
    server.register_tool(Arc::new(calculator_tool))?;
    
    // 启动服务器
    server.start("127.0.0.1:6000").await?;
    
    println!("MCP服务器已启动，地址: 127.0.0.1:6000");
    println!("MCP Server端工具:");
    println!("  1. get_weather: Get the weather information for a specified city. For example: 'What's the weather like in Beijing?'");
    println!("  2. simple_calculate: Perform simple mathematical calculations. Input should be a mathematical expression with numbers and operators (+, -, *, /). For example: '15.5 + 24.3'");
    println!("服务器正在运行中，按 Ctrl+C 停止服务器");
    
    // 保持服务器持续运行
    // tokio::time::sleep(tokio::time::Duration::from_secs(30)).await;
    // 这里我们使用 tokio::signal 来等待 Ctrl+C 信号
    #[cfg(unix)]
    let terminate = async {
        tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())
            .unwrap()
            .recv()
            .await;
    };
    
    #[cfg(not(unix))]
    let terminate = std::future::pending::<()>();
    
    tokio::select! {
        _ = tokio::signal::ctrl_c() => {
            println!("收到 Ctrl+C 信号，正在停止服务器...");
        },
        _ = terminate => {
            println!("收到终止信号，正在停止服务器...");
        },
    }
    
    // 停止服务器
    // server.stop().await?;
    println!("MCP服务器已停止");
    
    Ok(())
}

Trait Implementations

impl McpServer for SimpleMcpServer

fn start<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn register_tool(&self, tool: Arc<dyn Tool>) -> Result<(), Error>

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,