同时在 Rust 官方论坛发了贴 https://users.rust-lang.org/t/built-a-proxy-crate-looking-for-suggestions/90862/1,内容是一样的。
刚刚用 Rust 不久,前些阵子需要在程序中用到代理,查了一趟发现没有一个通用的代理库,那就干脆自己糊一个练手了。现在刚刚做了一个看起来能用的版本,想来寻求一些意见建议。
库名叫 proxie
,链接在此 GitHub docs.rs。当前还没来得及写文档,文档是 Cargo 生成的。基本用法如下:
use tokio::{io::{AsyncWriteExt, BufReader, AsyncBufReadExt}};
use futures::future;
use proxie::{SOCKS5Proxy, tokio::AsyncProxy};
#[tokio::main]
async fn main() {
let n_thread = 10;
let mut handles = vec![];
for _ in 0..n_thread {
handles.push(tokio::spawn(async {
let request = format!("GET / HTTP/1.1\r\n\r\n");
let server = SOCKS5Proxy::new("127.0.0.1", 1080, None);
let mut stream = server.connect("example.com:80").await.unwrap();
//let mut stream = TcpStream::connect("example.com:80").await.unwrap();
stream.write_all(request.as_bytes()).await.unwrap();
stream.flush().await.unwrap();
let mut reader = BufReader::new(&mut stream);
let mut buffer = String::new();
loop {
reader.read_line(&mut buffer).await.unwrap();
if buffer.ends_with("\r\n\r\n") {
break;
}
}
print!("{}", buffer);
}));
}
future::join_all(handles).await;
}
或者带认证的话
...
use proxie::{SOCKS5Proxy, tokio::AsyncProxy, Auth};
...
let server = SOCKS5Proxy::new("127.0.0.1", 1080, Auth::new("user", "pass"));
...
总之基本上就是在 TcpStream
上套了一层壳。除此之外还有 async-std
版本和同步的 std::net
版本,也支持 HTTP 代理。用法都是一样的。具体的运行时用 features 打开:
proxie = { version = "0.0.2", features = ["enable_tokio"] }
//Available features: "enable_tokio", "enable_async_std" and "enable_sync".
此外是接下来的计划:
TcpStream
上所有的方法都实现了,实现无痛接入现在比较关心的地方是这套面向用户的接口是否合理?如果可能的话还是希望尽快稳定 API 以后就不改了。感觉好像还行,听听大佬们建议。
差不多就是这样了,提前感谢一切意见建议!如果有人也在寻找类似的库的话欢迎来帮忙测试一下!
这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。
V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。
V2EX is a community of developers, designers and creative people.