V2EX › 5waker 的所有回复 › 第 1 页 / 共 2 页

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

1 2

❮

❯

1 天前

回复了 bzq 创建的主题 › 钓鱼 › 想入坑路亚了，请指教

路亚真的能中鱼吗 😭

3 天前

回复了 YUX 创建的主题 › 分享创造 › 我用 Zig 重写（并重新设计）了 frp 和 rathole

我很好奇，用 zig vibe coding 好用吗？容易出正确代码吗？

3 天前

回复了 NeilZhy1 创建的主题 › 生活 › 骂醒此龟！

多让龟龟健身，补充自己，心思花在自己身上就能逐渐从那种龟的状态脱离出来了

11 天前

回复了 BigChengzi 创建的主题 › Rust › 如何看待 Rust？

@cslive 深有同感，每次都是入门

16 天前

回复了 montaro2017 创建的主题 › Java › 用 netty 编写代理服务器，切换出口 IP，不能及时生效

@montaro2017 我刚好昨天也遇到了类似的问题，我的做法是在一个长连接里不断检测 header ，然后根据内容再做转发
```rust
loop {
// 读取到完整头部
let header_end = loop {
if let Some(pos) = headers_end_pos(&buf) {
break Some(pos);
}
let n = client_stream.read(&mut tmp).await?;
if n == 0 {
// 客户端关闭或无更多数据
if buf.is_empty() {
return Ok(());
} else {
return Ok(());
}
}
buf.extend_from_slice(&tmp[..n]);
if buf.len() > 128 * 1024 {
error!("请求头过大，终止连接");
return Ok(());
}
};
let header_end = header_end.unwrap();
let headers_vec: Vec<u8> = buf[..header_end].to_vec();

let virtual_env = parse_virtual_env_from_headers(&headers_vec);
let content_length = parse_content_length(&headers_vec);
let chunked = is_chunked(&headers_vec);

// 读取完整正文
let body_len = if let Some(cl) = content_length {
while buf.len() < header_end + cl {
let n = client_stream.read(&mut tmp).await?;
if n == 0 {
error!("Content-Length 指定但连接提前关闭");
return Ok(());
}
buf.extend_from_slice(&tmp[..n]);
}
cl
} else if chunked {
loop {
if let Some(end) = chunked_body_end_pos(&buf[header_end..]) {
break end;
}
let n = client_stream.read(&mut tmp).await?;
if n == 0 {
error!("chunked 正文未完整但连接已关闭");
return Ok(());
}
buf.extend_from_slice(&tmp[..n]);
}
} else {
0
};

let request_end = header_end + body_len;
let body = &buf[header_end..request_end];
let mut new_headers = rewrite_connection_close(&headers_vec);
new_headers.extend_from_slice(body);

// 路由：每个请求一个目标连接；响应仅回写到客户端
if let Some(env) = virtual_env {
let ctrl_opt = {
let envs = (*VIRTUAL_ENVS).lock().unwrap();
envs.get(&env).cloned()
};
if let Some(mut ctrl) = ctrl_opt {
match ctrl.open_stream().await {
Ok(mut sub) => {
sub.write_all(&new_headers).await?;
let _ = tokio::io::copy(&mut sub, &mut client_stream).await;
}
Err(e) => {
error!("打开虚拟环境 {} 的子流失败: {:?}", env, e);
let mut upstream_stream = TcpStream::connect(upstream_addr).await?;
upstream_stream.write_all(&new_headers).await?;
let _ = tokio::io::copy(&mut upstream_stream, &mut client_stream).await;
}
}
} else {
let mut upstream_stream = TcpStream::connect(upstream_addr).await?;
upstream_stream.write_all(&new_headers).await?;
let _ = tokio::io::copy(&mut upstream_stream, &mut client_stream).await;
}
} else {
let mut upstream_stream = TcpStream::connect(upstream_addr).await?;
upstream_stream.write_all(&new_headers).await?;
let _ = tokio::io::copy(&mut upstream_stream, &mut client_stream).await;
}

// 删除已消费的请求字节，保留后续请求（若已到达）
if request_end < buf.len() {
let remaining = buf.split_off(request_end);
buf = remaining;
} else {
buf.clear();
}
}
```

16 天前

回复了 montaro2017 创建的主题 › Java › 用 netty 编写代理服务器，切换出口 IP，不能及时生效

```rust

24 天前

回复了 BeijingBaby 创建的主题 › 程序员 › 除了编程外，你还有什么取悦自己的爱好？

钓鱼？

29 天前

回复了 LittleYe233 创建的主题 › 程序员 › 感谢华为打钱，准备拿钱买个 iphone17 512g

ai 写的应用月活怎么弄的，买的吗？

53 天前

回复了 isno 创建的主题 › 程序员 › [盖楼抽奖] 新书上市，《深入高可用系统原理与设计》

支持一下