Spring中定时任务

xiaoxiao2021-02-28 17

需求:每天上午9点运行任务

使用Spring框架实现定时任务的编写,这里有两种方法.

一、timer定时器

public class TestListen implements ServletContextListener { private Timer timer = null; //时间间隔(一天) private static final long PERIOD_DAY = 24 * 60 * 60 * 1000; @Override public void contextDestroyed(ServletContextEvent arg0) { System.out.println("task stop..............."); timer.cancel(); } @Override public void contextInitialized(ServletContextEvent arg0) { System.out.println("task statr............."); Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.HOUR_OF_DAY, 9); //每天9点 calendar.set(Calendar.MINUTE, 0); calendar.set(Calendar.SECOND, 0); Date date=calendar.getTime(); //第一次执行定时任务的时间 //如果第一次执行定时任务的时间小于当前的时间 //此时要在第一次执行定时任务的时间加一天，以便此任务在下个时间点执行。如果不加一天，任务会立即执行。 if (date.before(new Date())) { date = this.addDay(date, 1); } timer = new Timer(true); //安排指定的任务在指定的时间开始进行重复的固定延迟执行。 timer.schedule(new TestTask(),date,PERIOD_DAY); } // 增加或减少天数 public Date addDay(Date date, int num) { Calendar startDT = Calendar.getInstance(); startDT.setTime(date); startDT.add(Calendar.DAY_OF_MONTH, num); return startDT.getTime(); } } public class TestTask extends TimerTask { @Override public void run() { System.out.println("这是定时任务==============================="+new Date().getSeconds()); } }

具体步骤:

1.一个TestListen继承 ServletContextListener,重写 contextInitialized()方法,项目启动时,调用 contextInitialized()方法.

2.在contextInitialized()方法中使用 timer.schedule(new TestTask(),date,PERIOD_DAY) 按规定时间调用具体任务类TestTask.

3. TFPTask 继承 TimerTask 重写 run() 方法, 定时任务具体的代码在 run() 方法里.

参考文章:

点击打开链接

二、Spring 整合Quartz框架

在Spring 的配置文件 quartz-task.xml 中配置:

<bean id="resetPidTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"> <description>每天日重置线程池运行任务</description> <property name="jobDetail"> <bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject">  <bean class="com.cares.ceseas.service.timetask.SendEmailForCard" /> </property>  <property name="targetMethod"><value>run</value></property> </bean> </property> <property name="cronExpression">    <value>0 */1 * * * ?</value> </property> </bean> <bean id="schedulerFactory" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <description>定时触发器设置</description> <property name="triggers"> <list> <ref local="resetPidTrigger"/> </list> </property> </bean> public class SendEmailForCard { public void run() { System.out.println("Quartz的任务调度！！！发送邮件-=====--==="+new Date().getSeconds()); } }

参考文章:

点击打开链接

执行多个定时任务

一、使用 ScheduledExecutorService 并发包,开启多个线程执行多个定时任务

public class SummaryListen implements ServletContextListener { /** * 使用工厂方法初始化一个ScheduledThreadPool */ ScheduledExecutorService newScheduledThreadPool = Executors .newScheduledThreadPool(10); Logger logger = Logger.getLogger(SummaryListen.class.getName()); @Override public void contextDestroyed(ServletContextEvent arg0) { newScheduledThreadPool.shutdown(); } @Override public void contextInitialized(ServletContextEvent arg0) { Future<?>f1 = newScheduledThreadPool.scheduleAtFixedRate( new Task1(), 0, 15, TimeUnit.MINUTES); Future<?>f2 = newScheduledThreadPool.scheduleAtFixedRate( new Task2(), 0, 24, TimeUnit.HOURS); Future<?>f3 = newScheduledThreadPool.scheduleAtFixedRate( new Task3(),0, 5, TimeUnit.MINUTES); Future<?>f4 = newScheduledThreadPool.scheduleAtFixedRate( new Task4(),0, 10, TimeUnit.MINUTES); ...... try { f1.get(); f2.get(); f3.get(); f4.get(); ...... } catch (InterruptedException e) { logger.error(e.getMessage(), e); } catch (ExecutionException e) { logger.error(e.getMessage(), e); } } } public class Task1 extends TimerTask { Logger logger = Logger.getLogger(Task1.class.getName()); @Override public void run() { logger.info("*** Task1 START!! *****************"); ...... } }

二、Spring 整合Quartz框架,quartz-task.xml配置多个 Job

<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.2.xsd" default-lazy-init="false">  <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="job1" class="com.care.service.Job1"></bean> <bean id="Job1Detail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="job1" /> <property name="targetMethod" value="execute" /> </bean>  <bean id="Job1Trigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="Job1Detail" /> <property name="cronExpression" value="0/11 * * * * ?" /> </bean>  <bean id="job2" class="com.care.service.Job2"></bean> <bean id="Job2Detail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="job2" /> <property name="targetMethod" value="execute" /> </bean> <bean id="Job2Trigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="Job2Detail" /> <property name="cronExpression" value="0/21 * * * * ?" /> </bean>  <bean name="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  <property name="applicationContextSchedulerContextKey"> <value>applicationContext</value> </property> <property name="triggers"> <list> <ref bean="Job1Trigger" /> <ref bean="Job2Trigger" /> </list> </property> <property name="taskExecutor" ref="executor" /> </bean> </beans>

在Spring核心配置文件application.xml 导入定时任务的配置文件

三、Quartz注解

在Spring核心配置文件application.xml 配置

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:task="http://www.springframework.org/schema/task" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd"> ......  <task:scheduler id="tmTaskScheduler" pool-size="1"/> <task:annotation-driven scheduler="tmTaskScheduler" mode="proxy"/> ...... @Service public class Job1 { @Scheduled(cron="0/10 * * * * ? ") public void execute(){ System.out.println("定时任务 1 ------------------------------------"); } } @Service public class Job2 { @Scheduled(cron="0/10 * * * * ? ") public void execute(){ System.out.println("定时任务 2 ------------------------------------"); } }

转载请注明原文地址: https://www.6miu.com/read-1650013.html

技术

最新回复(0)