我试图将以下Spring任务xml配置转换为纯粹基于代码/注释的版本:
<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和/或@EnableSync一样简单。
然而,我看不到任何地方可以实际实例化调度器。@EnableScheduling的javadoc(http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/scheduling/annotation/EnableScheduling.html)展示了如何在自己创建的Executor中获得插件,尽管我不确定它应该是什么类(我仍然希望能够控制池大小、队列容量和拒绝策略)。它还显示了如何使用configureTasks覆盖来计划createPartitions方法。然而,我希望能够命名我的调度程序(这样我就可以识别它的线程)并控制它的池大小。
所以,我想知道这些事情:
1) 我可以使用什么类来设置XML的executor字段?
2) 有没有办法创建一个调度器实例,我可以控制它的名称和池大小?
如果想要更细粒度的控制,可以另外实现调度配置器
和/或异步配置器
接口。
如下所示,
请注意游泳池,
@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);
}
}
对于异步,
@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();
}
}
请注意,@enablesync
和@EnableScheduling
必须在那里才能工作。
查看类型AsyncConfigurer
,AsyncConfigurerSupport
,以及SchedulingConfigurer
。它们是帮助器类型,可用于通过异步/调度配置增强@Configuration
类。
在所有这些方法中,以及@EnabledAsync
的javadoc中,您将找到设置异步/调度@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>
调度配置程序
对任务有类似的设置:调度程序
。
问题内容: 我正在尝试将以下Spring任务xml配置转换为纯粹基于代码/注释的版本: 根据Spring规范28.4.1(http://docs.spring.io/spring/docs/current/spring-framework- reference/html/scheduling.html ),他们说要像这样从XML中获取: 代码配置就像启用@EnableScheduling和/或@E
我怎么能改变这个xml配置: 到目前为止的java代码配置我有这个我只有这部分的问题: 这就是我到目前为止在java代码中所拥有的: 这一行给我这个错误:
问题内容: 我正在尝试将Hibernate 4仅用于注释和一个文件。我做了自己的注释,并使用反射将其添加到配置中。我可以用这种方式很好地使用Hibernate 4,但是我的配置是使用不推荐使用的方法构建的。 (不建议使用的代码:)。 甚至hibernate 4文档也显示以这种方式构建配置。 如果我尝试使用新方法(,则不会得到相同的结果,并且似乎很多不必要的代码可以完全执行不推荐使用的方法。但是,我
我试图创建一个简单的spring mvc应用程序进行实践,但我不断地得到这样的错误: 在名为'MVC-Dispatcher'的DispatcherServlet中没有找到带有URI的HTTP请求映射,我从Tomcat得到了404错误。 这是我的控制器 当在dispatcher servlet中使用bean时,我可以让控制器工作,但出于某种原因,我无法获得带有注释的正确处理程序映射。我是不是猜我的m
我一直使用hibernate。cfg。配置Hibernate的xml。由于各种原因,我需要将所有配置转移到Java,并且我在映射实体方面存在问题。 以前在XML中,我的映射是这样的: 一切都是注释驱动的,所以我不需要指定其他任何东西。 现在,我使用Hibernate的配置来配置一切。类,如何添加映射?我尝试了配置。addClass(Test.class)但这会引发一个错误,即file 但是在第一次
我正在努力学习Spring并理解它是如何工作的。我已经学习了一些设置Spring和Camel的教程,并使用默认设置进行了操作。 我现在正试图将尽可能多的配置XML文件转换为Java类。到目前为止,我已经成功地在Java类中创建了camel路由(扩展SpringRouteBuilder并实现configure()),以及spring配置文件(Bean)中的所有Bean- 这相当于什么样的非XML?