这篇文章主要为大家展示了“spring-data-redis 2.0怎么用”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“spring-data-redis 2.0怎么用”这篇文章吧。
创新互联成立于2013年,我们提供高端成都网站建设、成都网站制作公司、成都网站设计、网站定制、营销型网站、小程序制作、微信公众号开发、seo优化服务,提供专业营销思路、内容策划、视觉设计、程序开发来完成项目落地,为成都格栅板企业提供源源不断的流量和订单咨询。
在使用Spring Boot2.x运行Redis时,发现百度不到顺手的文档,搞通后发现其实这个过程非常简单和简洁,觉得有必要拿出来分享一下。
Spring Boot2.x 不再使用Jedis,换成了Lettuce。Lettuce是基于 Netty 实现的,所以性能更好。但是我看到很多文章居然在Spring Boot 2.x还在写Jedis的配置。
依赖
依赖比较简单,spring-boot-starter-data-redis、commons-pool2 即可。
<!-- redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!--spring2.0集成redis所需common-pool2--> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> <version>2.4.2</version> </dependency>
属性配置
在属性中配置Redis Server的访问地址、密码、数据库,并配置连接池的属性。
redis: # reids的连接ip host: 127.0.0.1 port: 6379 password: helloworld # Redis默认情况下有16个分片,这里配置具体使用的分片,默认是0 database: 0 # 连接超时时间(毫秒) timeout: 10000ms # redis client配置,使用lettuce lettuce: pool: # 连接池中的最小空闲连接 默认 0 min-idle: 0 # 连接池最大阻塞等待时间(使用负值表示没有限制) 默认 -1 max-wait: 1000ms # 连接池最大连接数(使用负值表示没有限制) 默认 8 max-active: 8 # 连接池中的最大空闲连接 默认 8 max-idle: 8
注解配置
全局使能缓存
@EnableSwagger2 // 使用swagger api 功能 @EnableCaching // 使用缓存 @SpringBootApplication public class Starter { public static void main(String[] args) { SpringApplication.run(Starter.class, args); } }
通过注解使用缓存,@Cacheable 将获取值存入缓存
/** * 基于id 获取用户信息 */ @Cacheable(value="user", key="#id", unless="#result == null") public UserDTO GetUserById(int id) { User userEntity = userMapper.getUserByID(id); if (userEntity == null){ return null; } /* entity 转 DTO */ UserDTO userDTO = new UserDTO(); userDTO.setAge(userEntity.getAge()); userDTO.setId(id); userDTO.setName(userEntity.getName()); userDTO.setCreateTime(unixTime2String(userEntity.getCreateTime())); userDTO.setPhone(userEntity.getPhone()); userDTO.setEmail(userEntity.getEmail()); return userDTO; }
@CachePut 更新缓存
@CachePut(value = "user", key="#p0.id") public UserDTO updateUser(InputUserInfoDTO inputUserInfoDTO){ userMapper.updateUser(inputUserInfoDTO.getId(), inputUserInfoDTO.getName(), inputUserInfoDTO.getAge()); User userEntity = userMapper.getUserByID(inputUserInfoDTO.getId());/* entity 转 DTO */ if (null == userEntity){ return null; } UserDTO userDTO = new UserDTO(); 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()); return userDTO; }
@CacheEvict 删除缓存
@CacheEvict(value = "user", key="#id") public void deleteUser(int id){ userMapper.deleteUser(id); }
当然为了支持序列化,我的UserDTO得implements Serializable
@Data public class UserDTO implements Serializable { //public class UserDTO implements Serializable { private int id; private String name; private int age; private String createTime; private String phone; private String email; }
至此缓存已经可以用起来了,不需要编写RedisConfig代码,有点小遗憾,直接去Redis查看数据,发现是乱码。这是因为我使用的是Java自带的序列化,如果要更换Redis序列化方法,就要重写RedisConfig了。
RedisConfig
这个配置也不复杂,使用Jackson2JsonRedisSerializer将对象转换为Json串,注意这里一定要使用ObjectMapper,否则再将json串反序列化为对象时会报。
@Configuration @ConditionalOnClass(RedisOperations.class) @EnableConfigurationProperties(RedisProperties.class) public class RedisConfig extends CachingConfigurerSupport{ @Bean public CacheManager cacheManager(RedisConnectionFactory factory) { RedisSerializer<String> redisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); //解决查询缓存转换异常的问题 ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); // 配置序列化(解决乱码的问题) RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ZERO) .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer)) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) .disableCachingNullValues(); RedisCacheManager cacheManager = RedisCacheManager.builder(factory).cacheDefaults(config).build(); return cacheManager; } }
以上是“spring-data-redis 2.0怎么用”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!
当前名称:spring-data-redis2.0怎么用
标题链接:https://www.cdcxhl.com/article20/psjpjo.html
成都网站建设公司_创新互联,为您提供网站制作、定制网站、网站设计公司、标签优化、面包屑导航、App开发
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联