Spring-data-redis操作redis cluster的示例代码

set<hostandport> jedisclusternodes = new hashset<hostandport>();

  //jedis cluster will attempt to discover cluster nodes automatically

  jedisclusternodes.add( new hostandport( "10.96.5.183" , 9001 ));

  jedisclusternodes.add( new hostandport( "10.96.5.183" , 9002 ));

  jedisclusternodes.add( new hostandport( "10.96.5.183" , 9003 ));

jediscluster jc = new jediscluster(jedisclusternodes);

jc.set( "foo" , "bar" );

jc.get( "foo" );

src

   com.example.bean

   com.example.repo

   com.example.repo.impl

   resources

<!--通过构造方法注入redisnode-->

  <bean id= "clusterredisnodes1"   class = "org.springframework.data.redis.connection.redisnode" >

     <constructor-arg value= "10.96.5.183" />

     <constructor-arg value= "9002" type= "int" />

  </bean>

  ....

<!--setter方式注入-->

<bean id= "redisclusterconfiguration"   class = "org.springframework.data.redis.connection.redisclusterconfiguration" >

   <property name= "clusternodes" >

      <set>

           <ref bean= "clusterredisnodes1" />

           <ref bean= "clusterredisnodes2" />

           <ref bean= "clusterredisnodes3" />

      </set>

   </property>

  <!--红色所示部分在从github上获取的jar包中无对应setter方法，因此需要修改其对应的源码。

     <property name= "clustertimeout" value= "10000" />

     <property name= "maxredirects"   value= "5" />

   </bean>

  <!--setter方式注入,对应的属性需存在setterxxx方法-->

   <bean id= "jedispoolconfig"   class = "redis.clients.jedis.jedispoolconfig" >

       <property name= "maxtoal" value= "1000" />

       <property name= "maxidle" value= "1000" />

       <property name= "maxwaitmillis" value= "1000" />

   </bean>

  <bean id= "jedisconnfactory"   class = "org.springframework.data.redis.connection.jedis.jedisconnectionfactory" p:use-pool= "true" >

       <constructor-arg ref= "redisclusterconfiguration" />

       <constructor-arg ref= "jedispoolconfig" />

  </bean>

  <bean id= "redistemplate"   class = "org.springframework.data.redis.core.redistemplate" p:connection-factory-ref= "jedisconnfactory" />

<!--setter方式注入personrepoimpl-->

<bean id= "personrepo" class = "com.example.repo.impl.personrepoimpl" >

     <property name= "redistemplate" ref= "redistemplate" />

</bean>

<bean id = "xxx" class = "org.springframework.data.redis.core.script.defaultredisscript" >

   <property name= "location" value= "./redis/xxx.lua" />

  <property name= "resulttype" value= "java.lang.void" />

</bean>

classpathxmlapplicationcontext context = new classpathxmlapplicationcontext( new classpathresource( "resources/spring-config.xml" ).getpath());

repo repo =(repo)context.getbean( "personrepo" );

src

   com.redis.cluster.support.config

        monitorconfig

   resources

       spring-config.xml

        redis.properties

<!--配置文件加载-->

  <context:property-placeholder location= "resources/redis.properties" />

<context:property-placeholder location= "resources/xxx.properties" />

  <bean class = "com.redis.cluster.support.config.monitorconfig" />

<!--对静态资源文件的访问-->

  <mvc: default -servlet-handler/>

  <mvc:annotation-driven />

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

spring.redis.cluster.nodes= 10.48 . 193.201 : 7389 , 10.48 . 193.201 : 7388

spring.redis.cluster.timeout= 2000

spring.redis.cluster.max-redirects= 8

@configuration

public class monitorconfig {

   @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;

   @bean

   public redisclusterconfiguration getclusterconfiguration() {

     map<string, object> source = new hashmap<string, object>();

     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 getconnectionfactory() {

     return new jedisconnectionfactory(getclusterconfiguration());

    }

  @bean

   public jedisclusterconnection getjedisclusterconnection() {

     return (jedisclusterconnection) getconnectionfactory().getconnection();

    }

   @bean

   public redistemplate getredistemplate() {

     redistemplate clustertemplate = new redistemplate();

     clustertemplate.setconnectionfactory(getconnectionfactory());

     clustertemplate.setkeyserializer( new defaultkeyserializer());

     clustertemplate.setdefaultserializer( new genericjackson2jsonredisserializer());

     return clustertemplate;

    }

   }

@autowired

  jedisclusterconnection clusterconnection;

@autowired

redistemplate redistemplate;

@autowired

jediscluster jediscluster;

<bean id= "testredis" class = "com.test.testredis" >

   <property name= "jediscluster" ref= "jedisclusterfactory" />

</bean>

classpathxmlapplicationcontext context = new classpathxmlapplicationcontext( new classpathresource( "resources/spring-config.xml" ).getpath());

testredis testredis=(testredis)context.getbean( "testredis" );

jediscluster(set<hostandport> jedisclusternode, int timeout, int maxredirections) ;

jediscluster jc = new jediscluster(jedisclusternodes, 5000 , 1000 );