Springboot2.X集成redis集群(Lettuce)连接的方法

<dependency>

   <groupid>org.springframework.boot</groupid>

   <artifactid>spring-boot-starter-data-redis</artifactid>

</dependency>

spring.redis.cluster.nodes= 127.0 . 0.1 : 6380 , 127.0 . 0.1 : 6381 , 127.0 . 0.1 : 6382 , 127.0 . 0.1 : 6383 , 127.0 . 0.1 : 6384 , 127.0 . 0.1 : 6385

spring.redis.cluster.timeout= 1000

spring.redis.cluster.max-redirects= 3

@configuration

public class redisconfiguration {

   @resource

   private lettuceconnectionfactory mylettuceconnectionfactory;

   @bean

   public redistemplate<string, serializable> redistemplate() {

     redistemplate<string, serializable> template = new redistemplate<>();

     template.setkeyserializer( new stringredisserializer());

     template.setvalueserializer( new genericjackson2jsonredisserializer());

     template.setconnectionfactory(mylettuceconnectionfactory);

     return template;

   }

}

@configuration

public class redisfactoryconfig {

   @autowired

   private environment environment;

   @bean

   public redisconnectionfactory mylettuceconnectionfactory() {

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

     source.put( "spring.redis.cluster.nodes" , environment.getproperty( "spring.redis.cluster.nodes" ));

     source.put( "spring.redis.cluster.timeout" , environment.getproperty( "spring.redis.cluster.timeout" ));

     source.put( "spring.redis.cluster.max-redirects" , environment.getproperty( "spring.redis.cluster.max-redirects" ));

     redisclusterconfiguration redisclusterconfiguration;

     redisclusterconfiguration = new redisclusterconfiguration( new mappropertysource( "redisclusterconfiguration" , source));

     return new lettuceconnectionfactory(redisclusterconfiguration);

   }

}

@springboottest

@runwith (springrunner. class )

public class redisconfigurationtest {

   @autowired

private redistemplate redistemplate;

@test

public void redistemplate() throws exception {

     redistemplate.opsforvalue().set( "author" , "damein_xym" );

}

}