Redis 秒杀案例

实现ab工具模拟并发超卖和超时问题解决

配置JedisPool连接池来解决超时问题利用乐观锁淘汰用户，解决超卖问题 库存遗留问题解决

什么是Lua脚本Lua脚本在redis中的优势编写Lua脚本

写一个简单的springboot + thymeleaf页面示例

    
    




    iPhone 13 Pro !!! 1元秒杀


    
    

controller

    @PostMapping("/doseckill")
    @ResponseBody
    public String doseckill(String prodid) throws IOException {
        String userid = new Random().nextInt(50000) + "";
        boolean isSuccess = SecKill_redis.doSecKill(userid, prodid);
        return JSON.toJSONString(isSuccess);
    }

秒杀过程

    // 秒杀过程
    public static boolean doSecKill(String uid,String prodid) throws IOException{
        //1.uid和prodid非空判断
        if (uid == null || prodid == null){
            return false;
        }
        //2.连接redis
        Jedis jedis = new Jedis("192.168.0.2",6379);
        jedis.auth("password");

        //3.拼接Key
        //3.1 库存key
        String kcKey = "sk:"+prodid+":qt";
        //3.2 用户key
        String userKey = "sk:"+prodid+":user";

        //4. 获取库存，如果库存为null，秒杀还没又开始
        String kc = jedis.get(kcKey);
        if (kc == null){
            System.out.println("秒杀还没有开始请等待");
            jedis.close();
            return false;
        }
        //5. 判断用户是否重复秒杀操作
        if(jedis.sismember(userKey,uid)//命令判断成员元素是否是集合的成员
        ){
            System.out.println("已经成功秒杀");
            jedis.close();
            return false;
        }
        //6 判断如果商品数量，库存数量小于1，秒杀结束
        if (Integer.parseInt(kc) < 1){
            System.out.println("秒杀已经结束");
            jedis.close();
            return false;
        }

        //7 秒杀过程
        //7.1 库存-1
        jedis.decr(kcKey);
        //7.2 把秒杀成功的用户添加到清单里面
        jedis.sadd(userKey,uid);
        System.out.println("秒杀成功");
        jedis.close();
        return true;
    }

redis 中添加库存

set sk:0101:qt 10

点击秒杀

查看控制台输出情况

查看redis，可以看到库存已清空，并且用户id添加到秒杀成功的集合中

为了模拟并发的效果，我们使用工具ab模拟测测试

centos7 安装

yum install httpd-tools

ab模拟提交post请求

在linux中创建postfile文件

prodid=0101&

在postfile所在的目录执行命令，1000个请求100个并发

ab -n 1000 -c 100 -p /home/xm/postfile -T application/x-www-form-urlencoded http://192.168.2.2:8080/doseckill

查看控制台和redis中的数据，发现问题

还出现了连接超时的问题

编写工具类

public class JedisPoolUtil {

    private static volatile JedisPool jedisPool = null;

    private JedisPoolUtil() {
    }

    public static JedisPool getJedisPoolInstance(){
        if (null == jedisPool){
            synchronized (JedisPoolUtil.class){
                if (null == jedisPool){
                    JedisPoolConfig poolConfig = new JedisPoolConfig();
                    poolConfig.setMaxTotal(200);
                    poolConfig.setMaxIdle(32);
                    poolConfig.setMaxWaitMillis(100*1000);
                    poolConfig.setBlockWhenExhausted(true);
                    poolConfig.setTestOnBorrow(true);

                    jedisPool = new JedisPool(poolConfig,"192.168.2.2",6379,60000,"password");
                }
            }
        }
        return jedisPool;
    }

    public static void release(JedisPool jedisPool, Jedis jedis){
        if (null != jedis){
            jedisPool.close();
        }
    }
}

修改代码，doSecKill方法中通过连接池获取Jedis对象

// 秒杀过程
    public static boolean doSecKill(String uid,String prodid) throws IOException{
        //1.uid和prodid非空判断
        if (uid == null || prodid == null){
            return false;
        }
        //2.通过连接池得到jedis对象
        Jedis jedis = JedisPoolUtil.getJedisPoolInstance().getResource();

    // 秒杀过程
    public static boolean doSecKill(String uid,String prodid) throws IOException{
        //1.uid和prodid非空判断
        if (uid == null || prodid == null){
            return false;
        }
        //2.通过连接池得到jedis对象
        Jedis jedis = JedisPoolUtil.getJedisPoolInstance().getResource();

        //3.拼接Key
        //3.1 库存key
        String kcKey = "sk:"+prodid+":qt";
        //3.2 用户key
        String userKey = "sk:"+prodid+":user";

        //监视库存
        jedis.watch(kcKey);

        //4. 获取库存，如果库存为null，秒杀还没又开始
        String kc = jedis.get(kcKey);
        if (kc == null){
            System.out.println("秒杀还没有开始请等待");
            jedis.close();
            return false;
        }
        //5. 判断用户是否重复秒杀操作
        if(jedis.sismember(userKey,uid)//命令判断成员元素是否是集合的成员
        ){
            System.out.println("已经成功秒杀");
            jedis.close();
            return false;
        }
        //6 判断如果商品数量，库存数量小于1，秒杀结束
        if (Integer.parseInt(kc) < 1){
            System.out.println("秒杀已经结束");
            jedis.close();
            return false;
        }

        //7 秒杀过程
        // 使用事务
        Transaction multi = jedis.multi();
        //组队操作
        multi.decr(kcKey);
        multi.sadd(userKey,uid);
        //执行
        List