❶ 用java的Quartz包定時調用方法,我想實現每隔一個半小時調用一次方法, 請問Corn表達式怎麼寫
結合spring框架寫的
<beanid="cronTriggerPay"
class="org.springframework.scheling.quartz.CronTriggerBean">
<propertyname="jobDetail">
<!--使用嵌套Bean的方式來定義任務Bean-->
<bean
class="org.springframework.scheling.quartz.JobDetailBean">
<!--指定任務Bean的實現類-->
<propertyname="jobClass"
value="org.seu.yto.schele.PayJob"/>
<!--為任務Bean注入屬性-->
<propertyname="jobDataAsMap">
<map>
<entrykey="empMgr"value-ref="empManager"/>
</map>
</property>
</bean>
</property>
<!--指定Cron表達式:每月1日6點啟動-->
<propertyname="cronExpression"value="0061*?*"/>
</bean>
<!--定義觸發器來管理任務Bean-->
<beanid="cronTriggerPunch"
class="org.springframework.scheling.quartz.CronTriggerBean">
<propertyname="jobDetail">
<!--使用嵌套Bean的方式來定義任務Bean-->
<bean
class="org.springframework.scheling.quartz.JobDetailBean">
<!--指定任務Bean的實現類-->
<propertyname="jobClass"
value="org.seu.yto.schele.PunchJob"/>
<!--為任務Bean注入屬性-->
<propertyname="jobDataAsMap">
<map>
<entrykey="empMgr"value-ref="empManager"/>
</map>
</property>
</bean>
</property>
<!--指定Cron表達式:周一到周五8點、12點執行調度-->
<propertyname="cronExpression"
value="008,12?*MON-FRI"/>
</bean>
<!--執行實際的調度調度-->
<bean
class="org.springframework.scheling.quartz.SchelerFactoryBean">
<propertyname="triggers">
<list>
<reflocal="cronTriggerPay"/>
<reflocal="cronTriggerPunch"/>
</list>
</property>
</bean>
❷ java的幾種定時任務
java定時任務有三種:
- JDK自帶 :JDK自帶的Timer以及JDK1.5+ 新增的ScheledExecutorService;
- Quartz :簡單卻強大的JAVA作業調度框架
- Spring3.0以後自帶的task :可以將它看成一個輕量級的Quartz,而且使用起來比Quartz簡單許多;
代碼參考:
JDK 自帶的定時器實現
schele(TimerTask task, Date time) 特定時間執行
public static void main(String[] args) {
for (int i = 0; i < 10; ++i) {
new Timer("timer - " + i).schele(new TimerTask() {
@Override
public void run() {
println(Thread.currentThread().getName() + " run ");
}
}, new Date(System.currentTimeMillis() + 2000));
}
}
Quartz 定時器實現
2.1 通過maven引入依賴(這里主要介紹2.3.0) 注意:shiro-scheler中依賴的是1.x版本 如果同時使用會沖突
<!-- https://mvnrepository.com/artifact/org.quartz-scheler/quartz -->
<dependency>
<groupId>org.quartz-scheler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>
2.2創建Job類
public class TestJob implements Job{
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
println(Thread.currentThread().getName() + " test job begin " + DateUtil.getCurrentTimeStr());
}
}
2.3調度任務
public static void main(String[] args) throws InterruptedException, SchelerException {
Scheler scheler = new StdSchelerFactory().getScheler();
// 開始
scheler.start();
// job 唯一標識 test.test-1
JobKey jobKey = new JobKey("test" , "test-1");
JobDetail jobDetail = JobBuilder.newJob(TestJob.class).withIdentity(jobKey).build();
Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("test" , "test")
// 延遲一秒執行
.startAt(new Date(System.currentTimeMillis() + 1000))
// 每隔一秒執行 並一直重復
.withSchele(SimpleScheleBuilder.simpleSchele().withIntervalInSeconds(1).repeatForever())
.build();
scheler.scheleJob(jobDetail , trigger);
Thread.sleep(5000);
// 刪除job
scheler.deleteJob(jobKey);
}
3.Spring 相關的任務調度
3.1 配置文件實現
spring-schele.xml
<task:scheler id="myScheler" pool-size="10" />
<task:scheled-tasks scheler="myScheler">
<task:scheled ref="job" method="test" cron="0 * * * * ?"/>
</task:scheled-tasks>
3.2註解實現
spring-schele.xml
<task:scheler id="myScheler" pool-size="10" />
// 啟用註解
<task:annotation-driven scheler="myScheler"/>
@Component
public class Task{
@Scheled(cron="0/5 * * * * ? ") //每5秒執行一次
public void execute(){
DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println(sdf.format(DateTime.now().toDate())+"*********B任務每5秒執行一次進入測試");
}
}