目录
Redis setNX分布式锁超时时间失效 -1使用SETNX加锁使用 RedisTemplate 操作Redis解决死锁Redis分布式锁,超时问题的处理分布式可能会出现的超时问题总结Redis>
使用SETNX加锁
加锁的思路:
如果>
使用>
@Autowired
private RedisTemplate redisTemplate;
@RequestMapping("/setNx")
public String setNx() {
String key = "redis_nx_test";
String value = "1";
boolean res = redisTemplate.getConnectionFactory().getConnection().setNX(key.getBytes(), value.getBytes());
log.info("setNX:{}", res);
if (res) {
redisTemplate.getConnectionFactory().getConnection().expire(key.getBytes(), 50);
log.info("设置过期时间");
}
return "success";
}
解决死锁
考虑一种情况,如果进程获得锁后,断开了与>
目前考虑是使用定时任务进行扫描处理超时时间为 -1的key
@Scheduled(initialDelay = 1000,fixedDelay = 1000*60*30)
public void deleteExceptionKey(){
String key = "redis_nx_test";
//返回 -2 表示这个key已过期,已不存在
//返回 -1 表示这个key没有设置有效期
//返回0以上的值 表示是这个key的剩余有效时间
Long l = redisTemplate.opsForValue().getOperations().getExpire(key);
log.info("Expire:{}", l);
if(l == -1){
Boolean b = redisTemplate.delete(key);
log.info("删除key:{},{}", key,b);
}
}
Redis分布式锁,超时问题的处理
分布式锁超时问题解决方案,主要是基于redission。Redisson是架设在Redis基础上的一个Java驻内存数据网格(In-Memory>
redis实现分布式锁,主要是通过SETNX命令,设置一组 key,value。在同一时刻只能有一个线程设置成功,该线程获得了分布式锁。
分布式可能会出现的超时问题
1、误删除别人的锁
A获取锁后,事务执行超时。锁到期自动释放,B线程获取到锁。A完成事务后,释放锁时,把B的锁释放了。
解决方案:
每个线程在获取锁式,在写key-value时,将自己生成的一个独一无二的id写入value。先校验value,再删除锁。这两个操作要保证原子性,可以采用Lua脚本。
(如果没有保证原子性,会出现A校验完value,锁失效。B写入key-value。A删除B写入的锁。)
2、A到期自动释放锁后,B获得锁。出现两个锁并行的情况
A获取锁后,开启一个守护线程,定期为A刷新锁的时间。这样A就是一直保持锁的情况。在redission源码中有相应的程序。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持易采站长站。










