Go中实现网络流量限速需基于rate.Limiter封装io.Reader/Writer,按字节申请令牌实现收发双向限速,可集成到net.Conn、HTTP Server/Client,并注意burst设置、并发安全及TCP协议影响。
在 Go 中实现网络流量限速,核心是控制单位时间内读写的数据量。标准库 net 本身不提供限速能力,但可通过封装 io.Reader 和 io.Writer,结合令牌桶(Token Bucket)或漏桶(Leaky Bucket)算法实现精确的速率控制。最常用、易用且生产就绪的方式是使用 golang.org/x/net 中的 rate 包配合自定义的限速读写器。
对 TCP 连接或 HTTP 请求体等输入流做接收限速,本质是在每次读取前“申请配额”。推荐基于 rate.Limiter 封装一个带限速的 io.Reader:
rate.Limiter,例如每秒最多允许 100KB:limiter := rate.NewLimiter(rate.Limit(100*1024), 100*1024)(第二个参数为初始令牌数,建议设为 burst 值)io.Reader 和 *rate.Limiter
Read(p []byte) (n int, err error) 方法:先调用 limiter.WaitN(ctx, len(p)) 等待足够令牌,再执行底层读取len(p) 个令牌,而非固定值;实际中常按 chunk(如 4KB)申请,避免频繁阻塞发送限速逻辑类似,但需在每次 Write 前申请对应字节数的令牌:
rate.Limiter,配置与 Reader 一致或独立(可实现上下行不同速率)io.Writer,Write(p []byte) 中先 limiter.WaitN(ctx, len(p)),再调用底层 Write
n ),应只申请 n 个令牌,并对剩余数据递归处理或分片重试
限速 Reader/Writer 可无缝接入标准库生态:
立即学习“go语言免费学习笔记(深入)”;
net.Conn:用限速 Reader 包装 conn.Read,限速 Writer 包装 conn.Write;可实现双向限速的自定义 net.Conn 实现http.Handler 中,将 http.Request.Body 替换为限速 Reader;将 http.ResponseWriter 包装为限速 Writer(需实现 http.ResponseWriter 接口并代理写操作)http.Client.Transport 自定义 RoundTripper,
在 RoundTrip 中对请求体和响应体分别应用限速器WaitN 支持 context.Context,可用于超时控制或取消,避免永久阻塞实际部署中需关注几个关键点:
limiter.ReserveN 预留后异步等待SetNoDelay(true) 并监控实际吞吐