Pourquoi Spring 4 n'autorise qu'un TaskScheduler dans un contexte?

Nous avons un Printemps de l'application web, nous sommes de portage à partir du Printemps de 3,2 à Ressort 4. Notre application a plusieurs sous-contextes assemblés en un seul contexte d'exécution lors de l'application web est démarré.

Nous utilisons séparé TaskSchedulers dans deux de nos sous-contextes. Avec le Printemps 3.2 cela fonctionne bien; lors de l'utilisation de Spring 4, nous avons une exception avec le message suivant:

java.lang.IllegalStateException: More than one TaskScheduler and/or ScheduledExecutorService  exist within the context. Remove all but one of the beans; or implement the SchedulingConfigurer interface and call ScheduledTaskRegistrar#setScheduler explicitly within the configureTasks() callback. Found the following beans: [commonScheduler, communicationTaskScheduler]
at org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor.onApplicationEvent(ScheduledAnnotationBeanPostProcessor.java:289) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor.onApplicationEvent(ScheduledAnnotationBeanPostProcessor.java:72) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:98) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:333) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:776) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:485) ~[spring-context-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:403) ~[spring-web-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:306) ~[spring-web-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:106) ~[spring-web-4.0.1.RELEASE.jar:4.0.1.RELEASE]
at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4961) ~[catalina.jar:7.0.50]
at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5455) ~[catalina.jar:7.0.50]
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) ~[catalina.jar:7.0.50]
at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901) ~[catalina.jar:7.0.50]
at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877) ~[catalina.jar:7.0.50]
at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:634) ~[catalina.jar:7.0.50]
at org.apache.catalina.startup.HostConfig.deployWAR(HostConfig.java:1074) ~[catalina.jar:7.0.26]
at org.apache.catalina.startup.HostConfig$DeployWar.run(HostConfig.java:1858) ~[catalina.jar:7.0.26]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ~[na:1.7.0_25]
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) ~[na:1.7.0_25]
at java.util.concurrent.FutureTask.run(FutureTask.java:166) ~[na:1.7.0_25]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ~[na:1.7.0_25]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ~[na:1.7.0_25]
at java.lang.Thread.run(Thread.java:724) ~[na:1.7.0_25]

Un planificateur est défini par:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd">
<!-- Enables annotation-driven task scheduling; detects @Scheduled- and 
@Async-annotated process methods to be invoked via proxy -->
<task:annotation-driven mode="aspectj" />
<task:scheduler id="commonScheduler" pool-size="5" />
</beans>

Les autres planificateur est définie en (en plus des haricots retiré pour plus de clarté):

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
<context:spring-configured />
<bean id="communicationExecutor"
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="15" />
<property name="maxPoolSize" value="20" />
<property name="queueCapacity" value="20" />
</bean>
<bean id="communicationTaskScheduler"
class="org.springframework.scheduling.concurrent.ConcurrentTaskScheduler">
<property name="concurrentExecutor" ref="communicationExecutor" />
</bean>
</beans>

Les contextes sont assemblés au moment de l'exécution à l'aide de (contextes supplémentaires retiré pour plus de clarté):

<beans xmlns="http://www.springframework.org/schema/beans"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
<import resource="classpath:spring/tasks-context.xml" />
<import resource="classpath:spring/collectors-context.xml" />
</beans>

Pourquoi ne Ressort 4 cette restriction? Comment le contourner?

source d'informationauteur user2112901

  1. 16

    Ouais, c'est un changement dans le comportement sûr. Il semble que la ScheduledAnnotationBeanPostProcessor a maintenant une limite de 2 programmateurs par le contexte. J'ai couru dans ce Ressort avec 4 nouveaux WebSocket message broker comme il alloue 2 planificateurs pour la Simple STOMP courtier et le SockJS adaptateur. Quand j'ai ajouté ma propre, c'est complètement dorked avec le même message que vous avez obtenu. J'ai trouvé ça plutôt ennuyeux que j'ai eu à trouver cette limitation par les erreurs plutôt que de la documentation. Cette chasse aux sorcières ne semble pas être décrit dans le Ressort 4 de la documentation.

    La solution est de créer votre propre SchedulingConfigurer qui gère son propre TaskScheduler. Je soupçonne que la raison en est qu'il existe une seule et supplémentaires TaskScheduler implémentations doivent être ajoutés afin de les isoler l'un de l'autre. J'ai fait quelque chose comme ça:

    @Configuration
@EnableScheduling
public class MySchedulingConfigurer implements SchedulingConfigurer
{
@Bean
public TimedThingy timedThingy()
{
return new TimedThingy();
}
@Bean()
public ThreadPoolTaskScheduler taskScheduler() {
return new ThreadPoolTaskScheduler();
}
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar)
{
taskRegistrar.setTaskScheduler(taskScheduler());
taskRegistrar.addFixedRateTask(new Runnable()
{
public void run()
{
timedThingy().sendIt();
}
}, 1000);
}
}

    Une fois que je l'ai fait, le problème s'en alla, et les choses travaillé comme souhaité. L'inconvénient est que vous ne pouvez pas utiliser les annotations comme @Scheduledetc.. Mais vous faire gagner plus de contrôle et les choses fonctionnent. Espérons que cette aide.

  2. 0

    Vous devez explicitement spécifier l'algorithme à utiliser avec @Scheduled annotations. Juste ajouter scheduler attribut:

    <task:annotation-driven scheduler="commonScheduler" mode="aspectj" />
<task:scheduler id="commonScheduler" pool-size="5" />
  3. 0

    Juste ajouter la fève à votre config:

     @Bean()
public ThreadPoolTaskScheduler taskScheduler() {
return new ThreadPoolTaskScheduler();
}