Redis分布式锁过期时间续约问题

Redis实现分布式锁的自动续命问题

首先了解lua脚本，原子性。

lua脚本在Redis中是原子性的，就是在执行lua脚本的时候，不会被其他外部命令干扰，但是不能回滚，结果错就是错了，结果没有回滚一说。

HashedWheelTimer时间轮异步定时执行

HashedWheelTimer的demo使用演示

package com.lxx;import io.netty.util.HashedWheelTimer;
import io.netty.util.Timeout;import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;public class shiyan {//HashedWheelTimer异步执行static SimpleDateFormat formatter = new SimpleDateFormat("dd-MM-yyyy HH:mm:ss");public static void main(String[] args) {Date date = new Date(System.currentTimeMillis());System.out.println(formatter.format(date));testTimeout();System.out.println("结束吧");//现在又想取消掉这个任务
//        if(!newTimeout.isExpired()){
//            newTimeout.cancel();
//        }}public static void testTimeout() {HashedWheelTimer timer = new HashedWheelTimer();
//        timer.newTimeout(new TimerTask() {
//            @Override
//            public void run(Timeout timeout) throws Exception {
//                Date datee = new Date(System.currentTimeMillis());
//                System.out.println("10s后执行" + formatter.format(datee));
//            }
//        }, 10, TimeUnit.SECONDS);Timeout newTimeout = timer.newTimeout(timerTask -> {Date datee = new Date(System.currentTimeMillis());System.out.println("10s后执行" + formatter.format(datee));testTimeout();//回调自己，在进行10s执行一次。}, 10, TimeUnit.SECONDS);//10s后执行Lambda表达式/*现在又想取消掉这个任务if (!newTimeout.isExpired()) {newTimeout.cancel();}*/}
}

执行结果:

Redis通过异步定时使用lua脚本重置分布式锁的过期时间

使用StringRedisTemplate，因为使用的序列化问题。不建议使用RedisTemplate，如果使用，要改序列化。可自行搜索。

package com.lxx;import io.netty.util.HashedWheelTimer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.Arrays;
import java.util.concurrent.TimeUnit;@RestController
@RequestMapping("shiyan")
public class RedisSuo {@Autowiredprivate StringRedisTemplate redisTemplate;//lua脚本如果有当前key那么就去重置当前key的过期时间返回1，否则返回0。private static String luas = "if (redis.call('exists',KEYS[1]) == 1) then redis.call('expire',KEYS[1], ARGV[1]) return 1 end return 0";private static DefaultRedisScript luaaa = new DefaultRedisScript(luas, Boolean.class);//讲lua脚本封装到类中private HashedWheelTimer timer = new HashedWheelTimer();private String key = "suo";@RequestMapping("select")public Boolean selectById(String valueid, int time) {//redis底层执行的是SET K V NX EX 60Boolean status = redisTemplate.opsForValue().setIfAbsent(key, valueid, time, TimeUnit.SECONDS);//加锁以及超时时间if (status) {try {//核心是异步多长时间后执行就可以。watchdog(time);//执行业务代码Thread.sleep(15 * 1000);} catch (Exception e) {throw new RuntimeException(e.getMessage());} finally {//释放锁资源。底层就是DEL kredisTemplate.delete(key);}return true;} else {System.out.println("服务器正忙请稍后再试..........");return false;}}public void watchdog(int time) {timer.newTimeout(timerTask -> {Boolean execute = (Boolean) redisTemplate.execute(luaaa, Arrays.asList(key), String.valueOf(time));//意思就是执行luaaa,key给KEYS[1]，time给ARGV[1]if (execute) {System.out.println("如果当前的key有，并且已经续期了，那么现在需要递归判断下一次是否还有key。");watchdog(time);} else {System.out.println("没有key了。锁已经没了，就不会进行续期了");}}, time / 3, TimeUnit.SECONDS);//time的三分之一时间去执行看有没有key，有重置过期时间,没有就什么都不做。}
}

请求，时间为30s。代码里面是15s，会进行续命。

执行结果。进行了一次续命。

走到了23

重置续命后30

附上Redisson官网

最后用Redisson的API来实现分布式锁的应用。
结束！感谢观看！