最近在使用spring-boot的Cache功能时，出现了一下奇葩问题
问题现象如下图：
error.png
很滑稽的一个问题，相同的类型还出现类型转换错误
项目中的使用情况如下：
缓存配置
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
@Resource
private LettuceConnectionFactory lettuceConnectionFactory;
@Bean
@Override
public KeyGenerator keyGenerator() {
return (target, method, params) -> {
StringBuffer sb = new StringBuffer();
sb.append(target.getClass().getName());
sb.append(method.getName());
for (Object obj : params) {
if (obj != null) {
sb.append(obj.toString());
}
}
return sb.toString();
};
}
/**
* 缓存管理器
*
* @return
*/
@Bean
@Override
public CacheManager cacheManager() {
RedisCacheManager.RedisCacheManagerBuilder builder =
RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(lettuceConnectionFactory);
Map<String, RedisCacheConfiguration> configurationMap = getStringRedisCacheConfigurationMap();
builder.withInitialCacheConfigurations(configurationMap);
return builder.build();
}
/**
* 不同的缓存可采用个性化的配置
*
* @return
*/
private Map<String, RedisCacheConfiguration> getStringRedisCacheConfigurationMap() {
Map<String, RedisCacheConfiguration> configurationMap = new HashMap<>();
// 基本配置
configurationMap.put("codeNameCache", RedisCacheConfiguration.defaultCacheConfig());
configurationMap.put("baseStationData", RedisCacheConfiguration.defaultCacheConfig()
// 不缓存null
.disableCachingNullValues()
// 监测测站数据很少变动，保存1天
.entryTtl(Duration.ofHours(24)));
return configurationMap;
}
}
缓存使用
@Cacheable(value = "baseStationData", unless = "#result == null")
public List<T> query(String tableEnName, String whereCond, String queryFields) throws UnsupportedEncodingException {
......
}
缓存使用场景
@lombok.Data
public class User implements Serializable{
private String username;
private Integer age;
}
public class Service{
public List<User> getUsers(String... args){
......
// 在这里调用上面的 query 方法，假设我这里的范型 T 是 User对象
List<User> users = xxx.query("user","username='test'","username,age");
for(User user : users){
// 注意：就是这里，只要调用了user对象的任何方法，都会报错，类型转换错误，说 User connot be cast to User
System.out.println(user.getAge());
}
......
}
}
我们把上面出错的地方单独拿出来
for(User user : users){
// 注意：就是这里，只要调用了user对象的任何方法，都会报错，类型转换错误，说 User connot be cast to User
System.out.println(user.getAge());
}
对于这个问题，网上也有人遇到过，但是都说什么是spring-boot devtools工具的问题，感觉挺扯的，我没用这个devtools工具，但是看网上分析的大致可以得出以下结论：
当cache将数据放入缓存时，使用了默认的序列化方式（JdkSerializationRedisSerializer），该序列化使用了二进制保存了对象的上下文ClassLoader，而由于devtools导致服务重启，然后重启后ClassLoad和原来的ClassLoader不是同一个对象了，所以导致对象的Class也不一样，虽然看上去都是User，但是它就是不同的类型，因为它的Class也不相等。
这个就太扯了，我把数据放到缓存中，然后服务器重启了下，再去查缓存就不能用了，那这个缓存有啥用。
解决方案
这个问题肯定是和序列化有关的，我们指定一下缓存value的序列化方式，使用json来序列化对象，配置类的改造如下：
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
......省略不变的代码
/**
* 不同的缓存可采用个性化的配置
*
* @return
*/
private Map<String, RedisCacheConfiguration> getStringRedisCacheConfigurationMap() {
Map<String, RedisCacheConfiguration> configurationMap = new HashMap<>();
// 基本配置
configurationMap.put("codeNameCache", RedisCacheConfiguration.defaultCacheConfig());
configurationMap.put("baseStationData", RedisCacheConfiguration.defaultCacheConfig()
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer()))
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
// 不缓存null
.disableCachingNullValues()
// 监测测站数据很少变动，保存1天
.entryTtl(Duration.ofHours(24)));
return configurationMap;
}
private Jackson2JsonRedisSerializer<Object> redisSerializer() {
Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, Visibility.ANY);
om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
return jackson2JsonRedisSerializer;
}
}
再重启服务，缓存读取出来反序列化后的对象，可以正常使用。
搞定！！！
