一、应用场景
分布式锁是一种控制分布式系统中并发访问共享资源的方法。在分布式系统中,由于多个进程或线程同时访问共享资源,可能会导致数据的不一致性或者并发问题。分布式锁的作用就是确保在同一时间内只有一个进程或线程可以访问共享资源。
二、代码实现与讲解
通过Redis分布式锁的方案来实现秒杀,这里主要使用了Redis的两个命令SETNX(key,value)和GETSET(key,value),setnx的含义是只有key不存在的情况下,将键key的值设置为value,如果key已经存在,则setnx命令不做任何操作。Getset的含义是先获取key的值,然后再重新设置key的值。
假设此时有线程A和线程B同时访问临界区代码,假设线程A首先执行了SETNX命令,并返回结果1,继续向下执行。而此时线程B再次执行SETNX命令时,返回的结果为0,则线程B不能继续向下执行。只有当线程A执行DELETE命令将设置的锁状态删除时,线程B才会成功执行SETNX命令设置加锁状态后继续向下执行。
但是会产生死锁问题,假设线程A在业务处理过程中发生异常导致线程A没有执行锁的释放,那么接下来的所有线程都会被阻塞,所以这里通过加时间戳的形式来解决死锁问题。Key设置为商品Id,value值为当前时间+过期时间。首先获取currentValue,通过与当前时间进行比较判断是否过期,如果过期了,通过getSet获取oldValue并重新设置value值,如果获取的oldValue与currentValue相同,那么成功获取锁,如果不同,说明锁已经被其它线程获取了,那么返回失败。
/*** 加锁* setnx + getset* @param key* @param value 当前时间+超时时间 150* @return*/publicstaticbooleanlock(Stringkey, Stringvalue) { if (stringRedisTemplate.opsForValue().setIfAbsent(key, value)) { returntrue; } StringcurrentValue=stringRedisTemplate.opsForValue().get(key); /*如果锁过期在业务处理过程中可能由于某种未知异常,导致死锁产生,下面是让死锁解锁的代码*/if (StringUtils.hasLength(currentValue) &&Long.parseLong(currentValue) <System.currentTimeMillis()) { // 获取上一个锁的时间StringoldValue=stringRedisTemplate.opsForValue().getAndSet(key, value); if (StringUtils.hasLength(oldValue) &&oldValue.equals(currentValue)) { returntrue; } } returnfalse; } /*** 解锁** @param key* @param value*/publicstaticvoidunlock(Stringkey, Stringvalue) { try { StringcurrentValue=stringRedisTemplate.opsForValue().get(key); if (StringUtils.hasLength(currentValue) &¤tValue.equals(value)) { stringRedisTemplate.opsForValue().getOperations().delete(key); } } catch (Exceptione) { log.error("【redis分布式锁】解锁异常, {}", e); } }