Redis 分布式鎖使用不當(dāng)，釀成一個(gè)重大事故，超賣了100瓶飛天茅臺(tái)?。?！

public SeckillActivityRequestVO seckillHandle(SeckillActivityRequestVO request) {SeckillActivityRequestVO response;    String key = "key:" + request.getSeckillId;    try {        Boolean lockFlag = redisTemplate.opsForValue().setIfAbsent(key, "val", 10, TimeUnit.SECONDS);        if (lockFlag) {            // HTTP請(qǐng)求用戶服務(wù)進(jìn)行用戶相關(guān)的校驗(yàn)            // 用戶活動(dòng)校驗(yàn)
            // 庫(kù)存校驗(yàn)            Object stock = redisTemplate.opsForHash().get(key+":info", "stock");            assert stock != null;            if (Integer.parseInt(stock.toString()) <= 0) {                // 業(yè)務(wù)異常            } else {                redisTemplate.opsForHash().increment(key+":info", "stock", -1);                // 生成訂單                // 發(fā)布訂單創(chuàng)建成功事件                // 構(gòu)建響應(yīng)VO            }        }    } finally {        // 釋放鎖        stringRedisTemplate.delete("key");        // 構(gòu)建響應(yīng)VO    }    return response;}

public void safedUnLock(String key, String val) {    String luaScript = "local in = ARGV[1] local curr=redis.call('get', KEYS[1]) if in==curr then redis.call('del', KEYS[1]) end return 'OK'"";    RedisScript<String> redisScript = RedisScript.of(luaScript);    redisTemplate.execute(redisScript, Collections.singletonList(key), Collections.singleton(val));}

// redis會(huì)返回操作之后的結(jié)果，這個(gè)過程是原子性的Long currStock = redisTemplate.opsForHash().increment("key", "stock", -1);

public SeckillActivityRequestVO seckillHandle(SeckillActivityRequestVO request) {SeckillActivityRequestVO response;    String key = "key:" + request.getSeckillId();    String val = UUID.randomUUID().toString();    try {        Boolean lockFlag = distributedLocker.lock(key, val, 10, TimeUnit.SECONDS);        if (!lockFlag) {            // 業(yè)務(wù)異常        }

        // 用戶活動(dòng)校驗(yàn)        // 庫(kù)存校驗(yàn)，基于redis本身的原子性來保證        Long currStock = stringRedisTemplate.opsForHash().increment(key + ":info", "stock", -1);        if (currStock < 0) { // 說明庫(kù)存已經(jīng)扣減完了。            // 業(yè)務(wù)異常。            log.error("[搶購(gòu)下單] 無庫(kù)存");        } else {            // 生成訂單            // 發(fā)布訂單創(chuàng)建成功事件            // 構(gòu)建響應(yīng)        }    } finally {        distributedLocker.safedUnLock(key, val);        // 構(gòu)建響應(yīng)    }    return response;}

// 通過消息提前初始化好，借助ConcurrentHashMap實(shí)現(xiàn)高效線程安全private static ConcurrentHashMap<Long, Boolean> SECKILL_FLAG_MAP = new ConcurrentHashMap<>();// 通過消息提前設(shè)置好。由于AtomicInteger本身具備原子性，因此這里可以直接使用HashMapprivate static Map<Long, AtomicInteger> SECKILL_STOCK_MAP = new HashMap<>();

...

public SeckillActivityRequestVO seckillHandle(SeckillActivityRequestVO request) {SeckillActivityRequestVO response;
    Long seckillId = request.getSeckillId();    if(!SECKILL_FLAG_MAP.get(requestseckillId)) {        // 業(yè)務(wù)異常    }     // 用戶活動(dòng)校驗(yàn)     // 庫(kù)存校驗(yàn)    if(SECKILL_STOCK_MAP.get(seckillId).decrementAndGet() < 0) {        SECKILL_FLAG_MAP.put(seckillId, false);        // 業(yè)務(wù)異常    }    // 生成訂單    // 發(fā)布訂單創(chuàng)建成功事件    // 構(gòu)建響應(yīng)    return response;}