Spring的业务层和Web层

Easter79
• 阅读 797

任务调度

　　quartz框架

　　quartz框架实现了Spring的任务调度，用户可以随意的定义触发器调度时间表，并将触发器和任务进行映射。quartz通过调度器、触发器和任务实现任务调度。

　　Job：主要用来设计任务实现的逻辑，并且只有一个方法execute。

　　JobDetail：主要用来通过newInstance()方法创建Job实例，该角色主要通过一些静态信息来描述Job的名称等信息。

　　Triger：作为任务的触发器，有两个类：SimpleTriger和CronTriger。当只触发一次或者周期性触发选择SimpleTriger。当定时触发时可以选择CronTriger。

　　Calendar：作为时间点的集合。

　　Scheduler：任务调度容器，Scheduler中注册Triger和JobDetail，将Triger和JobDetail关联起来。

　　实现任务调度步骤：

1、创建任务，并设置名称和组名。2、创建触发器，并设置名称和组名。3、对触发器设置时间规则。4、定义任务调度容器，将触发器与任务加入容器，并这只关联。

　　SimpleTriger任务调度实例：

创建任务类

package scheduler;

import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class SimpleJob implements Job{

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("定时任务调度=================");
    }
    
}

　　将任务与触发器关联

/**
 * 
 */
/**
 * @author Administrator
 *
 */
package scheduler;

import java.util.Collection;

import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

import sun.java2d.pipe.SpanShapeRenderer.Simple;

public class SimpleTriggerRunner {
    public static void main(String[] args){
        try{
            JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job_1", "group_1").build();
            SimpleTrigger trigger = TriggerBuilder
                    .newTrigger()
                    .withIdentity("trigger_1","group_triger")
                    .startNow()
                    .withSchedule(SimpleScheduleBuilder
                            .simpleSchedule()
                            .withIntervalInSeconds(5)
                            .repeatForever())
                    .build();
            SchedulerFactory factory = new StdSchedulerFactory();
            Scheduler scheduler = factory.getScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.start();
        }catch(Exception e){
            e.printStackTrace();
        }        
    }
}

CronTriger实现任务调度实例：

import java.util.Collection;

import org.quartz.Job;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

import sun.java2d.pipe.SpanShapeRenderer.Simple;

public class SimpleTriggerRunner {
    public static void main(String[] args){
        try{
            JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job_1", "group_1").build();
            SimpleTrigger trigger = TriggerBuilder
                    .newTrigger()
                    .withIdentity("trigger_1","group_triger")
                    .startNow()
                    .withSchedule(SimpleScheduleBuilder
                            .simpleSchedule()
                            .withIntervalInSeconds(5)
                            .repeatForever())
                    .build();
            SchedulerFactory factory = new StdSchedulerFactory();
            Scheduler scheduler = factory.getScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.start();
        }catch(Exception e){
            e.printStackTrace();
        }        
    }
}

　　Spring中使用quartz

创建JobDetailBean

　　步骤：

　　1、创建JobDetail实例JobDetailBean。对JobDetailBean进行属性设置，jobClass：用来指定任务；beanName：设置任务的名称；JobDataAsMap为任务的JobDataMap提供值；applicationContextJobDataKey：为Job提供applicationContext。2、创建Trigger触发器，主要是通过SimpleTriggerBean、CronTriggerBean和CronTriggerFactoryBean进行创建，需要将任务实例配置其中。3、通过SchedulerFactoryBean类配置Scheduler，将Trigger加入Schedulerde的Trigger列表中。

　　实例：

　　定义任务类

package scheduler;

import java.util.Map;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.stereotype.Component;

import bean.User;
@Component("myJob")
public class MyJob{

    public void myexecute() {
        // TODO Auto-generated method stub
        System.out.println("Spring开始任务调度=========");
        System.out.println("Spring结束任务调度==========");
    }
    
}

　　　将任务加入触发器，并设置调度时间。将触发器加入调度。

<?xml version="1.0" encoding="UTF-8"?>
<beans
 xmlns="http://www.springframework.org/schema/beans"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:p="http://www.springframework.org/schema/p"
 xmlns:util="http://www.springframework.org/schema/util"
 xmlns:mvc="http://www.springframework.org/schema/mvc"
 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
                    http://www.springframework.org/schema/context
                    http://www.springframework.org/schema/context/spring-context-3.0.xsd
                    http://www.springframework.org/schema/mvc
                    http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
                    http://www.springframework.org/schema/util
                    http://www.springframework.org/schema/util/spring-util-3.0.xsd"
                    >
<context:component-scan base-package="scheduler"/>
<!-- jobDetail -->
<bean id="jobnew" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject" ref="myJob"/>
    <property name="targetMethod" value="myexecute"/>
