- 這里是SpringBoot2集成RedisCacheManager的方式
SpringBoot1配置CacheManager有區(qū)別
maven依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<version>2.0.3.RELEASE</version>
</dependency>
RedisConfig
@Configuration
@ConfigurationProperties(prefix = "redis")
@EnableCaching // 需要這個注解才能啟用注解驅(qū)動的緩存管理功能
public class RedisConfig {
private String clusterNodes;
private String redisHost;
private int redisPort;
private String redisPasswd;
private int timeOut = 2000;
private int redirects = 8;
@Bean // redis配置
public RedisClusterConfiguration getClusterConfiguration() {
Map<String, Object> source = Maps.newHashMap();
source.put("spring.redis.cluster.nodes", clusterNodes);
source.put("spring.redis.cluster.timeout", timeOut);
source.put("spring.redis.cluster.max-redirects", redirects);
return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source));
}
@Bean // redis連接
public RedisConnectionFactory redisConnectionFactory() {
JedisConnectionFactory cf = null;
if (clusterNodes != null && !clusterNodes.isEmpty()) {
cf = new JedisConnectionFactory(getClusterConfiguration());
} else {
RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
redisStandaloneConfiguration.setHostName(redisHost);
redisStandaloneConfiguration.setPort(redisPort);
redisStandaloneConfiguration.setPassword(RedisPassword.of(redisPasswd));
cf = new JedisConnectionFactory(redisStandaloneConfiguration);
}
cf.afterPropertiesSet();
return cf;
}
@Bean // 實際使用的redisTemplate营曼，可以直接注入到代碼中，直接操作redis
public RedisTemplate<String, Object> redisTemplate() {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
RedisSerializer stringSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringSerializer);
redisTemplate.setConnectionFactory(redisConnectionFactory());
return redisTemplate;
}
@Bean // 關(guān)聯(lián)redis到注解
CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory);
// 默認(rèn)配置颜阐，過期時間指定是30分鐘
RedisCacheConfiguration defaultCacheConfig = RedisCacheConfiguration.defaultCacheConfig();
defaultCacheConfig.entryTtl(Duration.ofMinutes(30));
// redisExpire1h cache配置跃惫，過期時間指定是1小時宙攻，緩存key的前綴指定成prefixaaa_（存到redis的key會自動添加這個前綴）
RedisCacheConfiguration userCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig().
entryTtl(Duration.ofHours(1)).prefixKeysWith("prefixaaa_");
Map<String, RedisCacheConfiguration> redisCacheConfigurationMap = new HashMap<>();
redisCacheConfigurationMap.put("redisExpire1h", userCacheConfiguration);
RedisCacheManager cacheManager = new RedisCacheManager(redisCacheWriter, defaultCacheConfig, redisCacheConfigurationMap);
return cacheManager;
}
使用注解驅(qū)動的緩存管理功能
-
TestUser必須實現(xiàn)implements Serializable，不然無法序列化到redis；而且serialVersionUID務(wù)必指定髓需，不然增加字段玻褪，會導(dǎo)致反序列化回來失敗 -
key的語法是SpEL
注解使用在interface接口上肉渴，key需要使用#p0#p0.id這種index下標(biāo)的方式訪問，0表示第一個入?yún)⒋洌源祟愅疲?br> 其他具體的bean同规，key可以使用#id#testUser.id方式訪問，interface接口用這種方式訪問會報錯：java.lang.IllegalArgumentException: Null key returned for cache operation -
value對應(yīng)的是cacheManager中的redisCacheConfigurationMap中的配置（map可以放多個配置）窟社，這里指定的是redisExpire1h券勺；
不寫或者匹配不上，使用的是cacheManager中默認(rèn)的defaultCacheConfig
@Repository("testUserDAO")
public interface TestUserDAO {
// 查詢操作---緩存
@Cacheable(value = "redisExpire1h", key = "'test_user_'.concat(#p0)")
TestUser selectById(@Param("id") String id);
// 更新操作---清除緩存
@CacheEvict(value = "redisExpire1h", key = "'test_user_'.concat(#p0.id)")
Integer updateConfigByCorp(TestUser testUser);
}
null值處理
- 如上配置的話灿里，null值會被緩存关炼，所以insert的時候也需要CacheEvict；不然先查（緩存了null）匣吊，再插儒拂，后查詢可能一直返回null
nullValue緩存如下： "\xac\xed\x00\x05sr\x00+org.springframework.cache.support.NullValue\x00\x00\x00\x00\x00\x00\x00\x01\x02\x00\x00xp"
參考
擴展
Mysql緩存機制寸潦，Mybatis緩存機制
