Comment mettre en cache Redis

redis est souvent utilisé comme serveur de cache. L’avantage de la mise en cache est qu’elle réduit la pression sur le serveur et accélère l’interrogation des données. Résolvez le problème de la réponse lente des données.

Ajouter du cache : Utilisez uniquement le type de données Hash de Redis pour ajouter du cache. (Apprentissage recommandé : Tutoriel vidéo Redis )

Par exemple : besoin d'ajouter du cache dans la fonction métier de la requête

1.

premier besoin à exécuter Avant la logique métier normale (avant d'interroger la base de données), interrogez le cache. S'il n'y a pas de données requises dans le cache, interrogez la base de données

Afin d'éviter les erreurs d'ajout. cache et affectant l'exécution du code métier normal, ajoutez du code mis en cache et placez-le dans le bloc de code try-catch afin que le programme puisse le capturer automatiquement.

2. Terminez l'opération de requête de base de données. Une fois la requête terminée, les données interrogées doivent être ajoutées au cache.

Code :

@Override
    public List<TbContent> findContentByCategoryId(Long categoryId) {
        // 查询出的内容列表可以添加到缓存中，便于展示，为了保证添加缓存出现错误不影响程序的正常业务功能，可以使用try catch的方式加缓存
        try {
            String json = jedisClient.hget(CONTENT_LIST, categoryId + "");
            if (json != null) {
                List<TbContent> list = JsonUtils.jsonToList(json, TbContent.class);
                return list;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        TbContentExample example = new TbContentExample();
        Criteria criteria = example.createCriteria();
        criteria.andCategoryIdEqualTo(categoryId);
        // 使用selectByExampleWithBLOBs方法会将content属性框中的内容也查询出来
        List<TbContent> list = contentMapper.selectByExampleWithBLOBs(example);

        // 操作完成后需要将查询的内容添加到缓存中,因为添加缓存的过程可能出错，所以使用try catch将异常抛出即可
        // categoryId+""将Long类型的数据转换成String类型的
        try {
            jedisClient.hset(CONTENT_LIST, categoryId + "", JsonUtils.objectToJson(list));
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

Classe de l'outil de conversion Json :

package nyist.e3.utils;

import java.util.List;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.ObjectMapper;

/**
 * 淘淘商城自定义响应结构
 */
public class JsonUtils {

    // 定义jackson对象
    private static final ObjectMapper MAPPER = new ObjectMapper();

    /**
     * 将对象转换成json字符串。
     * <p>Title: pojoToJson</p>
     * <p>Description: </p>
     * @param data
     * @return
     */
    public static String objectToJson(Object data) {
        try {
            String string = MAPPER.writeValueAsString(data);
            return string;
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
        return null;
    }
    
    /**
     * 将json结果集转化为对象
     * 
     * @param jsonData json数据
     * @param clazz 对象中的object类型
     * @return
     */
    public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
        try {
            T t = MAPPER.readValue(jsonData, beanType);
            return t;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
    
    /**
     * 将json数据转换成pojo对象list
     * <p>Title: jsonToList</p>
     * <p>Description: </p>
     * @param jsonData
     * @param beanType
     * @return
     */
    public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
        JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
        try {
            List<T> list = MAPPER.readValue(jsonData, javaType);
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        }
        
        return null;
    }
    
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!