以下是根据您提供的内容整理的完整示例代码，首先展示内容中的示例，然后提供完整的demo实现：

内容中提供的示例汇总

1. 基本GET请求示例：

use rquest::Client;

#[tokio::main]
async fn main() -> Result<(), rquest::Error> {
    let client = Client::new();
    let response = client.get("https://httpbin.org/get")
        .send()
        .await?;
    
    println!("Status: {}", response.status());
    println!("Body: {}", response.text().await?);
    
    Ok(())
}

1. POST请求示例：

use rquest::Client;
use std::collections::HashMap;

#[tokio::main]
async fn main() -> Result<(), rquest::Error> {
    let client = Client::new();
    let mut data = HashMap::new();
    data.insert("key", "value");
    
    let response = client.post("https://httpbin.org/post")
        .json(&data)
        .send()
        .await?;
    
    println!("Response: {}", response.text().await?);
    
    Ok(())
}

1. 插件系统示例：

use rquest::{Client, Plugin, Request, Response};
use std::time::Instant;

struct TimingPlugin;

#[async_trait::async_trait]
impl Plugin for TimingPlugin {
    async fn on_request(&self, request: &mut Request) {
        request.extensions_mut().insert(Instant::now());
    }

    async fn on_response(&self, response: &mut Response) {
        if let Some(start) = response.extensions().get::<Instant>() {
            let duration = start.elapsed();
            println!("Request took {}ms", duration.as_millis());
        }
    }
}

完整示例Demo

//! 完整的rquest使用示例，包含GET/POST请求、插件系统和错误处理

use rquest::{Client, Plugin, Request, Response, Error};
use std::collections::HashMap;
use std::time::{Instant, Duration};
use async_trait::async_trait;
use futures::future::join_all;

/// 自定义插件：记录请求耗时和状态
struct MetricsPlugin;

#[async_trait]
impl Plugin for MetricsPlugin {
    async fn on_request(&self, request: &mut Request) {
        request.extensions_mut().insert(Instant::now());
    }

    async fn on_response(&self, response: &mut Response) {
        if let Some(start) = response.extensions().get::<Instant>() {
            let duration = start.elapsed();
            println!(
                "Request to {} took {}ms, status: {}",
                response.url(),
                duration.as_millis(),
                response.status()
            );
        }
    }
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    // 1. 创建配置化的客户端
    let client = Client::builder()
        .timeout(Duration::from_secs(5))
        .plugin(MetricsPlugin)
        .build();

    // 2. 发送GET请求
    println!("--- Sending GET request ---");
    let get_response = client.get("https://httpbin.org/get")
        .header("X-Custom-Header", "Rust")
        .send()
        .await?;
    
    println!("GET Response status: {}", get_response.status());
    println!("GET Body: {}", get_response.text().await?);

    // 3. 发送POST请求
    println!("\n--- Sending POST request ---");
    let mut post_data = HashMap::new();
    post_data.insert("name", "rquest");
    post_data.insert("version", "0.7");

    let post_response = client.post("https://httpbin.org/post")
        .json(&post_data)
        .send()
        .await?;
    
    println!("POST Response: {}", post_response.text().await?);

    // 4. 并发请求示例
    println!("\n--- Sending concurrent requests ---");
    let urls = vec![
        "https://httpbin.org/get?req=1",
        "https://httpbin.org/get?req=2",
        "https://httpbin.org/status/404",
    ];
    
    let requests = urls.into_iter().map(|url| {
        client.get(url).send()
    });
    
    let responses = join_all(requests).await;
    
    for response in responses {
        match response {
            Ok(res) => println!("Concurrent response status: {}", res.status()),
            Err(e) => println!("Error: {}", e),
        }
    }

    // 5. 错误处理示例
    println!("\n--- Error handling example ---");
    match client.get("https://httpbin.org/status/500").send().await {
        Ok(res) if res.status().is_success() => {
            println!("Request succeeded");
        }
        Ok(res) => {
            println!("Server returned error status: {}", res.status());
        }
        Err(Error::Timeout) => {
            eprintln!("Request timed out");
        }
        Err(e) => {
            eprintln!("Request failed: {}", e);
        }
    }

    Ok(())
}

示例说明

1. 客户端配置：

   • 设置了5秒超时
   • 添加了自定义的MetricsPlugin插件

2. GET请求：

   • 添加自定义header
   • 打印响应状态和内容

3. POST请求：

   • 发送JSON格式数据
   • 打印完整响应

4. 并发请求：

   • 使用join_all同时发送多个请求
   • 处理各个请求的结果

5. 错误处理：

   • 演示了不同错误类型的处理方式
   • 包括HTTP错误状态码的处理

这个完整示例展示了rquest库的主要功能：

• 基本的HTTP请求(GET/POST)
• 插件系统的使用
• 并发请求处理
• 详细的错误处理
• 客户端配置选项

使用前请确保Cargo.toml中添加了正确的依赖：

[dependencies]
rquest = "0.7"
tokio = { version = "1.0", features = ["full"] }
async-trait = "0.1"
futures = "0.3"