jedis操作redis来抢购秒杀商品

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>

将jedis注入到spring中,略

@Autowired
JedisPool jedisPool;

下面是源码,在servie层函数中接口执行 :

生产数据

        String goodsKey = "goods:iphone8";
        Jedis jedis = jedisPool.getResource();
        jedis.set(goodsKey, "100"); // 设置100个商品
        jedisPool.returnResource(jedis);

 开始抢购:

        /** 1000线程抢购100个商品 */
        ExecutorService executorService = Executors.newFixedThreadPool(20);
        CountDownLatch count = new CountDownLatch(10000);
        long startTime = System.currentTimeMillis();
        for (int i = 0; i < 10000; i++) {
            int finalI = i;
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    Jedis jedis =null;
                    while (true) {
                        try {
                            jedis = jedisPool.getResource();
                            // watch 监视一个key，当事务执行之前这个key发生了改变，事务会被打断
                            jedis.watch(goodsKey);
                            int currentGoodsCount = Integer.parseInt(jedis.get(goodsKey)); // 当前剩余商品数量
                            if (currentGoodsCount <= 0) {
                                System.out.println("商品已抢完，" + finalI + "---> 抢购失败 XXX");
                                break;
                            }
                            Transaction tran = jedis.multi(); // 开启事务
                            tran.incrBy(goodsKey, -1); // 商品数量-1
                            List<Object> exec = tran.exec(); // 执行事务
                            if (CollectionUtil.isEmpty(exec)) {
                                System.out.println(finalI + "---> 抢购失败，继续抢购");
                                Thread.sleep(1);
                            } else {
                                Jedis finalJedis = jedis;
                                exec.forEach(
                                        succ -> {
                                            String succStr = finalI + "===========================> 抢购到第【"
                                                    + ((100 - currentGoodsCount) + 1)
                                                    + "】份商品，该商品剩余："
                                                    + succ.toString();
                                            System.out.println(succStr);
                                            finalJedis.set("goodsResult:" + finalI, succStr); // 业务代码，处理抢购成功
                                        });
                                break;
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                        } finally {
                            if (jedis != null) {
                                jedis.unwatch();
                                jedisPool.returnResource(jedis);

                            }
                        }

                    }
                }
            });
            count.countDown();
        }
        executorService.shutdown();
        try {
            count.await();
            long time = System.currentTimeMillis() - startTime;
            System.out.println("共耗时：" + time + "毫秒");
            // JedisPoolUtil.close();
            System.in.read();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }