Как перейти от конфигурации XML Spring к конфигурации аннотации/кода?
Я пытаюсь преобразовать следующую конфигурацию x7 для Spring задачи в чисто версию на основе кода/аннотации:
<task:executor id="xyz.executor"
pool-size="${xyz.job.executor.pool.size:1-40}"
queue-capacity="${xyz.job.executor.queue.capacity:0}"
rejection-policy="CALLER_RUNS"/>
<task:scheduler id="xyz.scheduler" pool size="${xyz.job.scheduler.pool.size:4}" />
<task:annotation-driven executor="xyz.executor" scheduler="xyz.scheduler" />
<bean id='xyzProcessor' class="xyz.queueing.QueueProcessor" />
<task:scheduled-tasks scheduler="xyz.scheduler" >
<task:scheduled ref="partitioner" method="createPartitions" cron="${xyz.job.partitioner.interval:0 0 3 * * *}" />
</task:scheduled-tasks>
В спецификации Spring, 28.4.1 (http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html), они говорят, что перейти от XML следующим образом:
<task:annotation-driven executor="myExecutor" scheduler="myScheduler"/>
<task:executor id="myExecutor" pool-size="5"/>
<task:scheduler id="myScheduler" pool-size="10"/>
для конфигурации кода так же просто, как включение @EnableScheduling и/или @EnableAsync.
Однако я не вижу нигде, где я могу создать экземпляр планировщика. Javadoc для @EnableScheduling (http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/scheduling/annotation/EnableScheduling.html) показывает, как я могу подключиться к своему собственному созданному Executor, хотя я не совсем уверен, какой класс это должно быть (я все еще хочу иметь возможность контролировать размер пула, емкость очереди и политику отклонения). Он также показывает, как я могу запланировать мой метод createPartitions с помощью переопределения configureTasks. Тем не менее, я хотел бы иметь возможность назвать мой планировщик (чтобы я мог идентифицировать его потоки) и контролировать его размер пула.
Итак, я хочу знать эти вещи:
1) Какой класс я могу использовать для установки полей исполнителя, которые есть в XML?
2) Есть ли способ создать экземпляр планировщика, чтобы я мог управлять именем и размером пула?
Ответы
Ответ 1
Проверьте типы AsyncConfigurer
, AsyncConfigurerSupport
и SchedulingConfigurer
. Они являются вспомогательными типами, которые вы можете использовать для улучшения вашего класса @Configuration
с настройками async/scheduling.
Во всех них и javadoc @EnabledAsync
вы найдете все методы настройки, необходимые для настройки асинхронизации /scheduling @Configuration
.
Приведенный пример приравнивает
@Configuration
@EnableAsync
public class AppConfig implements AsyncConfigurer {
@Bean
public MyAsyncBean asyncBean() {
return new MyAsyncBean();
}
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(7);
executor.setMaxPoolSize(42);
executor.setQueueCapacity(11);
executor.setThreadNamePrefix("MyExecutor-");
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}
с
<beans>
<task:annotation-driven executor="myExecutor" exception-handler="exceptionHandler"/>
<task:executor id="myExecutor" pool-size="7-42" queue-capacity="11"/>
<bean id="asyncBean" class="com.foo.MyAsyncBean"/>
<bean id="exceptionHandler" class="com.foo.MyAsyncUncaughtExceptionHandler"/>
</beans>
SchedulingConfigurer
имеет аналогичную настройку для task:scheduler
.
Ответ 2
Если вам нужен более мелкозернистый элемент управления, вы можете дополнительно реализовать интерфейсы SchedulingConfigurer
и/или AsyncConfigurer
.
Как утверждают,
Также обратите внимание на пулы,
@Configuration
@EnableScheduling
public class CronConfig implements SchedulingConfigurer{
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(taskExecutor());
}
@Bean(destroyMethod="shutdown")
public Executor taskExecutor() {
return Executors.newScheduledThreadPool(10);
}
}
И для Asyncs,
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(100);
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new SimpleAsyncUncaughtExceptionHandler();
}
}
Обратите внимание, что @EnableAsync
и @EnableScheduling
должны быть там, чтобы это работало.