Spring框架中TaskExecutor类型Bean冲突导致的自动注入失败问题的解决步骤

Caused by: org.springframework.beans.factory.NoUniqueBeanDefinitionException: 
No qualifying bean of type 'org.springframework.core.task.TaskExecutor' available: 
expected single matching bean but found 3: applicationTaskExecutor, applicationTaskExecutor, taskScheduler

ERROR 12345 --- [           main] o.s.b.SpringApplication                  : Application run failed

org.springframework.beans.factory.BeanCreationException: 
Error creating bean with name 'myService': Injection of resource dependencies failed; 
nested exception is org.springframework.beans.factory.NoUniqueBeanDefinitionException: 
No qualifying bean of type 'org.springframework.core.task.TaskExecutor' available: 
expected single matching bean but found 3: applicationTaskExecutor, applicationTaskExecutor, taskScheduler

@Configuration
public class TaskExecutorConfig {
    @Bean
    public TaskExecutor applicationTaskExecutor() {
        return new ThreadPoolTaskExecutor();
    }

    @Bean
    public TaskExecutor applicationTaskExecutor() {
        return new ConcurrentTaskExecutor(Executors.newFixedThreadPool(5));
    }

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

@Service
public class MyService {
    @Autowired
    private TaskExecutor taskExecutor;
}

logging.level.org.springframework=DEBUG

@Service
public class MyService {
    @Autowired
    @Qualifier("applicationTaskExecutor")
    private TaskExecutor taskExecutor;
}

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

@Bean("customTaskExecutor")
public TaskExecutor customTaskExecutor() {
    return new ConcurrentTaskExecutor(Executors.newFixedThreadPool(5));
}

spring.task.execution.pool.core-size=0

@SpringBootApplication(exclude = TaskExecutionAutoConfiguration.class)
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

public class TaskExecutorFactory {
    public static TaskExecutor createExecutor(String type) {
        switch (type) {
            case "threadPool":
                return new ThreadPoolTaskExecutor();
            case "concurrent":
                return new ConcurrentTaskExecutor(Executors.newFixedThreadPool(5));
            default:
                throw new IllegalArgumentException("Unknown executor type");
        }
    }
}

@Service
public class TaskExecutorStrategy {
    @Autowired
    @Qualifier("threadPoolExecutor")
    private TaskExecutor threadPoolExecutor;

    @Autowired
    @Qualifier("concurrentExecutor")
    private TaskExecutor concurrentExecutor;

    public TaskExecutor chooseExecutor(String taskType) {
        if ("heavy".equals(taskType)) {
            return threadPoolExecutor;
        } else {
            return concurrentExecutor;
        }
    }
}

@Autowired
public void setTaskExecutor(@Qualifier("applicationTaskExecutor") TaskExecutor taskExecutor) {
    if (taskExecutor == null) {
        throw new IllegalStateException("TaskExecutor must not be null");
    }
    this.taskExecutor = taskExecutor;
}

management:
  endpoints:
    web:
      exposure:
        include: health

@SpringBootTest
public class MyServiceTest {
    @Autowired
    private MyService myService;

    @Test
    public void testTaskExecutorInjection() {
        assertNotNull(myService.getTaskExecutor());
        assertEquals(ThreadPoolTaskExecutor.class, myService.getTaskExecutor().getClass());
    }
}

@SpringBootTest
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
public class TaskExecutorIntegrationTest {
    @Autowired
    private ApplicationContext context;

    @Test
    public void testBeanNames() {
        String[] beanNames = context.getBeanNamesForType(TaskExecutor.class);
        assertEquals(1, beanNames.length); // 确保只有一个Bean被注册
    }
}