Rust匿名网络库arti-client的使用，arti-client提供Tor协议实现的安全隐私保护功能

概述

arti-client crate旨在为需要通过Tor网络匿名化流量的应用程序提供安全、易用的API。它是Arti项目的一部分，该项目用Rust实现了Tor协议。arti-client是Arti中最高级别的库crate，几乎所有仅客户端程序都应该使用它。

使用arti-client

连接到Tor

调用TorClient::create_bootstrapped可以建立与Tor网络的连接，根据需要拉取网络共识状态。这些状态会持久化到TorClientConfig中指定的位置。

// 客户端配置描述如何连接Tor网络，以及使用哪些目录存储持久状态
let config = TorClientConfig::default();

// 启动Arti客户端，让它引导连接到Tor网络
// (这需要一些时间来收集必要的目录信息，会尽可能使用缓存信息)
let tor_client = TorClient::create_bootstrapped(config).await?;

创建客户端并稍后连接

如果需要立即创建Tor客户端而不等待引导(或不需要使用await)，可以使用TorClient::builder创建一个TorClientBuilder，然后调用TorClientBuilder::create_unbootstrapped。

// 指定`BootstrapBehavior::OnDemand`意味着客户端会在使用时自动引导
// `Manual`存在是为了让你可以完全控制
let tor_client = TorClient::builder()
    .bootstrap_behavior(BootstrapBehavior::OnDemand)
    .create_unbootstrapped()?;

使用客户端

客户端可以用来通过TorClient::connect建立Tor连接，该方法接受任何实现了IntoTorAddr的类型。这返回一个DataStream，这是一个实现了AsyncRead和AsyncWrite的匿名TCP流类型。

示例：通过Tor建立连接

// 通过Tor连接到example.com，端口80
let mut stream = tor_client.connect(("example.com", 80)).await?;

use futures::io::{AsyncReadExt, AsyncWriteExt};

// 写出HTTP请求
stream
    .write_all(b"GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n")
    .await?;

// 重要：确保请求已写入
// Arti会缓冲数据，所以通常需要刷新缓冲区
stream.flush().await?;

// 读取并打印结果
let mut buf = Vec::new();
stream.read_to_end(&mut buf).await?;

println!("{}", String::from_utf8_lossy(&buf));

报告Arti错误

Arti经常输出非常长的Debug消息，这很难理解。为了更好地理解程序中出了什么问题，应该match每个Error并记录err.report()。

// 通过Tor连接到example.com，端口80
// 注意：这里我们尝试使用match处理潜在的错误
match tor_client.connect("example.com:80").await {
    Ok(mut stream) => {
        eprintln!("sending request...");

        stream
            .write_all(b"GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n")
            .await?;

        // 重要：确保请求已写入
        stream.flush().await?;

        eprintln!("reading response...");

        let mut buf = Vec::new();
        stream.read_to_end(&mut buf).await?;

        println!("{}", String::from_utf8_lossy(&buf));
    }
    Err(err) => {
        // 使用.report()获取更友好的错误消息
        eprintln!("{}", err.report());
    }
}

完整示例代码

下面是一个增强版的完整示例，展示了如何使用arti-client通过Tor网络进行匿名HTTP请求，包含错误处理和配置自定义：

use arti_client::{BootstrapBehavior, TorClient, TorClientConfig};
use futures::io::{AsyncReadExt, AsyncWriteExt};
use std::{error::Error, path::PathBuf};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    // 1. 创建自定义Tor客户端配置
    let mut config = TorClientConfig::default();
    // 设置状态目录
    config.storage.arti_dir = PathBuf::from("./tor_data");
    // 设置日志级别
    config.logging.log_rust = Some("info".parse()?);
    
    // 2. 创建Tor客户端构建器
    let tor_client = TorClient::builder()
        .config(config)
        .bootstrap_behavior(BootstrapBehavior::OnDemand)
        .create_unbootstrapped()?;
    
    // 3. 通过Tor连接到目标网站
    let target = ("example.com", 80);
    match tor_client.connect(target).await {
        Ok(mut stream) => {
            println!("成功连接到Tor网络，开始请求数据...");
            
            // 4. 发送HTTP请求
            let request = b"GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n";
            stream.write_all(request).await?;
            stream.flush().await?;
            
            // 5. 读取响应
            let mut response = Vec::new();
            stream.read_to_end(&mut response).await?;
            
            // 6. 打印响应
            println!("{}", String::from_utf8_lossy(&response));
        }
        Err(err) => {
            eprintln!("连接失败: {}", err.report());
        }
    }
    
    Ok(())
}

注意事项

1. 集成Arti需要准备定期升级，否则可能完全停止工作。Tor网络协议会随时间变化，过时的协议将不被支持。

2. 此库可能会调用exit(1)并终止你的进程，如果它收到网络共识文档告诉它已过时。

3. arti-client的API尚未完全稳定，虽然我们会尽量避免无理由的破坏性变更，但在arti-client 1.x之前请预期会有一定程度的破坏性变更。

4. Arti中较低级别crate暴露的API更加不稳定，它们会比arti-client中的API更频繁地破坏。