久久99精品久久久久久琪琪,精品999视频,国产精品一区二区a

Quartz 中的任務(wù)開(kāi)始、暫停和繼續(xù)

第一個(gè)TASK:

package com.paul.springbatchtest.tasklet;

import org.quartz.SchedulerException;

public class TaskOne {

public void execue() throws SchedulerException

{

System.out.println("Hello Spring Schedule!" + Thread.currentThread().getName());

}

第二個(gè)TASK用來(lái)恢復(fù)第一個(gè)TASK的：

package com.paul.springbatchtest.tasklet;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

public class DailyTask {

private Scheduler scheduler;

private CronTrigger taskOneCronTrigger;

private JobDetail taskOneJobDetail;

public void execue() throws SchedulerException

{

System.out.println("Start taskOneCronTrigger in DailyTask " + Thread.currentThread().getName());

scheduler.addJob(taskOneJobDetail, true);

scheduler.scheduleJob(taskOneCronTrigger);

}

public Scheduler getScheduler() {

return scheduler;

}

public void setScheduler(Scheduler scheduler) {

this.scheduler = scheduler;

}

public CronTrigger getTaskOneCronTrigger() {

return taskOneCronTrigger;

}

public void setTaskOneCronTrigger(CronTrigger taskOneCronTrigger) {

this.taskOneCronTrigger = taskOneCronTrigger;

}

public JobDetail getTaskOneJobDetail() {

return taskOneJobDetail;

}

public void setTaskOneJobDetail(JobDetail taskOneJobDetail) {

this.taskOneJobDetail = taskOneJobDetail;

}

第三個(gè)TASK，用來(lái)暫停第一個(gè)TASK的：

package com.paul.springbatchtest.tasklet;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.springframework.beans.BeansException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.ApplicationContextAware;

public class StopTaskOne implements ApplicationContextAware {

private ApplicationContext applicationContext;

private Scheduler scheduler;

private CronTrigger taskOneCronTrigger;

private JobDetail taskOneJobDetail;

public void execue() throws SchedulerException

{

System.out.println("Stop Task One in " + Thread.currentThread().getName());

scheduler = (Scheduler)this.applicationContext.getBean("scheduler");

scheduler.unscheduleJob(taskOneCronTrigger.getName(), taskOneCronTrigger.getGroup());

}

public CronTrigger getTaskOneCronTrigger() {

return taskOneCronTrigger;

}

public void setTaskOneCronTrigger(CronTrigger taskOneCronTrigger) {

this.taskOneCronTrigger = taskOneCronTrigger;

}

public JobDetail getTaskOneJobDetail() {

return taskOneJobDetail;

}

public void setTaskOneJobDetail(JobDetail taskOneJobDetail) {

this.taskOneJobDetail = taskOneJobDetail;

}

public Scheduler getScheduler() {

return scheduler;

}

public void setScheduler(Scheduler scheduler) {

this.scheduler = scheduler;

}

@Override

public void setApplicationContext(ApplicationContext applicationContext)

throws BeansException {

this.applicationContext = applicationContext;

}

SPRING配置文件：

<?xml version="1.0" encoding="UTF-8"?>

<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-3.0.xsd">

</bean>

</bean>

</bean>

</bean>

</bean>

</bean>

</bean>

</bean>

</bean>

<bean id="scheduler"

class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >

<list>

</list>

</property>

</bean>

</beans>

MAVEN的POM文件：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<artifactId>springbatchtest</artifactId>

<name>springbatchtest</name>

<url>http://maven.apache.org</url>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<spring.batch.version>

2.1.8.RELEASE

</spring.batch.version>

<maven.compiler.source>1.6</maven.compiler.source>

<maven.compiler.target>1.6</maven.compiler.target>

<spring.version>3.0.5.RELEASE</spring.version>

</properties>

<groupId>org.springframework.batch</groupId>

<artifactId>spring-batch-core</artifactId>

<version>${spring.batch.version}</version>

<groupId>commons-logging</groupId>

<artifactId>commons-logging</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.springframework.batch</groupId>

<artifactId>spring-batch-infrastructure</artifactId>

<version>${spring.batch.version}</version>

</dependency>

<groupId>org.springframework.batch</groupId>

<artifactId>spring-batch-test</artifactId>

<version>${spring.batch.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-beans</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-context</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-core</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-jdbc</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-tx</artifactId>

<version>${spring.version}</version>

</dependency>

</dependency>

</dependency>

<groupId>ch.qos.logback</groupId>

<artifactId>logback-classic</artifactId>

</dependency>

<groupId>commons-io</groupId>

<artifactId>commons-io</artifactId>

</dependency>

<groupId>com.h2database</groupId>

</dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-test</artifactId>

<version>${spring.version}</version>

</dependency>

<groupId>javax.mail</groupId>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-context-support</artifactId>

<version>${spring.version}</version>

</dependency>

<!-- <dependency>

<groupId>org.opensymphony.quartz</groupId>

<artifactId>quartz</artifactId>

</dependency> -->

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

</dependency>

<groupId>org.quartz-scheduler</groupId>

<artifactId>quartz</artifactId>

</dependency>

</dependencies>

</project>

測(cè)試文件：

package com.paul.springbatch.test;

import junit.framework.Assert;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = { "/schedule/quartz.xml"})

public class QuartzTaskOneTest {

@Test

public void simpleTest() throws Exception{

while(true)

{

Assert.assertTrue(true);

}

posted on 2012-10-13 16:18 paulwong 閱讀(3995) 評(píng)論(1) 編輯收藏所屬分類(lèi): SRPING BATCH

Feedback

# re: Quartz 中的任務(wù)開(kāi)始、暫停和繼續(xù) 2014-04-14 10:45 最代碼

可以參考下最代碼網(wǎng)站上的這個(gè)代碼:http://www.zuidaima.com/share/1748776162790400.htm 回復(fù) 更多評(píng)論

新用戶注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問(wèn) 管理
相關(guān)文章: csv 文件打開(kāi)亂碼，有哪些方法可以解決？ SPRING BATCH中STEP如果沒(méi)加TRANSACTION MANAGER 使用 Spring Batch 構(gòu)建企業(yè)級(jí)批處理應(yīng)用-2 使用 Spring Batch 構(gòu)建企業(yè)級(jí)批處理應(yīng)用-1 配置SPRING BATCH中的JUNIT TEST Transform RemoteChunk to remote with json format in Spring Batch Spring Batch JUnit test for multiple jobs SPRING BATCH & SPRING INTEGRATION TUTORIAL SPRING BATCH remote chunking模式下可同時(shí)處理多文件 STEP范圍內(nèi)的ROUTER

paulwong

My Links

Blog Stats

常用鏈接

留言簿(66)

隨筆分類(lèi)(1388)

隨筆檔案(1146)

文章分類(lèi)(7)

文章檔案(10)

相冊(cè)

收藏夾(2)

AI

Develop

E-BOOK

Other

養(yǎng)生

微服務(wù)

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

60天內(nèi)閱讀排行

Quartz 中的任務(wù)開(kāi)始、暫停和繼續(xù)

Feedback

# re: Quartz 中的任務(wù)開(kāi)始、暫停和繼續(xù) 2014-04-14 10:45 最代碼