Spring使用之：Quartz定时任务为什么会被阻塞
2011-02-15 11:36
561 查看
Spring使用之：Quartz定时任务为什么会被阻塞
文章分类:Java编程关键字: spring, quartz, 定时任务
问题：
周日，公司CTO给我打电话说，监控系统的数据从下午1点就不更新了。我登录服务器排除了数据同步问题，查看日志也没有例外抛出，查询了前一天的
日志发现几个数据库表空间溢出例外。最后定位，Spring定时任务挂掉了。重启应用恢复正常。周一早上，同样的问题又发生了，6点开始定时任务又停了。
Spring定时任务为什么会被阻塞呢？
原因：
周一中午，我在进行接口状态监控测试时发现，接口状态查询任务尽然会执行半小时。问题找到了，由于我在接口状态查询任务中没有设置读超时、在接口
网络繁忙时，接口状态查询任务会占用很长的时间，Spring定时任务默认都是并发执行的，不会等待上一次任务执行完毕，只要间隔时间到就会执行。接口状
态查询任务每5分钟执行一次，假如每次都执行1小时的话，其他任务就会被阻塞。因为Quartz的线程都被接口状态查询任务占用了。其他任务只有等待。
解决方法：
1.将JobDetail的concurrent属性配置为false。不允许任务并发执行。
2.任务执行时间较长时，查找根本问题。
实验：
JobOne.java
Java代码
package
test.job;
import
java.util.Date;
public
class
JobOne {
public
void
execute(){
System.out.println("execute JobOne("
+
new
Date()+
")"
);
try
{
Thread.sleep(1000000
);
}catch
(InterruptedException ire) {
}
}
}
package test.job;
import java.util.Date;
public class JobOne {
public void execute(){
System.out.println("execute JobOne("+new Date()+")");
try {
Thread.sleep(1000000);
}catch(InterruptedException ire) {
}
}
}JobTwo.java
Java代码
package
test.job;
import
java.util.Date;
public
class
JobTwo {
public
void
execute(){
System.out.println("execute JobTwo("
+
new
Date()+
")"
);
}
}
package test.job;
import java.util.Date;
public class JobTwo {
public void execute(){
System.out.println("execute JobTwo("+new Date()+")");
}
}配置文件
Xml代码
<?
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:aop
=
"http://www.springframework.org/schema/aop"
xmlns:tx
=
"http://www.springframework.org/schema/tx"
xsi:schemaLocation
="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-
beans-2.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd">
<!--===== jobOne =====-->
<!-- job -->
<
bean
id
=
"jobOne"
class
=
"test.job.JobOne"
>
</
bean
>
<!-- job detail -->
<
bean
id
=
"jobOneDetail"
class
=
"org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"
>
<
property
name
=
"targetObject"
ref
=
"jobOne"
/>
<
property
name
=
"targetMethod"
value
=
"execute"
/>
<
property
name
=
"concurrent"
value
=
"true"
/>
</
bean
>
<!-- Trigger -->
<
bean
id
=
"jobOneSimpleTrigger"
class
=
"org.springframework.scheduling.quartz.SimpleTriggerBean"
>
<
property
name
=
"jobDetail"
ref
=
"jobOneDetail"
/>
<
property
name
=
"startDelay"
>
<
value
>
0
</
value
>
</
property
>
<
property
name
=
"repeatInterval"
>
<
value
>
1000
</
value
>
</
property
>
</
bean
>
<!--===== jobTwo =====-->
<!-- job -->
<
bean
id
=
"jobTwo"
class
=
"test.job.JobTwo"
>
</
bean
>
<!-- job detail -->
<
bean
id
=
"jobTwoDetail"
class
=
"org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"
>
<
property
name
=
"targetObject"
ref
=
"jobTwo"
/>
<
property
name
=
"targetMethod"
value
=
"execute"
/>
<
property
name
=
"concurrent"
value
=
"true"
/>
</
bean
>
<!-- Trigger -->
<
bean
id
=
"jobTwoSimpleTrigger"
class
=
"org.springframework.scheduling.quartz.SimpleTriggerBean"
>
<
property
name
=
"jobDetail"
ref
=
"jobTwoDetail"
/>
<
property
name
=
"startDelay"
>
<
value
>
0
</
value
>
</
property
>
<
property
name
=
"repeatInterval"
>
<
value
>
1000
</
value
>
</
property
>
</
bean
>
<!--===== Schedule =====-->
<!-- schedule -->
<
bean
class
=
"org.springframework.scheduling.quartz.SchedulerFactoryBean"
>
<
property
name
=
"triggers"
>
<
list
>
<
ref
local
=
"jobOneSimpleTrigger"
/>
<
ref
local
=
"jobTwoSimpleTrigger"
/>
</
list
>
</
property
>
</
bean
>
</
beans
>
<?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:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring- beans-2.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd"> <!--===== jobOne =====--> <!-- job --> <bean id="jobOne" class="test.job.JobOne" > </bean> <!-- job detail --> <bean id="jobOneDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="jobOne"/> <property name="targetMethod" value="execute"/> <property name="concurrent" value="true" /> </bean> <!-- Trigger --> <bean id="jobOneSimpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> <property name="jobDetail" ref="jobOneDetail" /> <property name="startDelay"><value>0</value></property> <property name="repeatInterval"><value>1000</value></property> </bean> <!--===== jobTwo =====--> <!-- job --> <bean id="jobTwo" class="test.job.JobTwo" > </bean> <!-- job detail --> <bean id="jobTwoDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="jobTwo"/> <property name="targetMethod" value="execute"/> <property name="concurrent" value="true" /> </bean> <!-- Trigger --> <bean id="jobTwoSimpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> <property name="jobDetail" ref="jobTwoDetail" /> <property name="startDelay"><value>0</value></property> <property name="repeatInterval"><value>1000</value></property> </bean> <!--===== Schedule =====--> <!-- schedule --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref local="jobOneSimpleTrigger"/> <ref local="jobTwoSimpleTrigger"/> </list> </property> </bean> </beans>
MAIN类：
Java代码
package
test.job;
import
org.springframework.context.ApplicationContext;
import
org.springframework.context.support.ClassPathXmlApplicationContext;
public
class
JobTest {
private
ApplicationContext ac;
public
JobTest(ApplicationContext ac) {
this
.ac = ac;
}
/**
* @param args
*/
public
static
void
main(String[] args) {
JobTest job = new
JobTest(
new
ClassPathXmlApplicationContext(
"applicationContext.xml"
));
}
}
package test.job;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class JobTest {
private ApplicationContext ac;
public JobTest(ApplicationContext ac) {
this.ac = ac;
}
/**
* @param args
*/
public static void main(String[] args) {
JobTest job = new JobTest(new ClassPathXmlApplicationContext("applicationContext.xml"));
}
}测试结果：
当jobOne的concurrent为true时：
execute JobOne(Thu Jan 24 13:40:22 CST 2008)
execute JobTwo(Thu Jan 24 13:40:22 CST 2008)
execute JobOne(Thu Jan 24 13:40:22 CST 2008)
execute JobTwo(Thu Jan 24 13:40:22 CST 2008)
execute JobOne(Thu Jan 24 13:40:23 CST 2008)
execute JobTwo(Thu Jan 24 13:40:23 CST 2008)
execute JobOne(Thu Jan 24 13:40:24 CST 2008)
execute JobTwo(Thu Jan 24 13:40:24 CST 2008)
execute JobOne(Thu Jan 24 13:40:25 CST 2008)
execute JobTwo(Thu Jan 24 13:40:25 CST 2008)
execute JobOne(Thu Jan 24 13:40:26 CST 2008)
execute JobTwo(Thu Jan 24 13:40:26 CST 2008)
execute JobOne(Thu Jan 24 13:40:27 CST 2008)
execute JobTwo(Thu Jan 24 13:40:27 CST 2008)
execute JobOne(Thu Jan 24 13:40:28 CST 2008)
execute JobTwo(Thu Jan 24 13:40:28 CST 2008)
execute JobOne(Thu Jan 24 13:40:29 CST 2008)
execute JobTwo(Thu Jan 24 13:40:29 CST 2008)
execute JobOne(Thu Jan 24 13:40:31 CST 2008)
（JobOne并发执行，到这里所有任务阻塞没有信息输出，可以看出默认有10个线程，都被JobOne占用）
当jobOne的concurrent为false时：
execute JobOne(Thu Jan 24 13:43:00 CST 2008)
execute JobTwo(Thu Jan 24 13:43:00 CST 2008)
execute JobTwo(Thu Jan 24 13:43:00 CST 2008)
execute JobTwo(Thu Jan 24 13:43:01 CST 2008)
execute JobTwo(Thu Jan 24 13:43:02 CST 2008)
execute JobTwo(Thu Jan 24 13:43:03 CST 2008)
execute JobTwo(Thu Jan 24 13:43:04 CST 2008)
execute JobTwo(Thu Jan 24 13:43:05 CST 2008)
execute JobTwo(Thu Jan 24 13:43:06 CST 2008)
execute JobTwo(Thu Jan 24 13:43:07 CST 2008)
execute JobTwo(Thu Jan 24 13:43:08 CST 2008)
execute JobTwo(Thu Jan 24 13:43:09 CST 2008)
（JobOne不并发执行，JobTwo不会被阻塞）
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- Spring使用之：Quartz定时任务为什么会被阻塞
- Spring使用之：Quartz定时任务为什么会被阻塞
- spring quartz定时下载ftp文件任务被阻塞
- spring-quartz定时任务使用小结
- 使用spring 的Quartz 定时任务入门
- spring中使用quartz实现定时任务
- 使用Spring提供Quartz来实现定时任务
- spring-quartz定时任务使用小结
- Spring与Quartz集成实现定时调度任务的简单使用
- Spring与Quartz的结合使用 主要用于定时任务！！！
- 使用spring quartz实现定时任务
- 使用Spring Quartz执行定时任务
- 使用Spring+Quartz的定时任务。
- spring boot环境下使用quartz设置定时任务
- 使用Spring3+Quartz实现定时任务
- 使用spring quartz实现定时任务
- 使用Spring(17)Spring中的定时调度(Scheduling)--传统方式创建Quartz任务
- Springboot中使用数据库配置Quartz定时任务
- 使用spring quartz实现定时任务
- Spring 动态管理定时任务（使用quartz） 只是管理启动时间 不能做启动和暂停