<!--false表示等上一个任务执行完后再开启新的任务-->
    <property name="concurrent" value="false"/>
</bean>
<!-- Trigger-->
<bean id="oceanStatusCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="jobnew"/>
    <property name="cronExpression" value="0 */2 * * * ?"/>
</bean>
<!--Scheduler -->
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
        <list>
            <ref bean="oceanStatusCronTrigger"/>
        </list>
    </property>
</bean>    
</beans>

　　Spring中使用Timer

Timer

　　当使用调度比较频繁时，可以考虑使用Timer，并不适合固定时间点例如每周周一上午八点的调度策略。但是对于长时间执行的任务来说，该调度会严重影响性能，因为每一个Timer是在同一个线程，Timer中的有多个TimerTask，执行时间过长容易引起积压。　　

TmierTask

　　TimerTask相当于Job，TimerTask实现了Runnable接口，该类中主要有三个方法：任务执行逻辑，执行时间，取消执行。
　　实现任务调度的步骤：
　　1、创建TimerTask类。2、创建Timer类。3、将TimerTask实例注册到Timer中。　　

实例

　　创建任务实例

package scheduler;

import java.util.TimerTask;

public class SimpleTimerTask extends TimerTask{
    private int count=0;
    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println("线程执行次数========="+count);
        count++;
        if(count>10){
            cancel();
        }
    }
}

　　将任务注册到Timer中

package scheduler;

import java.util.Timer;
import java.util.TimerTask;

public class TimerRunner {

    public static void main(String[] args){
        Timer timer = new Timer();
        TimerTask timerTask = new SimpleTimerTask();
        timer.schedule(timerTask, 1000, 2000);
    }
}

Spring对Timer的使用

 　　创建任务类

package scheduler;

import org.springframework.stereotype.Component;

@Component("myService")
public class MyService {

    public void timerTest(){
        System.out.println("开始使用TimerTask=========");
    }
}

　　将任务类封装为TimerTask，并将TimerTask设置定时规则，将规则注入Timer。

<!-- 通过生成任务TimerTask -->
<bean id="timerTask" class="org.springframework.scheduling.timer.MethodInvokingTimerTaskFactoryBean" 
    p:targetObject-ref="myService"
    p:targetMethod="timerTest"/>
<!-- 定义调度规则 -->
<bean id="scheduledTask" class="org.springframework.scheduling.timer.ScheduledTimerTask"
    p:timerTask-ref="timerTask"
    p:delay="1000"
    p:period="1000"/>
<!-- 将调度规则放入调度队列 -->
<bean id="timerFactoryBean" class="org.springframework.scheduling.timer.TimerFactoryBean">
    <property name="scheduledTimerTasks">
    <list>
        <ref bean="scheduledTask"/>
    </list>
    </property>
    </bean>

　　Spring中使用Executor

　　　　Executor主要有两个任务：任务提交和任务执行。Executor只有一个方法：void execute(Runnable command)，该方法接收任何实现了Runnable的实例。

　　　　Executor的简单实现：

package scheduler;

import java.util.concurrent.Executor;

public class SimpleExecutor implements Executor{

    @Override
    public void execute(Runnable command) {
        // TODO Auto-generated method stub
        command.run();
    }

}

　　　　可以为每个任务创建一个线程：

package scheduler;

import java.util.concurrent.Executor;

public class TaskExecutor implements Executor{

    @Override
    public void execute(Runnable command) {
        // TODO Auto-generated method stub
        //为每一个任务重新创建一个线程
        new Thread(command).start();
    }

}

　　　　可以将任务放到线程池调度中，每一个任务会通过获取线程，进行任务处理。SchedulerThreadPoolExecutor继承ThreadPoolExecutor，ThreadPoolExecutor继承了Executor和ExecutorService。而SchedulerThreadPoolExecutor通过newFixedThreadPool(int nThreads)创建一个线程池进行任务处理。

　　　　使用实例：

package scheduler;

public class SimpleRunnable implements Runnable{

    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println("开启任务执行==========");
    }

}

package scheduler;

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

public class ExecutorExample {

    private Executor executor;
    public void setExecutor(Executor executor){
        this.executor = executor;
    }
    
    public void executeTask(){
        for(int i=0;i<6;i++){
            executor.execute(new SimpleRunnable());
        }
    }
    public static void main(String args){
        ExecutorExample ee = new ExecutorExample();
        ee.setExecutor(Executors.newFixedThreadPool(3));
        ee.executeTask();
    }
}

Spring任务调度的注解支持

　　@Schedule的实例

 　　配置定时任务：

