标签：return String redis value 并发 call key

public static void main(String[] args) {
       String value = UUID.randomUUID() + ":" + Thread.currentThread().getName();
       long tryTime = 100000L;
       long expireTime = 100000L;
       String key = "lock";
       JedisPool jedisPool = new JedisPool();
       Jedis jedis = jedisPool.getResource();
       for (int i = 0; i < 10; i++) {
           System.out.println(getlock(jedis, key, value, tryTime, expireTime));
       }
       for (int i = 0; i < 10; i++) {
           System.out.println(releaseLock(jedis, key, value, tryTime));
       }
   }

/**
 *
 * @param jedis
 * @param key key
 * @param value 重如锁value
 * @param tryTime 重试时间
 * @return result
 */
   private static Object releaseLock(Jedis jedis, String key, String value, long tryTime) {
       String script = "if (redis.call('exists', KEYS[1]) == 0) then " +
               "return 0;" +
               "end;" +
               "if(redis.call('hexists', KEYS[1], ARGV[1]) == 1) then " +
               "local lo = redis.call('hincrby',KEYS[1],ARGV[1], -1)" +
               "if(lo < 1) then " +
               "redis.call('del', KEYS[1]);" +
               "return lo;" +
               "end;" +
               "return lo;" +
               "end;" +
               "return -1;";
   final long endTime = tryTime + System.currentTimeMillis();
   while (true) {
      Object res =  jedis.eval(script, Collections.singletonList(key), Collections.singletonList(value));
      if (Integer.parseInt(String.valueOf(res)) >= 0) {
         return true;
      }
      if (System.currentTimeMillis() - endTime > 0) {
         return false;
      }
      try {
         TimeUnit.SECONDS.sleep(1);
      } catch (InterruptedException e) {
         System.out.println("sleep error");
      }
   }
   }

/**
 *
 * @param jedis
 * @param key key
 * @param value 重如锁value
 * @param tryTime 重试时间
 * @param expireTime key过期时间
 * @return result
 */
   private static boolean getlock(Jedis jedis, String key, String value, long tryTime, long expireTime) {
       final long endTime = tryTime + System.currentTimeMillis();
       String script = "if (redis.call('exists', KEYS[1]) == 0) then " +
               "redis.call('hset', KEYS[1], ARGV[1], 1);" +
               "redis.call('pexpire', KEYS[1], ARGV[2]);" +
               "return 1;" +
               "end;" +
               "if(redis.call('hexists', KEYS[1], ARGV[1]) == 1) then " +
               "redis.call('pexpire', KEYS[1], ARGV[2]);" +
               "return redis.call('hincrby',KEYS[1],ARGV[1],1);" +
               "end;" +
               "return 0;";
       while (true) {
      Object res = jedis.eval(script, Collections.singletonList(key), Arrays.asList(value, expireTime+""));
      if (Integer.parseInt(String.valueOf(res)) > 0) {
         return true;
      }
      if (System.currentTimeMillis() - endTime > 0) {
         return false;
      }
      try {
         TimeUnit.SECONDS.sleep(1);
      } catch (InterruptedException e) {
         System.out.println("sleep error");
      }
   }
   }

标签：return,String,redis,value,并发,call,key
来源： https://www.cnblogs.com/wushenghfut/p/14883383.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。