调用计划任务时出错，实例化[io.micronaut.configuration.lettuce.health.RedisHealthIndicator]类型的bean时出错

问题描述

运行此计划时，我遇到以下问题。

@Singleton
public class TaskScheduler {

    private static final Logger LOG = LoggerFactory.getLogger(TaskScheduler.class);

    @Inject
    private BuildLayerJob buildLayerJob;

    @Scheduled(fixedDelay = "30s",initialDelay = "30s")
    public void loadRegistriesDescriptions(){
        try {
            LOG.info("Cargando lista de registries cada 30s.");
            buildLayerJob.getBuildLayer().loadRegistries();
        }
        catch(Exception exception) {
            LOG.error("Error cargando lista de registries cada 30s: " +exception.getMessage());
            //exception.printstacktrace();
        }
    }
}

第一次执行没有问题，但是当时间到期并再次执行时，会引发以下错误。

20:26:59.291 [pool-1-thread-6] ERROR i.m.s.DefaultTaskExceptionHandler - Error invoking scheduled task Error instantiating bean of type  [io.micronaut.configuration.lettuce.health.RedisHealthindicator]

    Message: Unable to connect to localhost:6379
    Path Taken: new HealthMonitorTask(CurrentHealthStatus currentHealthStatus,[List healthindicators]) --> new RedisHealthindicator(BeanContext beanContext,HealthAggregator healthAggregator,[StatefulRedisConnection[] connections])
    io.micronaut.context.exceptions.BeanInstantiationException: Error instantiating bean of type  [io.micronaut.configuration.lettuce.health.RedisHealthindicator]
    
    Message: Unable to connect to localhost:6379
    Path Taken: new HealthMonitorTask(CurrentHealthStatus currentHealthStatus,[StatefulRedisConnection[] connections])
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:1719)
        at io.micronaut.context.DefaultBeanContext.addCandidatetoList(DefaultBeanContext.java:2727)
        at io.micronaut.context.DefaultBeanContext.getBeansOfTypeInternal(DefaultBeanContext.java:2639)
        at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:924)
        at io.micronaut.context.AbstractBeanDeFinition.lambda$getBeansOfTypeForconstructorargument$9(AbstractBeanDeFinition.java:1124)
        at io.micronaut.context.AbstractBeanDeFinition.resolveBeanWithGenericsFromconstructorargument(AbstractBeanDeFinition.java:1762)
        at io.micronaut.context.AbstractBeanDeFinition.getBeansOfTypeForconstructorargument(AbstractBeanDeFinition.java:1119)
        at io.micronaut.context.AbstractBeanDeFinition.getBeanForconstructorargument(AbstractBeanDeFinition.java:981)
        at io.micronaut.configuration.lettuce.health.$RedisHealthindicatorDeFinition.build(UnkNown Source)
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:1693)
        at io.micronaut.context.DefaultBeanContext.addCandidatetoList(DefaultBeanContext.java:2727)
        at io.micronaut.context.DefaultBeanContext.getBeansOfTypeInternal(DefaultBeanContext.java:2639)
        at io.micronaut.context.DefaultBeanContext.getBeansOfType(DefaultBeanContext.java:924)
        at io.micronaut.context.AbstractBeanDeFinition.lambda$getBeansOfTypeForconstructorargument$9(AbstractBeanDeFinition.java:1124)
        at io.micronaut.context.AbstractBeanDeFinition.resolveBeanWithGenericsFromconstructorargument(AbstractBeanDeFinition.java:1762)
        at io.micronaut.context.AbstractBeanDeFinition.getBeansOfTypeForconstructorargument(AbstractBeanDeFinition.java:1119)
        at io.micronaut.context.AbstractBeanDeFinition.getBeanForconstructorargument(AbstractBeanDeFinition.java:984)
        at io.micronaut.management.health.monitor.$HealthMonitorTaskDeFinition.build(UnkNown Source)
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:1693)
        at io.micronaut.context.DefaultBeanContext.createAndRegisterSingletonInternal(DefaultBeanContext.java:2407)
        at io.micronaut.context.DefaultBeanContext.createAndRegisterSingleton(DefaultBeanContext.java:2393)
        at io.micronaut.context.DefaultBeanContext.getBeanForDeFinition(DefaultBeanContext.java:2084)
        at io.micronaut.context.DefaultBeanContext.getBeanInternal(DefaultBeanContext.java:2058)
        at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:618)
        at io.micronaut.scheduling.processor.ScheduledMethodProcessor.lambda$process$5(ScheduledMethodProcessor.java:123)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.runAndReset$$$capture(FutureTask.java:305)
        at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:834)
    Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to localhost:6379
        at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
        at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
        at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:234)
        at io.lettuce.core.RedisClient.connect(RedisClient.java:207)
        at io.lettuce.core.RedisClient.connect(RedisClient.java:192)
        at io.micronaut.configuration.lettuce.AbstractRedisClientFactory.redisConnection(AbstractRedisClientFactory.java:51)
        at io.micronaut.configuration.lettuce.DefaultRedisClientFactory.redisConnection(DefaultRedisClientFactory.java:52)
        at io.micronaut.configuration.lettuce.$DefaultRedisClientFactory$RedisConnection1DeFinition.build(UnkNown Source)
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:1693)
        ... 31 common frames omitted
    Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:6379
    Caused by: java.net.ConnectException: Connection refused
        at java.base/sun.nio.ch.socketChannelImpl.checkConnect(Native Method)
        at java.base/sun.nio.ch.socketChannelImpl.finishConnect(SocketChannelImpl.java:779)
        at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:330)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNIoUnsafe.finishConnect(AbstractNioChannel.java:334)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:702)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:834)

