如何在SpringBoot 2.1.2中启用ExecutorServiceMetrics？

Question

如何启用此处列出的ExecutorServiceMetrics？

https://github.com/micrometer-metrics/micrometer/blob/master/micrometer-core/src/main/java/io/micrometer/core/instrument/binder/jvm/ExecutorServiceMetrics.java

SpringBoot版本：2.1.2。释放

在/actuator/metrics下，我可以看到jvm和其他一些机箱外自动配置的指标，但看不到执行器指标。

我试过设置这个，但没有运气。

management:
  metrics:
    enable.executor: true

感谢任何帮助。

Answer 1

以下是我（在kotlin）解决这个问题的方法：

@EnableAsync
@Configuration
class AsyncConfig(
        private val taskExecutorBuilder: TaskExecutorBuilder,
        private val meterRegistry: MeterRegistry) : AsyncConfigurer {

    /**
     * Add monitoring of executor using micrometer.
     */
    override fun getAsyncExecutor(): Executor {
        // create executor based on default spring-boot properties
        val executor = taskExecutorBuilder.build()
        // we need to initialize it before calling monitor
        executor.initialize()
        // monitor the executor (so it is available in metrics) (must be wrapped)
        return ExecutorServiceMetrics.monitor(meterRegistry, executor.threadPoolExecutor, "AsyncExecutor", "async")
    }

}

所以基本上：

• 利用自动连线的TaskExecutorBuilder，根据Spring构建执行器。任务执行* 属性

请注意，要做到这一点，您必须归还装饰的遗嘱执行人！

在此示例中，由于我给出了前缀（async），因此可用的指标是：

• 异步。遗嘱执行人
• 异步。遗嘱执行人。活动
• 异步。遗嘱执行人。已完成
• 异步。遗嘱执行人。空闲
• 异步。遗嘱执行人。水塘核心
• 异步。遗嘱执行人。水塘最大值
• 异步。遗嘱执行人。水塘尺寸
• 异步。遗嘱执行人。队列剩余
• 异步。遗嘱执行人。已排队

Answer 2

我发现如果你想用Spring Boot锁定它，你必须手动操作。我使用的是Spring Boot 2.2.9。释放。

创建一个ExecutorServiceMetrics bean，使用应用程序任务执行器bean（这样，您就可以获得之前配置的任何bean大小）。它会自动绑定。

像这样的东西：

@Bean
@ConditionalOnMissingBean
public ExecutorServiceMetrics executorServiceMetrics(@Qualifier("applicationTaskExecutor") ThreadPoolTaskExecutor applicationTaskExecutor) {
    return new ExecutorServiceMetrics(applicationTaskExecutor.getThreadPoolExecutor(), "applicationTaskExecutor",
            Collections.emptyList());
}

Answer 3

我能够在Spring Boot 2.1.2中获得ExecutorServiceMetrics报告指标。发布应用程序，只需创建一个受监控的ExecutorServicebean。我不需要在我的应用程序中添加任何内容。yml或应用程序。属性来实现此功能。

例子：

@Configuration
public class ExecutorConfig {

    @Bean
    public ExecutorService executorService(final MeterRegistry registry) {
        return ExecutorServiceMetrics.monitor(registry, Executors.newFixedThreadPool(20), "my executor", Tags.of("key", "value"));
    }
}

然后，只需将您的executorService连接到您的组件中，并将任务提交给该executorService。