Comment résoudre l'exception de délai d'attente lorsque Springboot2.x intègre lettuce et se connecte au cluster Redis

Contexte : Récemment, je faisais un test de stress sur un système Springboot nouvellement développé. J'ai découvert que lorsque j'ai démarré le test de stress, je pouvais accéder normalement aux données du cluster Redis, puis après quelques minutes de pause. J'ai continué à utiliser jmeter pour effectuer le test de stress, j'ai découvert que Redis avait échoué. Soudain, un message anormal est apparu comme un fou : La commande a expiré après 6 seconde(s)...

  1 Caused by: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 6 second(s)  2     at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51)  3     at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:114)  4     at io.lettuce.core.cluster.ClusterFutureSyncInvocationHandler.handleInvocation(ClusterFutureSyncInvocationHandler.java:123)  5     at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:80)  6     at com.sun.proxy.$Proxy134.mget(Unknown Source)  7     at org.springframework.data.redis.connection.lettuce.LettuceStringCommands.mGet(LettuceStringCommands.java:119)  8     ... 15 common frames omitted

J'ai vérifié à la hâte le cluster Redis et j'ai trouvé. que tous les nœuds du cluster étaient normaux et que l'utilisation du processeur et de la mémoire était inférieure à 100 %. Vingt, en regardant tout cela, je suis soudainement tombé dans une longue méditation, quel est exactement le problème... Après avoir cherché sur Baidu, J'ai constaté que de nombreuses personnes ont vécu des situations similaires. Certaines personnes ont déclaré que définir un délai d'attente plus élevé pouvait résoudre le problème. J'ai suivi cette solution et défini la valeur du délai d'attente sur une valeur plus grande, mais le problème de délai d'attente n'était toujours pas résolu.

Parmi eux, le package de dépendances pour Springboot pour faire fonctionner Redis est——

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4 </dependency>

Configuration du cluster——

  1 redis:  2   timeout: 6000ms  3   cluster:  4     nodes:  5       - xxx.xxx.x.xxx:6379  6       - xxx.xxx.x.xxx:6379  7       - xxx.xxx.x.xxx:6379  8   jedis:  9     pool: 10       max-active: 1000 11       max-idle: 10 12       min-idle: 5 13       max-wait: -1

Cliquez sur spring-boot-starter-data-redis et constatez qu'il contient la dépendance de lettuce :

springboot1 .x utilise jedis par défaut et Springboot2.x utilise la laitue par défaut. Nous pouvons simplement vérifier que dans la classe de configuration de chargement du pilote redis, afficher les informations RedisConnectionFactory :

  1 @Configuration  2 @AutoConfigureAfter(RedisAutoConfiguration.class)  3 public class Configuration {  4     @Bean  5     public StringRedisTemplate redisTemplate(RedisConnectionFactory factory) {  6         log.info("测试打印驱动类型:"+factory);  7 }

Sortie d'impression -

测试打印驱动类型:org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory@74ee761e

On peut voir que la connexion du pilote lettuce est utilisée ici, donc lors de son remplacement par la précédente Quand Plus de pilotes Jedis sont connectés, cette commande a expiré après 6 secondes. Le problème ne se produit plus.

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4     <exclusions>  5         <exclusion>  6             <groupId>io.lettuce</groupId>  7             <artifactId>lettuce-core</artifactId>  8         </exclusion>  9     </exclusions> 10 </dependency> 11 <dependency> 12     <groupId>redis.clients</groupId> 13     <artifactId>jedis</artifactId> 14 </dependency>

Alors la question est : comment Springboot2.x utilise-t-il lettuce par défaut ? Nous devons étudier une partie du code qu'il contient. Nous pouvons entrer dans la partie redis de Springboot2. Cela signifie que lors de l'utilisation de la dépendance spring-boot-starter-data-redis, les pilotes lettuce et jedis peuvent être automatiquement importés. Logiquement, il n'y aura pas deux pilotes en même temps. , ce qui n'a pas beaucoup de sens. Par conséquent, l'ordre ici est C'est très important, pourquoi dites-vous cela ?

Entrez respectivement LettuceConnectionConfiguration.class et JedisConnectionConfiguration.class, et chacun affiche le code de base requis pour cet article :

  1 @Configuration(  2     proxyBeanMethods = false  3 )  4 @ConditionalOnClass({RedisOperations.class})  5 @EnableConfigurationProperties({RedisProperties.class})  6 @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})  7 public class RedisAutoConfiguration {  8     public RedisAutoConfiguration() {  9    } 10    ......省略 11 }

