Redis分布式锁如何实现续期_Redis_

public class DemoMain { public static void main(String[] args) throws Exception { Config config = new Config(); config.useSingleServer().setAddress("redis://127.0.0.1:6379"); RedissonClient redisson = Redisson.create(config); RLock lock = redisson.getLock("anyLock"); lock.lock(); //lock.unlock(); } } 

public class Config { private long lockWatchdogTimeout = 30 * 1000; public long getLockWatchdogTimeout() { return lockWatchdogTimeout; } //省略无关代码 } 

public void lock() {     while (true) {         boolean flag = this.getLock(key);         if (flag) {               TODO .........         } else {               // 释放当前redis连接               redis.close();               // 休眠1000毫秒              sleep(1000);        }      }  }

SETNX key value

 @Transaction  public void lock() {       while (true) {           boolean flag = this.getLock(key);           if (flag) {               insert();           }       }  }

  @Autowired   DataSourceTransactionManager dataSourceTransactionManager;   @Transaction   public void lock() {       //手动开启事务       TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);       try {           while (true) {              boolean flag = this.getLock(key);              if (flag) {                  insert();                  //手动提交事务                  dataSourceTransactionManager.commit(transactionStatus);              }          }      } catch (Exception e) {          //手动回滚事务          dataSourceTransactionManager.rollback(transactionStatus);      }  }

RLock lock = redissonClient.getLock("stockLock");

@Slf4j @Service public class RedisDistributionLockPlus {    /**     * 加锁超时时间，单位毫秒， 即：加锁时间内执行完操作，如果未完成会有并发现象     */    private static final long DEFAULT_LOCK_TIMEOUT = 30;   private static final long TIME_SECONDS_FIVE = 5 ;   /**    * 每个key的过期时间 {@link LockContent}    */   private Map lockContentMap = new ConcurrentHashMap<>(512);   /**    * redis执行成功的返回    */   private static final Long EXEC_SUCCESS = 1L;   /**    * 获取锁lua脚本， k1：获锁key, k2：续约耗时key, arg1:requestId，arg2：超时时间    */   private static final String LOCK_SCRIPT = "if redis.call('exists', KEYS[2]) == 1 then ARGV[2] = math.floor(redis.call('get', KEYS[2]) + 10) end " +           "if redis.call('exists', KEYS[1]) == 0 then " +              "local t = redis.call('set', KEYS[1], ARGV[1], 'EX', ARGV[2]) " +              "for k, v in pairs(t) do " +                "if v == 'OK' then return tonumber(ARGV[2]) end " +              "end " +           "return 0 end";   /**    * 释放锁lua脚本, k1：获锁key, k2：续约耗时key, arg1:requestId，arg2：业务耗时 arg3: 业务开始设置的timeout    */   private static final String UNLOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then " +           "local ctime = tonumber(ARGV[2]) " +           "local biz_timeout = tonumber(ARGV[3]) " +           "if ctime > 0 then  " +              "if redis.call('exists', KEYS[2]) == 1 then " +                  "local avg_time = redis.call('get', KEYS[2]) " +                  "avg_time = (tonumber(avg_time) * 8 + ctime * 2)/10 " +                  "if avg_time >= biz_timeout - 5 then redis.call('set', KEYS[2], avg_time, 'EX', 24*60*60) " +                  "else redis.call('del', KEYS[2]) end " +              "elseif ctime > biz_timeout -5 then redis.call('set', KEYS[2], ARGV[2], 'EX', 24*60*60) end " +           "end " +           "return redis.call('del', KEYS[1]) " +           "else return 0 end";   /**    * 续约lua脚本    */   private static final String RENEW_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('expire', KEYS[1], ARGV[2]) else return 0 end";   private final StringRedisTemplate redisTemplate;   public RedisDistributionLockPlus(StringRedisTemplate redisTemplate) {       this.redisTemplate = redisTemplate;       ScheduleTask task = new ScheduleTask(this, lockContentMap);       // 启动定时任务       ScheduleExecutor.schedule(task, 1, 1, TimeUnit.SECONDS);   }   /**    * 加锁    * 取到锁加锁，取不到锁一直等待知道获得锁    *    * @param lockKey    * @param requestId 全局唯一    * @param expire   锁过期时间, 单位秒    * @return    */   public boolean lock(String lockKey, String requestId, long expire) {       log.info("开始执行加锁, lockKey ={}, requestId={}", lockKey, requestId);       for (; ; ) {           // 判断是否已经有线程持有锁，减少redis的压力           LockContent lockContentOld = lockContentMap.get(lockKey);           boolean unLocked = null == lockContentOld;           // 如果没有被锁，就获取锁           if (unLocked) {               long startTime = System.currentTimeMillis();               // 计算超时时间               long bizExpire = expire == 0L ? DEFAULT_LOCK_TIMEOUT : expire;               String lockKeyRenew = lockKey + "_renew";               RedisScript script = RedisScript.of(LOCK_SCRIPT, Long.class);               List keys = new ArrayList<>();               keys.add(lockKey);               keys.add(lockKeyRenew);               Long lockExpire
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：使用Redis如何设置永久有效_Redis_
                                                                
下一篇：Linux快速部署Redis_Redis_