/**
 * 购票非高并发的情况 到 高并发的情况
 *
 * @param uid      用户id - 在后台生成
 * @param ticketNo 票的编号, 比如北京-成都的ticketNo 就是bj_cd
 */
public static boolean doSecKill(String uid, String ticketNo) {

    // uid 和 ticketNo进行非空校验

    //- 通过连接池获取到jedis对象/连接（优化获取连接的时间）
    JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();
    Jedis jedis = jedisPoolInstance.getResource();
    System.out.println("---使用的连接池技术----");

    //- 拼接票的库存key
    String stockKey = "sk:" + ticketNo + ":ticket";
    //- 拼接秒杀用户要存放到的set集合对应的key 这个set集合可以存放多个userId
    String userKey = "sk:" + ticketNo + ":user";

    /**
     * (1) 检查对应的票是否存在
     * (2) 检查用户是否重复购票
     * (3) 检查火车票是否还有剩余
     */

    /* 不使用Transaction事务进行处理的时候 两步操作单独分步执行*/
    jedis.decr(stockKey); // 1. 将票的库存量-1
    jedis.sadd(userKey, uid); // 2. 将该用户加入到抢购成功对应的set集合中

    System.out.println(uid + " 秒杀成功..");
    jedis.close();
    return true;
}

ab -n 1000 -c 100 -p ~/postfile -T application/x-www-form-urlencoded
http://192.168.198.1:8080/seckill/secKillServlet

(1) ~/postfile文件下存储请求要携带的参数
(2) -T application/x-www-form-urlencoded 表示以表单的方式提交
(3) -n 1000 -c 100 共1000个请求每次发送100个10次发完

/**
 * 购票非高并发的情况 到 高并发的情况
 *
 * @param uid      用户id - 在后台生成
 * @param ticketNo 票的编号, 比如北京-成都的ticketNo 就是bj_cd
 */
public static boolean doSecKill(String uid, String ticketNo) {

    // uid 和 ticketNo进行非空校验

    //- 通过连接池获取到jedis对象/连接（优化获取连接的时间）
    JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();
    Jedis jedis = jedisPoolInstance.getResource();
    System.out.println("---使用的连接池技术----");

    //- 拼接票的库存key
    String stockKey = "sk:" + ticketNo + ":ticket";
    //- 拼接秒杀用户要存放到的set集合对应的key 这个set集合可以存放多个userId
    String userKey = "sk:" + ticketNo + ":user";

    // 监控库存 注意这一步不能少 事务执行过程中如果库存变更 则事务会执行失败
    jedis.watch(stockKey);
    
    /**
     * (1) 检查对应的票是否存在
     * (2) 检查用户是否重复购票
     * (3) 检查火车票是否还有剩余
     */
    
    //使用事务,完成秒杀
    Transaction multi = jedis.multi();

    //组队操作
    multi.decr(stockKey);//减去票的库存
    multi.sadd(userKey, uid);//将该用户加入到抢购成功对应的set集合中

    //执行
    List<Object> results = multi.exec();

    if(results == null || results.size() == 0) {
        System.out.println("抢票失败...");
        jedis.close();
        return false;
    }

    System.out.println(uid + " 秒杀成功..");
    jedis.close();
    return true;
}

ab -n 1000 -c 300 -p ~/postfile -T application/x-www-form-urlencoded
http://192.168.98.1:8080/seckill/secKillServlet

(1) 库存设大一些 为600
(2) 并发量大一些 为300

/**
 * 处理秒杀请求的Servlet
 */
public class SecKillServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        //1. 请求时,模拟生成一个userId
        String userId = new Random().nextInt(10000) + "";
        //2. 获取用户要购买的票的编号
        String ticketNo = request.getParameter("ticketNo");
        //3. 调用秒杀的方法
        //boolean isOk = SecKillRedis.doSecKill(userId, ticketNo);
        //3. 调用lua脚本完成秒杀方法
        boolean isOk = SecKillRedisByLua.doSecKill(userId, ticketNo);
        //4. 将结果返回给前端-这个地方可以根据业务需要调整
        response.getWriter().print(isOk);
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
}

/**
 * 使用Lua脚本完成秒杀
 */
