Redis原子计数器incr,防止并发请求操作

127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> incr num
(integer) 11
127.0.0.1:6379> get num  # 数字值在 Redis 中以字符串的形式保存
"11"

public static boolean flowControl(String key){
    //最大允许100
    int max = 100;
    long total = 1L;
    try {
      if (jedisInstance.get(key) == null) {
        //jedisInstance是Jedis连接实例，可以使单链接也可以使用链接池获取，实现方式请参考之前的blog内容
        //如果redis目前没有这个key，创建并赋予0，有效时间为60s
        jedisInstance.setex(key, 60, "0");
      } else {
        //获取加1后的值
        total = jedisInstance.incr(redisKey).longValue();
        //Redis TTL命令以秒为单位返回key的剩余过期时间。当key不存在时，返回-2。当key存在但没有设置剩余生存时间时，返回-1。否则，以秒为单位，返回key的剩余生存时间。
        if (jedisInstance.ttl(redisKey).longValue() == -1L)
        {
          //为给定key设置生存时间，当key过期时(生存时间为0)，它会被自动删除。
          jedisInstance.expire(redisKey, 60);
        }
      }
    } catch (Exception e) {
      logger.error("流量控制组件:执行计数操作失败,无法执行计数");
    }
    long keytotaltransations = max;
    //判断是否已超过最大值，超过则返回false
    if (total > keytotaltransations) {
      return false;
    }
    return true;
  }

//每次请求进来，查询一下当前的计数值，如果超出请求数阈值，则拒绝请求，返回系统繁忙提示
private long limitFlow(String key) {
    //Setnx（SET if Not eXists） 命令在指定的 key 不存在时，为 key 设置指定的值。设置成功返回1，设置失败返回0
    Long lng = redisCacheClient.setnx(jedisGroup, key, "1");
    if (lng == 1) {
      //设置时间窗口，redis-key时效为10秒
      redisCacheClient.expire(jedisGroup, key, 10);
      return 1L;
    } else {
      //Redis Incrby 命令将 key 中储存的数字加上指定的增量值。相当于放在redis中的计数器，每次请求到来计数器自增1
      long val = redisCacheClient.incrBy(jedisGroup, key, 1);
 
      return val;
    }
  }