golang频率限制 rate详解

大树

golang.org/x/time/rate 提对速度进行限制的算法

1. l := rate.NewLimiter(1, 3) // 一个参数为每秒发生多少次事件，第二个参数是最大可运行多少个事件(burst)

复制代码

Limter提供三中主要的函数 Allow, Reserve, Wait. 大部分时候使用Wait
Wait/WaitN 当没有可用事件时，将阻塞等待

1. c, _ := context.WithCancel(context.TODO())
   
2. for {
   
3. l.Wait(c)
   
4. fmt.Println(time.Now().Format("04:05.000"))
   
5. }

复制代码

输出

1. 07:35.055
   
2. 07:35.055
   
3. 07:35.055
   
4. 07:36.060
   
5. 07:37.059
   
6. 07:38.059

复制代码

缓存3次后，每秒执行一次

1. Allow/AllowN 当没有可用事件时，返回false
   
2. for {
   
3. if (l.AllowN(time.Now(), 1)) {
   
4.   fmt.Println(time.Now().Format("04:05.000"))
   
5. } else {
   
6.   time.Sleep(1 * time.Second / 10)
   
7.   fmt.Println(time.Now().Format("Second 04:05.000"))
   
8. }
   
9. 
   
10. }

复制代码

Reserve/ReserveN 当没有可用事件时，返回 Reservation，和要等待多久才能获得足够的事件

1. for {
   
2.   r := l.ReserveN(time.Now(), 1)
   
3.   s := r.Delay()
   
4.   time.Sleep(s)
   
5.    fmt.Println(s, time.Now().Format("04:05.000"))
   
6. 
   
7. }

复制代码

补充：关于golang.org/x包问题
由于谷歌被墙，跟谷歌相关的模块无法通过go get来下载
解决方法：

1. git clone https://github.com/golang/net.git $GOPATH/src/github.com/golang/net
   
2. git clone https://github.com/golang/sys.git $GOPATH/src/github.com/golang/sys
   
3. git clone https://github.com/golang/tools.git $GOPATH/src/github.com/golang/tools
   
4. ln -s $GOPATH/src/github.com/golang $GOPATH/src/golang.org/x

复制代码

如果是Windows下，最后一条可以替换为mklink命令，或者直接拷贝文件夹修改一下名称即可。
go的官方包都在这个目录下：
https://github.com/golang
以上为个人经验，希望能给大家一个参考，也希望大家多多支持晓枫资讯。如有错误或未考虑完全的地方，望不吝赐教。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

王玉琴1

感谢大大分享~~~~~~~~

Plmmlyy

顶顶更健康！！！

谷8201

感谢楼主，顶。

珍293

路过，支持一下