Redis商品秒杀

@Component
public class RedisIdGenerator {
    /**
     * 构造方法注入stringRedisTemplate对象
     */
    private StringRedisTemplate stringRedisTemplate;
    public RedisIdGenerator(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }
    // 定义序列号的位数
    private static final int COUNT_BITS = 30;
    public long nextId(String keyPrefix) {
        // 生成从指定时间到现在的时间戳
        LocalDateTime beginTime = LocalDateTime.of(2022, 1, 1, 0, 0, 0);
        long beginTimeStamp = beginTime.toEpochSecond(ZoneOffset.UTC);
        long endTimeStamp = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
        long timeStamp = endTimeStamp - beginTimeStamp;
        /**
         * 生成序列号 使用redis的incr方法 K值为"icr:" + keyPrefix + ":" + date
         * 也就是按照日期作为K 每下一次单V就自增1作为序列号添加到后面
         * 这样的话既避免了K固定带来的V超过最大阈值(redis中的V最大为2^64)
         * 而且还方便了统计一天、一个月、一年的订单量，在这段时间内最大的序列号就是它的最多订单数
         */
        String date = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy:MM:dd"));
        Long sequenceId = stringRedisTemplate.opsForValue().increment("icr:" + keyPrefix + ":" + date);
        // 拼接生成全局唯一ID并返回 两个二进制的拼接可以使用前一个数左移一定位数 后一个数与位移后的进行或运算
        return timeStamp << COUNT_BITS | sequenceId;
    }
}

@Resource
private ISeckillVoucherService seckillVoucherService;
@Resource
private RedisIdGenerator generator;
@Override
@Transactional
public Result secKillVoucher(Long voucherId) {
    // 查询优惠券
    SeckillVoucher seckillVoucher = seckillVoucherService.getById(voucherId);
    // 获取时间 判断秒杀活动是否开始或者结束
    if (seckillVoucher.getBeginTime().isAfter(LocalDateTime.now())) {
        return Result.fail("活动暂未开始");
    } else if (seckillVoucher.getEndTime().isBefore(LocalDateTime.now())) {
        return Result.fail("活动已经结束");
    }
    // 判断库存是否充足
    if (seckillVoucher.getStock() < 1) {
        return Result.fail("库存不足，活动结束");
    }
    // 扣减库存
    seckillVoucherService.update()
            .setSql("stock = stock - 1")
            .eq("voucher_id", voucherId).update();
    // 创建订单 并返回id
    VoucherOrder order = new VoucherOrder();
    // 订单id(redis全局唯一id) 下单用户id(拦截器中做登录验证的用户id) 优惠券id(直接传过来的id)
    long orderId = generator.nextId("order");
    order.setId(orderId);
    order.setUserId(UserHolder.getUser().getId());
    order.setVoucherId(voucherId);
    save(order);
    return Result.ok(orderId);
}

// 扣减库存
boolean update = seckillVoucherService.update()
        .setSql("stock = stock - 1")
        .eq("voucher_id", voucherId)
        .gt("stock", 0)
        .update();
// 更新失败说明在扣除库存的时候 库存小于等于0
if (!update) {
    return Result.fail("库存不足！");
}

// 单用户id(拦截器中做登录验证的用户id)
Long userId = UserHolder.getUser().getId();
// 根据user_id加锁  intern方法是去字符常量池中查找值相同的，不加的话字符串值一样的地址不一样也会加上锁
synchronized (userId.toString().intern()) {
	// 查询优惠券
	// 判断库存是否充足
    // user_id和voucher_id联合查询订单数
    Integer count = query().eq("user_id", userId)
            .eq("voucher_id", voucherId)
            .count();
    // 订单数为1 就说明已经下过单了
    if (count.equals(1)) {
        return Result.fail("您已经购买过该商品了");
    }
    // 扣减库存  创建订单
    return Result.ok(orderId);
}