我正在尝试使用spring事件实现事件框架,后来我知道spring事件框架的默认行为是sync.但是在春季上下文初始化期间,如果它找到ID为applicationEventMulticaster的bean,则其行为为Async.

现在,我希望在我的应用程序中同时具有同步和异步事件发布者,因为某些事件需要同步发布.我尝试使用SysncTaskExecutor配置同步事件多播程序,但找不到将其注入到AsyncEventPublisher的applicationEventPublisher属性中的方法.

我的spring配置文件如下

有人可以帮我从这里出去吗 ？

解决方法:

不,您不能这样做,spring initApplicationEventMulticaster只能初始化一个,而BeanName必须是applicationEventMulticaster.因此您可以选择以下执行器之一：

-org.springframework.core.task.SyncTaskExecutor

-org.springframework.core.task.SimpleAsyncTaskExecutor

-您自己的执行器：org.springframework.scheduling.concurrent.ThreadPoolTask​​Executor

无论如何,您都可以修改org.springframework.context.event.SimpleApplicationEventMulticaster

添加逻辑,然后您可以控制是否需要同步/异步

/**

* Initialize the ApplicationEventMulticaster.

* Uses SimpleApplicationEventMulticaster if none defined in the context.

* @see org.springframework.context.event.SimpleApplicationEventMulticaster

*/

protected void initApplicationEventMulticaster() {

ConfigurableListableBeanFactory beanFactory = getBeanFactory();

if (beanFactory.containsLocalBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME)) {

this.applicationEventMulticaster =

beanFactory.getBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, ApplicationEventMulticaster.class);

if (logger.isDebugEnabled()) {

logger.debug("Using ApplicationEventMulticaster [" + this.applicationEventMulticaster + "]");

}

}

else {

this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory);

beanFactory.registerSingleton(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, this.applicationEventMulticaster);

if (logger.isDebugEnabled()) {

logger.debug("Unable to locate ApplicationEventMulticaster with name '" +

APPLICATION_EVENT_MULTICASTER_BEAN_NAME +

"': using default [" + this.applicationEventMulticaster + "]");

}

}

}

标签：java,spring,asynchronous

来源： https://codeday.me/bug/20191010/1886911.html