高并发秒杀系统springboot+mysql+mybatisSecKill.zip

高并发秒杀接口的设计：https://github.com/lizhixiong1994 参考：https://www.cnblogs.com/twoheads/p/8360830.html （写的很详细，并且拥有漂亮的个人博客） version-1.0：springboot+mysql+mybatis sql建表 ``` CREATE TABLE `seckill`( `seckill_id` bigint NOT NULL AUTO_INCREMENT COMMENT '商品ID', `title` varchar (1000) DEFAULT NULL COMMENT '商品标题', `image` varchar (1000) DEFAULT NULL COMMENT '商品图片', `price` decimal (10,2) DEFAULT NULL COMMENT '商品原价格', `cost_price` decimal (10,2) DEFAULT NULL COMMENT '商品秒杀价格', `stock_count` bigint DEFAULT NULL COMMENT '剩余库存数量', `start_time` timestamp NOT NULL DEFAULT '1970-02-01 00:00:01' COMMENT '秒杀开始时间', `end_time` timestamp NOT NULL DEFAULT '1970-02-01 00:00:01' COMMENT '秒杀结束时间', `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `status` int(1) NOT NULL DEFAULT 1 COMMENT '状态1：在用 0：废弃', PRIMARY KEY (`seckill_id`), KEY `idx_start_time` (`start_time`), KEY `idx_end_time` (`end_time`), KEY `idx_create_time` (`end_time`), KEY `idx_status` (`status`) ) CHARSET=utf8 ENGINE=InnoDB COMMENT '秒杀商品表'; CREATE TABLE `seckill_order`( `seckill_id` bigint NOT NULL COMMENT '秒杀商品ID', `money` decimal (10, 2) DEFAULT NULL COMMENT '支付金额', `user_phone` bigint NOT NULL COMMENT '用户手机号', `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间', `state` tinyint NOT NULL DEFAULT -1 COMMENT '状态：-1无效 0成功 1已付款', PRIMARY KEY (`seckill_id`, `user_phone`) /*联合主键，保证一个用户只能秒杀一件商品*/ ) CHARSET=utf8 ENGINE=InnoDB COMMENT '秒杀订单表'; ``` Bean ``` import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; import lombok.ToString; import org.springframework.format.annotation.DateTimeFormat; import java.io.Serializable; import java.math.BigDecimal; import java.util.Date; /** * 秒杀商品的单条记录 */ @Data @ToString public class Seckill implements Serializable { public static final int STATUS_NEW = 1; public static final int STATUS_DEAD = 0; private long seckillId; //商品ID private String title; //商品标题 private String image; //商品图片 private BigDecimal price; //商品原价格 private BigDecimal costPrice; //商品秒杀价格 private int status = STATUS_NEW; //状态 @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date createTime; //创建时间 @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date startTime; //秒杀开始时间 @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date endTime; //秒杀结束时间 private long stockCount; //剩余库存数量 } ``` ``` import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; import lombok.ToString; import org.springframework.format.annotation.DateTimeFormat; import java.io.Serializable; import java.math.BigDecimal; import java.util.Date; /** * 秒杀商品的订单 */ @Data @ToString public class SeckillOrder implements Serializable { private long seckillId; //秒杀到的商品ID private BigDecimal money; //支付金额 private long userPhone; //秒杀用户的手机号 public SeckillOrder(long seckillId, long userPhone) { this.seckillId = seckillId; this.userPhone = userPhone; } /** * @DateTimeFormat()(来自springframework)和@JsonFormat() * (来自jackson)标识可以实现Controller在返回JSON数据（用@ResponseBody标识的方法或@RestController标识的类）的时候能将Date类型的参数值（经Mybatis查询得到的数据是英文格式的日期，因为实体类中是Date类型） * 转换为注解中指定的格式返回给页面（相当于经过了一层SimpleDateFormate）。 */ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") private Date createTime; //创建时间 private boolean status; //订单状态， -1:无效 0:成功 1:已付款 private Seckill seckill; //秒杀商品，和订单是一对多的关系 } ``` ### 流程如下： 1、查询所有秒杀商品信息（select * from seckill where status = 1） ``` @GetMapping(name = "/getSecKillInfo") public Object getSecKillInfo() { //获取秒杀的信息，这里只是一个简单的事例 return seckillService.findSeckillAll(); } ``` 2：前端根据拼接的地址，开始调用秒杀接口秒杀"/{seckillGoodsId}/execution" ``` @RequestMapping(value = "/{seckillGoodsId}/{md5}/execution") public Boolean execution(@PathVariable("seckillGoodsId") Long seckillGoodsId, @PathVariable("md5") String md5) { //获取用户信息 long userPhone = 123456;//这个是编造的，一般都是通过认证服务获取当前用户的userPhone //开始执行秒杀 try { return seckillService.executionSeckillId(seckillGoodsId, userPhone); } catch (Exception e) { log.warn(e.getMessage()); return false; } } ``` 3：秒杀 3.1：获取秒杀商品的信息 判断是否超时，是否已经开始，是否用户重复秒杀 -从redis-mysql（利用redis做一级缓存，先访问redis，如果redis缓存中没有所需资源或者访问访问超时，则直接进入mysql获取系统资源，将获取的内容更新在redis当中） 3.2：Mysql执行update，执行秒杀。成功修改数据则返回true，表示秒杀成功 ``` @Override @Transactional//关于事务回滚，默认对runtimgexception 以及其他限定的几个异常进行回滚。 public Boolean executionSeckillId(Long seckillGoodsId, long userPhone) { //1：获取秒杀商品的记录。 Seckill seckill = getSeckillBySeckillId(seckillGoodsId); if (seckill == null) {//没有找到抢购记录 return false; } //2：查看是否已经过期 if (seckill.getEndTime().getTime() < System.currentTimeMillis()) { throw new RuntimeException("秒杀时间已经结束"); } //3:开始保存订单,如果下过订单，则不能继续秒杀。seckillGoodsId 以及 userPhone是联合主键。保证一个人对于一个抢购只能有一次下订单的记录 if (seckillMapper.insertOrder(seckillGoodsId, seckill.getCostPrice(), userPhone) == 0) { throw new RuntimeException("订单重复");//重复订单 } //4:开始执行秒杀策略，将抢购的商品库存减1 if (seckillMapper.reduceStock(seckillGoodsId, new Date()) > 0) { return true; } else { //秒杀失败,交给事务处理回滚 throw new RuntimeException("秒杀失败"); } } ``` 涉及到的sql如下：这里因为篇幅有限，暂时只贴出核心部分，如果想要看全部的话，请去github上查看源码 ``` <!--减少库存数量--> <update id="reduceStock"> UPDATE seckill SET stock_count = stock_count - 1 WHERE seckill_id = #{seckillId} <![CDATA[ AND start_time < #{killTime} AND end_time >= #{killTime} ]]> AND stock_count > 0 AND status = 1 </update> <!--插入订单--> <insert id="insertOrder"> INSERT ignore INTO seckill_order(seckill_id, money, user_phone) VALUES (#{seckillId}, #{money}, #{userPhone}) </insert> <!--查询秒杀--> <select id="findBySeckillId" resultMap="seckillResult