快捷導(dǎo)航

SpringBoot使用Quartz無法注入Bean的問題及解決

更新時(shí)間：2023年11月28日 09:02:17 作者：tian_shl

這篇文章主要介紹了SpringBoot使用Quartz無法注入Bean的問題及解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

依賴

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

任務(wù)工廠 JobFactory

// 解決SpringBoot不能再Q(mào)uartz中注入Bean的問題
@Component
public class JobFactory extends AdaptableJobFactory {
    /**
     * AutowireCapableBeanFactory接口是BeanFactory的子類
     * 可以連接和填充那些生命周期不被Spring管理的已存在的bean實(shí)例
     */
    private AutowireCapableBeanFactory factory;

    public JobFactory(AutowireCapableBeanFactory factory) {
        this.factory = factory;
    }

    /**
     * 創(chuàng)建Job實(shí)例
     */
    @Override
    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {

        // 實(shí)例化對(duì)象
        Object job = super.createJobInstance(bundle);
        // 進(jìn)行注入（Spring管理該Bean）
        factory.autowireBean(job);
        //返回對(duì)象
        return job;
    }
}

任務(wù)調(diào)度器 Scheduler

@Configuration
public class QuartzConfig {

    private JobFactory jobFactory;

    public QuartzConfig(JobFactory jobFactory){
        this.jobFactory = jobFactory;
    }

    /**
     * 配置SchedulerFactoryBean
     *
     * 將一個(gè)方法產(chǎn)生為Bean并交給Spring容器管理
     */
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() {
        // Spring提供SchedulerFactoryBean為Scheduler提供配置信息,并被Spring容器管理其生命周期
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        // 設(shè)置自定義Job Factory，用于Spring管理Job bean
        factory.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;
    }

    /**
     * 添加一個(gè)定時(shí)任務(wù)
     *
     * @param jobName           任務(wù)名
     * @param jobGroupName      任務(wù)組名
     * @param triggerName       觸發(fā)器名
     * @param triggerGroupName  觸發(fā)器組名
     * @param jobClass          任務(wù)
     * @param cron              時(shí)間設(shè)置，參考quartz說明文檔
     */
    @SuppressWarnings({ "unchecked", "rawtypes" })
    public void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron, Map<String, Object> params) {
        try {
            // 任務(wù)名，任務(wù)組，任務(wù)執(zhí)行類
            JobDetail job = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();
            // 任務(wù)參數(shù)
            job.getJobDataMap().putAll(params);

            // 觸發(fā)器
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            // 觸發(fā)器名,觸發(fā)器組
            triggerBuilder.withIdentity(triggerName, triggerGroupName);
            triggerBuilder.startNow();
            // 觸發(fā)器時(shí)間設(shè)定
            triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
            // 創(chuàng)建Trigger對(duì)象
            CronTrigger trigger = (CronTrigger) triggerBuilder.build();

            // 調(diào)度容器設(shè)置JobDetail和Trigger
            scheduler.scheduleJob(job, trigger);

            // 啟動(dòng)
            if (!scheduler.isShutdown()) {
                scheduler.start();
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 修改一個(gè)任務(wù)的觸發(fā)時(shí)間
     *
     * @param triggerName       觸發(fā)器名
     * @param triggerGroupName  觸發(fā)器組名
     * @param cron              時(shí)間設(shè)置，參考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)) {
                // 觸發(fā)器
                TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
                // 觸發(fā)器名,觸發(fā)器組
                triggerBuilder.withIdentity(triggerName, triggerGroupName);
                triggerBuilder.startNow();
                // 觸發(fā)器時(shí)間設(shè)定
                triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
                // 創(chuàng)建Trigger對(duì)象
                trigger = (CronTrigger) triggerBuilder.build();
                // 方式一 ：修改一個(gè)任務(wù)的觸發(fā)時(shí)間
                scheduler.rescheduleJob(triggerKey, trigger);

            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 移除一個(gè)任務(wù)
     *
     * @param jobName           任務(wù)名
     * @param jobGroupName      任務(wù)組名
     * @param triggerName       觸發(fā)器名
     * @param triggerGroupName  觸發(fā)器組名
     */
    public void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) {
        try {

            TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);

            // 停止觸發(fā)器
            scheduler.pauseTrigger(triggerKey);
            // 移除觸發(fā)器
            scheduler.unscheduleJob(triggerKey);
            // 刪除任務(wù)
            scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName));
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 獲取任務(wù)是否存在
     *
     * STATE_BLOCKED 4 阻塞
     * STATE_COMPLETE 2 完成
     * STATE_ERROR 3 錯(cuò)誤
     * 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);
        }
    }

}

舉個(gè)栗子

自定義任務(wù) Job

@Service
public class SftpJob extends QuartzJobBean {

    // 該類必須為public修飾
    // 該類必須含有空參數(shù)的構(gòu)造器

    @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;

    @Autowired
    private SftpRepository sftpRepository;

    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        // 傳入的參數(shù)
        JobDataMap params = context.getJobDetail().getJobDataMap();
        
        ...業(yè)務(wù)邏輯...
    }
}

管理任務(wù)

@Service
public class SftpTask {
    // 任務(wù)名前綴
    private final String job_prefix = "job_";
    // 任務(wù)組前綴
    private final String job_group_prefix = "job_group_";
    // 觸發(fā)器前綴
    private final String trigger_prefix = "trigger_";
    // 觸發(fā)組前綴
    private final String trigger_group_prefix = "trigger_group_";
    
    private QuartzManager quartzManager;
    
    public SftpTask (QuartzManager quartzManager) {
        this.quartzManager = quartzManager;
    }
    
    /**
     *  根據(jù)配置生成cron表達(dá)式
     */
    private String getCron(SftpDTO dto) {

        // 時(shí)
        Integer hour = dto.getHour();
        // 分
        Integer minute = dto.getMinute();
        // 每周幾
        Integer week = dto.getWeek();
        // 每月幾號(hào)
        Integer day = dto.getDay();

        /* 執(zhí)行時(shí)間 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;
    }
    
    /**
     *  添加定時(shí)任務(wù)
     */
    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
        );
    }
    
    /**
     *  修改定時(shí)任務(wù)
     */
    public void modifyJob(SftpDTO dto) {

        Long id = dto.getId();
        if (quartzManager.notExists(trigger_prefix + id, trigger_group_prefix + id)){
            // 任務(wù)不存在
            addJob(dto);
        } else {
            // 任務(wù)存在 
            quartzManager.modifyJobTime(
                trigger_prefix + id,
                trigger_group_prefix + id,
                getCron(dto)
            );
        }
    }

    /**
     *  移除定時(shí)任務(wù)
     */
    public void removeJob(Long id) {
        quartzManager.removeJob(
            job_prefix + id,
            job_group_prefix + id,
            trigger_prefix + id,
            trigger_group_prefix + id
        );
    }
    
}