淘东电商项目（75） -秒杀系统（用户操作频率限制）-CFANZ编程社区

引言

本文代码已提交至Github（版本号：a08c2b261d8cd31850ccebc38a4a6620090e619f），有兴趣的同学可以下载来看看：https://github.com/ylw-github/taodong-shop

在上一篇博客《淘东电商项目（74） -秒杀系统（库存超卖解决方案）主要讲解了库存超卖的解决，继续完善上一篇博客的代码，以下的第二个步骤：

@Transactional
public BaseResponse<JSONObject> spike(String phone, Long seckillId) {
  // 1.参数验证
  if (StringUtils.isEmpty(phone)) {
    return setResultError("手机号码不能为空!");
  }
  if (seckillId == null) {
    return setResultError("商品库存id不能为空!");
  }
  SeckillEntity seckillEntity = seckillMapper.findBySeckillId(seckillId);
  if (seckillEntity == null) {
    return setResultError("商品信息不存在!");
  }
  // 2.用户频率限制 setnx 如果key存在话

  // 3.（悲观锁 ）修改数据库对应的库存 1万中只有100个抢购成功 提前生成好100个token 谁能够抢购成功token放入到mq中实现异步修改库存
  int inventoryDeduction = seckillMapper.pessimisticDeduction(seckillId);
  if (!toDaoResult(inventoryDeduction)) {
    log.info(">>>修改库存失败>>>>inventoryDeduction返回为{} 秒杀失败！", inventoryDeduction);
    return setResultError("亲，请稍后重试!");
  }

  // 4.添加秒杀成功订单 基于MQ实现异步形式
  OrderEntity orderEntity = new OrderEntity();
  orderEntity.setUserPhone(phone);
  orderEntity.setSeckillId(seckillId);
  int insertOrder = orderMapper.insertOrder(orderEntity);
  if (!toDaoResult(insertOrder)) {
    return setResultError("亲，请稍后重试!");
  }
  log.info(">>>修改库存成功>>>>inventoryDeduction返回为{} 秒杀成功", inventoryDeduction);
  return setResultSuccess("恭喜您，秒杀成功!");
}

本文目录结构：

l____引言

l____ 1.用户操作频率限制代码实现

l____ 2. 测试

1.用户操作频率限制代码实现

用户的操作频率限制很简单，可以使用Redis的操作机制限制，Redis超时设置通用方法如下:

/**
 * description: 如果key存在的话返回fasle 不存在的话返回true
 * create by: YangLinWei
 * create time: 2020/5/25 5:45 下午
 */
public Boolean setNx(String key, String value, Long timeout) {
  Boolean setIfAbsent = stringRedisTemplate.opsForValue().setIfAbsent(key, value);
  if (timeout != null) {
    stringRedisTemplate.expire(key, timeout, TimeUnit.SECONDS);
  }
  return setIfAbsent;
}

完善第二步骤：

@Transactional
public BaseResponse<JSONObject> spike(String phone, Long seckillId) {
  // 1.参数验证
  if (StringUtils.isEmpty(phone)) {
    return setResultError("手机号码不能为空!");
  }
  if (seckillId == null) {
    return setResultError("商品库存id不能为空!");
  }
  SeckillEntity seckillEntity = seckillMapper.findBySeckillId(seckillId);
  if (seckillEntity == null) {
    return setResultError("商品信息不存在!");
  }
  // 2.用户频率限制 setnx 如果key存在话

  Boolean reusltNx = redisUtil.setNx(phone, seckillId + "", 10l);
  if (!reusltNx) {
    return setResultError("访问次数过多，10秒后在实现重试!");
  }
  // 3.（悲观锁 ）修改数据库对应的库存 1万中只有100个抢购成功 提前生成好100个token 谁能够抢购成功token放入到mq中实现异步修改库存
  int inventoryDeduction = seckillMapper.pessimisticDeduction(seckillId);
  if (!toDaoResult(inventoryDeduction)) {
    log.info(">>>修改库存失败>>>>inventoryDeduction返回为{} 秒杀失败！", inventoryDeduction);
    return setResultError("亲，请稍后重试!");
  }

  // 4.添加秒杀成功订单 基于MQ实现异步形式
  OrderEntity orderEntity = new OrderEntity();
  orderEntity.setUserPhone(phone);
  orderEntity.setSeckillId(seckillId);
  int insertOrder = orderMapper.insertOrder(orderEntity);
  if (!toDaoResult(insertOrder)) {
    return setResultError("亲，请稍后重试!");
  }
  log.info(">>>修改库存成功>>>>inventoryDeduction返回为{} 秒杀成功", inventoryDeduction);
  return setResultSuccess("恭喜您，秒杀成功!");
}