您现在的位置是：网站首页> 编程资料编程资料

Redis之sql缓存的具体使用_Redis_

2023-05-27 602人已围观

简介 Redis之sql缓存的具体使用_Redis_

1.环境搭建

org.springframework.bootspring-boot-starter-data-redis
 spring: redis: host: 192.168.8.128 port: 6380 password: 1234 database: 0 timeout: 3000 jedis: pool: max-wait: -1 max-active: -1 max-idle: 20 min-idle: 10

在这里插入图片描述

2.Redis配置

 package com.yzm.redis01.config; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.annotation.JsonTypeInfo; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.core.JsonGenerator; import com.fasterxml.jackson.core.JsonParser; import com.fasterxml.jackson.databind.*; import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.io.IOException; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; @Configuration public class ObjectMapperConfig { private static final String PATTERN = "yyyy-MM-dd HH:mm:ss"; @Bean(name = "myObjectMapper") public ObjectMapper objectMapper() { JavaTimeModule javaTimeModule = new JavaTimeModule(); javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer()); javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer()); return new ObjectMapper() // 转换为格式化的json(控制台打印时，自动格式化规范) //.enable(SerializationFeature.INDENT_OUTPUT) // Include.ALWAYS 是序列化对像所有属性(默认) // Include.NON_NULL 只有不为null的字段才被序列化,属性为NULL 不序列化 // Include.NON_EMPTY 如果为null或者 空字符串和空集合都不会被序列化 // Include.NON_DEFAULT 属性为默认值不序列化 .setSerializationInclusion(JsonInclude.Include.NON_NULL) // 如果是空对象的时候,不抛异常 .configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false) // 反序列化的时候如果多了其他属性,不抛出异常 .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false) // 取消时间的转化格式,默认是时间戳,可以取消,同时需要设置要表现的时间格式 .configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false) .setDateFormat(new SimpleDateFormat(PATTERN)) // 对LocalDateTime序列化跟反序列化 .registerModule(javaTimeModule) .setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY) // 此项必须配置，否则会报java.lang.ClassCastException: java.util.LinkedHashMap cannot be cast to XXX .enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY) ; } static class LocalDateTimeSerializer extends JsonSerializer { @Override public void serialize(LocalDateTime value, JsonGenerator gen, SerializerProvider serializers) throws IOException { gen.writeString(value.format(DateTimeFormatter.ofPattern(PATTERN))); } } static class LocalDateTimeDeserializer extends JsonDeserializer { @Override public LocalDateTime deserialize(JsonParser p, DeserializationContext deserializationContext) throws IOException { return LocalDateTime.parse(p.getValueAsString(), DateTimeFormatter.ofPattern(PATTERN)); } } } 
 package com.yzm.redis01.config; import lombok.extern.slf4j.Slf4j; import org.springframework.cache.interceptor.KeyGenerator; import org.springframework.cache.interceptor.SimpleKey; import java.lang.reflect.Method; import java.util.Arrays; /** * key生成器 */ @Slf4j public class MyKeyGenerator implements KeyGenerator { private static final String NO_PARAM = "[]"; private static final String NULL_PARAM = "_"; @Override public Object generate(Object target, Method method, Object... params) { StringBuilder key = new StringBuilder(); key.append(target.getClass().getSimpleName()).append(".").append(method.getName()).append(":"); if (params.length == 0) { return new SimpleKey(key.append(NO_PARAM).toString()); } return new SimpleKey(key.append(Arrays.toString(params).replace("null", NULL_PARAM)).toString()); } }
 package com.yzm.redis01.config; 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.cache.RedisCacheWriter; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.*; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.RedisSerializationContext; import org.springframework.data.redis.serializer.StringRedisSerializer; import javax.annotation.Resource; import java.time.Duration; @Configuration @EnableCaching // 启动缓存 public class RedisConfig { @Bean(name = "myKeyGenerator") public MyKeyGenerator myKeyGenerator() { return new MyKeyGenerator(); } @Resource(name = "myObjectMapper") private ObjectMapper objectMapper; /** * 选择redis作为默认缓存工具 */ @Bean public CacheManager cacheManager(RedisConnectionFactory connectionFactory) { RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(connectionFactory); RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration .defaultCacheConfig() // 默认缓存时间(秒) .entryTtl(Duration.ofSeconds(300L)) // 序列化key、value .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer())) // 禁用缓存空值 .disableCachingNullValues(); return new RedisCacheManager(redisCacheWriter, cacheConfiguration); } /** * redisTemplate配置 */ @Bean public RedisTemplate redisTemplate(RedisConnectionFactory factory) { RedisTemplate template = new RedisTemplate<>(); // 配置连接工厂 template.setConnectionFactory(factory); Jackson2JsonRedisSerializer jacksonSerializer = jackson2JsonRedisSerializer(); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); // 使用StringRedisSerializer来序列化和反序列化redis的key,value采用json序列化 template.setKeySerializer(stringRedisSerializer); template.setValueSerializer(jacksonSerializer); // 设置hash key 和value序列化模式 template.setHashKeySerializer(stringRedisSerializer); template.setHashValueSerializer(jacksonSerializer); //支持事务 template.setEnableTransactionSupport(true); template.afterPropertiesSet(); return template; } private Jackson2JsonRedisSerializer jackson2JsonRedisSerializer() { //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式） Jackson2JsonRedisSerializer jacksonSerializer = new Jackson2JsonRedisSerializer<>(Object.class); jacksonSerializer.setObjectMapper(objectMapper); return jacksonSerializer; } } 
