在Spring Boot IntegrationTest上禁用

Question

如何在Spring Boot IntegrationTest上禁用计划自动启动？

谢了。

Answer 1

请注意，外部组件可能会自动启用调度（请参见Spring框架中的HystrixStreamAutoConfiguration和MetricExportAutoConfiguration）。因此，如果您尝试在指定@enablescheduling的@conditionalonproperty或@profile类上使用@conditionalproperty，那么由于外部组件的原因，无论如何都会启用调度。

有一个@configuration类，通过@enablescheduling启用调度，但要将调度的作业放在单独的类中，每个类都使用@conditionalonproperty启用/禁用包含@调度任务的类。

不要在同一个类中使用@schedured和@enablescheduling，否则会出现外部组件无论如何都在启用它的问题，因此忽略@conditionalonproperty。

例如：

@Configuration
@EnableScheduling
public class MyApplicationSchedulingConfiguration {
}

然后在另一堂课上

@Named
@ConditionalOnProperty(value = "scheduling.enabled", havingValue = "true", matchIfMissing = false)
public class MyApplicationScheduledTasks {

  @Scheduled(fixedRate = 60 * 60 * 1000)
  public void runSomeTaskHourly() {
    doStuff();
  }
}

public class ConditionalThreadPoolTaskScheduler extends ThreadPoolTaskScheduler {

  @Inject
  private Environment environment;

  // Override the TaskScheduler methods
  @Override
  public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {
    if (!canRun()) {
      return null;
    }
    return super.schedule(task, trigger);
  }

  @Override
  public ScheduledFuture<?> schedule(Runnable task, Date startTime) {
    if (!canRun()) {
      return null;
    }
    return super.schedule(task, startTime);
  }

  @Override
  public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, Date startTime, long period) {
    if (!canRun()) {
      return null;
    }
    return super.scheduleAtFixedRate(task, startTime, period);
  }

  @Override
  public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, long period) {
    if (!canRun()) {
      return null;
    }
    return super.scheduleAtFixedRate(task, period);
  }

  @Override
  public ScheduledFuture<?> scheduleWithFixedDelay(Runnable task, Date startTime, long delay) {
    if (!canRun()) {
      return null;
    }
    return super.scheduleWithFixedDelay(task, startTime, delay);
  }

  @Override
  public ScheduledFuture<?> scheduleWithFixedDelay(Runnable task, long delay) {
    if (!canRun()) {
      return null;
    }
    return super.scheduleWithFixedDelay(task, delay);
  }

  private boolean canRun() {
    if (environment == null) {
      return false;
    }

    if (!Boolean.valueOf(environment.getProperty("scheduling.enabled"))) {
      return false;
    }

    return true;
  }
}

配置类，使用自定义调度器创建taskScheduler bean，并启用调度

@Configuration
@EnableScheduling
public class MyApplicationSchedulingConfiguration {

  @Bean
  public TaskScheduler taskScheduler() {
    return new ConditionalThreadPoolTaskScheduler();
  }
}

上面的潜在问题是，您已经创建了一个内部Spring类的依赖项，因此如果将来有更改，您必须修复兼容性。