[Java] 详解简单基于spring的redis配置(单机和集群模式)

<bean id="redistemplate" class="org.springframework.data.redis.core.redistemplate">
  <property name="connectionfactory" ref="connectionfactory"/>
   <property name="defaultserializer" ref="stringredisserializer"/>
   <property name="keyserializer" ref="stringredisserializer"/>
   <property name="valueserializer" ref="valueserializer"/>
</bean>

<bean id="connectionfactory" class="org.springframework.data.redis.connection.jedis.jedisconnectionfactory">
  <!-- 配置ip -->
  <property name="hostname" value="${redis.host}"/>
  <!-- 配置port -->
  <property name="port" value="${redis.port}"/>
  <!-- 是否使用连接池-->
  <property name="usepool" value="${redis.usepool}"/>
  <!-- 配置redis连接池-->
  <property name="poolconfig" ref="poolconfig"/>
</bean>

<bean id="poolconfig" class="redis.clients.jedis.jedispoolconfig">
  <!--最大空闲实例数-->
  <property name="maxidle" value="${redis.maxidle}" />
  <!--最大活跃实例数-->
  <property name="maxtotal" value="${redis.maxtotal}" />
  <!--创建实例时最长等待时间-->
  <property name="maxwaitmillis" value="${redis.maxwaitmillis}" />
  <!--创建实例时是否验证-->
  <property name="testonborrow" value="${redis.testonborrow}" />
</bean>

<bean id="connectionfactory" class="org.springframework.data.redis.connection.jedis.jedisconnectionfactory">
  <!-- 配置redis连接池-->  
  <constructor-arg ref="poolconfig"></constructor-arg>
  <!-- 配置redis集群--> 
 <constructor-arg ref="clusterconfig"></constructor-arg>
  <!-- 是否使用连接池-->
  <property name="usepool" value="${redis.usepool}"/>
</bean>

<bean id="clusterconfig" class="org.springframework.data.redis.connection.redisclusterconfiguration">
  <property name="maxredirects" value="3"></property>
  <property name="clusternodes">
  <set>
    <bean class="org.springframework.data.redis.connection.redisclusternode">
    <constructor-arg value="${redis.host1}"></constructor-arg>
    <constructor-arg value="${redis.port1}"></constructor-arg>
    </bean>
    <bean class="org.springframework.data.redis.connection.redisclusternode">
    <constructor-arg value="${redis.host2}"></constructor-arg>
    <constructor-arg value="${redis.port2}"></constructor-arg>
    </bean>
    ......
  </set>
  </property>
</bean

<bean name="propertysource" class="org.springframework.core.io.support.resourcepropertysource">
  <constructor-arg name="location" value="classpath:properties/spring-redis-cluster.properties" />
</bean>
<bean id="clusterconfig" class="org.springframework.data.redis.connection.redisclusterconfiguration">
  <constructor-arg name="propertysource" ref="propertysource"/>
</bean>

@configuration
@enablecaching
public class redisconfig extends cachingconfigurersupport {
 
  //spring3支持注解方式获取value 在application里配置配置文件路径即可获取
  @value("${spring.redis.cluster.nodes}")
  private string clusternodes;
 
  @value("${spring.redis.cluster.timeout}")
  private long timeout;
 
  @value("${spring.redis.cluster.max-redirects}")
  private int redirects;
 
  @value("${redis.maxidle}")
  private int maxidle;
 
  @value("${redis.maxtotal}")
  private int maxtotal;
 
  @value("${redis.maxwaitmillis}")
  private long maxwaitmillis;
 
  @value("${redis.testonborrow}")
  private boolean testonborrow;
 
  /**
   * 选择redis作为默认缓存工具
   * @param redistemplate
   * @return
   */
  @bean
  public cachemanager cachemanager(redistemplate redistemplate) {
  rediscachemanager cachemanager = new rediscachemanager(redistemplate);
  //cachemanager.setdefaultexpiration(60);
  //map<string,long> expiresmap=new hashmap<>();
  //expiresmap.put("rediscache",5l);
  //cachemanager.setexpires(expiresmap);
  return cachemanager;
  }
 
  @bean
  public redisclusterconfiguration redisclusterconfiguration(){
  map<string, object> source = new hashmap<>();
  source.put("spring.redis.cluster.nodes", clusternodes);
  source.put("spring.redis.cluster.timeout", timeout);
  source.put("spring.redis.cluster.max-redirects", redirects);
  return new redisclusterconfiguration(new mappropertysource("redisclusterconfiguration", source));
  }
 
  @bean
  public jedisconnectionfactory redisconnectionfactory(redisclusterconfiguration configuration){
  jedispoolconfig poolconfig = new jedispoolconfig();
  poolconfig.setmaxidle(maxidle);
  poolconfig.setmaxtotal(maxtotal); 
  poolconfig.setmaxwaitmillis(maxwaitmillis);
  poolconfig.settestonborrow(testonborrow);
  return new jedisconnectionfactory(configuration,poolconfig);
  }
 
  /**
   * retemplate相关配置
   * @param factory
   * @return
   */
  @bean
  public redistemplate<string, object> redistemplate(jedisconnectionfactory factory) {
 
  redistemplate<string, object> template = new redistemplate<>();
  // 配置连接工厂
  template.setconnectionfactory(factory);
 
  //使用jackson2jsonredisserializer来序列化和反序列化redis的value值（默认使用jdk的序列化方式）
  jackson2jsonredisserializer jacksonseial = new jackson2jsonredisserializer(object.class);
 
  objectmapper om = new objectmapper();
  // 指定要序列化的域，field,get和set,以及修饰符范围，any是都有包括private和public
  om.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any);
  // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如string,integer等会跑出异常
  //om.enabledefaulttyping(objectmapper.defaulttyping.non_final);
  jacksonseial.setobjectmapper(om);
 
  // 值采用json序列化
  template.setvalueserializer(jacksonseial);
  //使用stringredisserializer来序列化和反序列化redis的key值
  template.setkeyserializer(new stringredisserializer());
 
  // 设置hash key 和value序列化模式
  template.sethashkeyserializer(new stringredisserializer());
  
  template.sethashvalueserializer(jacksonseial);
  template.afterpropertiesset();
 
  return template;
  }
}

<context:component-scan base-package="com.*"/>

<value>classpath:properties/spring-redis-cluster.properties</value>