org.tio.monitor

Class RateLimiterWrap

java.lang.Object

org.tio.monitor.RateLimiterWrap

public class RateLimiterWrap
extends Object

需要用本类的，需要自己引入 com.google.guava guava

Author:

tanyaowu 2017年5月23日 下午1:09:55

Constructor Summary

Constructors

Constructor and Description
RateLimiterWrap(int permitsPerSecond, int warnClearInterval, int maxWarnCount, int maxAllWarnCount)

Method Summary

Modifier and Type	Method and Description
AtomicInteger	getAllWarnCount()
long	getLastWarnTime()
int	getMaxAllWarnCount()
int	getMaxWarnCount()
com.google.common.util.concurrent.RateLimiter	getRateLimiter()
int	getWarnClearInterval()
AtomicInteger	getWarnCount()
void	setAllWarnCount(AtomicInteger allWarnCount)
void	setLastWarnTime(long lastWarnTime)
void	setMaxAllWarnCount(int maxAllWarnCount)
void	setMaxWarnCount(int maxWarnCount)
void	setRateLimiter(com.google.common.util.concurrent.RateLimiter rateLimiter)
void	setWarnClearInterval(int warnClearInterval)
void	setWarnCount(AtomicInteger warnCount)
boolean[]	tryAcquire()

Methods inherited from class java.lang.Object

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

Constructor Detail

RateLimiterWrap

public RateLimiterWrap(int permitsPerSecond,
                       int warnClearInterval,
                       int maxWarnCount,
                       int maxAllWarnCount)

Parameters:

permitsPerSecond - QPS

warnClearInterval - 清理本阶段警告的时间间隔，参考值1000 * 60 * 60 * 2，单位为ms

maxWarnCount - 本阶段最多警告多次数，参考值10

maxAllWarnCount - 一共最多警告多次数

Method Detail

getAllWarnCount

public AtomicInteger getAllWarnCount()

Returns:

the allWarnCount

getLastWarnTime

public long getLastWarnTime()

Returns:

the lastWarnTime

getMaxAllWarnCount

public int getMaxAllWarnCount()

Returns:

the maxAllWarnCount

getMaxWarnCount

public int getMaxWarnCount()

Returns:

the maxWarnCount

getRateLimiter

public com.google.common.util.concurrent.RateLimiter getRateLimiter()

Returns:

the rateLimiter

getWarnClearInterval

public int getWarnClearInterval()

Returns:

the warnClearInterval

getWarnCount

public AtomicInteger getWarnCount()

Returns:

the warnCount

setAllWarnCount

public void setAllWarnCount(AtomicInteger allWarnCount)

Parameters:

allWarnCount - the allWarnCount to set

setLastWarnTime

public void setLastWarnTime(long lastWarnTime)

Parameters:

lastWarnTime - the lastWarnTime to set

setMaxAllWarnCount

public void setMaxAllWarnCount(int maxAllWarnCount)

Parameters:

maxAllWarnCount - the maxAllWarnCount to set

setMaxWarnCount

public void setMaxWarnCount(int maxWarnCount)

Parameters:

maxWarnCount - the maxWarnCount to set

setRateLimiter

public void setRateLimiter(com.google.common.util.concurrent.RateLimiter rateLimiter)

Parameters:

rateLimiter - the rateLimiter to set

setWarnClearInterval

public void setWarnClearInterval(int warnClearInterval)

Parameters:

warnClearInterval - the warnClearInterval to set

setWarnCount

public void setWarnCount(AtomicInteger warnCount)

Parameters:

warnCount - the warnCount to set

tryAcquire

public boolean[] tryAcquire()

Returns:

0位置：根据QPS获取执行锁, false: 没拿到锁
1位置：根据警告次数获取执行锁, false: 没拿到锁