混合Spring集成和Spring调度器

Question

我们正在混合Spring集成和Spring引导的调度功能，使用：

@SpringBootApplication
@EnableIntegration
@IntegrationComponentScan
@EnableConfigurationProperties
@EnableScheduling
public class MyApplication {
...
}

@EnableScheduling创建一个名为“taskScheduler”的bean，然后由spring集成使用：

public abstract class IntegrationContextUtils {
  public static final String TASK_SCHEDULER_BEAN_NAME = "taskScheduler";
  ...
}

private void registerTaskScheduler() {
  if (!this.beanFactory.containsBean(IntegrationContextUtils.TASK_SCHEDULER_BEAN_NAME)) {
    ...
    this.registry.registerBeanDefinition(IntegrationContextUtils.TASK_SCHEDULER_BEAN_NAME, scheduler);
  }
}

问题是，Spring集成的默认 poolSize 是 10（当我们遇到饥饿时需要这个值），而 spring-boot 的默认值是 1（我们还需要避免在计划进程中并发）。

问题：

• 对于 spring-integration 来说，共享他的任务调度程序 Bean 与 spring-boot 调度功能是正常行为吗？
• 有没有办法为 Spring 集成指定一个唯一的任务调度程序，无论是否启用了引导中的调度？

感谢您的回答

Answer 1

行为和逻辑是正确的。从 Spring 启动的角度来看，配置约定的期望也是正确的。只是你错过的@EnableScheduling不是 Spring Boot 功能，而是 Spring Framework 原生的：https://docs.spring.io/spring-framework/docs/current/reference/html/integration.html#scheduling。Spring Boot 只是给了我们额外的配置自由度，在这个问题上有一些豆子。因此，我们只需要依靠其自动配置。

如果自动配置不符合您的要求，您可以随时提供自己的配置并在必要时进行覆盖。

看看 Spring Boot 中的@EnableScheduling、它的@Scheduled钩子和适当的 TaskSchedulingAutoConfiguration，要同时覆盖任何你想让 Spring 集成快乐的东西并不容易。因此，我们应该采取相反的方向，真正覆盖Spring Integrationendpoint的调度程序。使用轮询器的每个地方，您还需要配置自定义调度程序，而不是自动配置的调度程序。