若依之定时任务 定时任务实现与介绍 若依中定时任务是使用Quartz实现的,首先需要导入Quartz的依赖 org.quartz-scheduler quartz
若依中定时任务是使用Quartz实现的,首先需要导入Quartz的依赖
<dependency> <groupId>org.quartz-schedulergroupId> <artifactId>quartzartifactId> <version>2.3.2version> dependency>
定时任务逻辑
public class QuartzJobFactory implements Job { private Logger logger = Logger.getLogger(QuartzJobFactory.class); @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { //todo 定时任务逻辑 logger.info("=============定时任务=============="); }}
这里在系统初始化时触发定时任务,这里是添加了@PostConstruct注解,也可以实现InitializingBean接口
@Componentpublic class QuartzService { private Logger logger = Logger.getLogger(QuartzJobFactory.class);//每5秒执行一次 private static final String CRON_TIME = "*/5 * * * * ?"; private static final String TRIGGER_KEY_NAME = "00000000001"; @PostConstruct public void taskInit() { logger.info("系统初始化加载定时任务开始==========="); try { StdSchedulerFactory schedulerFactory = new StdSchedulerFactory(); 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。
public interface JobDetail { public JobKey geTKEy(); public String getDescription(); public Class<? extends Job> getJobClass(); public JobDataMap getJobDataMap(); public boolean isDurable(); public boolean isPersistJobDataAfterExecution(); public boolean isConcurrentExectionDisallowed(); public boolean requestsRecovery(); public JobBuilder getJobBuilder();}
触发器 | 作用 |
---|---|
SimpleTrigger | 简单触发器,适用于按指定的时间间隔执行多少次任务的情况 |
CronTrigger | Cron触发器,通过Cron表达式来控制任务的执行时间 |
通过Cron表达式来控制任务的执行时间 | 日期触发器,在给定的时间范围内或指定的星期内以秒、分钟或者小时为周期进行重复的情况 |
CalendarIntervalTrigger | 日历触发器,根据一个给定的日历时间进行重复 |
若依中定时任务主要在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删除以后,再创建一个和原来一样得到。
项目启动时需要把数据库中定时任务表的记录读取出来,然后根据这些记录还原出定时任务,然后执行,具体逻辑如下:
来源地址:https://blog.csdn.net/wsb_2526/article/details/129475335
--结束END--
本文标题: 若依之定时任务
本文链接: https://www.lsjlt.com/news/381252.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
2024-04-01
2024-04-03
2024-04-03
2024-01-21
2024-01-21
2024-01-21
2024-01-21
2023-12-23
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0