redisson异步解锁
前置
redis trylock锁默认会有看门狗机制,如果不传占有时间,默认会占有30s(应该是),每隔一段时间就会判断业务代码是否执行完,没有就会自动续锁,如果执行完了就会解锁。
如果传入了占有时间,看门狗机制就会失效,固定时间自动解锁或者手动解锁
锁实例
public Boolean pushHospital() {
logger.info("[pushHospital] 推送医院信息");
RLock lock = redissonClient.getLock(ServiceConstants.OLD_PUSH_HOS_ALL_LOCK_KEY);
try {
boolean b = lock.tryLock(0, time, TimeUnit.SECONDS);
if(!b){
throw new HospitalException(HttpStatus.INTERNAL_SERVER_ERROR.value(),"3分钟内请不要重复操作");
}
// 获取当前线程的id
long id = Thread.currentThread().getId();
//异步编排
CompletableFuture.supplyAsync(this::execPushHospital,taskExecutor)
// 正常结束或者异常结束都会执行
.whenComplete((res, e) -> {
logger.info("[pushHospital] 推送医院信息异步完成 res: {}, e:{}",res, e == null ? null : e.getMessage());
//判断是否锁定,以及是否是指定线程的锁
if(lock.isLocked() && lock.isHeldByThread(id)){
// 异步解锁--指定线程id
lock.unlockAsync(id);
}
});
}catch (Exception e){
logger.info("[pushHospital] 推送医院信息: {}", e.getMessage());
throw new HospitalException(HttpStatus.INTERNAL_SERVER_ERROR.value(),e.getMessage());
}
return Boolean.TRUE;
}