Reactor的Schedulers.enableMetrics()弃用后，Spring Boot中如何实现调度器计量？

原来的Schedulers.enableMetrics()已被弃用，官方推荐使用timedScheduler结合Micrometer实现调度器任务的计量，在Spring Boot中可以通过以下步骤快速落地：

1. 确保依赖就绪 #

你的项目需要引入这些核心依赖（Maven示例）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-core</artifactId>
</dependency>
<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-core</artifactId>
    <version>3.4.0+</version> <!-- 需确保版本支持timedScheduler API -->
</dependency>

2. 全局配置调度器计量钩子 #

通过Reactor的Schedulers.onScheduleHook可以为所有调度器统一添加计量逻辑，无需修改业务代码：

创建Spring配置类：

import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Timer;
import reactor.core.scheduler.Schedulers;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;

@Configuration
public class SchedulerMetricsConfig {

    private final MeterRegistry meterRegistry;

    // 依赖注入Spring Boot自动配置的MeterRegistry
    public SchedulerMetricsConfig(MeterRegistry meterRegistry) {
        this.meterRegistry = meterRegistry;
    }

    @PostConstruct
    public void setupSchedulerMetrics() {
        // 注册全局钩子，为每个调度任务添加计时
        Schedulers.onScheduleHook("micrometer-scheduler-timer", runnable -> {
            String schedulerName = Schedulers.currentSchedulerName();
            // 构建Timer，标签区分不同调度器
            Timer timer = Timer.builder("reactor.scheduler.task.execution.duration")
                    .tag("scheduler_name", schedulerName)
                    .register(meterRegistry);
            return timer.wrap(runnable);
        });
    }
}

3. 验证计量数据 #

启动应用后，访问Actuator的metrics端点（默认路径/actuator/metrics/reactor.scheduler.task.execution.duration），就能看到所有调度器的任务执行统计，包括总调用数、平均时长、分位数等指标。

可选：单独计量特定调度器 #

如果不需要全局覆盖，只想给某个特定调度器添加计量，可以直接用Schedulers.timedScheduler()包装：

import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Tags;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;

// 在业务代码或配置类中创建带计量的调度器
Scheduler timedParallelScheduler = Schedulers.timedScheduler(
        Schedulers.parallel(),
        meterRegistry,
        "reactor.scheduler.parallel.task.duration",
        Tags.of("scheduler", "custom-parallel")
);

// 使用该调度器执行任务
Mono.just("sample-data")
    .publishOn(timedParallelScheduler)
    .subscribe(result -> System.out.println("处理结果：" + result));

这种方式完全兼容Spring Boot的监控体系，计量数据会自动同步到Prometheus、Graphite等监控系统（如果配置了对应的Micrometer导出器）。

内容的提问来源于stack exchange，提问作者pixel