@Async Could not find unique TaskExecutor bean; NoUniqueBeanDefinitionException;

- 日理万妓 2023-06-28 06:23 5阅读 0赞

异步任务，项目启动或接口调用，控制台报错：Could not find unique TaskExecutor bean;

或者报错：org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type 'org.springframework.core.task.TaskExecutor' available: expected single matching bean but found 2: applicationTaskExecutor,taskScheduler

原因为：@Async所注解的方法存在相同的方法名，或者同一个异步任务被多个任务同时调用

解决方法：

1、将@Async所注解的方法名修改为不同的方法名

2、增加异步任务配置类：

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
    import org.springframework.context.annotation.ComponentScan;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.AsyncConfigurer;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    import java.util.concurrent.Executor;
    
    /**
     * @description 异步任务配置类，为防止异步任务如下错误：
     * No qualifying bean of type 'org.springframework.core.task.TaskExecutor' available:
     * expected single matching bean but found 2: applicationTaskExecutor,taskScheduler
     * @author: chenping
     * @create: 2020-01-17
     **/
    @Configuration
    @ComponentScan("cn.com.*.*.*.service")//异步任务所在的包
    @EnableAsync //开启异步任务支持
    public class TaskExecutorConfig implements AsyncConfigurer {
    
        /**
         * @description:  实现AsyncConfigurer接口并重写getAsyncExecutor方法，
         *  并返回一个ThreadPoolTaskExecutor，这样我们就获得了一个基于线程池TaskExecutor
         * @param:
         * @return: java.util.concurrent.Executor
         * @author: chenping
         * @date: 2020/1/17
         **/
        @Override
        public Executor getAsyncExecutor() {
            ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
            taskExecutor.setCorePoolSize(10);
            taskExecutor.setMaxPoolSize(80);
            taskExecutor.setQueueCapacity(100);
            taskExecutor.initialize();
            return taskExecutor;
        }
    
        @Override
        public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
            return null;
        }
    }