java 实现秒杀基本步骤

青旅半醒 2024-04-18 23:13 0阅读 0赞

> # 秒杀主要解决的问题 #

*  ### 防止商品超卖问题 ###
 *  ### 限制用户操作频率 ###
 *  ### 防止用户作弊行为 ###
 *  ### 服务器单台机器承受不了 ###

### 升级版会使用MQ异步实现秒杀、这两天不忙的时候再修改一下 ###

> ### 1、防止超卖 ###
> 
> 条件：inventory > 0   库存大于0的 才可以修改库存
> 
> 这个大于零  200人抢购100个库存、100个成功、这个不好、如果出现网络延迟情况 不可能百分比都会秒杀完
> 
>     @Update("update meite_seckill set inventory=inventory - 1 where seckill_id =#{seckillId} and inventory > 0;")
> 
> 第二种
> 
> 使用乐观锁 version版本号  
>  200人抢购100个库存、可能60个成功、他解决的就是网络延迟情况其他原因  
> 原理 两个人最后一起抢购同时拿到version版本号 也没关系、谁先进来谁就修改版本号、那个人在拿到老的版本号就无法修改   已经被第一个人修改过了、
> 
>     @Update("update meite_seckill set inventory=inventory - 1 ,version = version + 1 where seckill_id =#{seckillId} and inventory > 0  and version=#{version}")
> 
> ### 2、限制用户操作频率 ###
> 
> 使用 Redis 的setNX可以解决一个用户连续不停的访问、setnx他是如何限制的呐、它比set要好、set的key、如果存在、在set就会覆盖原来的值、分布式锁中使用的、
> 
> 而setNX是用户秒杀进来的时候 给用户手机号添加到redis中加入五秒过期时间、用户在连续枪的话 因为时间没有过期所以就秒杀不了、返回操作次数过于频繁、五秒后在操作信息、实现了一种限制、
> 
> 以下是封装的setNx的工具类
> 
>     public Boolean setNX(String key, String value, Long time) {
>         Boolean aBoolean = stringRedisTemplate.opsForValue().setIfAbsent(key, value);
>         if (time != null) {
>             stringRedisTemplate.expire(key, time, TimeUnit.SECONDS);
>         }
>         return aBoolean;
>     }

一下有两个接口需要自己写 我就不贴出来了 SQL在上面】可自行修改

<table> 
 <tbody> 
  <tr> 
   <td> <pre><code>@Autowired
private SeckillMapper seckillMapper;

@Autowired
private OrderMapper orderMapper;

@Autowired
private RedisUtil redisUtil;

@Autowired
private StringRedisTemplate stringRedisTemplate;

@Override
public BaseResponse&lt;JSONObject&gt; spike(String phone, Long seckillId) {

if (StringUtils.isEmpty(phone)) {
        return setResultError("手机号码不能为空！");
    }

if (seckillId == null) {
        return setResultError("商品库存id不能为空！");
    }

//查询到version
    SeckillEntity bySeckillId = seckillMapper.findBySeckillId(seckillId);
    if (bySeckillId == null) {
        return setResultError("商品信息不存在！");
    }

Boolean aBoolean = redisUtil.setNX(phone, seckillId + "", 10L);

if (!aBoolean) {
        return setResultError("访问次数过多 10秒之后重新访问！");
    }

//修改数据库对应的库存
    int deduction = seckillMapper.inventoryDeduction(seckillId, bySeckillId.getVersion());
    if (!toDaoResult(deduction)) {
        log.info("&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;&gt;修改库存失败》》》》》inventoryDeduction返回{} 秒杀失败");
        return setResultError("亲请稍后重试！");
    }

//添加秒杀成功的订单
    OrderEntity entity = new OrderEntity()
            .setUserPhone(phone)
            .setSeckillId(seckillId);

int order = orderMapper.insertOrder(entity);
    if (!toDaoResult(order)) {
        return setResultError("亲请稍后重试！");
    }
    return setResultSuccess("恭喜你，秒杀成功！");
}</code></pre> </td> 
  </tr> 
 </tbody> 
</table>