# 055. 基于 nginx + lua + java 完成多级缓存架构的核心业务逻辑（二）

/**
  * 这里的代码别看着奇怪，简单回顾下之前的流程： 1. nginx 获取 redis 缓存 2. 获取不到再获取服务的堆缓存（也就是这里的 ecache） 3.
  * 还获取不到就需要去数据库获取并重建缓存
  */
 @RequestMapping("/getProductInfo")
 @ResponseBody
 public ProductInfo getProductInfo(Long productId) {
     ProductInfo productInfo = cacheService.getProductInfoOfReidsCache(productId);
     log.info("从 redis 中获取商品信息");
     if (productInfo == null) {
         productInfo = cacheService.getProductInfoFromLocalCache(productId);
         log.info("从 ehcache 中获取商品信息");
     }
     if (productInfo == null) {
         // 两级缓存中都获取不到数据，那么就需要从数据源重新拉取数据，重建缓存
         // 但是这里暂时不讲
         log.info("缓存重建 商品信息");
     }
     return productInfo;
 }

 @RequestMapping("/getShopInfo")
 @ResponseBody
 public ShopInfo getShopInfo(Long shopId) {
     ShopInfo shopInfo = cacheService.getShopInfoOfReidsCache(shopId);
     log.info("从 redis 中获取店铺信息");
     if (shopInfo == null) {
         shopInfo = cacheService.getShopInfoFromLocalCache(shopId);
         log.info("从 ehcache 中获取店铺信息");
     }
     if (shopInfo == null) {
         // 两级缓存中都获取不到数据，那么就需要从数据源重新拉取数据，重建缓存
         // 但是这里暂时不讲
         log.info("缓存重建 店铺信息");
     }
     return shopInfo;
 }
 
        Copied!
    

/**
 * 从 redis 中获取商品
 */
ProductInfo getProductInfoOfReidsCache(Long productId);

/**
 * 从 redis 中获取店铺信息
 */
ShopInfo getShopInfoOfReidsCache(Long shopId);

 
        Copied!
    

@Override
public ProductInfo getProductInfoOfReidsCache(Long productId) {
    String key = "product_info_" + productId;
    String json = jedisCluster.get(key);
    return JSON.parseObject(json, ProductInfo.class);
}

@Override
public ShopInfo getShopInfoOfReidsCache(Long shopId) {
    String key = "shop_info_" + shopId;
    String json = jedisCluster.get(key);
    return JSON.parseObject(json, ShopInfo.class);
}
 
        Copied!