spring boot + Mybatis + redis 秒杀系统

向右看齐 2022-05-18 10:17 109阅读 0赞

最近开了一些高并发的东西，以及一些秒杀系统，但感觉都没有完整的描述。于是自己就动手实现了一个简单版本的抢购系统。

本系统采用spring boot + mybatis + redis实现。

项目结构图如下：

![78026186][]![Center][]

![78026186][]

项目工程已放到GitHub上了，https://github.com/feibabm/seckill，需要的请自行下载。

本文主要借鉴网上一些通用的做法，做出一个例子，主要实现了一个抢购接口:  
http://localhost:8080/seckill/product/1?userId=1  
  
  
seckill.sql文件为建表sql  
pro\_insert.sql文件为success\_killed表中数据添加10000条用户预约记录  
seckill\_insert.sql文件为seckill生成一条产品信息  
  
  
具体验证逻辑是执行test文件夹下的两个test类：  
RemoteInvote.java  
RemoteInvote2.java  
这两个test类没有什么差别，主要是为了增加并发量

主要的抢票逻辑如下：

![Center 1][]

1.  `public SecKillResult secKillProduct(String userPhone, long productId) {`
2.  `String state = (String)redisTemplate.opsForValue().get(userPhone + "_"+ productId);`
3.  `//用户信息加载`
4.  `if(null == state){`
5.  `SuccessKilled successKilled = new SuccessKilled();`
6.  `successKilled.setSeckillId(productId);`
7.  `successKilled.setUserPhone(Long.valueOf(userPhone));`
8.  `successKilled = successKilledMapper.selectOne(successKilled);`
9.  `if(null == successKilled){`
10. `return new SecKillResult(false, "该用户没有预约");`
11. `}else{`
12. `synchronized (this){`
13. `state = (String)redisTemplate.opsForValue().get(userPhone + "_"+ productId);`
14. `if(null == state){`
15. `redisTemplate.opsForValue().set(userPhone + "_" + productId, successKilled.getState().toString(), 300, TimeUnit.SECONDS);`
16. `state = String.valueOf(successKilled.getState());`
17. `}`
18. `}`
19. 
20. `}`
21. `}`
22. `if(state.equals("-1")){`
23. `//查询产品信息`
24. `// ProductInfo productInfo = (ProductInfo)redisTemplate.opsForValue().get(productId + "");`
25. `List values = redisTemplate.opsForHash().values(productId + "");`
26. `if(values.size() == 0){`
27. `Seckill seckill = seckillMapper.selectByPrimaryKey(productId);`
28. `if(null == seckill){`
29. `return new SecKillResult(false, "没有该秒杀商品信息");`
30. `}`
31. `synchronized (this){`
32. `if(!redisTemplate.opsForHash().hasKey(productId + "", "number")){`
33. `// productInfo = new ProductInfo(seckill.getSeckillId(), seckill.getNumber(), seckill.getStartTime(), seckill.getEndTime());`
34. `HashMap<String, String> productHash = new HashMap<>();`
35. `productHash.put("number", seckill.getNumber() + "");`
36. `productHash.put("startTime", seckill.getStartTime().getTime() + "");`
37. `productHash.put("endTime", seckill.getEndTime().getTime() + "");`
38. `redisTemplate.opsForHash().putAll(productId +"", productHash);`
39. `redisTemplate.expire(productId + "", 300, TimeUnit.SECONDS);`
40. `values = redisTemplate.opsForHash().values(productId + "");`
41. `}`
42. `}`
43. `}`
44. `if( new Date(Long.valueOf((String)values.get(1))).after(new Date(System.currentTimeMillis()))){`
45. `return new SecKillResult(false, "抢购还没有开始");`
46. `} else if(new Date(Long.valueOf((String)values.get(2))).before(new Date(System.currentTimeMillis()))){`
47. `return new SecKillResult(false, "抢购已经结束");`
48. `} else {`
49. `Long userState = redisTemplate.opsForValue().increment(userPhone + "_" + productId, 1);`
50. `if(userState == 0){`
51. `// Long increment = redisTemplate.opsForValue().increment(productId, -1);`
52. `Long number = redisTemplate.opsForHash().increment(productId + "", "number", -1);`
53. `if(number >= 0){`
54. `//消息队列异步更新库存，以及用户的预约信息`
55. `QueueEntity queueEntity = new QueueEntity(userPhone, productId);`
56. `ExecutorPool.queue.offer(queueEntity);`
57. `}else {`
58. `return new SecKillResult(false, "商品已经抢购完成");`
59. `}`
60. `}else {`
61. `redisTemplate.opsForValue().increment(userPhone + "_" + productId, -1);`
62. `return new SecKillResult(false, "您已抢购过该产品");`
63. `}`
64. `}`
65. `} else {`
66. `return new SecKillResult(false, "您已抢购过该产品");`
67. `}`
68. `return null;`
69. `}`

自己用两进程线程，大概两分钟掉了20000次，暂时没有出现啥问题。如果有什么问题，希望大家指出，谢谢。

[78026186]: /images/20220518/85a1e22dcf584506be14a879644b78f6.png
[Center]: /images/20220518/c9f0b21195024c238905ce8ebd43b163.png
[Center 1]: /images/20220518/a0ac89ae7d5847a797d7deb3419a9a36.png