我知道与Redis的连接存在问题，但是在GCP中部署的微服务中，它继续产生相同的问题。

app.yaml

runtime:    java11
service:    default
instance_class: B2

env_variables:
  LAYERS_SERVER_PORT: 8080
  REdis_FIXEDDELAY: 1s
  REdisA_URL: "redis://A"
  REdisB_URL: "redis://B"
  REdisC_URL: "redis://C"
  REdisD_URL: "redis://D"

basic_scaling:
  max_instances: 1
  idle_timeout: 270s
vpc_access_connector:
  name: "projects/example/locations/us-central1/connectors/example"

本地设置。 application.yml：

micronaut:
  application:
    name: example
  server:
    port: ${EXAMPLE_SERVER_PORT:3000}
    cors:
      enabled: true
---
redis:
  servers:
    REdisA:
      uri: redis://IP_A
    REdisB:
      uri: redis://IP_B
    REdisC:
      uri: redis://IP_C
    REdisD:
      uri: redis://IP_D

存储库layers.server.repo.InfoRepositoryImpl：

@Singleton
public class InfoRepositoryImpl implements InfoRepository {

    private BuildLayerJob buildLayerJob;

    @Inject @Named("REdisB")  RedisAsyncCommands<String,String> reddisConnectionB;
    @Inject @Named("REdisA")  RedisAsyncCommands<String,String> reddisConnectionA;

private static final Logger LOG = LoggerFactory.getLogger(InfoRepositoryImpl.class);

    public InfoRepositoryImpl(BuildLayerJob buildLayerJob) {
        this.buildLayerJob = buildLayerJob;
    }

... implementation of methods to process information with redis

 }

解决方法

自动配置所述数据源时，可能会发生此类错误。如果未在应用程序中使用Redis自动配置，则可以禁用它。如果您需要该应用程序的Redis，则应设置spring.redis.host和spring.redis.port。

能否请您检查是否已将io.micronaut.redis:micronaut-redis-lettuce依赖项添加到类路径/构建文件中。

默认情况下，Micronaut将假定redis服务器位于localhost：6379，因为在激活redis-lettuce时，默认情况下会启用运行状况检查。它将继续进行健康检查。

如果您使用的是micronaut application.yml，则需要提供可从正在运行的应用程序访问的服务器URL。

Micronaut redis

示例-application.yml

redis:
    uri: redis://localhost
    ssl: true
    timeout: 30s

您还可以使用下面的连接字符串模式来提供有关Redis服务器的详细信息。

Redis Standalone

redis：//：// [[用户名：]密码@]主机[：端口] [/数据库] [？ [timeout = timeout [d | h | m | s | ms | us | ns]] [＆_database = database _]]

Redis Standalone（SSL）

rediss：// [[用户名：]密码@]主机[：端口] [/数据库] [？ [timeout = timeout [d | h | m | s | ms | us | ns]] [＆_database = database _]]

Redis Standalone（Unix域套接字）

redis-socket：// [[用户名：]密码@]路径 [？[timeout = timeout [d | h | m | s | ms | us | ns]] [＆_ database = database _]]

有关连接字符串的更多详细信息-Redis connections string

Micronaut redis configuration properties

google-cloud-platform java java micronaut redis redis spring spring