<?xml version="1.0" encoding="UTF-8"?>
<beans
 xmlns="http://www.springframework.org/schema/beans"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:p="http://www.springframework.org/schema/p"
 xmlns:util="http://www.springframework.org/schema/util"
 xmlns:mvc="http://www.springframework.org/schema/mvc"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:task="http://www.springframework.org/schema/task"
 xsi:schemaLocation="http://www.springframework.org/schema/beans 
                    http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                    http://www.springframework.org/schema/context
                    http://www.springframework.org/schema/context/spring-context-4.0.xsd
                    http://www.springframework.org/schema/mvc
                    http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
                    http://www.springframework.org/schema/util
                    http://www.springframework.org/schema/util/spring-util-4.0.xsd
                    http://www.springframework.org/schema/task
                    http://www.springframework.org/schema/task/spring-task-4.0.xsd">
<context:component-scan base-package="scheduler"/>
<!-- 启用注解驱动的定时任务 -->
<task:annotation-driven scheduler="myScheduler"/>
<!-- 推荐配置线程池，若不配置多任务下会有问题。后面会详细说明单线程的问题。 -->
<task:scheduler id="myScheduler" pool-size="5"/>
</beans>

　　创建任务类

package scheduler;

import java.util.Map;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.stereotype.Component;

import bean.User;
@Component("myJob")
public class MyJob{

    public void myexecute() {
        // TODO Auto-generated method stub
        System.out.println("Spring开始任务调度=========");
        System.out.println("Spring结束任务调度==========");
    }
    
}
触发器spring框架任务调度quartz前端前端
点赞
收藏
评论区
推荐文章
blmius blmius
•
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时，报错：原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等，这样可以更容易地在不同的环境中使用MySQL。全局s
4268
0
0
helloworld_34035044 helloworld_34035044
•
2年前
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时，如何在新增行里自动增加id呢？能新增整数排序id吗？目前可以在新增行里自动增加id，但只能用uuid函数增加UUID编码，不能新增整数排序id。uuid函数说明：获取一个UUID，可以在填报表中用来创建数据ID语法：uuid()或uuid(sep)参数说明：sep布尔值，生成的uuid中是否包含分隔符''，缺省为
1222
0
0
Stella981 Stella981
•
3年前
Quartz结合SPRING多任务定时调用
public class QuartzJob {      public void work()      {              System.out.println(Spring Quartz的任务调度1被调用！");              //定时调用的业务逻辑      }
731
0
0
Stella981 Stella981
•
3年前
Nginx + lua +[memcached,redis]
精品案例1、Nginxluamemcached,redis实现网站灰度发布2、分库分表/基于Leaf组件实现的全球唯一ID(非UUID)3、Redis独立数据监控,实现订单超时操作/MQ死信操作SelectPollEpollReactor模型4、分布式任务调试Quartz应用
896
0
0
Stella981 Stella981
•
3年前
JFinal 整合Quartz
    项目中要加入调度和计划任务等功能，所以选择Quartz调度插件，原先都是在S2SH上整合的。现在项目用JFinal框架，不得不说JFinal框架的定制性真好，可以自己根据项目要求进行修改，并且很节省时间。    原先当然是先找有没有JFinal的quartz插件，先是找到了JFinalext，里面有一个QuartzPlugin
1178
0
0
Easter79 Easter79
•
3年前
SpringQuartz定时任务调度器
JAVA代码测试类public class TestQuartz {public void test(){System.out.println("Quartz的任务调度");}}Quartz配
726
0
0
Stella981 Stella981
•
3年前
JFinal Quartz 支持配置文件和持久化
    随着需求的增加，现在要定时启动一个调度和计划任务，原先写的QuartzPlugin，是持久化保存到数据库中的，从数据库中读取任务并执行。要是添加一个每天循环任务，就要在代码里写一次开始任务的代码，执行后，再注释掉，最后重启项目。否则会因为启动同name，同group的任务而报错org.quartz.ObjectAlreadyExistsE
816
0
0
Wesley13 Wesley13
•
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
1593
0
0
京东云开发者 京东云开发者
•
1年前
Java服务总在半夜挂，背后的真相竟然是... | 京东云技术团队
最近有用户反馈测试环境Java服务总在凌晨00:00左右挂掉，用户反馈Java服务没有定时任务，也没有流量突增的情况，Jvm配置也合理，莫名其妙就挂了
555
0
0
Python进阶者 Python进阶者
•
11个月前
Excel中这日期老是出来00：00：00，怎么用Pandas把这个去除
大家好，我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下：这日期老是出来00：00：00，怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下：pd.toexcel之前把这
563
0
0
Easter79
Easter79
Lv1
今生可爱与温柔，每一样都不能少。
文章
2.8k
粉丝
5
获赞
1.2k
热门文章
uni app video、视频播放开发
tmux的复制粘贴
tableau地图源之高德地图
storybook配置之基本配置和webpack配置
twint 安装及使用