public interface ILock {
    /**
     * 嘗試獲取鎖
     * @param timeoutSec 鎖的超時(shí)時(shí)間
     * @return 是否成功獲取鎖
     */
    boolean tryLock(long timeoutSec);
    /**
     * 釋放鎖
     */
    void unLock();
}

public class SimpleRedisLock implements ILock {
    private String name;
    /**
     *先獲取StringRedisTemplate對(duì)象，才能使用代碼操作Redis
     */
    private StringRedisTemplate stringRedisTemplate;
    public SimpleRedisLock(String name, StringRedisTemplate stringRedisTemplate) {
        this.name = name;
        this.stringRedisTemplate = stringRedisTemplate;
    }
    @Override
    public boolean tryLock(long timeoutSec) {
        // 獲取當(dāng)前操作線程的標(biāo)識(shí)
        long threadId = Thread.currentThread().getId();
        // 獲取鎖
        Boolean res = stringRedisTemplate.opsForValue()
                .setIfAbsent(RedisConstants.KEY_PREFIX + name, threadId + "", timeoutSec, TimeUnit.SECONDS);
        // res是Boolean的包裝類，返回結(jié)果的時(shí)候涉及到拆箱問(wèn)題，有可能存在結(jié)果為null的情況，此時(shí)就需要返回結(jié)果與true的比較，避免了空指針風(fēng)險(xiǎn)
        return Boolean.TRUE.equals(res);
    }
    @Override
    public void unLock() {
        // 釋放鎖
        stringRedisTemplate.delete(RedisConstants.KEY_PREFIX + name);
    }
}

public Result secKillVoucher(Long voucherId) {
    // 單用戶id(攔截器中做登錄驗(yàn)證的用戶id)
    Long userId = UserHolder.getUser().getId();
    // 創(chuàng)建鎖對(duì)象
    SimpleRedisLock lock = new SimpleRedisLock("order:" + userId, stringRedisTemplate);
    // 獲取鎖
    boolean isLock = lock.tryLock(1200);
    // 判斷是否獲取鎖成功
    if (!isLock) {
        // 獲取鎖失敗，返回錯(cuò)誤或者重試
        return Result.fail("不允許重復(fù)下單！" );
    }
    // 獲取鎖成功，繼續(xù)下單的業(yè)務(wù)邏輯
    try {
        // 查詢優(yōu)惠券
        SeckillVoucher seckillVoucher = seckillVoucherService.getById(voucherId);
        // 獲取時(shí)間 判斷秒殺活動(dòng)是否開(kāi)始或者結(jié)束
        if (seckillVoucher.getBeginTime().isAfter(LocalDateTime.now())) {
            return Result.fail("活動(dòng)暫未開(kāi)始");
        } else if (seckillVoucher.getEndTime().isBefore(LocalDateTime.now())) {
            return Result.fail("活動(dòng)已經(jīng)結(jié)束");
        }
        // 判斷庫(kù)存是否充足
        if (seckillVoucher.getStock() < 1) {
            return Result.fail("庫(kù)存不足，活動(dòng)結(jié)束");
        }
        // user_id和voucher_id聯(lián)合查詢訂單數(shù)
        int count = query().eq("user_id", userId)
                .eq("voucher_id", voucherId)
                .count();
        // 訂單數(shù)為1 就說(shuō)明已經(jīng)下過(guò)單了
        if (count > 0) {
            return Result.fail("您已經(jīng)購(gòu)買過(guò)該商品了");
        }
        // 扣減庫(kù)存
        boolean update = seckillVoucherService.update()
                .setSql("stock = stock - 1")
                .eq("voucher_id", voucherId)
                .gt("stock", 0)
                .update();
        if (!update) {
            return Result.fail("庫(kù)存不足！");
        }
        // 創(chuàng)建訂單 并返回id
        VoucherOrder order = new VoucherOrder();
        // 訂單id(redis全局唯一id) 下單用戶id(攔截器中做登錄驗(yàn)證的用戶id) 優(yōu)惠券id(直接傳過(guò)來(lái)的id)
        long orderId = generator.nextId("order");
        order.setId(orderId);
        order.setUserId(userId);
        order.setVoucherId(voucherId);
        save(order);
        return Result.ok(orderId);
    } finally {
        // 釋放鎖
        lock.unLock();
    }
}

public static final String ID_PREFIX = UUID.randomUUID(true) + "-";
public boolean tryLock(long timeoutSec) {
    // 獲取當(dāng)前操作線程的標(biāo)識(shí)
    String threadId = RedisConstants.ID_PREFIX + Thread.currentThread().getId();
    // 獲取鎖
    Boolean res = stringRedisTemplate.opsForValue()
            .setIfAbsent(RedisConstants.KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS);
    // res是Boolean的包裝類，返回結(jié)果的時(shí)候涉及到拆箱問(wèn)題，有可能存在結(jié)果為null的情況，此時(shí)就需要返回結(jié)果與true的比較，避免了空指針風(fēng)險(xiǎn)
    return Boolean.TRUE.equals(res);
}

public void unLock() {
    // 獲取當(dāng)前操作線程的標(biāo)識(shí)
    String threadId = RedisConstants.ID_PREFIX + Thread.currentThread().getId();
    // 通過(guò)鎖名 獲取redis中存儲(chǔ)的鎖對(duì)應(yīng)的標(biāo)識(shí)
    String rid = stringRedisTemplate.opsForValue().get(RedisConstants.KEY_PREFIX + name);
    if (threadId.equals(rid)) {
        // 釋放鎖
        stringRedisTemplate.delete(RedisConstants.KEY_PREFIX + name);
    }
}