使用Golang怎么模拟令牌桶进行访问

使用Golang怎么模拟令牌桶进行访问？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

golang的优点

golang是一种编译语言，可以将代码编译为机器代码，编译后的二进制文件可以直接部署到目标机器而无需额外的依赖，所以golang的性能优于其他的解释性语言，且可以在golang中使用goroutine来实现并发性，它提供了一个非常优雅的goroutine调度程序系统，可以很容易地生成数百万个goroutine。

利用channel进行模拟令牌桶对访问进行限流

func FW(max int,duration time.Duration){//定义一个channel ，进行初始化contain := make(chan bool , max)for i := 0 ; i < max ; i ++{contain <- true//写入channel}go func() {//开启一个线程for {contain <- truetime.Sleep(duration)}}()for <- contain {//如果上一个线程写入一个true，就会运行这个代码块fmt.Println("helllo world")}}

补充：golang简易令牌桶算法实现

基本思路：

定义一个chan，chan大小为需要限制的qps大小，go一个协程启动tick，每1000/qps时间在tick中写入数值，启动另一个协程，读取chan中的值，如果读取到chan中有值，则向下层接口发送请求。

代码如下：

package mainimport (    "fmt"    "time"    "httpclient")var LEN int = 10func tickStoreCh(arrlen int, ch chan int) {    len := 1000/arrlen    fmt.Println(len)    tickTime := time.NewTicker(time.Duration(len)*time.Millisecond)    var i int    for {        fmt.Println(len)        i++        <-tickTime.C        ch<- i    }}func OrganReq(org string, qps int) {    ch := make(chan int, qps)    go tickStoreCh(qps, ch)    time.Sleep(1000*time.Millisecond)    for {        //收客户请求，发送http请求给RE        client := httpclient.NewHttpClient(time.Duration(1000)*time.Millisecond, time.Duration(2000)*time.Millisecond)        header := make(map[string]string)        header["Content-Type"] = "application/json;charset=utf-8"        code, err := client.ResponseCode("http://127.0.0.1:19988", header, "llltest")        value := <- ch        fmt.Println(code, value, err, "lenchan:", len(ch))        //time.Sleep(time.Second)    }}

看完上述内容，你们掌握使用Golang怎么模拟令牌桶进行访问的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注编程网行业资讯频道，感谢各位的阅读！