boot使用Redis集群替换mybatis二级缓存,redis配置文件

spring-boot-starter-Redis主要是通过配置RedisConnectionFactory中的相关参数去实现连接redis
service。

1 . pom.xml添加相关依赖

RedisConnectionFactory是一个接口,有如下4个具体的实现类,我们通常使用的是JedisConnectionFactory。

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.1.RELEASE</version>
</parent>

  <!-- 依赖 -->
  <dependencies>
    <!-- mybatis -->
    <dependency>
      <groupId>org.mybatis.spring.boot</groupId>
      <artifactId>mybatis-spring-boot-starter</artifactId>
      <version>1.2.0</version>
    </dependency>
    <!-- redis相关 -->
    <dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
    </dependency>

    <dependency>
      <groupId>org.springframework.data</groupId>
      <artifactId>spring-data-redis</artifactId>
    </dependency>
  <dependencies>

在spring boot的配置文件中redis的基本配置如下:

2 .
配置Redis集群,参考spring-data-redis官方文档

# Redis服务器地址
spring.redis.host=192.168.0.58
# Redis服务器连接端口
spring.redis.port=6379 
# Redis服务器连接密码(默认为空,如果redis服务端配置文件开启了requirepass 密码,此处就应该填写相应的配置密码)
spring.redis.password= 
# 连接超时时间(毫秒)
spring.redis.timeout=0
@Component
@ConfigurationProperties(prefix = "spring.redis.cluster")
public class ClusterConfigurationProperties {

  /*
   * spring.redis.cluster.nodes[0] = 127.0.0.1:7379
   * spring.redis.cluster.nodes[1] = 127.0.0.1:7380
   * ...
   */
  List<String> nodes;

  /**
   * Get initial collection of known cluster nodes in format {@code host:port}.
   *
   * @return
   */
  public List<String> getNodes() {
    return nodes;
  }

  public void setNodes(List<String> nodes) {
    this.nodes = nodes;
  }
}

@Configuration
public class AppConfig {

  /**
   * Type safe representation of application.properties
   */
  @Autowired ClusterConfigurationProperties clusterProperties;

  public @Bean RedisConnectionFactory connectionFactory() {

    return new JedisConnectionFactory(
      new RedisClusterConfiguration(clusterProperties.getNodes()));
  }
}

上边这4项是在JedisConnectionFactory类中的基本配置项,里边其实还包含了一些比如连接池,集群,主从,哨兵等的配置,这里先简单介绍下连接池(JedisPoolConfig),需要了解其它配置了可以看下源码。GenericObjectPoolConfig是JedisPoolConfig的父类,主要提供了maxTotal、maxIdle、maxIdle共三个参数的配置,其中还设置了默认的参数。

3 . 自定义二级缓存类

# 连接池最大连接数(使用负值表示没有限制,对应maxTotal)
spring.redis.pool.max-active=8
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0
public class RedisCache implements Cache {

  private static final String PREFIX = "SYS_CONFIG:";

  private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock(true);

  private String id;
  private JdkSerializationRedisSerializer jdkSerializer = new JdkSerializationRedisSerializer();

  private static RedisConnectionFactory redisConnectionFactory;

  public RedisCache(final String id) {
    if (id == null) {
      throw new IllegalArgumentException("Cache instances require an ID");
    }
    this.id = id;
  }

  @Override
  public String getId() {
    return this.id;
  }

  @Override
  public void putObject(Object key, Object value) {
    RedisClusterConnection conn = redisConnectionFactory
        .getClusterConnection();
    if (key == null)
      return;
    String strKey = PREFIX + key.toString();
    conn.set(strKey.getBytes(), jdkSerializer.serialize(value));
    conn.close();
  }

  @Override
  public Object getObject(Object key) {
    if (key != null) {
      String strKey = PREFIX + key.toString();
      RedisClusterConnection conn = redisConnectionFactory
          .getClusterConnection();
      byte[] bs = conn.get(strKey.getBytes());
      conn.close();
      return jdkSerializer.deserialize(bs);
    }
    return null;
  }

  @Override
  public Object removeObject(Object key) {
    if (key != null) {
      RedisClusterConnection conn = redisConnectionFactory
          .getClusterConnection();
      conn.del(key.toString().getBytes());
      conn.close();
    }
    return null;
  }

  @Override
  public void clear() {
    // 关键代码,data更新时清理缓存
    RedisClusterConnection conn = redisConnectionFactory
        .getClusterConnection();
    Set<byte[]> keys = conn.keys((PREFIX+"*").getBytes());
    for (byte[] bs : keys) {
      conn.del(bs);
    }
    conn.close();
  }
  @Override
  public int getSize() {
    // TODO Auto-generated method stub
    return 0;
  }

