SpringBoot2.x Método de conexión de clúster redis (lechuga) integrado

Prerrequisito: construya un entorno de clúster Redis. Consulte el método de construcción: https://www.vevb.com/article/143749.htm

1. Cree un nuevo proyecto y agregue soporte Redis al archivo pom.xml

 <Spendency> <MoupRoMID> org.springframework.boot </groupid> <artifactid> spring-boot-starter-data-redis </artifactid> </dependence>

2. Configurar la aplicación. Properties

 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: 6385spring.redis.cluster.timeout = 1000spring.redis.cluster.max-redirects = 3

3. Crea las siguientes dos clases

 @ConfigurationPublic Class Redisconfiguration {@Resource LettuceconnectionFactory myLettucEconnectionFactory; @Bean public Redistemplate <String, Serializable> redistemplate () {redistemplate <string, serializable> template = new Redistemplate <> (); Template.setKeySerializer (new StringRedisSerializer ()); Template.SetValuueSerializer (nuevo GenericJackson2JsonRedisSerializer ()); Template.SetConnectionFactory (myLettucEconnectionFactory); plantilla de retorno; }}

 @ConfigurationPublic Class RedIsfactoryConfig {@AUTOWIREDREDENTE ENTUNDO PRIVADO SENTIENTE; @Bean public redisConnectionFactory myLetTucEconnectionFactory () {map <string, objeto> fuente = new HashMap <String, Object> (); Source.put ("Spring.redis.cluster.nodes", Environment.getProperty ("Spring.Redis.cluster.nodes")); Source.put ("Spring.redis.cluster.timeout", ambiente.getproperty ("spring.redis.cluster.timeout")); Source.put ("Spring.redis.cluster.max-redirects", Environment.getProperty ("Spring.redis.cluster.max-redirects")); RedisclusterConfiguration RedisclusterConfiguration; RedIsClusterConfiguration = new RedIsClusterConfiguration (nuevo MappropertySource ("RedisClusterConfiguration", fuente)); devolver nuevo LettucEconnectionFactory (redisclusterConfiguration); }}

4. Realizar pruebas

 @Springboottest@runwith (springrunner.class) public class RedisconfigurationTest {@aUtowiredPrivate redistemplate redistemplate; @testpublic void redistemplate () lanza la excepción {redistemplate.opsforvalue (). Set ("autor", "damein_xym");}}

5. Verifique que use Redis Desktop Manager para conectarse al nodo Redis y verifique si los datos internos existe como autor. Lo siguiente lo muestra y resulta exitoso.

Lo anterior es todo el contenido de este artículo. Espero que sea útil para el aprendizaje de todos y espero que todos apoyen más a Wulin.com.