如何在Spring Boot中防止像Redis服务器这样的外部连接故障fail fast？

Question

spring.cloud.config.fail-fast=true

您可以通过关闭Redis服务器来使用我为我的问题创建的这个项目来重现。

下面是我的代码的样子-

@Lazy
@Configuration
public class RedisConfiguration {
    @Value("${spring.redis.sentinel.master}")
    private String SENTINEL_MASTER;

    @Value("${spring.redis.sentinel.nodes}")
    private String SENTINEL_NODES;

    @Value("${spring.redis.security.enabled:false}")
    private boolean REDIS_SECURITY_ENABLED;

    @Value("${spring.redis.security.password:}")
    private String REDIS_PASSWORD;

    @Lazy
    @Bean // somehow this always gets initialized
    public RedisConnectionFactory jedisConnectionFactory() { 
        // create set of sentinel nodes
        System.out.println(SENTINEL_NODES);
        Set<String> sentinelNodesSet = new HashSet<>(5);
        StringTokenizer st = new StringTokenizer(SENTINEL_NODES, ",");
        while (st.hasMoreTokens())
            sentinelNodesSet.add(st.nextToken());
        RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration(SENTINEL_MASTER, sentinelNodesSet);
        if (REDIS_SECURITY_ENABLED) {
            sentinelConfig.setPassword(REDIS_PASSWORD);
        }
        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(sentinelConfig);
        return jedisConnectionFactory;
    }

下面是异常跟踪-

简而言之：

1. @lazy注释适用于RedisstandalOneConfiguration而不适用RedissentinelConfiguration,不确定原因吗？
2. 使用@lazy注释是有风险的，因为您需要确保使用redis的所有服务都是懒散加载的。
3. 正在查找为spring Cloud提供的类似spring.cloud.config.fail-fast=true的解决方案。

更新：

Answer 1

在hood下，Spring Cloud Config使用spring-retry和AOP(spring-boot-starter-aop)配置重试机制。

此过程在ConfigServiceBootstrapConfiguration中实现。

守则的有关部分如下：

/* @ConditionalOnProperty("spring.cloud.config.fail-fast") */
@ConditionalOnClass({ Retryable.class, Aspect.class, AopAutoConfiguration.class })
@Configuration(proxyBeanMethods = false)
@EnableRetry(proxyTargetClass = true)
@Import(AopAutoConfiguration.class)
@EnableConfigurationProperties(RetryProperties.class)
protected static class RetryConfiguration {

  @Bean
  @ConditionalOnMissingBean(name = "configServerRetryInterceptor")
  public RetryOperationsInterceptor configServerRetryInterceptor(
      RetryProperties properties) {
    return RetryInterceptorBuilder.stateless()
        .backOffOptions(properties.getInitialInterval(),
            properties.getMultiplier(), properties.getMaxInterval())
        .maxAttempts(properties.getMaxAttempts()).build();
  }

}

正如您所看到的，基本思想是提供一个RetryConfiguration，它在认为应用程序失败之前处理一定数量的重试。

Spring Cloud Client的文档提供了更多关于用于配置该机制的不同属性的信息。您还可以在RetryProperties类的源代码中看到默认值。

请尝试将两个必需的依赖项spring-retry和spring-boot-starter-aop以及retryconfiguration作为主配置的子项，为重试机制的配置属性提供一些合理的默认值，然后看看会发生什么。

您可以将解决方案推向极限，并尝试在非常多的场合重新连接，也许增加它们之间的抑扬顿挫，等待服务器可用。

我认为@lazy注释不再是必需的，可以安全地删除。

编辑

查看错误堆栈跟踪，您还可以尝试禁用字符串引导Redis自动配置类。

@SpringBootApplication(
  exclude = { RedisAutoConfiguration.class, RedisRepositoriesAutoConfiguration.class }
)

spring.autoconfigure.exclude= \
org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration, \
org.springframework.boot.autoconfigure.data.redis.RedisRepositoriesAutoConfiguration

您还可以使用此属性禁用Redis存储库配置：

spring.data.redis.repositories.enabled: false

一旦您禁用了Redis自动配置，您将可以自由地实例化redistemplate或您认为合适时与Redis交互所需的东西。

例如，当实际需要时，您可以按需初始化它，尝试通过初始化所有所需的工厂来建立到Redis的连接。您可以使用try和catch包围初始化Redis连接所需的逻辑，并且只有在连接可用时才初始化Redistemplate（如下所示）。

public RedisConnectionFactory jedisConnectionFactory() { 
    try {
      // create set of sentinel nodes
      System.out.println(SENTINEL_NODES);
      Set<String> sentinelNodesSet = new HashSet<>(5);
      StringTokenizer st = new StringTokenizer(SENTINEL_NODES, ",");
      while (st.hasMoreTokens())
          sentinelNodesSet.add(st.nextToken());
      RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration(SENTINEL_MASTER, sentinelNodesSet);
      if (REDIS_SECURITY_ENABLED) {
          sentinelConfig.setPassword(REDIS_PASSWORD);
      }
      JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(sentinelConfig);
      return jedisConnectionFactory;
    } catch (redis.clients.jedis.exceptions.JedisConnectionException re) {
      logger.error("Unable to initialize Redis connection factory", re);
      return null;
    }
}

另一方面：

public RedisTemplate getRedisTemplate() {
  // We can assume that both methods are defined in the same class, 
  // although it is not necessary
  final RedisConnectionFactory redisConnectionFactory = this.jedisConnectionFactory();
  if (redisConnectionFactory == null) {
    return null;
  }

  final RedisTemplate redisTemplate = new StringRedisTemplate(redisConnectionFactory);
  return redisTemplate;
}

您可以以您认为合适的方式使用这个redistemplate，当然，还可以根据需要缓存和重用它。

这些方法可以在为此任务创建的服务或帮助器类中定义，当然，不能在您的配置类中定义。