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

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

public Result secKillVoucher(Long voucherId) {
    // 單用戶id(攔截器中做登錄驗證的用戶id)
    Long userId = UserHolder.getUser().getId();
    // 創(chuàng)建鎖對象
    SimpleRedisLock lock = new SimpleRedisLock("order:" + userId, stringRedisTemplate);
    // 獲取鎖
    boolean isLock = lock.tryLock(1200);
    // 判斷是否獲取鎖成功
    if (!isLock) {
        // 獲取鎖失敗，返回錯誤或者重試
        return Result.fail("不允許重復下單！" );
    }
    // 獲取鎖成功，繼續(xù)下單的業(yè)務(wù)邏輯
    try {
        // 查詢優(yōu)惠券
        SeckillVoucher seckillVoucher = seckillVoucherService.getById(voucherId);
        // 獲取時間 判斷秒殺活動是否開始或者結(jié)束
        if (seckillVoucher.getBeginTime().isAfter(LocalDateTime.now())) {
            return Result.fail("活動暫未開始");
        } else if (seckillVoucher.getEndTime().isBefore(LocalDateTime.now())) {
            return Result.fail("活動已經(jīng)結(jié)束");
        }
        // 判斷庫存是否充足
        if (seckillVoucher.getStock() < 1) {
            return Result.fail("庫存不足，活動結(jié)束");
        }
        // user_id和voucher_id聯(lián)合查詢訂單數(shù)
        int count = query().eq("user_id", userId)
                .eq("voucher_id", voucherId)
                .count();
        // 訂單數(shù)為1 就說明已經(jīng)下過單了
        if (count > 0) {
            return Result.fail("您已經(jīng)購買過該商品了");
        }
        // 扣減庫存
        boolean update = seckillVoucherService.update()
                .setSql("stock = stock - 1")
                .eq("voucher_id", voucherId)
                .gt("stock", 0)
                .update();
        if (!update) {
            return Result.fail("庫存不足！");
        }
        // 創(chuàng)建訂單 并返回id
        VoucherOrder order = new VoucherOrder();
        // 訂單id(redis全局唯一id) 下單用戶id(攔截器中做登錄驗證的用戶id) 優(yōu)惠券id(直接傳過來的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) {
    // 獲取當前操作線程的標識
    String threadId = RedisConstants.ID_PREFIX + Thread.currentThread().getId();
    // 獲取鎖
    Boolean res = stringRedisTemplate.opsForValue()
            .setIfAbsent(RedisConstants.KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS);
    // res是Boolean的包裝類，返回結(jié)果的時候涉及到拆箱問題，有可能存在結(jié)果為null的情況，此時就需要返回結(jié)果與true的比較，避免了空指針風險
    return Boolean.TRUE.equals(res);
}

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