net.listentcp后直接conn.write会丢包,根本原因是tcp连接需双向收发,未启动goroutine持续read会导致接收缓冲区满而丢包,必须配对启动local→remote和remote→local两个goroutine。

为什么 net.ListenTCP 后直接 conn.Write 会丢包?
端口转发不是简单地把 A 收到的数据发给 B,关键在于连接生命周期和缓冲区管理。常见现象是:本地能连上,但 HTTP 请求卡住、SSH 登录失败、或者只传了前几个字节就断开。
- 根本原因是 TCP 连接两端必须同时收发——
conn.Write不阻塞不代表对端已读;若不启动 goroutine 持续Read,内核接收缓冲区满后会丢后续包(尤其高吞吐场景) - 必须为每个连接配对启动两个 goroutine:
local → remote和remote → local,否则单向转发必然卡死 - 别用
io.Copy就完事——它内部虽有循环Read/Write,但出错时不会通知另一路,导致一端挂了另一端还在傻等
正确做法是自己控制循环,并在任一端 Read 返回 io.EOF 或错误时,主动关闭双端连接:
go func() {
io.Copy(localConn, remoteConn)
localConn.CloseWrite()
remoteConn.CloseRead()
}()
如何避免 listen tcp :8080: bind: address already in use?
开发调试时反复启停程序,TIME_WAIT 状态会让端口短时间不可重用,报错很常见。这不是代码写错了,而是系统行为。
- Go 默认不启用
SO_REUSEADDR,需手动设置net.ListenConfig - 仅 Linux/macOS 支持该选项,Windows 下无效(但通常问题不明显)
- 不能只靠
defer ln.Close()——进程崩溃或 Ctrl+C 时没机会执行,得靠系统级重用
实操写法:
立即学习“go语言免费学习笔记(深入)”;
lc := net.ListenConfig{
Control: func(network, address string, c syscall.RawConn) error {
return c.Control(func(fd uintptr) {
syscall.SetsockoptInt32(int(fd), syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)
})
},
}
ln, err := lc.Listen(context.Background(), "tcp", ":8080")
转发 HTTPS 流量时为什么浏览器提示 ERR_SSL_PROTOCOL_ERROR?
HTTP 可以直转,HTTPS 不行——因为 TLS 握手发生在应用层之下,你看到的只是加密流。强行转发只会让客户端和真实服务端之间无法完成密钥协商。
- 端口转发工具本身**不解析也不终止 TLS**,所以对 HTTPS 来说,它只是透传字节流;只要后端是合法 HTTPS 服务,且域名证书匹配,浏览器就不会报错
- 真正出问题的场景是:你在本地
localhost:8080转发到远程example.com:443,但浏览器访问的是http://localhost:8080(少了个 s),自然触发协议错误 - 另一个坑:某些代理工具(如
mitmproxy)会主动解密 HTTPS,但标准端口转发不干这事——别混淆“转发”和“中间人”
验证方法:用 curl -v https://localhost:8080 看是否返回远程站点的真实响应头,而不是 Go 的 panic 或空响应。
怎么让转发支持 UDP(比如 DNS 查询)?
TCP 转发好做,UDP 更棘手——没有连接状态,每个 WriteTo 都要指定目标地址,且必须自己维护映射关系。
-
net.ListenUDP返回的是无连接 socket,收到数据包时只能拿到 payload + 对端地址,无法像 TCP 那样复用conn对象 - 若想实现双向中转(如本地 DNS 查询转远程 DNS 服务器),必须缓存每次请求的源地址,并在收到响应后用
WriteTo回发到原始请求方 - UDP 没有超时重传,丢包率高;建议加简单超时控制(比如用
time.AfterFunc清理 5 秒未响应的请求槽位)
最小可行结构:
conn, _ := net.ListenUDP("udp", &net.UDPAddr{Port: 5353})
buf := make([]byte, 1500)
for {
n, src, _ := conn.ReadFromUDP(buf)
go func() {
resp, _ := dnsQuery(buf[:n]) // 自定义查询逻辑
conn.WriteToUDP(resp, src)
}()
}
注意:UDP 转发没法像 TCP 那样优雅关连接,Close 后新包会被静默丢弃,老包可能还在路上——这点容易被忽略。










