2019獨角獸企業重金招聘Python工程師標準>>>

依賴

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

任務工廠 JobFactory

// 解決SpringBoot不能再Quartz中注入Bean的問題 @Component public class JobFactory extends AdaptableJobFactory {/*** AutowireCapableBeanFactory接口是BeanFactory的子類* 可以連接和填充那些生命周期不被Spring管理的已存在的bean實例*/private AutowireCapableBeanFactory factory;public JobFactory(AutowireCapableBeanFactory factory) {this.factory = factory;}/*** 創建Job實例*/@Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {// 實例化對象Object job = super.createJobInstance(bundle);// 進行注入（Spring管理該Bean）factory.autowireBean(job);//返回對象return job;} }

任務調度器 Scheduler

@Configuration public class QuartzConfig {private JobFactory jobFactory;public QuartzConfig(JobFactory jobFactory){this.jobFactory = jobFactory;}/*** 配置SchedulerFactoryBean** 將一個方法產生為Bean并交給Spring容器管理*/@Beanpublic SchedulerFactoryBean schedulerFactoryBean() {// Spring提供SchedulerFactoryBean為Scheduler提供配置信息,并被Spring容器管理其生命周期SchedulerFactoryBean factory = new SchedulerFactoryBean();// 設置自定義Job Factory，用于Spring管理Job beanfactory.setJobFactory(jobFactory);return factory;}@Bean(name = "scheduler")public Scheduler scheduler() {return schedulerFactoryBean().getScheduler();} }

QuartzManager 工具類

@Service public class QuartzManager {private Scheduler scheduler;public QuartzManager(Scheduler scheduler){this.scheduler = scheduler;}/*** 添加一個定時任務** @param jobName 任務名* @param jobGroupName 任務組名* @param triggerName 觸發器名* @param triggerGroupName 觸發器組名* @param jobClass 任務* @param cron 時間設置，參考quartz說明文檔*/@SuppressWarnings({ "unchecked", "rawtypes" })public void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron, Map<String, Object> params) {try {// 任務名，任務組，任務執行類JobDetail job = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();// 任務參數job.getJobDataMap().putAll(params);// 觸發器TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();// 觸發器名,觸發器組triggerBuilder.withIdentity(triggerName, triggerGroupName);triggerBuilder.startNow();// 觸發器時間設定triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));// 創建Trigger對象CronTrigger trigger = (CronTrigger) triggerBuilder.build();// 調度容器設置JobDetail和Triggerscheduler.scheduleJob(job, trigger);// 啟動if (!scheduler.isShutdown()) {scheduler.start();}} catch (Exception e) {throw new RuntimeException(e);}}/*** 修改一個任務的觸發時間** @param triggerName 觸發器名* @param triggerGroupName 觸發器組名* @param cron 時間設置，參考quartz說明文檔*/public void modifyJobTime(String triggerName, String triggerGroupName, String cron) {try {TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(cron)) {// 觸發器TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();// 觸發器名,觸發器組triggerBuilder.withIdentity(triggerName, triggerGroupName);triggerBuilder.startNow();// 觸發器時間設定triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));// 創建Trigger對象trigger = (CronTrigger) triggerBuilder.build();// 方式一 ：修改一個任務的觸發時間scheduler.rescheduleJob(triggerKey, trigger);}} catch (Exception e) {throw new RuntimeException(e);}}/*** 移除一個任務** @param jobName 任務名* @param jobGroupName 任務組名* @param triggerName 觸發器名* @param triggerGroupName 觸發器組名*/public void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) {try {TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);// 停止觸發器scheduler.pauseTrigger(triggerKey);// 移除觸發器scheduler.unscheduleJob(triggerKey);// 刪除任務scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName));} catch (Exception e) {throw new RuntimeException(e);}}/*** 獲取任務是否存在** STATE_BLOCKED 4 阻塞* STATE_COMPLETE 2 完成* STATE_ERROR 3 錯誤* STATE_NONE -1 不存在* STATE_NORMAL 0 正常* STATE_PAUSED 1 暫停**/public Boolean notExists(String triggerName, String triggerGroupName) {try {return scheduler.getTriggerState(TriggerKey.triggerKey(triggerName, triggerGroupName)) == Trigger.TriggerState.NONE;} catch (Exception e) {throw new RuntimeException(e);}}}

---

舉個栗子

自定義任務 Job

@Service public class SftpJob extends QuartzJobBean {// 該類必須為public修飾// 該類必須含有空參數的構造器@Value("${sftp.root.username}")private String username;@Value("${sftp.root.password}")private String password;@Value("${sftp.host}")private String host;@Value("${sftp.port}")private Integer port;@Autowiredprivate SftpRepository sftpRepository;@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {// 傳入的參數JobDataMap params = context.getJobDetail().getJobDataMap();...業務邏輯...} }

管理任務

@Service public class SftpTask {// 任務名前綴private final String job_prefix = "job_";// 任務組前綴private final String job_group_prefix = "job_group_";// 觸發器前綴private final String trigger_prefix = "trigger_";// 觸發組前綴private final String trigger_group_prefix = "trigger_group_";private QuartzManager quartzManager;public SftpTask (QuartzManager quartzManager) {this.quartzManager = quartzManager;}/*** 根據配置生成cron表達式*/private String getCron(SftpDTO dto) {// 時Integer hour = dto.getHour();// 分Integer minute = dto.getMinute();// 每周幾Integer week = dto.getWeek();// 每月幾號Integer day = dto.getDay();/* 執行時間 0每天,1每周,2每月 */Integer execType = dto.getExecType();String cron;switch (execType) {case 0:cron = String.format("0 %s %s * * ?", minute, hour);break;case 1:week = (week + 1) % 7;cron = String.format("0 %s %s ? * %s", minute, hour, week == 0 ? 7: week);break;case 2:cron = String.format("0 %s %s %s * ?", minute, hour, day);break;default:cron = "0 0 0 * * ?";break;}return cron;}/*** 添加定時任務*/private void addJob(SftpDTO dto) {Long id = dto.getId();Map<String, Object> params = Maps.newHashMap();params.put("id", id);quartzManager.addJob(job_prefix + id,job_group_prefix + id,trigger_prefix + id,trigger_group_prefix + id,SftpJob.class, getCron(etlSftpDTO), params);}/*** 修改定時任務*/public void modifyJob(SftpDTO dto) {Long id = dto.getId();if (quartzManager.notExists(trigger_prefix + id, trigger_group_prefix + id)){// 任務不存在addJob(dto);} else {// 任務存在 quartzManager.modifyJobTime(trigger_prefix + id,trigger_group_prefix + id,getCron(dto));}}/*** 移除定時任務*/public void removeJob(Long id) {quartzManager.removeJob(job_prefix + id,job_group_prefix + id,trigger_prefix + id,trigger_group_prefix + id);}}

轉載于:https://my.oschina.net/tianshl/blog/1818841

《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的解决SpringBoot使用Quartz无法注入Bean的问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。