guava之RateLimiter限流算法
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.png4、其他方法简介
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(无需等待)