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  # 數(shù)字值在 Redis 中以字符串的形式保存
"11"

public static boolean flowControl(String key){
    //最大允許100
    int max = 100;
    long total = 1L;
    try {
      if (jedisInstance.get(key) == null) {
        //jedisInstance是Jedis連接實例，可以使單鏈接也可以使用鏈接池獲取，實現(xiàn)方式請參考之前的blog內(nèi)容
        //如果redis目前沒有這個key，創(chuàng)建并賦予0，有效時間為60s
        jedisInstance.setex(key, 60, "0");
      } else {
        //獲取加1后的值
        total = jedisInstance.incr(redisKey).longValue();
        //Redis TTL命令以秒為單位返回key的剩余過期時間。當(dāng)key不存在時，返回-2。當(dāng)key存在但沒有設(shè)置剩余生存時間時，返回-1。否則，以秒為單位，返回key的剩余生存時間。
        if (jedisInstance.ttl(redisKey).longValue() == -1L)
        {
          //為給定key設(shè)置生存時間，當(dāng)key過期時(生存時間為0)，它會被自動刪除。
          jedisInstance.expire(redisKey, 60);
        }
      }
    } catch (Exception e) {
      logger.error("流量控制組件:執(zhí)行計數(shù)操作失敗,無法執(zhí)行計數(shù)");
    }
    long keytotaltransations = max;
    //判斷是否已超過最大值，超過則返回false
    if (total > keytotaltransations) {
      return false;
    }
    return true;
  }

//每次請求進(jìn)來，查詢一下當(dāng)前的計數(shù)值，如果超出請求數(shù)閾值，則拒絕請求，返回系統(tǒng)繁忙提示
private long limitFlow(String key) {
    //Setnx（SET if Not eXists） 命令在指定的 key 不存在時，為 key 設(shè)置指定的值。設(shè)置成功返回1，設(shè)置失敗返回0
    Long lng = redisCacheClient.setnx(jedisGroup, key, "1");
    if (lng == 1) {
      //設(shè)置時間窗口，redis-key時效為10秒
      redisCacheClient.expire(jedisGroup, key, 10);
      return 1L;
    } else {
      //Redis Incrby 命令將 key 中儲存的數(shù)字加上指定的增量值。相當(dāng)于放在redis中的計數(shù)器，每次請求到來計數(shù)器自增1
      long val = redisCacheClient.incrBy(jedisGroup, key, 1);
 
      return val;
    }
  }