一、使用示例：

1、自定义RateLimiterConfig配置

public class CustomRateLimiterConfig extends RateLimiterConfig {private final String FILE_NAME = "test-rate-limiter.properties";@Overridepublic String getConfigFile() {return FILE_NAME;}}

2、自定义RedisConfig配置

public class RateRedisConfig extends RedisConfig {private final String FILE_NAME = "test-redis_config.properties";@Overridepublic String getConfigFile() {return FILE_NAME;}}

3、限流控制使用

private final static Loggerlogger= LoggerFactory.getLogger(LimiterTest.class);private static Limiterlimiter= null;private volatile static intmaxNum= 0;private final static StringROUTER_NAME= "/thread-test";public static void main(String[] args) {RedisConfig redisConfig = new RateRedisConfig();RateLimiterConfig rateLimiterConfig = new CustomRateLimiterConfig();singleLimiter(rateLimiterConfig);// 实例化单机限流对象// DistributedLimiter(rateLimiterConfig, redisConfig); // 示例化分布式限流对象simulateConcurrentThread(); // 模拟并发线程}private static void simulateConcurrentThread() {DoThing dt = null;Thread t = null;for (int i = 0; i < 6; i++) {dt = new DoThing("Thread " + i);t = new Thread(dt);t.start();}}private static void singleLimiter(RateLimiterConfig rateLimiterConfig) {limiter = LimiterFactory.getInstance().single(rateLimiterConfig);}private static void DistributedLimiter(RateLimiterConfig rateLimiterConfig, RedisConfig redisConfig) {limiter = LimiterFactory.getInstance().distributed(rateLimiterConfig, redisConfig);}/** * 自定义线程，用于模拟并发 */static class DoThing implements Runnable {String name;public DoThing(String name) {this.name = name;}@SuppressWarnings("static-access")@Overridepublic void run() {try {for (int i = 0; i < 20; i++) {if (!limiter.execute(ROUTER_NAME, 4, 1)) {// 进行限流控制logger.info("Thread Name is [{}]，调用频率太高了.", name);Thread.currentThread().sleep(1000);continue;}maxNum++;logger.info("Thread Name is [{}]，最新maxNum的值 = [" + maxNum + "]", name);}}catch (InterruptedException e) {logger.error("Thread Name [{}] is Error.", name, e);}}}

4、并发控制

private final static Loggerlogger   = LoggerFactory.getLogger(LockTest.class);private static StringUNIQUE_KEY = "/lock1";private static Locklock   = null;private volatile static intsuccessNum = 0;public static void main(String[] args) {RateLimiterConfig rateLimiterConfig = new CustomRateLimiterConfig();// lock = getSingleLock(rateLimiterConfig);RedisConfig redisConfig = new RateRedisConfig();lock = getDistributedLock(rateLimiterConfig, redisConfig);// RedisClientFactory.getClient(redisConfig).set("/lock1", "10");//// 模拟releaseLock没有执行导致的缓存中存在较多正数值得锁KEYsimulateConcurrentThread(80); // 模拟并发线程}private static Lock getSingleLock(RateLimiterConfig rateLimiterConfig) {return LockFactory.getInstance().single(rateLimiterConfig);}private static Lock getDistributedLock(RateLimiterConfig rateLimiterConfig, RedisConfig redisConfig) {return LockFactory.getInstance().distributed(rateLimiterConfig, redisConfig);}private static void simulateConcurrentThread(int threadNum) {DoThing dt = null;Thread t = null;for (int i = 0; i < threadNum; i++) {dt = new DoThing("Thread " + i);t = new Thread(dt);try {Thread.sleep(100);}catch (InterruptedException e) {e.printStackTrace();}// 模拟程序执行时间t.start();}}/** * 自定义线程，用于模拟并发 */static class DoThing implements Runnable {String name;public DoThing(String name) {this.name = name;}@SuppressWarnings("static-access")@Overridepublic void run() {try {if (lock.lock(UNIQUE_KEY)) {// 进行并发控制logger.info("Thread Name is [{}] 成功获得锁，正在处理中...", name);successNum++;logger.info("当前成功并发数successNum的值为 [" + successNum + "]");Thread.currentThread().sleep(2000);// 模拟程序执行时间successNum--;lock.releaseLock(UNIQUE_KEY);}else {logger.warn("Thread Name is [{}] 尝试获得锁失败", name);}}catch (InterruptedException e) {logger.error("Thread Name [{}] is Error.", name, e);}}}

二、具体参考：