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

/** * 获取限流权限 * @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;}