调用调度任务时出错示例化[io.micronaut.configuration.莴苣.health.redishealthindicator]类型的bean时出错

zdwk9cvp  于 2021-06-09  发布在  Redis
关注(0)|答案(2)|浏览(397)

运行此计划时出现以下问题。

@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,[List healthIndicators]) --> new RedisHealthIndicator(BeanContext beanContext,HealthAggregator healthAggregator,[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中部署的微服务中，它继续产生同样的问题。
附录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"

本地设置。应用程序.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

存储库层.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

 }
Javaredisspringgoogle-cloud-platformmicronaut

2条答案

按热度按时间
0md85ypi

0md85ypi1#

当所述数据源被自动配置时，这种错误可能发生。如果应用程序中没有使用redis自动配置，则可以禁用它。如果应用程序需要redis，那么应该设置 spring.redis.host 以及 spring.redis.port .

赞(0）分享  回复(0）举报  2021-06-09
k75qkfdt

k75qkfdt2#

你能检查一下你有没有 io.micronaut.redis:micronaut-redis-lettuce 已将依赖项添加到类路径/生成文件中。
默认情况下，micronaut将假定redis服务器处于localhost:6379，因为在激活redis时默认启用运行状况检查。它将继续探测健康检查。
如果您使用的是micronaut application.yml，则需要提供可从运行的应用程序访问的服务器url。
micronaut redis公司
示例-application.yml

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

您还可以使用下面的连接字符串模式来提供有关redis服务器的详细信息。
redis单机版
redis://[[用户名：]密码@]主机：端口][/数据库][[timeout=timeout[d | h | m | s | ms | us | ns]][&u database=database |]]
redis单机版（ssl）
redis://[[用户名：]密码@]主机：端口][/数据库][[timeout=timeout[d | h | m | s | ms | us | ns]][&u database=database |]]
redis独立（unix域套接字）
redis socket://[[username:]password@]路径[？[timeout=timeout[d | h | m | s | ms | us | ns]][&| u database=database |]]
有关连接字符串的详细信息，请参阅redis connections string
micronaut redis配置属性

赞(0）分享  回复(0）举报  2021-06-09
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com