spring-data-redis 2.0 的使用示例代码
在使用SpringBoot2.x运行Redis时，发现百度不到顺手的文档，搞通后发现其实这个过程非常简单和简洁，觉得有必要拿出来分享一下。
SpringBoot2.x不再使用Jedis，换成了Lettuce。Lettuce是基于Netty实现的，所以性能更好。但是我看到很多文章居然在SpringBoot2.x还在写Jedis的配置。
依赖
依赖比较简单，spring-boot-starter-data-redis、commons-pool2即可。
org.springframework.boot spring-boot-starter-data-redis org.apache.commons commons-pool2 2.4.2
属性配置
在属性中配置RedisServer的访问地址、密码、数据库，并配置连接池的属性。
redis: #reids的连接ip host:127.0.0.1 port:6379 password:helloworld #Redis默认情况下有16个分片，这里配置具体使用的分片，默认是0 database:0 #连接超时时间（毫秒) timeout:10000ms #redisclient配置，使用lettuce lettuce: pool: #连接池中的最小空闲连接默认0 min-idle:0 #连接池最大阻塞等待时间（使用负值表示没有限制）默认-1 max-wait:1000ms #连接池最大连接数（使用负值表示没有限制）默认8 max-active:8 #连接池中的最大空闲连接默认8 max-idle:8
注解配置
全局使能缓存
@EnableSwagger2//使用swaggerapi功能
@EnableCaching//使用缓存
@SpringBootApplication
publicclassStarter{
publicstaticvoidmain(String[]args){
SpringApplication.run(Starter.class,args);
}
}
通过注解使用缓存，@Cacheable将获取值存入缓存
/**
*基于id获取用户信息
*/
@Cacheable(value="user",key="#id",unless="#result==null")
publicUserDTOGetUserById(intid){
UseruserEntity=userMapper.getUserByID(id);
if(userEntity==null){
returnnull;
}
/*entity转DTO*/
UserDTOuserDTO=newUserDTO();
userDTO.setAge(userEntity.getAge());
userDTO.setId(id);
userDTO.setName(userEntity.getName());
userDTO.setCreateTime(unixTime2String(userEntity.getCreateTime()));
userDTO.setPhone(userEntity.getPhone());
userDTO.setEmail(userEntity.getEmail());
returnuserDTO;
}
@CachePut更新缓存
@CachePut(value="user",key="#p0.id")
publicUserDTOupdateUser(InputUserInfoDTOinputUserInfoDTO){
userMapper.updateUser(inputUserInfoDTO.getId(),inputUserInfoDTO.getName(),inputUserInfoDTO.getAge());
UseruserEntity=userMapper.getUserByID(inputUserInfoDTO.getId());/*entity转DTO*/
if(null==userEntity){
returnnull;
}
UserDTOuserDTO=newUserDTO();
userDTO.setAge(userEntity.getAge());
userDTO.setId(userEntity.getId());
userDTO.setName(userEntity.getName());
userDTO.setCreateTime(unixTime2String(userEntity.getCreateTime()));
userDTO.setPhone(userEntity.getPhone());
userDTO.setEmail(userEntity.getEmail());
returnuserDTO;
}
@CacheEvict删除缓存
@CacheEvict(value="user",key="#id")
publicvoiddeleteUser(intid){
userMapper.deleteUser(id);
}
当然为了支持序列化，我的UserDTO得implementsSerializable
@Data
publicclassUserDTOimplementsSerializable{
//publicclassUserDTOimplementsSerializable{
privateintid;
privateStringname;
privateintage;
privateStringcreateTime;
privateStringphone;
privateStringemail;
}
至此缓存已经可以用起来了，不需要编写RedisConfig代码，有点小遗憾，直接去Redis查看数据，发现是乱码。这是因为我使用的是Java自带的序列化，如果要更换Redis序列化方法，就要重写RedisConfig了。
RedisConfig
这个配置也不复杂，使用Jackson2JsonRedisSerializer将对象转换为Json串，注意这里一定要使用ObjectMapper，否则再将json串反序列化为对象时会报。
@Configuration
@ConditionalOnClass(RedisOperations.class)
@EnableConfigurationProperties(RedisProperties.class)
publicclassRedisConfigextendsCachingConfigurerSupport{
@Bean
publicCacheManagercacheManager(RedisConnectionFactoryfactory){
RedisSerializerredisSerializer=newStringRedisSerializer();
Jackson2JsonRedisSerializerjackson2JsonRedisSerializer=newJackson2JsonRedisSerializer(Object.class);
//解决查询缓存转换异常的问题
ObjectMapperom=newObjectMapper();
om.setVisibility(PropertyAccessor.ALL,JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
//配置序列化（解决乱码的问题）
RedisCacheConfigurationconfig=RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ZERO)
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
.disableCachingNullValues();
RedisCacheManagercacheManager=RedisCacheManager.builder(factory).cacheDefaults(config).build();
returncacheManager;
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。