若依之定时任务

定时任务实现与介绍

若依中定时任务是使用Quartz实现的，首先需要导入Quartz的依赖

<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.2</version></dependency>

定时任务逻辑

/**
 * 实现Job接口，重写Execute方法
 */publicclassQuartzJobFactoryimplementsJob{privateLogger logger =Logger.getLogger(QuartzJobFactory.class);@Overridepublicvoidexecute(JobExecutionContext jobExecutionContext)throwsJobExecutionException{//todo 定时任务逻辑
        logger.info("=============定时任务==============");}}

这里在系统初始化时触发定时任务，这里是添加了@PostConstruct注解，也可以实现InitializingBean接口

@ComponentpublicclassQuartzService{privateLogger logger =Logger.getLogger(QuartzJobFactory.class);//每5秒执行一次privatestaticfinalString CRON_TIME ="*/5 * * * * ?";privatestaticfinalString TRIGGER_KEY_NAME ="00000000001";@PostConstructpublicvoidtaskInit(){
        logger.info("系统初始化加载定时任务开始===========");try{StdSchedulerFactory schedulerFactory =newStdSchedulerFactory();Scheduler scheduler = schedulerFactory.getScheduler();TriggerKey triggerKey =TriggerKey.triggerKey(TRIGGER_KEY_NAME,Scheduler.DEFAULT_GROUP);JobDetail jobDetail =JobBuilder.newJob(QuartzJobFactory.class).withDescription("quartz测试定制化定时任务").withIdentity(TRIGGER_KEY_NAME,Scheduler.DEFAULT_GROUP).build();CronScheduleBuilder cronScheduleBuilder =CronScheduleBuilder.cronSchedule(CRON_TIME);CronTrigger cronTrigger =TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build();
            scheduler.scheduleJob(jobDetail, cronTrigger);
            scheduler.start();
            logger.info("初始化定时任务加载完成");}catch(Exception e){
            logger.info("初始化加载定时任务失败===========");
            e.printStackTrace();}}}

通过上面三步就实现了一个简单的定时任务。接下来我们看看Quartz的核心组件。
Quartz的核心组件主要是Scheduler、Job 、JobDetail、Trigger。

Job：用于定义任务具体的逻辑。这里面需要注意的是怎么传入参数、获取参数；
JobDetail：定义任务详情。包含执行任务的Job、任务的一些身份信息（方便找到Job），传入参数到任务中去；Job key是任务的唯一标识，可以通过Job key找到任务。

publicinterfaceJobDetail{/**
     * job的身份，通过他来找到对应的job
     */publicJobKeygetKey();/**
     * job描述
     */publicStringgetDescription();/**
     * 执行job的具体类，定时任务的动作都在这个类里面完成
     */publicClass<?extendsJob>getJobClass();/**
     * 给job传递数据(把需要的参数带到job执行的类里面去)
     */publicJobDataMapgetJobDataMap();/**
     * 任务孤立的时候是否需要继续报错(孤立:没有触发器关联该任务)
     */publicbooleanisDurable();/**
     * 和@PersistJobDataAfterExecution注解一样
     * PersistJobDataAfterExecution注解是添加在Job类上的：表示 Quartz 将会在成功执行 execute()
     * 方法后（没有抛出异常）更新 JobDetail 的 JobDataMap，下一次执行相同的任务（JobDetail）
     * 将会得到更新后的值，而不是原始的值
     */publicbooleanisPersistJobDataAfterExecution();/**
     * 和DisallowConcurrentExecution注解的功能一样
     * DisallowConcurrentExecution注解添加到Job之后，Quartz 将不会同时执行多个 Job 实例，
     * 怕有数据更新的时候不知道取哪一个数据
     */publicbooleanisConcurrentExectionDisallowed();/**
     * 指示调度程序在遇到“恢复”或“故障转移”情况时是否应重新执行作业
     */publicbooleanrequestsRecovery();/**
     * JobDetail是通过构建者模式来实现的
     */publicJobBuildergetJobBuilder();}

Trigger：触发器，设置Job什么时候执行。Quartz框架默认提供了四种触发器。
触发器作用SimpleTrigger简单触发器，适用于按指定的时间间隔执行多少次任务的情况CronTriggerCron触发器，通过Cron表达式来控制任务的执行时间通过Cron表达式来控制任务的执行时间日期触发器，在给定的时间范围内或指定的星期内以秒、分钟或者小时为周期进行重复的情况CalendarIntervalTrigger日历触发器，根据一个给定的日历时间进行重复
Scheduler：Scheduler调度器用来管理Trigger和Job，并保证Job能在Trigger设置的时间被触发执行

若依中定时任务实现

若依中定时任务主要在quartz模块中。
在这里插入图片描述

若依中定时任务监控页面：
在这里插入图片描述

若依中设计了sys_job：来记录定时任务的信息，sys_job_log：来记录定时任务执行的信息。
在这里插入图片描述

若依中Job的设计如下，QuartzJobExecution支持并发，QuartzDisallowCOncurrentExceution不支持并发执行。
在这里插入图片描述

在AbstractQuartzJob类中保存了定时任务执行的日志。
在这里插入图片描述

当我们创建一个定时任务时，其核心方法是ScheduleUtils类的createScheduleJob方法。
在这里插入图片描述
定时任务的执行，则是在AbstractQuartzJob的实现类中调用JobInvokeUtil的invokeMethod方法，然后通过反射找到要执行的类的方法去执行。

通过要执行的类的类名TASK_CLASS_NAME、jobId还有jobGroup作为Job的key，后面删除、修改Job的时候需要通过Job key获取Job；在这里插入图片描述
修改的时候除了修改sys_job表中的信息，还需要修改Quartz中Job的信息。而若依中的修改是先把原来的Job删除以后，再创建一个和原来一样得到。

项目启动时需要把数据库中定时任务表的记录读取出来，然后根据这些记录还原出定时任务，然后执行，具体逻辑如下：
在这里插入图片描述