gpt4 book ai didi

基于Redis的限流器的实现(示例讲解)

转载 作者:qq735679552 更新时间:2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章基于Redis的限流器的实现(示例讲解)由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.

1 概述 。

系统中的接口通常都有限流,比如 70次/秒 ,如何保证我们的接口的调用次数在超过第三方接口限流的时候快速失败呢?这时候就需要限流器了。下面是笔者用redis实现限流器的流程图.

基于Redis的限流器的实现(示例讲解)

2 代码 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
/**
  * 获取限流权限
  * @param key
  * @param millisecond 毫秒数
  * @param limitCount 限流次数
  * @return
  */
public static boolean getCurrentLimiting(String key, Long millisecond, Integer limitCount){
   try {
     boolean currentLimitingLock = RedisDistributeLockUtil.lock(key);
     if(currentLimitingLock){
       Long llen = RedisClient.llen(getCurrentLimitingRedisKey(key));
       if(llen < limitCount ){
         RedisClient.lpush(getCurrentLimitingRedisKey(key), DateUtil.current(false) + "");
         return true;
       }else{
         Long lastTime = Long .parseLong(RedisClient.lindex(getCurrentLimitingRedisKey(key), -1));
         if((DateUtil.current(false) - lastTime) >= millisecond){
           RedisClient.lpush(getCurrentLimitingRedisKey(key), DateUtil.current(false) + "");
           RedisClient.ltrim(getCurrentLimitingRedisKey(key), 0, limitCount);
           return true;
         }
       }
     }
   }finally {
     RedisDistributeLockUtil.unlock(key);
   }
   return false;
}

以上这篇基于Redis的限流器的实现(示例讲解)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持我.

最后此篇关于基于Redis的限流器的实现(示例讲解)的文章就讲到这里了,如果你想了解更多关于基于Redis的限流器的实现(示例讲解)的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com