  @Override
  public ReadWriteLock getReadWriteLock() {
    return this.readWriteLock;
  }


  public static void setRedisConnectionFactory(RedisConnectionFactory redisConnectionFactory) {
    RedisCache.redisConnectionFactory = redisConnectionFactory;
  }

}

配置文件配置好后,还需要建立一个redis的配置类,主要用来配置key和value的序列化及加载配置文件中的相关参数

使用一个Transfer类间接注入RedisConnectionFactory

如果你只需要使用基本的redis配置,那么使用如下配置类即可,spring
boot会自动扫描redis的基本配置,但是有一项要注意那就是password,如果你在配置文件中设置了password,那么就必须在配置类中手工注入JedisConnectionFactory中,否则会在启动过程中报NOAUTH
Authentication required.;:

@Component 
public class RedisCacheTransfer {

@Autowired
public void setJedisConnectionFactory(
    RedisConnectionFactory jedisConnectionFactory) {
  RedisCache.setRedisConnectionFactory(jedisConnectionFactory);
}
}
@Configuration 
@EnableCaching 
public class RedisConfig extends CachingConfigurerSupport{ 
 @Bean 
 public KeyGenerator keyGenerator() { 
  return new KeyGenerator() { 
   public Object generate(Object target, Method method, Object... params) { 
    StringBuilder sb = new StringBuilder(); 
    sb.append(target.getClass().getName()); 
    sb.append(method.getName()); 
    for (Object obj : params) { 
     sb.append(obj.toString()); 
    } 
    return sb.toString(); 
   } 
  }; 
 } 
 @SuppressWarnings("rawtypes") 
 @Bean 
 public CacheManager cacheManager(RedisTemplate redisTemplate) { 
  RedisCacheManager rcm = new RedisCacheManager(redisTemplate); 
  //设置缓存过期时间 
  //rcm.setDefaultExpiration(60);//秒 
  return rcm; 
 } 
 @Bean 
 public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) { 
  StringRedisTemplate template = new StringRedisTemplate(factory); 
  @SuppressWarnings({ "rawtypes", "unchecked" }) 
  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); 
  template.setValueSerializer(jackson2JsonRedisSerializer); 
  template.afterPropertiesSet(); 
  JedisConnectionFactory jc = (JedisConnectionFactory) factory; 
  System.out.println(jc.getHostName()); 
  return template; 
 } 
} 

4 . 在application.propreties中开启二级缓存

如果你还配置了如连接池之类的参数,在上边配置类中加入:

开启mybatis的二级缓存

@Bean 
public JedisConnectionFactory redisConnectionFactory() { 
  JedisConnectionFactory factory = new JedisConnectionFactory(); 
  factory.setHostName(host); 
  factory.setPort(port); 
  factory.setPassword(password); 
  factory.setTimeout(timeout); //设置连接超时时间 
  return factory; 
} 
spring.datasource.cachePrepStmts=true

使用factory进行set你所配置的值即可。

5 . 基于注解的使用

附带解释一点就是在配置类中注入配置文件中的属性方案有多种,如需了解可参考下文:

@CacheNamespace(implementation = RedisCache.class)
public interface ConfigDaoMapper {
  .....
}

点击打开链接

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

以上所述是小编给大家介绍的详解spring boot starter
redis配置文件,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

您可能感兴趣的文章:

  • Spring Boot Redis
    集成配置详解
  • 详解springboot配置多个redis连接
  • Spring Boot 基于注解的 Redis
    缓存使用详解
  • 详解Spring-Boot集成Spring
    session并存入redis
  • springboot整合spring-data-redis遇到的坑
  • 详解Spring
    Boot使用redis实现数据缓存
  • SpringBoot利用redis集成消息队列的方法
  • springboot整合redis进行数据操作(推荐)
  • 详解spring boot starter
    redis配置文件
  • spring
    boot中内嵌redis的使用方法示例

您可能感兴趣的文章:

  • Spring Boot Redis
    集成配置详解
  • 详解springboot配置多个redis连接
  • Spring Boot 基于注解的 Redis
    缓存使用详解
  • 详解Spring-Boot集成Spring
    session并存入redis
  • springboot整合spring-data-redis遇到的坑
  • 详解Spring
    Boot使用redis实现数据缓存
  • 详解Spring
    boot使用Redis集群替换mybatis二级缓存
  • SpringBoot利用redis集成消息队列的方法
  • springboot整合redis进行数据操作(推荐)
  • spring
    boot中内嵌redis的使用方法示例

Post Author: admin

发表评论

电子邮件地址不会被公开。 必填项已用*标注