Redis+Lua实现简易的秒杀抢购

1  商品抢购
主要逻辑是：减库存，记录抢购成功的用户

1. @RestController
2. public class DemoController {
4.     @Resource
5.     private StringRedisTemplate stringRedisTemplate;
7.     private static final String GOODS_STOCK_KEY = "goods:001";  //  秒杀商品库存
8.     private static final String GOODS_USER_KEY = "users:001";   //  抢购成功的用户列表
10.     /**
11.      * 在不加锁的情况下，会发生超卖
12.      */
13.     @GetMapping("/seckill")
14.     public String seckill() {
15.         int userId = (int) (Math.random() * 1000);
17.         ValueOperations<string, string=""> valueOps = stringRedisTemplate.opsForValue();
18.         ListOperations<string, string=""> listOps = stringRedisTemplate.opsForList();
20.         int stock = Integer.parseInt(valueOps.get(GOODS_STOCK_KEY));
22.         if (stock > 0) {
23.             valueOps.decrement(GOODS_STOCK_KEY);
24.             listOps.leftPush(GOODS_USER_KEY, String.valueOf(userId));
25.             return "抢购成功";
26.         } else {
27.             return "商品已售罄";
28.         }
29.     }
31.     /**
32.      * 将多个命令打包成一个原子操作，利用redis单线程执行命令的特性，在不加锁的情况下避免了资源竞争
33.      */
34.     @GetMapping("/seckill_lua")
35.     public String seckill_lua() {
36.         int userId = (int) (Math.random() * 1000);
38.         String script = "if tonumber(redis.call('get', KEYS[1])) > 0 then " +
39.                 "redis.call('decr', KEYS[1]); " +
40.                 "redis.call('lpush', KEYS[2], ARGV[1]); " +
41.                 "return 1; " +
42.                 "else " +
43.                 "return 0; " +
44.                 "end; ";
46.         DefaultRedisScript<long> redisScript = new DefaultRedisScript();
47.         redisScript.setResultType(Long.class);
48.         redisScript.setScriptText(script);
50.         List<string> keyList = Arrays.asList(GOODS_STOCK_KEY, GOODS_USER_KEY);
52.         Long result = stringRedisTemplate.execute(redisScript, keyList, String.valueOf(userId));
54.         if (result == 1) {
55.             return "抢购成功";
56.         } else {
57.             return "商品已售罄";
58.         }
59.     }
60. }</string></long></string,></string,>

复制代码

2  多线程处理Excel导入

1. /**
2. * 多线程处理Excel导入
3. *
4. * PS:
5. *  Executors返回的线程池对象的弊端如下：
6. *  (1) FixedThreadPool和SingleThreadPool： 允许的请求队列长度为Integer.MAX_VALUE，可能会堆积大量的请求，从而导致OOM。
7. *  (2) CachedThreadPool： 允许的创建线程数量为Integer.MAX_VALUE，可能会创建大量的线程，从而导致OOM。
8. */
9. @PostMapping
10. public void excelImport() throws InterruptedException {
11.     //  待处理的数据（比如：从Excel中读取的数据）
12.     List dataList = new ArrayList();
14.     //  多线程处理
15.     ExecutorService executorService = Executors.newFixedThreadPool(5);
16.     CountDownLatch countDownLatch = new CountDownLatch(dataList.size());
17.     for (Object obj : dataList) {
18.         executorService.submit(new Runnable() {
19.             @Override
20.             public void run() {
21.                 try {
23.                 } catch (Exception ex) {
25.                 } finally {
26.                    countDownLatch.countDown();
27.                 }
28.             }
29.         });
30.     }
32.     countDownLatch.await(30, TimeUnit.SECONDS);
34.     //  后续执行
36.     //  返回结果
37. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！