@Autowired
private StockMapper stockMapper;
/**
* redisTemplate
*/
//StringRedisTemplate 和 RedisTemplate 序列化器不同
@Autowired
private StringRedisTemplate redisTemplate;
//redis的乐观锁保证了线程安全,但是效率比较慢,而且还会因为机器的性能问题,导致连接不够用,所以不推荐使用redis的的乐观锁
public void deduct() {
//防止锁被误删
String uuid = UUID.randomUUID().toString();
//加锁setnx
Boolean lockFirst = this.redisTemplate.opsForValue().setIfAbsent("lock", uuid,3, TimeUnit.SECONDS);
// 重试、循环
while(!lockFirst){
try {
Thread.sleep(50);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
try {
// 1.查询库存信息
String stock = redisTemplate.opsForValue().get("stock").toString();
//2.判断库存是否充足
if (stock != null && stock.length() != 0) {
Integer st = Integer.valueOf(stock);
if (st > 0) {
//扣减库存
redisTemplate.opsForValue().set("stock", String.valueOf(--st));
}
}
} finally {
//解锁
//判断是自己的锁,然后再进行解锁
if(StringUtils.equals(this.redisTemplate.opsForValue().get("lock"),uuid )){
this.redisTemplate.delete("lock");
}
}
}