Files
4566704 a0133f5881 feat(flow): 自 go-hua 迁入流量统计器
- 并发安全收发字节数累计(Add/Get/Reset), 附测试、例程与 README
2026-09-20 12:25:36 +08:00

698 B

flow

并发安全的流量统计器(只统计、不限制):按累计字节数记录收发流量, 常配合 conn 包给限速连接挂统计。

迁移自 go-hua/flow,代码保持原样。

用法

import "git.zeroonesoft.cn/golib/zogo/flow"

f := &flow.Flow{}
f.Add(100, 200)       // 累计:发送 100、接收 200
send, recv := f.Get() // (150, 280)

send, recv = f.Reset() // 取走并清零(周期性上报场景)

完整可运行例程:examples/flow/main.go

注意

  • 计数跨进程生命周期累计,需要"每分钟流量"这类指标时用 Reset 取走清零。
  • json 序列化字段为 sendFlow/recvFlow。