Spring @Async не работает

Ответ 1

С помощью этого отличного ответа Райана Стюарта я смог понять это (по крайней мере, для моей конкретной проблемы).

Вкратце, контекст, загруженный ContextLoaderListener (обычно из applicationContext.xml), является родителем контекста, загружаемого DispatcherServlet (обычно из *-servlet.xml). Если у вас есть bean с объявленным/компонентным сканированием @Async в обоих контекстах, версия из дочернего контекста (DispatcherServlet) переопределит версию в родительском контексте (ContextLoaderListener). Я проверил это, исключив этот компонент из сканирования компонентов в *-servlet.xml - теперь он работает так, как ожидалось.

Ответ 2

Для меня решение заключалось в том, чтобы добавить @EnableAsync в мой аннотированный класс @Configuration:

@Configuration
@ComponentScan("bla.package")
@EnableAsync
public class BlaConfiguration {

}

Теперь класс в пакете bla.package, у которого есть @Async аннотированные методы, действительно может быть вызван асинхронно.

Ответ 3

• Попробуйте добавить proxy-target-class="true" ко всем <*:annotation-driven/> элементам, которые поддерживают этот атрибут.
• Проверьте, является ли ваш метод аннотированным с помощью @Async общедоступным.

Ответ 4

Jiří Vypědřík ответ решил мою проблему. В частности,

2. Проверьте, является ли ваш метод аннотированным с @Async общедоступным.

Еще одна полезная информация из Spring tutorials https://spring.io/guides/gs/async-method/:

Создание локального экземпляра класса FacebookLookupService НЕ разрешить метод findPage асинхронно. Он должен быть создан внутри класс @Configuration или выбранный @ComponentScan.

Это означает, что если бы у вас был статический метод Foo.bar(), вызов его таким образом не выполнял бы его в async, даже если он был аннотирован с @Async. Вам нужно будет аннотировать Foo с @Component, а в вызывающем классе получить @Autowired экземпляр Foo.

Т.е., если у вас есть аннотированная панель методов в классе Foo:

@Component
class Foo { 
   @Async
   public static void bar(){ /* ... */ }

   @Async
   public void bar2(){ /* ... */ }
}

An в вашем классе вызывающего абонента:

class Test {

  @Autowired Foo foo;

  public test(){
     Foo.bar(); // Not async
     foo.bar(); // Not async
     foo.bar2(); // Async
  }

}

Изменить: похоже, что вызов статически также не выполняется в async.

Надеюсь, что это поможет.

Ответ 5

Сначала создайте конфигурацию .xml:

<task:scheduler id="myScheduler" pool-size="10" />
<task:executor id="myExecutor" pool-size="10" />
<task:annotation-driven executor="myExecutor" scheduler="myScheduler" proxy-target-class="true" />

(Да, размер планировщика и размер пула потоков исполнителей настраивается)

Или просто используйте значение по умолчанию:

<!-- enable task annotation to support @Async, @Scheduled, ... -->
<task:annotation-driven />

Во-вторых, убедитесь, что методы @Async общедоступны.

Ответ 6

Я понял после учебника код учебника асинхронного метода, который был моим источником проблем: bean с аннотированным методом @Async не создавался, завернутый в прокси. Я начал копать и понял, что было сообщение о том, что

Bean 'NameOfTheBean' не подлежит обработке всеми BeanPostProcessors (например: не допускается автопроксирование)

Вы можете увидеть здесь ответы об этой проблеме и ее в основном, что BeanPostProcessors требуются каждым Bean, поэтому каждый bean, введенный здесь и его зависимостями, будет исключается для обработки позже другими BeanPostProcessors, потому что это испортило жизненный цикл beans. Поэтому укажите, что является BeanPostProcessor, которое вызывает это и не использует или не создает beans внутри него.

В моем случае у меня была эта конфигурация

@EnableWs
@Configuration
public class WebServiceConfig extends WsConfigurerAdapter {

