RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
spring-data-redis2.0怎么用

这篇文章主要为大家展示了“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 即可。


    
      org.springframework.boot
      spring-boot-starter-data-redis
    


    
    
      org.apache.commons
      commons-pool2
      2.4.2
    

属性配置

在属性中配置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 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怎么用
分享URL:http://lswzjz.com/article/psjpjo.html