玩转 Spring Boot 应用篇（引入Redis解决店铺高并发读的问题）

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
    <exclusions>
        <exclusion>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
        </exclusion>
        <exclusion>
            <groupId>io.lettuce</groupId>
            <artifactId>lettuce-core</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
</dependency>

### Redis 缓存配置信息
# 主机名称
spring.redis.host=127.0.0.1
# 端口号
spring.redis.port=6379
# 认证密码
spring.redis.password=
# 连接超时时间
spring.redis.timeout=500
# 默认数据库
spring.redis.database=0

/**获取缓存的商品列表*/
public List<Goods> findAllCacheGoods();

@Override
public Collection<Goods> findAllCacheGoods() {
    // 从缓存中查询商品数据
    Map<Integer, Goods> goodsMap = redisTemplate.opsForHash().entries(GOODS_LIST_CACHE_KEY);
    // 缓存的商品列表为空，则从库中加载然后放入缓存中（此操作可以前置，在商品管理时加入到缓存中）
    if (MapUtils.isEmpty(goodsMap)) {
        logger.info("商品缓存列表为空，先从库中查询商品列表信息");
        // 查询库中的所有商品
        List<Goods> goodsList = findAllGoods();
        // 将商品 list 转换为商品 map
        goodsMap = convertToMap(goodsList);
        logger.info("从库中查询商品条数为：" + goodsMap.size());
        // 把商品信息缓存到 redis 中
        redisTemplate.opsForHash().putAll(GOODS_LIST_CACHE_KEY, goodsMap);
        // 设置商品缓存数据的过期时间为 10 秒
        redisTemplate.expire(GOODS_LIST_CACHE_KEY, 10000, TimeUnit.MILLISECONDS);
        logger.info("商品信息放入 redis 中完毕");
    }
    // 返回商品列表
    return goodsMap.values();
}

/**
 * 商品列表转成Map<Integer,Goods>
 */
private Map<Integer, Goods> convertToMap(Collection<Goods> goodsList) {
    if (CollectionUtils.isEmpty(goodsList)) {
        return Collections.EMPTY_MAP;
    }

    Map<Integer, Goods> goodsMap = new HashMap<>(goodsList.size());
    for (Goods goods : goodsList) {
        goodsMap.put(goods.getId(), goods);
    }
    return goodsMap;
}

@Controller
public class IndexController {

    @Resource
    private GoodsService goodsService;

    @RequestMapping({"","/","/index"})
    public String index(Model model) {
        // v1：从数据库中加载商品列表
        // model.addAttribute("goodsList", goodsService.findAllGoods());
        
        // v3：优先从 redis 中获取商品列表
        model.addAttribute("goodsList", goodsService.findAllCacheGoods());
        return "index";
    }
}

//扣减库存成功，则更新 redis 中缓存的商品信息
redisTemplate.opsForHash().put(GOODS_LIST_CACHE_KEY, goodsId, goodsDao.getGoodsById(goodsId));
logger.info("更新缓存中的商品信息：" + goodsId + "成功");