soup2-rs

TODO 迁移到 gnome 社区，一旦这个 crate 稳定。

Rust 对 libsoup2 的绑定和包装。

贡献 贡献者，欢迎您！

许可证 soup-sys 可在 MIT 许可证下使用，请参考该许可证。

元数据 pkg:cargo/soup2@0.2.1 超过 3 年前 2021 版本 MIT 59.8 KiB

安装 运行以下 Cargo 命令在您的项目目录中：

cargo add soup2

或者将以下行添加到您的 Cargo.toml：

soup2 = “0.2.1”

所有者 Wu Yuwei Lucas Fernandes Nogueira

以下是一个使用 soup2 进行 HTTP GET 请求的完整示例：

use soup2::prelude::*;
use soup2::Session;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个新的会话
    let session = Session::new();
    
    // 创建一个 GET 请求
    let request = session.request("GET", "https://httpbin.org/get")?;
    
    // 发送请求并获取响应
    let response = request.send()?;
    
    // 检查响应状态
    if response.status_code() == 200 {
        // 读取响应体
        let body = response.read_to_string()?;
        println!("Response: {}", body);
    } else {
        println!("Request failed with status: {}", response.status_code());
    }
    
    Ok(())
}

以下是一个使用 soup2 进行 POST 请求的完整示例：

use soup2::prelude::*;
use soup2::Session;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个新的会话
    let session = Session::new();
    
    // 创建一个 POST 请求
    let mut request = session.request("POST", "https://httpbin.org/post")?;
    
    // 设置请求头
    request.set_header("Content-Type", "application/json")?;
    
    // 设置请求体
    let json_data = r#"{"name": "test", "value": 123}"#;
    request.set_body(json_data.as_bytes());
    
    // 发送请求并获取响应
    let response = request.send()?;
    
    // 读取响应体
    let body = response.read_to_string()?;
    println!("Response: {}", body);
    
    Ok(())
}

以下是一个处理异步请求的完整示例：

use soup2::prelude::*;
use soup2::Session;
use std::time::Duration;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 创建一个新的会话
    let session = Session::new();
    
    // 设置超时时间
    session.set_timeout(Some(Duration::from_secs(30)));
    
    // 创建多个并发请求
    let urls = vec![
        "https://httpbin.org/get",
        "https://httpbin.org/ip",
        "https://httpbin.org/user-agent",
    ];
    
    for url in urls {
        let request = session.request("GET", url)?;
        
        // 使用 spawn 异步发送请求
        std::thread::spawn(move || {
            match request.send() {
                Ok(response) => {
                    if let Ok(body) = response.read_to_string() {
                        println!("Response from {}: {}", url, body);
                    }
                }
                Err(e) => println!("Error requesting {}: {}", url, e),
            }
        });
    }
    
    // 等待所有请求完成
    std::thread::sleep(Duration::from_secs(5));
    
    Ok(())
}

完整示例代码：

// 完整示例：使用 soup2-rs 进行 HTTP 请求处理
use soup2::prelude::*;
use soup2::Session;
use std::time::Duration;
use std::thread;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 示例 1: 同步 GET 请求
    println!("=== 同步 GET 请求示例 ===");
    sync_get_request()?;
    
    // 示例 2: 同步 POST 请求
    println!("\n=== 同步 POST 请求示例 ===");
    sync_post_request()?;
    
    // 示例 3: 异步并发请求
    println!("\n=== 异步并发请求示例 ===");
    async_requests()?;
    
    Ok(())
}

// 同步 GET 请求函数
fn sync_get_request() -> Result<(), Box<dyn std::error::Error>> {
    let session = Session::new();
    let request = session.request("GET", "https://httpbin.org/get")?;
    let response = request.send()?;
    
    if response.status_code() == 200 {
        let body = response.read_to_string()?;
        println!("GET 请求成功: {}", body);
    } else {
        println!("GET 请求失败，状态码: {}", response.status_code());
    }
    
    Ok(())
}

// 同步 POST 请求函数
fn sync_post_request() -> Result<(), Box<dyn std::error::Error>> {
    let session = Session::new();
    let mut request = session.request("POST", "https://httpbin.org/post")?;
    
    request.set_header("Content-Type", "application/json")?;
    
    let json_data = r#"{"name": "rust_user", "language": "Rust"}"#;
    request.set_body(json_data.as_bytes());
    
    let response = request.send()?;
    let body = response.read_to_string()?;
    println!("POST 请求响应: {}", body);
    
    Ok(())
}

// 异步请求函数
fn async_requests() -> Result<(), Box<dyn std::error::Error>> {
    let session = Session::new();
    session.set_timeout(Some(Duration::from_secs(10)));
    
    let endpoints = vec![
        ("用户代理", "https://httpbin.org/user-agent"),
        ("IP 地址", "https://httpbin.org/ip"),
        ("Headers", "https://httpbin.org/headers"),
    ];
    
    let mut handles = vec![];
    
    for (name, url) in endpoints {
        let session_clone = session.clone();
        let handle = thread::spawn(move || {
            match session_clone.request("GET", url) {
                Ok(request) => {
                    match request.send() {
                        Ok(response) => {
                            if let Ok(body) = response.read_to_string() {
                                println!("{} 响应: {}", name, body);
                            }
                        }
                        Err(e) => println!("{} 请求错误: {}", name, e),
                    }
                }
                Err(e) => println!("创建 {} 请求失败: {}", name, e),
            }
        });
        handles.push(handle);
    }
    
    // 等待所有线程完成
    for handle in handles {
        handle.join().unwrap();
    }
    
    println!("所有异步请求已完成");
    Ok(())
}