SpringBoot2整合Redis缓存三步骤代码详解

SpringBoot2整合Redis缓存三步骤代码详解

遵循SpringBoot三板斧

第一步加依赖

org.springframework.boot

spring-boot-starter-data-redis

org.apache.commons

commons-pool2

2.6.0

第二步写注解

@EnableCaching//开启缓存支持

第三步写配置

spring:

redis:

database: 0

host: 192.168.1.11

port: 6379

password:

timeout: 600

lettuce:

pool:

max-active: 50

max-wait: -1

max-idle: 8

min-idle: 0

编写Redis配置类

/**

* @Author: zc

* @Date: 2019/11/3 14:12

* @Description: SpringBoot2.0 Redis缓存配置

* @EnableCaching:开启缓存支持

*/

@Slf4j

@Configuration

@EnableCaching

public class RedisConfig extends CachingConfigurerSupport {

@Value("${sys.dataCaching.expireTime:0}")

private int expireTime;

@Resource

private LettuceConnectionFactory lettuceConnectionFactory;

@Override

@Bean

public KeyGenerator keyGenerator() {//设置自定义key{ClassName + methodName + params}

return (target, method, params) -> {

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append(",Method:");

sb.append(method.getName());

sb.append(",Params[");

for (int i = 0; i < params.length; i++) {

sb.append(params[i].toString());

if (i != (params.length - 1)) {

sb.append(",");

}

}

sb.append("]");

log.debug("Data Caching Redis Key : {}", sb.toString());

return sb.toString();

};

}

//自定义keyGenerator，Key生成器

@Bean

public KeyGenerator updateByIdkeyGenerator() {

return (target, method, params) -> {

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append(",Method:");

sb.append("getById");

sb.append(",Params[");

try {

Field id = params[0].getClass().getDeclaredField("id");

id.setAccessible(true);

sb.append(id.get(params[0]).toString());

} catch (IllegalAccessException e) {

e.printStackTrace();

} catch (NoSuchFieldException e) {

e.printStackTrace();

}

sb.append("]");

log.debug("Data Caching Redis Key : {}", sb.toString());

return sb.toString();

};

}

//自定义keyGenerator，Key生成器

@Bean

sdLTAcX public KeyGenerator deleteByIdkeyGenerator() {

return (target, method, params) -> {

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append(",Method:");

sb.append("getById");

sb.append(",Params[");

for (int i = 0; i < params.length; i++) {

sb.append(params[i].toString());

if (i != (params.length - 1)) {

sb.append(",");

}

}

sb.append("]");

log.debug("Data Caching Redis Key : {}", sb.toString());

return sb.toString();

};

}

@Bean

public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {

RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig();

//设置缓存过期时间

if (expireTime > 0) {

log.info("Redis 缓存过期时间 : {}", expireTime);

//设置缓存有效期 秒

redisCacheConfiguration.entryTtl(Duration.ofSeconds(expireTime));

} else {

log.info("Redis 未设置缓存过期时间");

}

return RedisCacheManager

.builder(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory))

.cacheDefaults(redisCacheConfiguration).build();

}

@Bean

public RedisTemplate redisTemplate(RedisConnectionFactory factory) {//创建RedisTemplate

// 设置序列化

Jackson2jsonRedisSerializer

Object.class);

ObjectMapper om = new ObjectMapper();

om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

jackson2JsonRedisSerializer.setObjectMapper(om);

// 配置redisTemplate

RedisTemplate redisTemplate = new RedisTemplate();

redisTemplate.setConnectionFactory(lettuceConnectionFactory);

RedisSerializer> stringSerializer = new StringRedisSerializer();

// key序列化

redisTemplate.setKeySerializer(stringSerializer);

// value序列化

redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

// Hash key序列化

redisTemplate.setHashKeySerializer(stringSerializer);

// Hash value序列化

redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.afterPropertiesSet();

return redisTemplate;

}

}

如何使用查询缓存

@CacheConfig(cacheNames = "demoDao")

@Component

public class DemoDao implements IDemoDAO<> {

@Autowired

DemoMapper mapper;

//用默认配置的keyGenerator

@Cacheable

@Override

public Demo getById(Integer id) {

return mapper.getById(id);

}

//使用配置的keyGenerator，清空http://缓存

@CacheEvict(keyGenerator = "updateByIdkeyGenerator")

@Override

public int update(T entity) {

return mapper.update(entity);

}

//使用配置的keyGenerator，清空缓存

@CacheEvict(keyGenerator = "deleteByIdkeyGenerator")

@Override

public int deleteById(Integer id) {

return mapper.deleteById(id);

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。