com.gitee.baa.limiter

类 BucketLimiter

java.lang.Object

com.gitee.baa.limiter.BucketLimiter

public class BucketLimiter
extends Object

从以下版本开始:

2020/7/2 桶 限流器 这是一种总量限流方式 对于瞬间请求都可能被允许 最多能放 bucketSize个桶 每个桶最多能请求多少次根据 maxLimit 参数决定

作者:

deacon

字段概要

字段

限定符和类型	字段和说明
private com.google.common.cache.Cache<String,AtomicInteger>	cache

构造器概要

构造器

构造器和说明
BucketLimiter(int maxSize, long duration, TimeUnit timeUnit)

方法概要

限定符和类型	方法和说明
int	acquire(String key)
static BucketLimiter	create(int bucketSize, long duration, TimeUnit timeUnit)
private int	tryAcquire(String key)
boolean	tryAcquire(String key, int limitSize) 是否被限流 可根据不同的key 指定数量
boolean	tryAcquireIncrement(String key, int limitSize) 值自动原子性 +1 后判断是否被限流 可根据不同的key 指定数量

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

cache

private final com.google.common.cache.Cache<String,AtomicInteger> cache

构造器详细资料

BucketLimiter

public BucketLimiter(int maxSize,
                     long duration,
                     TimeUnit timeUnit)

参数:

maxSize - 桶大小

duration - 记录缓存时间

timeUnit - 单位时间

方法详细资料

create

public static BucketLimiter create(int bucketSize,
                                   long duration,
                                   TimeUnit timeUnit)

tryAcquire

public boolean tryAcquire(String key,
                          int limitSize)

是否被限流 可根据不同的key 指定数量

参数:

key -

limitSize -

返回:

tryAcquireIncrement

public boolean tryAcquireIncrement(String key,
                                   int limitSize)

值自动原子性 +1 后判断是否被限流 可根据不同的key 指定数量

参数:

key -

limitSize -

返回:

tryAcquire

private int tryAcquire(String key)

acquire

public int acquire(String key)