太原cms模板建站,百度输入法免费下载,南宁网站建设速成培训,ps软件下载电脑版数据表 加不加无所谓,如果需要重启服务器后重新执行所有JOB就把sql加上
如果不加表 将application.properties中的quartz数据库配置去掉
自己执行自己的逻辑来就好,大不了每次启动之后重新加载自己的逻辑
链接#xff1a;https://pan.baidu.com/s/1KqOPYMfI4eHcEMxt5Bmt…数据表 加不加无所谓,如果需要重启服务器后重新执行所有JOB就把sql加上
如果不加表 将application.properties中的quartz数据库配置去掉
自己执行自己的逻辑来就好,大不了每次启动之后重新加载自己的逻辑
链接https://pan.baidu.com/s/1KqOPYMfI4eHcEMxt5BmtYg 提取码o9ql --来自百度网盘超级会员V4的分享 SpringBoot工程 pom依赖 dependenciesdependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion2.0.26/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.4.3/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIddruid-spring-boot-starter/artifactIdversion1.2.16/version/dependencydependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scope/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!-- dependency--
!-- groupIdorg.springframework.boot/groupId--
!-- artifactIdspring-boot-devtools/artifactId--
!-- /dependency--!--解决加了ConfigurationProperties注解 类上的提示--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-configuration-processor/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-quartz/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactIdconfigurationimagebuilderpaketobuildpacks/builder-jammy-base:latest/builder/imageexcludesexcludegroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/exclude/excludes/configuration/plugin/plugins/build application.properties
spring.datasource.typecom.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver
spring.datasource.urljdbc:mysql://localhost:3306/job3?serverTimezoneUTCuseUnicodetruecharacterEncodingUTF8useSSLfalserewriteBatchedStatementstrue
spring.datasource.usernameroot
spring.datasource.password123456
#
##
#mybatis-plus.configuration.map-underscore-to-camel-casetrue
#
#mybatis-plus.configuration.log-implorg.apache.ibatis.logging.stdout.StdOutImpl
#
#
#mybatis-plus.global-config.db-config.table-prefixtbl_
#
#
#mybatis-plus.global-config.db-config.id-typeauto# 定时任务Quartz的数据源配置
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.URLjdbc:mysql://localhost:3306/job3?useUnicodetruecharacterEncodingutf-8serverTimezoneAsia/ShanghaiuseSSLfalse
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.drivercom.mysql.cj.jdbc.Driver
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.maxConnections5
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.usernameroot
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.password123456
spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.providerhikaricp# Quartz调度器配置
spring.quartz.properties.org.quartz.scheduler.instanceNameglobalScheduler
spring.quartz.properties.org.quartz.scheduler.instanceIdAUTO
spring.quartz.properties.org.quartz.scheduler.typecom.alibaba.druid.pool.DruidDataSource# Quartz作业存储配置
spring.quartz.properties.org.quartz.jobStore.dataSourceglobalJobDataSource
spring.quartz.properties.org.quartz.jobStore.classorg.quartz.impl.jdbcjobstore.JobStoreTX
spring.quartz.properties.org.quartz.jobStore.driverDelegateClassorg.quartz.impl.jdbcjobstore.StdJDBCDelegate
spring.quartz.properties.org.quartz.jobStore.tablePrefixQRTZ_
spring.quartz.properties.org.quartz.jobStore.misfireThreshold100
spring.quartz.properties.org.quartz.jobStore.isClusteredtrue# Quartz线程池配置
spring.quartz.properties.org.quartz.threadPool.classorg.quartz.simpl.SimpleThreadPool
spring.quartz.properties.org.quartz.threadPool.threadCount10
spring.quartz.properties.org.quartz.threadPool.threadPriority5包结构 实体类
package com.example.springbootquartz.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;/*** author hrui* date 2023/11/16 22:57*/
Data
NoArgsConstructor
AllArgsConstructor
Accessors(chain true)
public class JobInfo {/*** 任务名称*/private String jobName;/*** 任务组*/private String jobGroup;/*** 触发器名称*/private String triggerName;/*** 触发器组*/private String triggerGroup;/*** cron表达式*/private String cron;/*** 类名*/private String className;/*** 状态*/private String status;/*** 下一次执行时间*/private String nextTime;/*** 上一次执行时间*/private String prevTime;/*** 配置信息(data)*/private String config;}package com.example.springbootquartz.job;import com.alibaba.fastjson.JSONObject;
import com.example.springbootquartz.pojo.JobInfo;
import org.quartz.*;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import javax.annotation.Resource;
import java.util.List;
import java.util.Objects;/*** author hrui* date 2023/11/16 23:10*/
Component
public class SchedulerManage {Autowiredprivate Scheduler scheduler;/*** 添加任务*/SuppressWarnings(unchecked)public void addJob(JobInfo jobInfo) throws SchedulerException, ClassNotFoundException {Objects.requireNonNull(jobInfo, 任务信息不能为空);// 生成job keyJobKey jobKey JobKey.jobKey(jobInfo.getJobName(), jobInfo.getJobGroup());// 当前任务不存在才进行添加if (!scheduler.checkExists(jobKey)) {ClassJob jobClass (ClassJob)Class.forName(jobInfo.getClassName());// 任务明细JobDetail jobDetail JobBuilder.newJob(jobClass).withIdentity(jobKey).withIdentity(jobInfo.getJobName(), jobInfo.getJobGroup()).withDescription(jobInfo.getJobName()).build();// 配置信息jobDetail.getJobDataMap().put(config, jobInfo.getConfig());// 定义触发器TriggerKey triggerKey TriggerKey.triggerKey(jobInfo.getTriggerName(), jobInfo.getTriggerGroup());// 设置任务的触发机制Trigger trigger TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(CronScheduleBuilder.cronSchedule(jobInfo.getCron()).withMisfireHandlingInstructionDoNothing()).build();scheduler.scheduleJob(jobDetail, trigger);} else {throw new SchedulerException(jobInfo.getJobName() 任务已存在无需重复添加);}}/*** 任务暂停*/public void pauseJob(String jobGroup, String jobName) throws SchedulerException {JobKey jobKey JobKey.jobKey(jobName, jobGroup);if (scheduler.checkExists(jobKey)) {scheduler.pauseJob(jobKey);}}/*** 继续任务*/public void continueJob(String jobGroup, String jobName) throws SchedulerException {JobKey jobKey JobKey.jobKey(jobName, jobGroup);if (scheduler.checkExists(jobKey)) {scheduler.resumeJob(jobKey);}}/*** 删除任务*/public boolean deleteJob(String jobGroup, String jobName) throws SchedulerException {JobKey jobKey JobKey.jobKey(jobName, jobGroup);if (scheduler.checkExists(jobKey)) {// 这里还需要先删除trigger相关//TriggerKey triggerKey TriggerKey.triggerKey(jobInfo.getTriggerName(), jobInfo.getTriggerGroup());//scheduler.getTrigger()//scheduler.rescheduleJob()return scheduler.deleteJob(jobKey);//不需要删除trigger 一个job可以有多个trigger 删除job同时源码底层会删除对应trigger}return false;}/*** 获取任务信息*/public JobInfo getJobInfo(String jobGroup, String jobName) throws SchedulerException {JobKey jobKey JobKey.jobKey(jobName, jobGroup);if (!scheduler.checkExists(jobKey)) {return null;}List? extends Trigger triggers scheduler.getTriggersOfJob(jobKey);if (Objects.isNull(triggers)) {throw new SchedulerException(未获取到触发器信息);}TriggerKey triggerKey triggers.get(0).getKey();Trigger.TriggerState triggerState scheduler.getTriggerState(triggerKey);JobDetail jobDetail scheduler.getJobDetail(jobKey);JobInfo jobInfo new JobInfo();jobInfo.setJobName(jobGroup);jobInfo.setJobGroup(jobName);jobInfo.setTriggerName(triggerKey.getName());jobInfo.setTriggerGroup(triggerKey.getGroup());jobInfo.setClassName(jobDetail.getJobClass().getName());jobInfo.setStatus(triggerState.toString());if (Objects.nonNull(jobDetail.getJobDataMap())) {jobInfo.setConfig(JSONObject.toJSONString(jobDetail.getJobDataMap()));}CronTrigger theTrigger (CronTrigger) triggers.get(0);jobInfo.setCron(theTrigger.getCronExpression());return jobInfo;}} package com.example.springbootquartz.job;import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobExecutionContext;
import org.quartz.PersistJobDataAfterExecution;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.scheduling.quartz.QuartzJobBean;import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.Date;/*** author hrui* date 2023/11/16 22:58*/
DisallowConcurrentExecution//避免并发执行
PersistJobDataAfterExecution//Job状态
public class QuartzJob1 extends QuartzJobBean {Overrideprotected void executeInternal(JobExecutionContext context) {System.out.println(QuartzJob1正在执行...getTime());}private String getTime(){DateFormat dateFormatnew SimpleDateFormat(yyyy-MM-dd hh:mm:ss:SSS);return dateFormat.format(new Date());}} 控制器
package com.example.springbootquartz.controller;import com.example.springbootquartz.job.SchedulerManage;
import com.example.springbootquartz.pojo.JobInfo;
import org.quartz.*;
import org.quartz.impl.StdScheduler;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.web.bind.annotation.*;import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;/*** author hrui* date 2023/11/16 23:13*/
RestController
RequestMapping(/job)
public class QuartzController {Autowiredprivate SchedulerManage schedulerManage;Autowiredprivate Scheduler scheduler;//StdSchedulerAutowiredprivate SchedulerFactoryBean SchedulerFactoryBean;/*** 查询所有的任务*/RequestMapping(/all)public ListJobInfo list() throws SchedulerException {ListJobInfo jobInfos new ArrayList();ListString triggerGroupNames scheduler.getTriggerGroupNames();for (String triggerGroupName : triggerGroupNames) {SetTriggerKey triggerKeySet scheduler.getTriggerKeys(GroupMatcher.triggerGroupEquals(triggerGroupName));for (TriggerKey triggerKey : triggerKeySet) {Trigger trigger scheduler.getTrigger(triggerKey);JobKey jobKey trigger.getJobKey();JobInfo jobInfo schedulerManage.getJobInfo(jobKey.getGroup(), jobKey.getName());jobInfos.add(jobInfo);}}return jobInfos;}/*** 添加任务*/PostMapping(/add)public JobInfo addJob(RequestBody JobInfo jobInfo) throws SchedulerException, ClassNotFoundException {schedulerManage.addJob(jobInfo);return jobInfo;}/*** 暂停任务*/RequestMapping(/pause)public void pauseJob(RequestParam(jobGroup) String jobGroup, RequestParam(jobName) String jobName)throws SchedulerException {schedulerManage.pauseJob(jobGroup, jobName);}/*** 继续任务*/RequestMapping(/continue)public void continueJob(RequestParam(jobGroup) String jobGroup, RequestParam(jobName) String jobName)throws SchedulerException {schedulerManage.continueJob(jobGroup, jobName);}/*** 删除任务*/RequestMapping(/delete)public boolean deleteJob(RequestParam(jobGroup) String jobGroup, RequestParam(jobName) String jobName)throws SchedulerException {return schedulerManage.deleteJob(jobGroup, jobName);}}
{ jobName:job1, jobGroup:group1, triggerName:trigger1, triggerGroup:tGroup1, cron:*/5 * * * * ?, className:com.example.springbootquartz.job.QuartzJob1
}
