guava之RateLimiter限流算法

2019-04-15  本文已影响0人  Eden666

1、漏桶算法

请求进入漏桶里,漏桶以一定速度响应,请求速度过大直接溢出,拒绝服务。


1.png

2、令牌桶算法

请求获取token,直到没有token可拿,阻塞或者拒绝服务。


2.png

3、RateLimiter工具类之令牌桶算法

配置10个令牌测试


2.png
 boolean tryAcquire = accessLimitService.getRateLimiter()
                .tryAcquire();
        if (tryAcquire) {
            accessLimitService.addData();
            return "success";
        } else {
            throw new IllegalAccessException("failed");
        }

使用jemeter模拟并发请求测试结果如下(注:配置n=10个令牌限流,实际限制n+1=11个)

333.png 4444.png

4、其他方法简介

double acquire(): 从RateLimiter获取一个许可,该方法会被阻塞直到获取到请求。
double acquire(int permits):从RateLimiter获取指定许可数,该方法会被阻塞直到获取到请求。
static RateLimiter create(double permitsPerSecond):根据指定的稳定吞吐率创建RateLimiter,这里的吞吐率是指每秒多少许可数(通常是指QPS,每秒多少查询)
static RateLimiter create(double permitsPerSecond, long warmupPeriod, TimeUnit unit):根据指定的稳定吞吐率和预热期来创建RateLimiter,这里的吞吐率是指每秒多少许可数(通常是指QPS,每秒多少个请求量),在这段预热时间内,RateLimiter每秒分配的许可数会平稳地增长直到预热期结束时达到其最大速率。(只要存在足够请求数来使其饱和)
double getRate():返回RateLimiter 配置中的稳定速率,该速率单位是每秒多少许可数
void setRate(double permitsPerSecond):更新RateLimite的稳定速率,参数permitsPerSecond: 由构造RateLimiter的工厂方法提供。
boolean tryAcquire():从RateLimiter 获取许可,如果该许可可以在无延迟下的情况下立即获取得到的话
boolean tryAcquire(int permits):从RateLimiter 获取许可数,如果该许可数可以在无延迟下的情况下立即获取得到的话
boolean tryAcquire(int permits, long timeout, TimeUnit unit):从RateLimiter 获取指定许可数如果该许可数可以在不超过timeout的时间内获取得到的话,或者如果无法在timeout 过期之前获取得到许可数的话,那么立即返回false (无需等待)
boolean tryAcquire(long timeout, TimeUnit unit):从RateLimiter 获取许可如果该许可可以在不超过timeout的时间内获取得到的话,或者如果无法在timeout 过期之前获取得到许可的话,那么立即返回false(无需等待)

5、github代码地址:

https://github.com/zpg0624/guava-spring-boot-demo

上一篇下一篇

猜你喜欢

热点阅读