详解简单基于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>