商品秒杀_Sentinel解决缓存雪崩-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
public interface SeckillService {
    /**
      * 从数据库根据商品id查询秒杀商品
      */
    SeckillGoods findSecillGoodsByMySql(Long goodsId);
}

public class SeckillServiceImpl implements SeckillService {
    @Override
    public SeckillGoods findSeckillGoodsByRedis(Long goodsId) {
        // 布隆过滤器判断商品是否存在，如果不存在，直接返回空
        if (!bitMapBloomFilter.contains(goodsId.toString())){
            System.out.println("布隆过滤器判断商品不存在！");
            return null;
        }
        // 1. 从redis中查询秒杀商品
        SeckillGoods seckillGoods = (SeckillGoods) redisTemplate.boundHashOps("seckillGoods").get(goodsId);
        // 2. 如果查到商品，返回
        if (seckillGoods != null) {
            System.out.println("从redis中查询秒杀商品");
            return seckillGoods;
        }
        return null;
    }

    @Override
    public SeckillGoods findSecillGoodsByMySql(Long goodsId) {
        // 4. 如果该商品不在秒杀状态，返回null
        QueryWrapper<SeckillGoods> queryWrapper = new QueryWrapper();
        queryWrapper.eq("goodsId", goodsId);
        SeckillGoods seckillGoodsMysql = seckillGoodsMapper.selectOne(queryWrapper);
        System.out.println("从mysql中查询秒杀商品");

        Date now = new Date();
        if (seckillGoodsMysql == null
            || now.after(seckillGoodsMysql.getEndTime())
            || now.before(seckillGoodsMysql.getStartTime())
            || seckillGoodsMysql.getStockCount() <= 0){
            return null;
        }
        // 5. 如果该商品在秒杀状态，将商品保存到redis中，并返回该商品
        addRedisSeckillGoods(seckillGoodsMysql);
        return seckillGoodsMysql;
    }
}

修改查询秒杀商品详情的控制器方法


xxxxxxxxxx
/**
     * 用户查询秒杀商品详情
     * @param id 商品id
     * @return 查询结果
     */
@GetMapping("/findById")
public BaseResult<SeckillGoods> findById(Long id) {
    // 从redis中查询秒杀商品详情
    SeckillGoods seckillGoods = seckillService.findSeckillGoodsByRedis(id);
    if (seckillGoods != null){
        return BaseResult.ok(seckillGoods);
    }else {
        // 如果redis中查找不到，再从数据库查询秒杀商品详情
        SeckillGoods secillGoodsByMySql = seckillService.findSecillGoodsByMySql(id);
        return BaseResult.ok(secillGoodsByMySql);
    }
}

给从数据库查询秒杀商品详情方法设置Setinel资源


xxxxxxxxxx
@SentinelResource("findSecillGoodsByMySql")
@Override
public SeckillGoods findSecillGoodsByMySql(Long goodsId) {
    // 4. 如果该商品不在秒杀状态，返回null
    QueryWrapper<SeckillGoods> queryWrapper = new QueryWrapper();
    queryWrapper.eq("goodsId", goodsId);
    SeckillGoods seckillGoodsMysql = seckillGoodsMapper.selectOne(queryWrapper);
    System.out.println("从mysql中查询秒杀商品");

    Date now = new Date();
    if (seckillGoodsMysql == null
            || now.after(seckillGoodsMysql.getEndTime())
            || now.before(seckillGoodsMysql.getStartTime())
            || seckillGoodsMysql.getStockCount() <= 0){
        return null;
    }
    // 5. 如果该商品在秒杀状态，将商品保存到redis中，并返回该商品
    addRedisSeckillGoods(seckillGoodsMysql);
    return seckillGoodsMysql;
}

JAVA最全学习路线图和就业分析

北京市昌平区回龙观镇南店村综合商业楼2楼226室