public class SecKillRedisByLua {
    /**
     * 1. 这个脚本字符串是在lua脚本上修改的, 但是不完全是字符串处理
     * 2. 比如 : 这里就使用了 \" , 还有换行使用了 \r\n
     * 3. 如果直接把lua脚本粘贴过来是不可行的
     */
    static String secKillScript = "local userid=KEYS[1];\r\n" +
            "local ticketno=KEYS[2];\r\n" +
            "local stockKey='sk:'..ticketno..\":ticket\";\r\n" +
            "local usersKey='sk:'..ticketno..\":user\";\r\n" +
            "local userExists=redis.call(\"sismember\",usersKey,userid);\r\n" +
            "if tonumber(userExists)==1 then \r\n" +
            "   return 2;\r\n" +
            "end\r\n" +
            "local num= redis.call(\"get\" ,stockKey);\r\n" +
            "if tonumber(num)<=0 then \r\n" +
            "   return 0;\r\n" +
            "else \r\n" +
            "   redis.call(\"decr\",stockKey);\r\n" +
            "   redis.call(\"sadd\",usersKey,userid);\r\n" +
            "end\r\n" +
            "return 1";

    //使用lua脚本完成秒杀的核心方法
    public static boolean doSecKill(String uid,String ticketNo) {
        //先从redis连接池，获取连接
        JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();
        Jedis jedis = jedisPoolInstance.getResource();
        //就是将lua脚本进行加载
        String sha1 = jedis.scriptLoad(secKillScript);
        /*
         (1) Object result：这是方法的返回类型。这意味着jedis.evalsha方法执行后，返回的结果将被存储在名为result的变量中。
             具体返回什么起决于lua脚本的返回值
         (2) jedis.evalsha：这是Jedis库中的一个方法，用于执行Redis的EVALSHA命令。EVALSHA命令用于执行存储在Redis中的Lua脚本。
         (3) sha1：这是evalsha方法的第一个参数，它是一个字符串，表示要执行的Lua脚本的SHA-1校验和。SHA-1是一种散列算法，用于将数据（在这种情况下是Lua脚本）转换为固定长度的唯一标识符。通过这个SHA-1值，Redis可以在其脚本缓存中快速查找并执行相应的脚本。
         (4) 2：这是evalsha方法的第二个参数，表示传递给Lua脚本的参数的数量。在这个例子中，脚本将接收两个参数。
         (5) uid 和 ticketNo：这两个参数是具体的值，它们将被传递给Lua脚本作为输入。uid代表用户ID，而ticketNo代表票号
             这两个参数会在lua脚本中用到 -> local userid=KEYS[1]; local ticketno=KEYS[2]; lua脚本会使用KEYS关键字把变量值取出来使用
         */
        Object result = jedis.evalsha(sha1, 2, uid, ticketNo);
        String resString = String.valueOf(result);

        //根据lua脚本执行返回的结果，做相应的处理
        if("0".equals(resString)) {
            System.out.println("票已经卖光了..");
            jedis.close();
            return false;
        }
        if("2".equals(resString)) {
            System.out.println("不能重复购买..");
            jedis.close();
            return false;
        }
        if("1".equals(resString)) {
            System.out.println("抢购成功");
            jedis.close();
            return true;
        } else {
            System.out.println("购票失败..");
            jedis.close();
            return false;
        }
    }
}