3.功能实现
新增、更新、删除、查询数据时，对缓存执行对应相同的操作
 package com.yzm.redis01.entity; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; import lombok.experimental.Accessors; import java.io.Serializable; import java.time.LocalDateTime; import java.util.Date; @Data @Builder @NoArgsConstructor @AllArgsConstructor @Accessors(chain = true) public class User implements Serializable { private static final long serialVersionUID = -2468903864827432779L; private Integer id; private String username; private String password; private Date createDate; private LocalDateTime updateDate; } 
 package com.yzm.redis01.service; import com.yzm.redis01.entity.User; import java.util.List; public interface UserService { User saveUser(User user); User updateUser(User user); int deleteUser(Integer id); void deleteAllCache(); User getUserById(Integer id); List selectAll(); List findAll(Object... params); } 
为了简便，数据不从数据库获取，这里是创建Map存储数据实现
 package com.yzm.redis01.service.impl; import com.yzm.redis01.entity.User; import com.yzm.redis01.service.UserService; import lombok.extern.slf4j.Slf4j; import org.springframework.cache.annotation.CacheConfig; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.util.*; @Slf4j @Service @CacheConfig(cacheNames = "users") public class UserServiceImpl implements UserService { private static final Map userMap; static { userMap = new HashMap<>(); userMap.put(userMap.size() + 1, User.builder() .id(userMap.size() + 1).username("root").password("root").createDate(new Date()).updateDate(LocalDateTime.now()).build()); userMap.put(userMap.size() + 1, User.builder() .id(userMap.size() + 1).username("admin").password("admin").createDate(new Date()).updateDate(LocalDateTime.now()).build()); } @Override @CachePut(key = "#result.id", condition = "#result.id gt 0") public User saveUser(User user) { log.info("保存数据"); int id = userMap.size() + 1; User build = User.builder() .id(id) .username(user.getUsername()) .password(user.getPassword()) .createDate(new Date()) .updateDa
                
                

                

                                            
上一篇：Redis分布式锁详细介绍_Redis_

                                                                
下一篇：Redis可视化工具Redis Desktop Manager的具体使用_Redis_

                                    

            

        
        

            
相关内容

            
        

    
    

        

            
点击排行

            
        

        

            
本栏推荐

            
        


        

            
猜你喜欢