1.全局ID生成器下单时IDRedis自增UUIDsnowflake算法数据库自增Redis自增ID策略每天一个key方便统计订单量ID构造是 时间戳计数器满足唯一性高可用高性能递增性安全性在utils工具类中创建RedisIdWorker类Component public class RedisIdWorker { private StringRedisTemplate stringRedisTemplate; public RedisIdWorker(StringRedisTemplate stringRedisTemplate) { this.stringRedisTemplate stringRedisTemplate; } private static final long BEGIN_TIMESTAMP 1640995200L; // 序列号位数 private static final long COUNT_BITS 32; public Long nextId(String keyPrefix) { //1.生成时间戳 LocalDateTime now LocalDateTime.now(); long nowSecond now.toEpochSecond(ZoneOffset.UTC); long timestamp nowSecond - BEGIN_TIMESTAMP; //2.生成序列号 //2.1.获取当前日期 String date now.format(DateTimeFormatter.ofPattern(yyyy:MM:dd)); Long count stringRedisTemplate.opsForValue().increment(icr: keyPrefix : date); //3.拼接返回 return timestampCOUNT_BITS|count; } }2.添加优惠卷表关系tb_voucher:优惠卷的基本信息优惠金额使用规则等tb_seckill_voucher:优惠卷的库存开始抢购时间结束抢购时间。特价优惠卷才需要填写这些信息。路径/voucher/seckill方式POST封装到Voucher中添加3.优惠卷下单路径/voucher-order/seckill/{id}方式POSTResource private ISeckillVoucherService seckillVoucherService; Resource private RedisIdWorker redisIdWorker; /** * 秒杀优惠券下单 * param voucherId * return */ Override Transactional public Result seckillVoucher(Long voucherId) { //1.查询优惠券信息 SeckillVoucher voucher seckillVoucherService.getById(voucherId); //2.判断优惠卷是否开始 if (voucher.getBeginTime().isAfter(LocalDateTime.now())) { return Result.fail(秒杀尚未开始); } //3.判断优惠券是否结束 if (voucher.getEndTime().isBefore(LocalDateTime.now())) { return Result.fail(秒杀已经结束); } //4.判断优惠券是否还有库存 if (voucher.getStock() 0) { return Result.fail(优惠券已售罄); } //5.扣减库存 boolean success seckillVoucherService.update().setSql(stock stock - 1).eq(voucher_id, voucherId).update(); if(!success){ return Result.fail(优惠券已售罄); } //6.创建订单 VoucherOrder voucherOrder new VoucherOrder(); //6.1订单id long orderId redisIdWorker.nextId(order); voucherOrder.setId(orderId); //6.2用户id Long userId UserHolder.getUser().getId(); voucherOrder.setUserId(userId); //6.3优惠卷id voucherOrder.setVoucherId(voucherId); save(voucherOrder); //7.返回订单id return Result.ok(orderId); } }超卖问题当有大量的请求时可能会出现超卖问题乐观锁的常见方式版本号法CAS法基于乐观锁解决超卖问题用库存做判断失败率较高4.一人一单但是仍然可能会出现并发问题我们需要对其加锁。同时还要避免事务失效在集群下也可能出现线程并发安全问题模拟集群环境首先在IDEA中然后在Ngnix中配置所以要让对个JVM使用同一个锁基于Redis的分布式锁分布式锁满足分布式系统或集群模式下多进程可见并且互斥的锁。常见的三种需要实现的两个基本方法1.获取锁互斥确保只能有一个线程获取锁 利用setnx的互斥特性非阻塞尝试一次成功返回true,失败返回false2.释放锁手动释放 DEL key超时释放获取锁时添加一个超时时间避免服务宕机引起的死锁代码实现1.先创建锁的接口2.创建类实现这个接口改进Redis的分布式锁1.在获取锁时存入线程标识可以用UUID表示2.在释放锁时先获取锁中的线程标识判断是否与当前线程标识一致如果一致则释放锁如果不一致则不释放锁Redis的Lua脚本Redis提供了Lua脚本功能在一个脚本中编写多条Redis命令确保多条命令执行时的原子性。Lua是一种编程语言它的基本语法可以参考网站https://www.runoob.com/lua/lua-tutorial.html这里重点介绍Redis提供的调用函数redis.call(命令名称,key,其他参数,……)如果脚本中的key,value不想写死可以作为参数传递。key类型参数会放入KEYS数组其他参数会放入ARGV数组在脚本中可以从数组中获取这些参数在JAVA中调用lua脚本1.编写lua脚本2.在SimpleRedisLock中编写unlock保证了判断和删除的原子性
1.全局ID生成器下单时IDRedis自增UUIDsnowflake算法数据库自增Redis自增ID策略每天一个key方便统计订单量ID构造是 时间戳计数器满足唯一性高可用高性能递增性安全性在utils工具类中创建RedisIdWorker类Component public class RedisIdWorker { private StringRedisTemplate stringRedisTemplate; public RedisIdWorker(StringRedisTemplate stringRedisTemplate) { this.stringRedisTemplate stringRedisTemplate; } private static final long BEGIN_TIMESTAMP 1640995200L; // 序列号位数 private static final long COUNT_BITS 32; public Long nextId(String keyPrefix) { //1.生成时间戳 LocalDateTime now LocalDateTime.now(); long nowSecond now.toEpochSecond(ZoneOffset.UTC); long timestamp nowSecond - BEGIN_TIMESTAMP; //2.生成序列号 //2.1.获取当前日期 String date now.format(DateTimeFormatter.ofPattern(yyyy:MM:dd)); Long count stringRedisTemplate.opsForValue().increment(icr: keyPrefix : date); //3.拼接返回 return timestampCOUNT_BITS|count; } }2.添加优惠卷表关系tb_voucher:优惠卷的基本信息优惠金额使用规则等tb_seckill_voucher:优惠卷的库存开始抢购时间结束抢购时间。特价优惠卷才需要填写这些信息。路径/voucher/seckill方式POST封装到Voucher中添加3.优惠卷下单路径/voucher-order/seckill/{id}方式POSTResource private ISeckillVoucherService seckillVoucherService; Resource private RedisIdWorker redisIdWorker; /** * 秒杀优惠券下单 * param voucherId * return */ Override Transactional public Result seckillVoucher(Long voucherId) { //1.查询优惠券信息 SeckillVoucher voucher seckillVoucherService.getById(voucherId); //2.判断优惠卷是否开始 if (voucher.getBeginTime().isAfter(LocalDateTime.now())) { return Result.fail(秒杀尚未开始); } //3.判断优惠券是否结束 if (voucher.getEndTime().isBefore(LocalDateTime.now())) { return Result.fail(秒杀已经结束); } //4.判断优惠券是否还有库存 if (voucher.getStock() 0) { return Result.fail(优惠券已售罄); } //5.扣减库存 boolean success seckillVoucherService.update().setSql(stock stock - 1).eq(voucher_id, voucherId).update(); if(!success){ return Result.fail(优惠券已售罄); } //6.创建订单 VoucherOrder voucherOrder new VoucherOrder(); //6.1订单id long orderId redisIdWorker.nextId(order); voucherOrder.setId(orderId); //6.2用户id Long userId UserHolder.getUser().getId(); voucherOrder.setUserId(userId); //6.3优惠卷id voucherOrder.setVoucherId(voucherId); save(voucherOrder); //7.返回订单id return Result.ok(orderId); } }超卖问题当有大量的请求时可能会出现超卖问题乐观锁的常见方式版本号法CAS法基于乐观锁解决超卖问题用库存做判断失败率较高4.一人一单但是仍然可能会出现并发问题我们需要对其加锁。同时还要避免事务失效在集群下也可能出现线程并发安全问题模拟集群环境首先在IDEA中然后在Ngnix中配置所以要让对个JVM使用同一个锁基于Redis的分布式锁分布式锁满足分布式系统或集群模式下多进程可见并且互斥的锁。常见的三种需要实现的两个基本方法1.获取锁互斥确保只能有一个线程获取锁 利用setnx的互斥特性非阻塞尝试一次成功返回true,失败返回false2.释放锁手动释放 DEL key超时释放获取锁时添加一个超时时间避免服务宕机引起的死锁代码实现1.先创建锁的接口2.创建类实现这个接口改进Redis的分布式锁1.在获取锁时存入线程标识可以用UUID表示2.在释放锁时先获取锁中的线程标识判断是否与当前线程标识一致如果一致则释放锁如果不一致则不释放锁Redis的Lua脚本Redis提供了Lua脚本功能在一个脚本中编写多条Redis命令确保多条命令执行时的原子性。Lua是一种编程语言它的基本语法可以参考网站https://www.runoob.com/lua/lua-tutorial.html这里重点介绍Redis提供的调用函数redis.call(命令名称,key,其他参数,……)如果脚本中的key,value不想写死可以作为参数传递。key类型参数会放入KEYS数组其他参数会放入ARGV数组在脚本中可以从数组中获取这些参数在JAVA中调用lua脚本1.编写lua脚本2.在SimpleRedisLock中编写unlock保证了判断和删除的原子性