    @Autowired
    private Wss4jSecurityInterceptor securityInterceptor;

    @Autowired
    private DefaultPayloadLoggingInterceptor payloadLoggingInterceptor;

    @Override
    public void addInterceptors(List<EndpointInterceptor> interceptors) {
        interceptors.add(securityInterceptor);
        interceptors.add(payloadLoggingInterceptor);
    }
}

WsConfigurerAdapter на самом деле является BeanPostProcessor, и вы понимаете это, потому что всегда существует шаблон: @Configuration, который расширяет классы и переопределяет некоторые из его функций для установки или настройки beans, задействованных в некоторых не функциональных функциях, таких как веб-службы или безопасности.

В вышеприведенном примере вам нужно переопределить addInterceptors и добавленные перехватчики beans, поэтому, если вы используете некоторую аннотацию типа @Async внутри DefaultPayloadLoggingInterceptor, она не будет работать. Каково решение? Пройдите WsConfigurerAdapter, чтобы начать. После копания бит я понял, что класс с именем PayloadRootAnnotationMethodEndpointMapping в конце был у всех допустимых перехватчиков, поэтому я сделал это вручную, чтобы переопределить функцию.

@EnableWs
@Configuration
public class WebServiceConfig {

    @Autowired
    private Wss4jSecurityInterceptor securityInterceptor;

    @Autowired
    private DefaultPayloadLoggingInterceptor payloadLoggingInterceptor;

    @Autowired
    public void setupInterceptors(PayloadRootAnnotationMethodEndpointMapping endpointMapping) {
        EndpointInterceptor[] interceptors = {
                securityInterceptor,
                payloadLoggingInterceptor
        };

        endpointMapping.setInterceptors(interceptors);
    }
}

Итак, это будет запущено после того, как все BeanPostProcessor выполнили свою работу. Функция setupInterceptors будет работать, когда эта сторона закончится, и установите перехватчики beans. Этот вариант использования может быть экстраполирован на такие случаи, как Безопасность.

Выводы:

• Если вы используете @Configuration, проходящую от некоторого класса, который автоматически запускает некоторые заданные функции, и вы переопределяете их, вы, вероятно, внутри BeanPostProcessor, поэтому не вводите beans и не пытайтесь использовать поведение AOP, потому что он не будет работать, и вы увидите, что Spring сообщит вам об этом с предыдущим сообщением в консоли. В этих случаях не используйте beans, а объекты (используя предложение new).
• Если вам нужно использовать beans digg, о том, какой класс несет beans, который вы хотите установить в конце, @Autowired и добавьте те beans, как раньше.

Надеюсь, это может сэкономить вам некоторое время.

Ответ 7

@Async нельзя использовать в сочетании с обратными вызовами жизненного цикла, такими как @PostConstruct. Чтобы асинхронно инициализировать Spring beans, вам в настоящее время нужно использовать отдельную инициализацию Spring bean, которая затем вызывает аннотированный метод @Async для целевого объекта.

public class SampleBeanImpl implements SampleBean {

  @Async
  void doSomething() { … }
}


public class SampleBeanInititalizer {

  private final SampleBean bean;

  public SampleBeanInitializer(SampleBean bean) {
    this.bean = bean;
  }

  @PostConstruct
  public void initialize() {
    bean.doSomething();
  }
}

источник

Ответ 8

написать независимую конфигурацию Spring для асинхронного bean.
например:

@Configuration
@ComponentScan(basePackages="xxxxxxxxxxxxxxxxxxxxx")
@EnableAsync
public class AsyncConfig {

    /**
     *  used by  asynchronous event listener.
     * @return
     */
    @Bean(name = "asynchronousListenerExecutor")
    public Executor createAsynchronousListenerExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(100);
        executor.initialize();
        return executor;
    }
}

Я преодолеваю эту проблему с этой ситуацией.