java - 连接特定组件字段类型的特定子类(@SpringBootApplication 和 @Autowire)

Question

我有一个带有 Autowiring 功能的简单 Spring 应用程序 AppMain，我不想在其中使用任何显式 XML 配置。

在我的 TaskScheduler 组件中，我想将 ThreadPoolTask​​Executor 对象连接到父类(super class)类型的 taskExecutor 字段。在 Spring 中使用 XML 来实现这一点很简单。

但是 Autowiring 和基于纯注释的配置是否可能？如何做到这一点？

AppMain

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class AppMain {
    public static void main(String[] args) {
        SpringApplication app = new SpringApplication(AppMain.class);
        app.run(args);
    }
}

任务调度

import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Component;
import org.springframework.beans.factory.annotation.Autowired;

@Component
public class TaskScheduler {

    @Autowired 
    private final TaskExecutor taskExecutor;

    @Scheduled(fixedDelay = 1000)
    public void checkConfiguration() {
        // TODO: do some business with task executor (expecting it to be ThreadPoolTaskExecutor in runtime)
    }

}

Answer 1

如果我正确地理解了您的问题，那么当您需要为 TaskExecutor 连接时，您需要一个特定的实现 (ThreadPoolTask​​Executor)。

在这种情况下，您需要创建一个配置类，其中包含一个 spring bean，用于构建 ThreadPoolTask​​Executor，然后将配置导入到主应用程序中。

    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.task.TaskExecutor;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

    @Configuration
    public class AppConfiguration {

        @Bean
        public TaskExecutor taskExecutor() {
            return new ThreadPoolTaskExecutor();
        }
    }

然后像这样修改你的主类:

import org.springframework.boot.SpringApplication;
import org.springframework.context.annotation.Import;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
@Import(AppConfiguration.class)
public class AppMain {
    public static void main(String[] args) {
        SpringApplication app = new SpringApplication(AppMain.class);
        app.run(args);
    }
}