On peut voir que LettuceConnectionConfiguration.class et JedisConnectionConfiguration.class ont la même annotation @ConditionalOnMissingBean({RedisConnectionFactory.class }), cela signifie que si le bean RedisConnectionFactory a été enregistré dans le conteneur, les autres beans similaires ne seront pas chargés et enregistrés. Pour faire simple, ajoutez l'annotation @ConditionalOnMissingBean({RedisConnectionFactory. class}), une seule des annotations. deux peuvent être chargés et enregistrés dans le conteneur, et l'autre ne sera pas chargé et enregistré à nouveau.

La question se pose alors : qui sera inscrit en premier ?

Cela revient à la phrase mentionnée ci-dessus, l'ordre dans la phrase @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class}) est critique devant, ce qui signifie que LettuceConnectionConfiguration sera enregistrée.

On peut voir que Springboot utilise lettuce pour se connecter à Redis par défaut.

Lorsque nous introduisons le package de dépendance spring-boot-starter-data-redis, cela équivaut en fait à l'introduction du package lettuce. À ce stade, le pilote lettuce sera utilisé si vous ne souhaitez pas utiliser le pilote lettuce par défaut. , vous pouvez directement exclure la dépendance à la laitue.

  1   2 @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})  3

Puis introduisez la dépendance jedis——

  1 //LettuceConnectionConfiguration  2 @ConditionalOnClass({RedisClient.class})  3 class LettuceConnectionConfiguration extends RedisConnectionConfiguration {  4    ......省略  5     @Bean  6     @ConditionalOnMissingBean({RedisConnectionFactory.class})  7     LettuceConnectionFactory redisConnectionFactory(ObjectProvider<LettuceClientConfigurationBuilderCustomizer> builderCustomizers, ClientResources clientResources) throws UnknownHostException {  8         LettuceClientConfiguration clientConfig = this.getLettuceClientConfiguration(builderCustomizers, clientResources, this.getProperties().getLettuce().getPool());  9         return this.createLettuceConnectionFactory(clientConfig); 10    } 11 } 12 //JedisConnectionConfiguration 13 @ConditionalOnClass({GenericObjectPool.class, JedisConnection.class, Jedis.class}) 14 class JedisConnectionConfiguration extends RedisConnectionConfiguration { 15    ......省略 16     @Bean 17     @ConditionalOnMissingBean({RedisConnectionFactory.class}) 18     JedisConnectionFactory redisConnectionFactory(ObjectProvider<JedisClientConfigurationBuilderCustomizer> builderCustomizers) throws UnknownHostException { 19         return this.createJedisConnectionFactory(builderCustomizers); 20    } 21 } 22

De cette façon, lors de l'importation de l'annotation de RedisAutoConfiguration, parce que la dépendance lettuce n'est pas trouvée, cette annotation @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class}) est le second, JedisConnectionConfiguration à l'emplacement, est valide et peut être enregistré dans le conteneur en tant que pilote permettant à Springboot d'exploiter Redis.

Quelle est la différence entre la laitue et les jedis ? lettuce : La couche inférieure est implémentée dans netty, thread-safe et n'a qu'une seule instance par défaut.

jedis : Peut être directement connecté au serveur redis et utilisé avec le pool de connexions pour augmenter les connexions physiques.

Trouvez la méthode d'erreur en fonction de l'invite d'exception. Dans le code suivant, LettuceConverters.toBoolean(this.getConnection().zadd(key, score, value))——

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4     <exclusions>  5         <exclusion>  6             <groupId>io.lettuce</groupId>  7             <artifactId>lettuce-core</artifactId>  8         </exclusion>  9     </exclusions> 10 </dependency>

LettuceConverters.toBoolean() doit convertir long C'est un booléen. Dans des circonstances normales, this.getConnection().zadd(key, score, value) renverra 1 si l'ajout est réussi, donc LettuceConverters.toBoolean(1) deviendra vrai au contraire. échoue, puis il renvoie 0, c'est-à-dire LettuceConverters.toBoolean(0). Il existe également un troisième cas, c'est-à-dire qu'une exception se produit dans la méthode this.getConnection().zadd(key, score, value). une exception se produira-t-elle ?

Cela devrait être le cas lorsque la connexion échoue.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!