<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        


    


    paulwong
    

    

    



    
	
					
	
    
		
    
			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 id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
                <property name="corePoolSize" value="10" />
                <property name="maxPoolSize" value="100" />
                <property name="queueCapacity" value="500" />
            </bean>
        
            <bean id="taskOne" class="com.paul.springbatchtest.tasklet.TaskOne" />

            <bean id="taskOneJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject" ref="taskOne" />
                <property name="targetMethod" value="execue" />
                <property name="concurrent" value="false" />
            </bean>

            <bean id="taskOneCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
                <property name="jobDetail" ref="taskOneJobDetail" />
                <property name="cronExpression" value="0/1 * * * * ?" />
            </bean>
        
            <!-- //////////////////////// -->
        
            <bean id="dailyTask" class="com.paul.springbatchtest.tasklet.DailyTask"  >
                <property name="scheduler" ref="scheduler" />
                <property name="taskOneCronTrigger" ref="taskOneCronTrigger" />
                <property name="taskOneJobDetail" ref="taskOneJobDetail" />
            </bean>

            <bean id="dailyJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject" ref="dailyTask" />
                <property name="targetMethod" value="execue" />
                <property name="concurrent" value="false" />
            </bean>

            <bean id="dailyCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
                <property name="jobDetail" ref="dailyJobDetail" />
                <property name="cronExpression" value="0/15 * * * * ?" />
            </bean>
        
            <!-- //////////////////////// -->
        
        
            <bean id="stopTaskOne" class="com.paul.springbatchtest.tasklet.StopTaskOne" >
                <property name="taskOneCronTrigger" ref="taskOneCronTrigger" />
                <!-- <property name="scheduler" ref="scheduler" /> -->
                <property name="taskOneJobDetail" ref="taskOneJobDetail" />
            </bean>

            <bean id="stopTaskOneJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject" ref="stopTaskOne" />
                <property name="targetMethod" value="execue" />
                <property name="concurrent" value="false" />
            </bean>

            <bean id="stopTaskOneCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
                <property name="jobDetail" ref="stopTaskOneJobDetail" />
                <property name="cronExpression" value="10,25,40,55 * * * * ?" />
            </bean> <!-- -->

            <bean id="scheduler"
            class    ="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
                <property name="triggers">
                    <list>
                        <!-- <ref bean="taskOneCronTrigger" /> -->
                        <ref bean="dailyCronTrigger" />
                        <ref bean="stopTaskOneCronTrigger"/>
                    </list>
                </property>
                <property name="taskExecutor" ref="executor" />
            </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">
            <modelVersion>4.0.0</modelVersion>

            <groupId>com.paul</groupId>
            <artifactId>springbatchtest</artifactId>
            <version>1.0</version>
            <packaging>jar</packaging>

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

            <properties>
                <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>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.batch</groupId>
                    <artifactId>spring-batch-core</artifactId>
                    <version>${spring.batch.version}</version>
                    <exclusions>
                        <exclusion>
                            <groupId>commons-logging</groupId>
                            <artifactId>commons-logging</artifactId>
                        </exclusion>
                    </exclusions>
                </dependency>
                <dependency>
                    <groupId>org.springframework.batch</groupId>
                    <artifactId>spring-batch-infrastructure</artifactId>
                    <version>${spring.batch.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework.batch</groupId>
                    <artifactId>spring-batch-test</artifactId>
                    <version>${spring.batch.version}</version>
                    <scope>test</scope>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-beans</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-context</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-core</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-jdbc</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-tx</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-api</artifactId>
                    <version>1.6.1</version>
                </dependency>
                <dependency>
                    <groupId>org.slf4j</groupId>
                    <artifactId>jcl-over-slf4j</artifactId>
                    <version>1.6.1</version>
                </dependency>
                <dependency>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-classic</artifactId>
                    <version>0.9.29</version>
                </dependency>
                <dependency>
                    <groupId>commons-io</groupId>
                    <artifactId>commons-io</artifactId>
                    <version>2.0.1</version>
                </dependency>
                <dependency>
                    <groupId>com.h2database</groupId>
                    <artifactId>h2</artifactId>
                    <version>1.3.168</version>
                </dependency>
                <dependency>
                    <groupId>junit</groupId>
                    <artifactId>junit</artifactId>
                    <version>4.8.2</version>
                    <scope>test</scope>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-test</artifactId>
                    <version>${spring.version}</version>
                    <scope>test</scope>
                </dependency>
                <dependency>
                    <groupId>javax.mail</groupId>
                    <artifactId>mail</artifactId>
                    <version>1.4.1</version>
                </dependency>
                <dependency>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring-context-support</artifactId>
                    <version>${spring.version}</version>
                </dependency>
                <!-- <dependency>
                <groupId>org.opensymphony.quartz</groupId>
                <artifactId>quartz</artifactId>
                <version>1.6.1</version>
            </dependency>     -->
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>5.1.21</version>
                </dependency>
                <dependency>
                    <groupId>org.quartz-scheduler</groupId>
                    <artifactId>quartz</artifactId>
                    <version>1.8.4</version>
                </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 閱讀(3992) 評(píng)論(1)  編輯  收藏  所屬分類: 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)論
				  
				
			
    
		

    

    




    








    

				

    



    







    
        
	



主站蜘蛛池模板：
亚洲AV成人精品一区二区三区|
四虎影视免费在线|
亚洲欧洲在线观看|
国产精品免费看久久久|
久久亚洲国产午夜精品理论片|
久久久精品视频免费观看|
亚洲一区视频在线播放
|
美女黄网站人色视频免费国产|
色老板亚洲视频免在线观|
欧美好看的免费电影在线观看|
亚洲男人的天堂久久精品|
国产成人A在线观看视频免费|
亚洲卡一卡二卡乱码新区|
性xxxx视频播放免费|
亚洲av成人一区二区三区在线播放
|
亚洲第一成年免费网站|
国产福利免费在线观看|
成人免费网站久久久|
亚洲综合熟女久久久30p|
91免费福利视频|
亚洲AV日韩AV永久无码下载|
最近中文字幕国语免费完整
|
亚洲情综合五月天|
久久国产乱子伦精品免费看|
91在线亚洲精品专区|
99无码人妻一区二区三区免费|
亚洲三级高清免费|
国产伦精品一区二区三区免费下载|
国产亚洲视频在线观看|
中文字幕亚洲图片|
久久免费的精品国产V∧|
亚洲一区在线免费观看|
香蕉高清免费永久在线视频|
杨幂最新免费特级毛片|
国产亚洲一区二区三区在线|
18女人水真多免费高清毛片|
国产亚洲中文日本不卡二区|
日韩免费观看视频|
国产伦精品一区二区免费|
亚洲ⅴ国产v天堂a无码二区|
999国内精品永久免费观看|