public Boolean killItem(Integer killId, Integer userId) throws Exception {
    Boolean result=false;

    //TODO:判斷當(dāng)前用戶是否已經(jīng)搶購(gòu)過(guò)當(dāng)前商品
    if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){
      //TODO:查詢待秒殺商品詳情
      ItemKill itemKill=itemKillMapper.selectById(killId);

      //TODO:判斷是否可以被秒殺canKill=1?
      if (itemKill!=null && 1==itemKill.getCanKill() ){
        //TODO:扣減庫(kù)存-減一
        int res=itemKillMapper.updateKillItem(killId);

        //TODO:扣減是否成功?是-生成秒殺成功的訂單，同時(shí)通知用戶秒殺成功的消息
        if (res>0){
          commonRecordKillSuccessInfo(itemKill,userId);

          result=true;
        }
      }
    }else{
      throw new Exception("您已經(jīng)搶購(gòu)過(guò)該商品了!");
    }
    return result;
  }

@Autowired
  private StringRedisTemplate stringRedisTemplate;
  /**
   * 商品秒殺核心業(yè)務(wù)邏輯的處理-redis的分布式鎖
   * @param killId
   * @param userId
   * @return
   * @throws Exception
   */
  @Override
  public Boolean killItemV3(Integer killId, Integer userId) throws Exception {
    Boolean result=false;

    if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){

      //TODO:借助Redis的原子操作實(shí)現(xiàn)分布式鎖-對(duì)共享操作-資源進(jìn)行控制
      ValueOperations valueOperations=stringRedisTemplate.opsForValue();
      final String key=new StringBuffer().append(killId).append(userId).append("-RedisLock").toString();
      final String value=RandomUtil.generateOrderCode();
      Boolean cacheRes=valueOperations.setIfAbsent(key,value); //luna腳本提供“分布式鎖服務(wù)”，就可以寫(xiě)在一起
      //TOOD:redis部署節(jié)點(diǎn)宕機(jī)了
      if (cacheRes){
        stringRedisTemplate.expire(key,30, TimeUnit.SECONDS);

        try {
          ItemKill itemKill=itemKillMapper.selectByIdV2(killId);
          if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){
            int res=itemKillMapper.updateKillItemV2(killId);
            if (res>0){
              commonRecordKillSuccessInfo(itemKill,userId);

              result=true;
            }
          }
        }catch (Exception e){
          throw new Exception("還沒(méi)到搶購(gòu)日期、已過(guò)了搶購(gòu)時(shí)間或已被搶購(gòu)?fù)戤叄?);
        }finally {
          if (value.equals(valueOperations.get(key).toString())){
            stringRedisTemplate.delete(key);
          }
        }
      }
    }else{
      throw new Exception("Redis-您已經(jīng)搶購(gòu)過(guò)該商品了!");
    }
    return result;
  }

@Autowired
  private RedissonClient redissonClient;

  /**
   * 商品秒殺核心業(yè)務(wù)邏輯的處理-redisson的分布式鎖
   * @param killId
   * @param userId
   * @return
   * @throws Exception
   */
  @Override
  public Boolean killItemV4(Integer killId, Integer userId) throws Exception {
    Boolean result=false;

    final String lockKey=new StringBuffer().append(killId).append(userId).append("-RedissonLock").toString();
    RLock lock=redissonClient.getLock(lockKey);

    try {
      Boolean cacheRes=lock.tryLock(30,10,TimeUnit.SECONDS);
      if (cacheRes){
        //TODO:核心業(yè)務(wù)邏輯的處理
        if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){
          ItemKill itemKill=itemKillMapper.selectByIdV2(killId);
          if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){
            int res=itemKillMapper.updateKillItemV2(killId);
            if (res>0){
              commonRecordKillSuccessInfo(itemKill,userId);

              result=true;
            }
          }
        }else{
          throw new Exception("redisson-您已經(jīng)搶購(gòu)過(guò)該商品了!");
        }
      }
    }finally {
      lock.unlock();
      //lock.forceUnlock();
    }
    return result;
  }

@Autowired
  private CuratorFramework curatorFramework;

  private static final String pathPrefix="/kill/zkLock/";

  /**
   * 商品秒殺核心業(yè)務(wù)邏輯的處理-基于ZooKeeper的分布式鎖
   * @param killId
   * @param userId
   * @return
   * @throws Exception
   */
  @Override
  public Boolean killItemV5(Integer killId, Integer userId) throws Exception {
    Boolean result=false;

    InterProcessMutex mutex=new InterProcessMutex(curatorFramework,pathPrefix+killId+userId+"-lock");
    try {
      if (mutex.acquire(10L,TimeUnit.SECONDS)){

        //TODO:核心業(yè)務(wù)邏輯
        if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){
          ItemKill itemKill=itemKillMapper.selectByIdV2(killId);
          if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){
            int res=itemKillMapper.updateKillItemV2(killId);
            if (res>0){
              commonRecordKillSuccessInfo(itemKill,userId);
              result=true;
            }
          }
        }else{
          throw new Exception("zookeeper-您已經(jīng)搶購(gòu)過(guò)該商品了!");
        }
      }
    }catch (Exception e){
      throw new Exception("還沒(méi)到搶購(gòu)日期、已過(guò)了搶購(gòu)時(shí)間或已被搶購(gòu)?fù)戤叄?);
    }finally {
      if (mutex!=null){
        mutex.release();
      }
    }
    return result;
  }