L1296686146 冗谪 2023-07-20 08:18 发表于陕西
收录于合集#redis7个
数据表
-- 优惠券的表 优惠券的基本信息，优惠金额、使用规则等
CREATE TABLE `tb_voucher` (
`id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
`shop_id` bigint unsigned DEFAULT NULL COMMENT '商铺id',
`title` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '代金券标题',
`sub_title` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '副标题',
`rules` varchar(1024) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '使用规则',
`pay_value` bigint unsigned NOT NULL COMMENT '支付金额，单位是分。例如200代表2元',
`actual_value` bigint NOT NULL COMMENT '抵扣金额，单位是分。例如200代表2元',
`type` tinyint unsigned NOT NULL DEFAULT '0' COMMENT '0,普通券；1,秒杀券',
`status` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '1,上架; 2,下架; 3,过期',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=COMPACT;
-- 优惠券中的秒杀券表 优惠券的库存，开始抢购时间，结束抢购时间等。
CREATE TABLE `tb_seckill_voucher` (
`voucher_id` bigint unsigned NOT NULL COMMENT '关联的优惠券的id',
`stock` int NOT NULL COMMENT '库存',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`begin_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '生效时间',
`end_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '失效时间',
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`voucher_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=COMPACT COMMENT='秒杀优惠券表，与优惠券是一对一关系';
-- 优惠券的订单表
CREATE TABLE `tb_voucher_order` (
`id` bigint NOT NULL COMMENT '主键',
`user_id` bigint unsigned NOT NULL COMMENT '下单的用户id',
`voucher_id` bigint unsigned NOT NULL COMMENT '购买的代金券id',
`pay_type` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '支付方式 1：余额支付；2：支付宝；3：微信',
`status` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '订单状态，1：未支付；2：已支付；3：已核销；4：已取消；5：退款中；6：已退款',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '下单时间',
`pay_time` timestamp NULL DEFAULT NULL COMMENT '支付时间',
`use_time` timestamp NULL DEFAULT NULL COMMENT '核销时间',
`refund_time` timestamp NULL DEFAULT NULL COMMENT '退款时间',
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=COMPACT;
平价卷由于优惠力度并不是很大，所以是可以任意领取的，而特价卷由于优惠力度大，所有特价卷除了具有优惠券的基本信息外，还具有库存、抢购时间、结束时间等信息
在每年的618或者双十一等大型活动中，基本上每个店铺都会发布大量优惠券，当用户抢购时，就会生成相应的订单并保存，这期间会生成大量订单，这时，如果使用数据库自增ID就会存在一些问题：
id的规律性太明显：如果id具有很强规律性，用户等一些人很容易猜测出我们的一些敏感信息，例如商场一天内卖出多少单等，这样不合适
受单表数据量限制：随着订单的增加，mysql单表容量不宜超过500W，数据量过大时，需要进行拆库拆表，拆表之后，订单表在逻辑上讲，还是一张表，所有他们的id不能一样，而我们需要保证id的唯一性。
全局唯一ID生成策略
每天一个key，方便统计订单量
ID构造器：时间戳 + 计数器
UUID
snowflake算法
数据库自增
Redis自增
全局ID生成器
为了生成全局唯一ID，我们采用全局ID生成器，它是一种在分布式系统下用来生成全局唯一ID的工具。
全局ID生成器的特性：
唯一性
高可用
高性能
安全性
递增性
为了增加ID的安全性，一般不直接使用Redis自增的数值，而是拼接一些其他信息。例如：
image-20230707101019758
符号位：永远为0
时间戳：31bit，以秒为单位
序列号：32bit，秒内的计数器，支持每秒生成2的32次方个不同ID
@Component
public class RedisIdWorker {
@Resource
StringRedisTemplate stringRedisTemplate;
/**
* 序列号的位数
*/
private static final int COUNT_BITS = 32;
/**
* 生成全局唯一ID
* @param keyPrefix
* @return
*/
public long nextId(String keyPrefix) {
// 生成时间戳
LocalDateTime now = LocalDateTime.now();
long timestamp = now.toEpochSecond(ZoneOffset.UTC);
// 生成序列号
//获取当前日期
String date = now.format(DateTimeFormatter.ofPattern("yyyy:MM:dd"));
//生成自增长的值，其key为 "icr:" + keyPrefix + ":" + date 拼接
Long count = stringRedisTemplate.opsForValue().increment("icr:" + keyPrefix + ":" + date);
// 拼接唯一ID
return timestamp << COUNT_BITS | count;
}
}
下单时需要判断两点：
秒杀是否开始或结束，如果尚未开始或已经结束则无法下单
库存是否充足，不足则无法下单
秒杀下单
@Override
public Long seckillVoucher(Long voucherId) {
// 查询秒杀优惠券信息
SeckillVoucher seckillVoucher = seckillVoucherService.getById(voucherId);
//判断秒杀是否开始和结束
LocalDateTime beginTime = seckillVoucher.getBeginTime();
LocalDateTime endTime = seckillVoucher.getEndTime();
//如果当前时间 在开始时间之后 再结束时间之前 则表明秒杀能进行
LocalDateTime localDateTime = LocalDateTime.now();
if ( localDateTime.isBefore(beginTime) || localDateTime.isAfter(endTime) ){
return null;
}
//获取库存量
Integer stock = seckillVoucher.getStock();
if (ObjectUtil.isNull(stock) || ObjectUtil.isNotNull(stock) && stock.intValue() <= 0){
return null;
}
//扣减库存 存在线程安全问题
boolean success = seckillVoucherService.update(
new LambdaUpdateWrapper<SeckillVoucher>().setSql("stock= stock -1").eq(SeckillVoucher::getVoucherId, voucherId));
if (!update){
return null;
}
//创建订单
VoucherOrder voucherOrder = new VoucherOrder();
//创建订单ID
long orderId = redisIdWorker.nextId("order");
voucherOrder.setId(orderId);
//获取用户ID
Long id = UserHolder.getUser().getId();
voucherOrder.setUserId(id);
// 代金券id
voucherOrder.setVoucherId(voucherId);
this.save(voucherOrder);
return orderId;
}