io.jboot.components.limiter

类 LimiterManager

java.lang.Object

io.jboot.components.limiter.LimiterManager

public class LimiterManager
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	LimiterManager.LimitConfigBean

字段概要

字段

限定符和类型	字段和说明
private LimitFallbackProcesser	fallbackProcesser
private HashSet<String>	ipWhitelist
private LimitConfig	limitConfig
private HashSet<LimiterManager.LimitConfigBean>	limitConfigBeans
private static LimiterManager	me
private com.github.benmanes.caffeine.cache.Cache<String,com.google.common.util.concurrent.RateLimiter>	rateLimiterCache
private com.github.benmanes.caffeine.cache.Cache<String,Semaphore>	semaphoreCache

构造器概要

构造器

限定符	构造器和说明
private	LimiterManager()

方法概要

限定符和类型	方法和说明
private void	doInitFallbackProcesser()
private void	doParseConfig() 解析用户配置
private boolean	ensureLegal(String packageOrTarget, String type, String rate) 确保配置合法
HashSet<LimiterManager.LimitConfigBean>	getLimitConfigBeans()
com.google.common.util.concurrent.RateLimiter	getOrCreateRateLimiter(String resKey, int rate)
Semaphore	getOrCreateSemaphore(String resKey, int rate)
void	init()
boolean	isEnable()
boolean	isInIpWhitelist(String ip)
LimiterManager.LimitConfigBean	matchConfig(String packageOrTarget) 匹配用户配置
static LimiterManager	me()
void	processFallback(String resource, String fallback, com.jfinal.aop.Invocation inv)

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

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

字段详细资料

limitConfigBeans

private HashSet<LimiterManager.LimitConfigBean> limitConfigBeans

ipWhitelist

private HashSet<String> ipWhitelist

limitConfig

private LimitConfig limitConfig

semaphoreCache

private com.github.benmanes.caffeine.cache.Cache<String,Semaphore> semaphoreCache

rateLimiterCache

private com.github.benmanes.caffeine.cache.Cache<String,com.google.common.util.concurrent.RateLimiter> rateLimiterCache

fallbackProcesser

private LimitFallbackProcesser fallbackProcesser

me

private static LimiterManager me

构造器详细资料

LimiterManager

private LimiterManager()

方法详细资料

me

public static LimiterManager me()

init

public void init()

doInitFallbackProcesser

private void doInitFallbackProcesser()

doParseConfig

private void doParseConfig()

解析用户配置

matchConfig

public LimiterManager.LimitConfigBean matchConfig(String packageOrTarget)

匹配用户配置

参数:

packageOrTarget -

返回:

isInIpWhitelist

public boolean isInIpWhitelist(String ip)

getOrCreateRateLimiter

public com.google.common.util.concurrent.RateLimiter getOrCreateRateLimiter(String resKey,
                                                                            int rate)

getOrCreateSemaphore

public Semaphore getOrCreateSemaphore(String resKey,
                                      int rate)

getLimitConfigBeans

public HashSet<LimiterManager.LimitConfigBean> getLimitConfigBeans()

ensureLegal

private boolean ensureLegal(String packageOrTarget,
                            String type,
                            String rate)

确保配置合法

参数:

packageOrTarget -

type -

rate -

返回:

isEnable

public boolean isEnable()

processFallback

public void processFallback(String resource,
                            String fallback,
                            com.jfinal.aop.Invocation inv)