Maison  >  Article  >  base de données  >  Comment utiliser les annotations pour implémenter la fonction de mise en cache Redis

Comment utiliser les annotations pour implémenter la fonction de mise en cache Redis

王林
王林avant
2023-05-29 22:04:331231parcourir

Système de stockage de clés et de valeurs écrit en langage C (différent du stockage de tables bidimensionnelles de MySQL.)

rdb : persistance périodique

aof : ajouter sous forme de journal

RDB est activé par défaut, et aof est activé en même temps time

Types de données : chaîne, liste, ensemble, zset, hachage,

stockage au format d'octet bitMaps, type de latitude et de longitude géospatiales...

Thème unique : utilisez le multiplexage io multiple pour obtenir une concurrence élevée

Utilisation :

Ajouter des dépendances

<!-- redis -->
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- spring2.X集成redis所需common-pool2-->
<dependency>
 <groupId>org.apache.commons</groupId>
 <artifactId>commons-pool2</artifactId>
 <version>2.6.0</version>
</dependency>

Créer une classe de configuration Méthode d'écriture fixe

package com.lzq.yygh.common;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
 
import java.net.UnknownHostException;
import java.time.Duration;
@Configuration
@EnableCaching  //开启缓存功能
public class RedisConfig {
/**
 * 设置RedisTemplate规则
 * @param redisConnectionFactory
 * @return
 */
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)throws UnknownHostException {
    RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(redisConnectionFactory);
    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    //解决查询缓存转换异常的问题
    ObjectMapper om = new ObjectMapper();
    // 指定要序列化的域,field,get和set,以及修饰符范围,ANY是都有包括private和public
     om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等
                om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
     jackson2JsonRedisSerializer.setObjectMapper(om);
    //序列号key value
     redisTemplate.setKeySerializer(new StringRedisSerializer());
     redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
     redisTemplate.setHashKeySerializer(new StringRedisSerializer());
     redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
     redisTemplate.afterPropertiesSet();
     return redisTemplate;
}
    /**
     * 设置CacheManager缓存规则
     * @param factory
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory factory) {
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        //解决查询缓存转换异常的问题
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // 配置序列化(解决乱码的问题),过期时间600秒
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofSeconds(600)) //缓存过期10分钟 ---- 业务需求。
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))//设置key的序列化方式
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) //设置value的序列化
                .disableCachingNullValues();
        RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
                .cacheDefaults(config)
                .build();
        return cacheManager;
    }
}

Ajouter des informations de configuration

spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.database= 0
spring.redis.timeout=1800000
spring.redis.lettuce.pool.max-active=20
spring.redis.lettuce.pool.max-wait=-1
#最大阻塞等待时间(负数表示没限制)
spring.redis.lettuce.pool.max-idle=5
spring.redis.lettuce.pool.min-idle=0

Utiliser des annotations pour implémenter des fonctions

Cache @Cacheable

Cache le résultat de retour selon la méthode, et mettez-le en cache la prochaine fois qu'il est demandé, si le cache existe, lisez directement les données du cache et revenez si le cache n'existe pas, exécutez la méthode et stockez le résultat renvoyé dans le cache. Généralement utilisé dans les méthodes de requête.

Cache @CachePut

Chaque fois qu'une méthode marquée avec cette annotation est exécutée, les résultats seront stockés dans le cache spécifié. Les données peuvent être lues directement à partir du cache de réponses sans avoir à accéder à la base de données. Généralement utilisé pour ajouter de nouvelles méthodes.

Cache @CacheEvict

L'utilisation de cet indicateur d'annotation effacera le cache spécifié. Généralement utilisé dans les méthodes de mise à jour ou de suppression

Marquez l'annotation dans le serviceimpl renvoyé Lorsque la clé n'est pas définie, les paramètres seront automatiquement ajoutés en tant que clé

@Cacheable(value = "dict", key = "'selectIndexList'+#id")

.

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!

Déclaration:
Cet article est reproduit dans:. en cas de violation, veuillez contacter admin@php.cn Supprimer