Golang限流器rate使用

「爱情、让人受尽委屈。」 2022-12-24 10:50 143阅读 0赞

rate包是Google基于令牌桶的算法实现的限流器，可以在服务的限流中使用。

我们通过一个例子来使用rate

package main
    
    import (
    	"fmt"
    	"time"
    	"context"
    
    	"golang.org/x/time/rate"
    )
    
    func main() {
    	//初始化 limiter 每秒10个令牌，令牌桶容量为20
    	limiter :=  rate.NewLimiter(rate.Every(time.Millisecond*100),20)
    
    	for i := 0 ; i < 25 ; i++ {
    		if limiter.Allow() {
    			fmt.Println("success")  //do something
    		}else {
    			fmt.Println("busy")
    		}
    	}
    
    	//阻塞直到获取足够的令牌或者上下文取消
    	ctx,_ := context.WithTimeout(context.Background(),time.Second*10)
    	fmt.Println("start get token",time.Now())
    	err := limiter.WaitN(ctx,20)
    	if err != nil {
    		fmt.Println("error",err)
    	}
    
    	fmt.Println("success get token",time.Now())
    }

说明：rate.NewLimiter用于初始化限流器，指定限流的速率及令牌桶的最大容量

Limiter有三个主要的方法 Allow、Reserve和Wait，最常用的是Wait和Allow方法

这三个方法每调用一次都会消耗一个令牌，这三个方法的区别在于没有令牌时，他们的处理方式不同

Allow： 如果没有令牌，则直接返回false

Reserve：如果没有令牌，则返回一个reservation，

Wait：如果没有令牌，则等待直到获取一个令牌或者其上下文被取消。

想要深入学习rate，可以学习rate的源码：[https://skaygo.blog.csdn.net/article/details/110239775][https_skaygo.blog.csdn.net_article_details_110239775]

[https_skaygo.blog.csdn.net_article_details_110239775]: https://skaygo.blog.csdn.net/article/details/110239775

发表评论取消回复

表情：

评论列表（有 0 条评论，143人围观）

还没有评论，来说两句吧...

相关阅读

相关【Redisson】Redisson--限流器

Redisson系列文章： [【Redisson】Redisson–基础入门][Redisson_Redisson] [【Redisson】Redisson–布隆

冷不防/ 2023年10月13日 11:01/ 0 赞/ 8 阅读

相关信号量与令牌桶_Golang 限流器的使用和实现

限流器是服务中非常重要的一个组件，在网关设计、微服务、以及普通的后台应用中都比较常见。它可以限制访问服务的频次和速率，防止服务过载，被刷爆。限流器的算法比较多，常见的比如令

系统管理员/ 2023年01月01日 05:47/ 0 赞/ 134 阅读

相关 RabbitMQ学习（六）-- 限流器使用

目录一、添加配置二、添加代码三、测试结果一、添加配置 spring: rabbitmq: liste

女爷i/ 2022年12月29日 06:17/ 0 赞/ 118 阅读

相关 Golang限流器rate使用

rate包是Google基于令牌桶的算法实现的限流器，可以在服务的限流中使用。我们通过一个例子来使用rate package main i

「爱情、让人受尽委屈。」/ 2022年12月24日 10:50/ 0 赞/ 144 阅读

相关 Golang限流器rate包源码详细分析

源码地址：golang.org/x/time/rate rate包是Google基于令牌桶的算法实现的限流器，可以在服务的限流中使用。一、数据结构 1.常量变量

た入场券/ 2022年12月24日 10:50/ 0 赞/ 158 阅读

相关 Semaphore的使用并实现的限流器

semaphore 基本原理 semaphore 翻译成字面意思是信号量，Semaphore可以控制同时访问的线程个数，通过acquire（）获取一个许可，如果没有就等待

秒速五厘米/ 2022年12月03日 02:24/ 0 赞/ 186 阅读

相关限流（Rate limit）算法详解

一、前言保障服务稳定的三大利器：熔断降级、服务限流和故障模拟。今天和大家谈谈限流算法的几种实现方式，本文所说的限流并非是Nginx层面的限流，而是业务代码中的逻辑限流。

分手后的思念是犯贱/ 2022年09月11日 01:15/ 0 赞/ 161 阅读

相关使用spring-cloud-zuul-rate-limit在zuul中为服务限流

文章目录前言 spring cloud eureka server注册中心 pom文件启动类

迷南。/ 2022年09月07日 14:39/ 0 赞/ 170 阅读

相关限流 Rate Limiter

请参考，如下两篇文章： springside的限流介绍： https://github.com/springside/springside4/wiki/Rate-Limite

爱被打了一巴掌/ 2022年06月02日 05:09/ 0 赞/ 139 阅读

相关使用Guava实现限流器

为什么需要限流？在开发高并发系统时有三把利器用来保护系统：缓存、降级和限流。限流可以认为服务降级的一种，限流通过限制请求的流量以达到保护系统的目的。一般来说，系统的

骑猪看日落/ 2022年02月17日 07:37/ 0 赞/ 240 阅读