@RequestMapping("/seckill/{path}/addOneAndReturnInfo")
@ResponseBody
public Msg addOneAndReturnInfo(@RequestParam("userId") String userId,
                               @RequestParam("commId") Integer commId,
                               @RequestParam(value = "originPrice", required = false) Double originPrice,
                               @RequestParam(value = "seckillPrice",required = false) BigDecimal seckillPrice,
                               @RequestParam(value = "pic",required = false) String pic,
                               @PathVariable(value = "path",required = false) String path,
                               Model model) {
    System.out.println("C SeckillController M addOneAndReturnInfo()..");

    Msg msg = new Msg();

    log.info("判断秒杀路径是否正确");
    /****** 0 判断秒杀路径是否正确 ******/
    String redisPath = (String) redisTemplate.opsForValue().get("seckillPath:" + userId + ":" + commId);
    if (!StringUtils.hasText(path) || !redisPath.equals(path)) {
        msg.setCode(408);
        msg.setMsg("秒杀路径出错 请稍后重试~");
        //return "secKillFail";
        return msg;
    }

    //log.info("查询库存是否够用（内存优化）emptyStockMap");
    /****** 1.1 先查询库存是否够用（内存优化） ******/
    Boolean ifEmpty = emptyStockMap.get(commId);
    if(ifEmpty != null && ifEmpty) {
        msg.setCode(401);
        msg.setMsg("该商品已售罄~");
        return msg;
    }

    /**
     *  2 再查询用户是否重复购买
     *
     *  这个判断方法可以进一步改进 例如在所有的秒杀商品中增加一个字段
     *  用于标识不同活动 在判断用户是否复购时增加这个字段的判断
     *
     *  直接从redis中取用户的购买记录信息而不是MySQL数据库 优化查询效率
     */
    log.info("查询用户是否重复购买");
    Integer purchaseRecord = (Integer)redisTemplate.opsForValue().get("purchased" + ":" + commId + ":" + userId);
    if(purchaseRecord != null){
        msg.setCode(403);
        msg.setMsg("您已经购买过此商品 不能重复购买~");
        return msg;
    }

    // 获取分布式锁
    log.info("获取分布式锁");
    String uuid = UUID.randomUUID().toString();
    /**
     * 尝试设置一个键值对，其中键为"lock"，值为uuid，并且设置了过期时间为3秒
     *
     * 如果执行失败 redisTemplate.opsForValue().setIfAbsent()方法会返回一个false
     * 这个false布尔值表示操作未能成功执行 即键"lock"未能被成功设置
     */
    Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", uuid, 3, TimeUnit.SECONDS);
    // 如果锁未成功设置 则轮询继续获取这个锁 循环获取分布式锁
    while(lock == null){
        lock = redisTemplate.opsForValue().setIfAbsent("lock", uuid, 3, TimeUnit.SECONDS);
    }
    // 只有一个线程能执行if语句中的代码
    if(lock) {
        // 释放锁准备 为了防止误删除其它用户的锁 先判断当前的锁是不是前面获取到的锁 如果相同 再释放
        String script = "if redis.call('get', KEYS[1]) == ARGV[1] " +
            "then return redis.call('del', KEYS[1]) " +
            "else return 0 " +
            "end";
        DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
        redisScript.setScriptText(script);
        redisScript.setResultType(Long.class);

        // 从redis获取商品的库存并判断 然后预减库存
        Integer stock = (Integer)redisTemplate.opsForValue().get("seckillGoods:" + commId);

        if(stock == 0) {
            emptyStockMap.put(commId, true); // 此用户购买完成后存储就为空了
            msg.setCode(401);
            msg.setMsg("该商品已售罄~");
            return msg;
        } else {
            // 库存预减
            log.info("库存预减");
            redisTemplate.opsForValue().set("seckillGoods:" + commId, stock - 1);
        }
        /**
         * 释放分布式锁
         *
         * redisScript: 执行的lua脚本
         *
         */
        redisTemplate.execute(redisScript, Arrays.asList("lock"), uuid);

        /**
         * 释放锁之后 用 RabbitMQ 消息队列来处理最终的购买业务
         * 代码执行到这里 说明用户抢到了一个储存 只要后面的消息队列数据库操作成功 就购买成功
         */
        //Gson gson = new Gson();
        log.info("将秒杀操作交给消息队列");
        SeckillMessage seckillMessage = new SeckillMessage(userId, commId);
        mqSenderMessage.senderMessage(JSONUtil.toJsonStr(seckillMessage)); // 发出去之后 由Receiver进行处理
        msg.setCode(200);
        msg.setMsg("秒杀排队中，请稍后~");
    } else {
        msg.setCode(409);
        msg.setMsg("获取分布式锁失败，秒杀失败，请稍后重试~");
    }
    return msg;
}

sentinel monitor redis_master 127.0.0.1 6379 1

-redis_master 为监控对象起的服务器名称
-1 表示至少有多少个哨兵同意迁移的数量, 这里配置1 表示只要有1个哨兵同意迁移就可以切换

sentinel monitor <master-name> <ip> <port> <quorum>

sentinel down-after-milliseconds <master-name> <timeout>

sentinel failover-timeout <master-name> <timeout>

sentinel parallel-syncs <master-name> <count>

redis-sentinel /path/to/sentinel.conf

redis-cli -h <sentinel-ip> -p <sentinel-port> sentinel <command>

redis-sentinel /path/to/sentinel.conf reload