1.缓存分析

我们已经实现了商品详情页面的展示，但是有一个问题我们要思考的是：因为查询商品详情的时候要涉及到数据库，如果我们网页的访问量很大的时候，查询商品都去查数据库的话，数据库的压力是很大的。为了解决这个问题的话我们要引入缓存；但是引入缓存的话又要考虑一个问题，缓存的资源也是有限的。如果我们把大量商品详情信息都放到缓存的话，缓存的压力也很大。我们知道商品是分热点商品和冷门商品的，热点访问量很大，因此存储热门商品信息才能提高缓存的利用率。那么如何解决这个问题呢，有以下两种方案：
1.利用redis的的访问量统计功能并利用其zset数据类型进行访问量排序，把访问量高的商品详情内容添加到缓存当中。这种方案比较麻烦，我们不建议采用这种方式。
2.设置缓存的过期时间，用户只要点击查看商品详情，我们一律先都存放到缓存当中，但是我们要设置一下该条商品的缓存时间（比如半天或一天或其它），到期后该商品的缓存就会被删除掉，如果该商品是热门商品的话，用户再查看详情的时候就又会向缓存中添加该商品的缓存，如果该商品是冷门商品，过期后缓存中便没有这款商品的缓存信息了（直到有下一位用户查看该商品的详情信息），这样就可以节约缓存的空间，而且这种方式无疑是提高缓存利用率最简单的方法了。
那么我们如何在缓存中保存我们的信息呢？
redis有两种存储方式，一种是哈希，一种是字符串；前者适合信息分类存储，但不适合设置缓存的过期时间，因为它不支持到具体到对每个Field进行设置过期时间，这就意味着如果我们设置的key过期后，缓存的消息都会消失，这显然是不合理的，我们想要的是针对每个商品设置过期时间，因此设置过期时间的话，hash存储不合适。String存储是比较适合的，那么问题又来了，String存储时key是容易重复的，怎么来避免key冲突呢？我们可以通过添加前缀、后缀的方式对redis的key进行分类，如下图所示。既然是要存储商品详情，就在商品ID前面起个名字，就叫做ITEM_INFO（大家可以随便起），在ID的后面添加后缀BASE（代表是基本信息），DESC（代表是商品描述信息）
即：
ITEM_INFO:123456:BASE
ITEM_INFO:123456:DESC

image.png

如果把二维表保存到redis中:
1、表名就是第一层
2、主键是第二层
3、字段名第三次
三层使用“:”分隔作为key，value就是字段中的内容。

2.缓存的实现

我们一般把缓存加到service层中，因为Controller层使用的话有一定的局限性。将缓存加到service层的话，如果是其他工程引用这个服务的话也能使用缓存的功能
下面是实现的步骤：
第一步：在taotao-manager-service中添加依赖

第二步：将taotao-content-service中的jedis的代码复制一份

image.png

image.png

image.png

第四步：在代码中添加缓存

package com.taotao.service.impl;


import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.taotao.common.pojo.EasyUIDataGridResult;
import com.taotao.common.pojo.TaotaoResult;
import com.taotao.mapper.TbItemDescMapper;
import com.taotao.mapper.TbItemMapper;
import com.taotao.pojo.TbItem;
import com.taotao.pojo.TbItemDesc;
import com.taotao.pojo.TbItemExample;
import com.taotao.service.ItemService;
import com.taotao.service.jedis.JedisClient;
import com.taotao.utils.IDUtils;
import com.taotao.utils.JsonUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.jms.*;
import java.util.Date;
import java.util.List;

/**
 * 商品管理
 */
@Service
public class ItemServiceImpl implements ItemService {
    @Autowired
    private TbItemMapper tbItemMapper;
    @Autowired
    private TbItemDescMapper itemDescMapper;
    @Autowired
    private JmsTemplate jmsTemplate;
    @Resource(name = "itemAddTopic")
    private Destination itemAddTopic;
    @Autowired
    private JedisClient jedisClient;
    @Value("${ITEM_INFO}")
    private String ITEM_INFO;//商品的前缀
    @Value("${ITEM_EXPIRE}")
    private Integer ITEM_EXPIRE;//商品的后缀
    @Override
    public TbItem getItemById(long itemId) {
        //查询缓存
        try{
            String json = jedisClient.get(ITEM_INFO + ":"+ itemId + ":BASE");
            if (StringUtils.isNotBlank(json)) {
                TbItem item = JsonUtils.jsonToPojo(json,TbItem.class);
                return  item;
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
        TbItem item = tbItemMapper.selectByPrimaryKey(itemId);
        //如果在缓存中没有就添加进缓存
        try{
            //添加缓存
            jedisClient.set(ITEM_INFO + ":"+ itemId + ":BASE", JsonUtils.objectToJson(item));
            //设置过期时间
            jedisClient.expire(ITEM_INFO + ":"+ itemId + ":BASE",ITEM_EXPIRE);
        }catch(Exception e) {
            e.printStackTrace();
        }
        return item;
    }

    @Override
    public TbItemDesc getDescById(long itemId) {
        //查询缓存
        try{
            String json = jedisClient.get(ITEM_INFO + ":" + itemId  + ":DESC");
            if(StringUtils.isNotBlank(json)) {
                TbItemDesc desc = JsonUtils.jsonToPojo(json,TbItemDesc.class);
                return desc;
            }
        }catch(Exception e) {

        }
        TbItemDesc desc = itemDescMapper.selectByPrimaryKey(itemId);
        //如果在缓存中没有就添加进缓存
        try{
            jedisClient.set(ITEM_INFO + ":" + itemId  + ":DESC",JsonUtils.objectToJson(desc));
            jedisClient.expire(ITEM_INFO + ":" + itemId  + ":DESC",ITEM_EXPIRE);
        }catch(Exception e) {
            e.printStackTrace();
        }
        return desc;
    }

    @Override
    public EasyUIDataGridResult getItemList(int page, int rows) {
        //1.在执行查询之前配置分页条件。使用PageHelper的静态方法
        PageHelper.startPage(page,rows);
        //2.执行查询
        TbItemExample tbItemExample = new TbItemExample();
        List<TbItem> list = tbItemMapper.selectByExample(tbItemExample);
        //3.创建PageInfo对象
        PageInfo<TbItem> pageInfo = new PageInfo<>(list);
        EasyUIDataGridResult result = new EasyUIDataGridResult();
        //设置数目
        result.setTotal(pageInfo.getTotal());
        //设置返回的数据
        result.setRows(list);
        return result;
    }

    @Override
    public TaotaoResult addItem(TbItem item, String desc) {
        final long id = IDUtils.genItemId();
        item.setId(id);
        item.setCreated(new Date());
        item.setUpdated(new Date());
        item.setStatus((byte) 1);
        tbItemMapper.insert(item);
        TbItemDesc itemDesc = new TbItemDesc();
        itemDesc.setItemDesc(desc);
        itemDesc.setCreated(new Date());
        itemDesc.setUpdated(new Date());
        itemDescMapper.insert(itemDesc);
        //使用ActiveMq发送消息
        jmsTemplate.send(itemAddTopic,new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage(id + "");
                return textMessage;
            }
        });
        return TaotaoResult.ok();
    }


    @Override
    public TbItem updateItem(long itemId) {

        return null;
    }
}