com.chungkui.check.handler.ratelimiter.impl

类 StandAloneRateRateLimiterServiceImpl

java.lang.Object

com.chungkui.check.handler.ratelimiter.impl.StandAloneRateRateLimiterServiceImpl

所有已实现的接口:

RateLimiterService

public class StandAloneRateRateLimiterServiceImpl
extends Object
implements RateLimiterService

基于google guava的单机版本流控.
guava的ratelimiter实现的流控.

从以下版本开始:

[产品/模块版本] (可选)

作者:

jason

另请参阅:

[相关类/方法](可选)

字段概要

字段

限定符和类型	字段和说明
private com.google.common.util.concurrent.RateLimiter	rateLimiter
private boolean	sync 是否直接以阻塞方式执行，默认不阻塞，为true会线程等待直到拿到令牌
private Long	waitLimit 阻塞等待时间，0表示不阻塞，取不到直接返回

构造器概要

构造器

构造器和说明
StandAloneRateRateLimiterServiceImpl(double permitsPerSecond, Long warmupPeriod, Boolean sync, Long waitLimit)

方法概要

限定符和类型	方法和说明
boolean	check() 使用rateLimiter进行判断

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

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

字段详细资料

rateLimiter

private com.google.common.util.concurrent.RateLimiter rateLimiter

sync

private boolean sync

是否直接以阻塞方式执行，默认不阻塞，为true会线程等待直到拿到令牌

waitLimit

private Long waitLimit

阻塞等待时间，0表示不阻塞，取不到直接返回

构造器详细资料

StandAloneRateRateLimiterServiceImpl

public StandAloneRateRateLimiterServiceImpl(double permitsPerSecond,
                                            Long warmupPeriod,
                                            Boolean sync,
                                            Long waitLimit)

参数:

permitsPerSecond - 流控量

warmupPeriod - 20

sync - 是否同步等待

waitLimit - 等待超时时间

方法详细资料

check

public boolean check()

使用rateLimiter进行判断

指定者:

check 在接口中 RateLimiterService

返回:

true=放行/false=拒绝

另请参阅:

[相关类/方法](可选)