解決SpringBoot使用Quartz無法注入Bean的問題
依賴
<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例項
*/
@Override
protected 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容器管理
*/
@Bean
public SchedulerFactoryBean schedulerFactoryBean() {
// Spring提供SchedulerFactoryBean為Scheduler提供配置資訊,並被Spring容器管理其生命週期
SchedulerFactoryBean factory = new SchedulerFactoryBean();
// 設定自定義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;
}
/**
* 新增一個定時任務
*
* @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和Trigger
scheduler.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;
@Autowired
private SftpRepository sftpRepository;
@Override
protected 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:
cron = String.format("0 %s %s ? * %s", minute, hour, 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
);
}
}
相關推薦
解決SpringBoot使用Quartz無法注入Bean的問題
依賴 <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId>
netty學習----spring整合netty無法注入bean的問題解決
作者在使用netty整合spring注入呼叫時普通的@Autowired一直bean注入為null,這裡我只是記錄針對netty注入spring無法注入bean的解決發放,具體底層實現,希望大神不吝賜教 首先上解決程式碼塊,copy過去就可以直接用 @Component
訊息佇列監聽器無法注入bean的問題解決
在使用ActiveMq或者其他訊息佇列的過程中,第一步對ActiveMq進行初始化的過程是放在ContextListener的初始化的時候的; 然而當mq接收到訊息的時候觸發getMqMsg方法的時候報錯null,除錯發現MqManageService根本沒有獲取到,我的
springboot 在@Autowire無法注入bean時的臨時處理辦法
問題由來: 在用netty寫一個網路程式設計專案的時候,需要用到mongoTemplate這個springdata提供的mongodb的操作類。但是這個只能由springboot來注入,但是netty又會進行new操作,使得@Autowire無法正常工作。
問題:使用@Autowired無法注入Bean物件
問題 在公司的一個專案開發時,遇到了一個類的屬性無法注入的問題 public class DemoController extends BaseController implements BussinessProcessHandler { @Autow
Spring Boot無法自動注入bean問題解決方案
前言:在使用Spring Boot+Mybatis時,寫完Mapper介面、Service、Controller後,啟動(圖1)打包專案(圖2)均失敗,提示無法自動注入bean。完成目標:1、無法自動注入bean錯誤資訊2、程式碼展示3、解決方案一、錯誤資訊:Descript
Quartz Job類無法注入spring bean問題解決方法
問題描述: 在Quartz的任務類中,無法使用autowired注入spring bean @Component @PersistJobDataAfterExecution @DisallowConcurrentExecution publi
關於spring boot無法自動注入bean問題解決方案
. ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_|
解決Spring中Quart無法自動注入Bean問題
因專案需求,之前專案中已經有定時器的例子了,但是需求那邊過來的需求之前用的定時器並不能滿足,之前的定時器是用spring裡面的@Scheduled(cron = "0 0 0 * * ? ")這種方式,這是一種死的定時器,需求要的是動態定時器,使用者新增一個
解決Spring+Quartz無法自動注入bean問題
工作遇到的問題,使用Quartz定時任務,如果需要用到自動注入,會報空指標異常,看了原文博主的方法,只需要加上 SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); 就能正常注
pojo類無法注入service解決示例
pojo類無法注入service解決示例 歡迎關注作者部落格 簡書傳送門 本示例解決springboot中service無法注入普通jopo的問題。 不囉嗦,直接上程式碼。 如果該示例幫您解決了問題,請助推哦。 pojo類: package
Spring Boot 整合Mybatis非starter時,mapper一直無法注入解決
本來呢,直接使用mybatis-spring-boot-starter還是挺好的,但是我們系統比較複雜,有多個數據源,其中一個平臺自己的資料來源,另外一些是動態配置出來的,兩者完全沒有關係。所以直接使用mybatis-spring-boot-starter就很麻煩了,會報下列錯誤: Caused by
websocket採用tomcat方式,IOC類物件無法注入的解決方案
前言 我採用的spring框架做的,主要用於IOC AOP ,spring之前採用的2.0版本。(2.0版本出錯!下面有解釋); 要實現websocket 實現後臺主動與JSP傳送資料。 具體操作 在websocket類中 註解新增如下: import org.springframework.web.s
springboot中使用filter時注入bean為null的解決辦法
過濾器是servlet規範中定義的,並不歸spring容器管理,也無法直接注入spring中的bean(會報錯) 初始化時通過spring上下文獲取,進行bean的初始化: @Override public void init(FilterConfig filterConfig) throws Serv
Spring3.1完全基於註解配置@Configuration類中@Autowire無法注入問題解決
在上回介紹Spring3.1+Hibernate4.1.7基於註解配置的時候(《SpringMVC3.1+Hibernate4.1.7完全基於註解配置(零配置檔案)》)說過,在修改配置方式的時候遇到過不少問題。這裡介紹一下。 方式一 On
service手動例項化(new)導致類中的spring物件無法注入的問題解決
下面說的這個畫橫線的可能是錯誤的,因為我之前用controller繼承父類的註解物件的時候成功了,所以可能這次的唯一原因就是 不該把本該從ioc容器中拿出的物件通過new的方式例項化,至於繼承註解物件應該是可以的。 首先,如果打算用繼承,那麼父類被注入的物件是無法繼承的,手
Spring 無法注入靜態變數,直接在靜態方法中獲取bean
模組中想把一個類寫成工具類,提供靜態方法呼叫。但是方法中要用到@autowire注入的dao類變數,它要能在靜態方法中使用的話本身就加上static,但是static變數是無法用@autowire注入的。 @Autowired private AppConfMapper m
spring Junit單元測試 bean 無法注入的問題
本人菜鳥在學習ssh 過程 ,遇見問題 向各位大佬請教。進行單元測試 爆出下面提示: 貼出下面配置資訊: applicationContext.xml 實現service 介面類 實現dao介面類 單元測試 進過本菜鳥的各種錯嘗試,上面的配置檔案內容沒有錯誤,只是整合框架的過
靜態變數注入bean的解決方法
解決方法是新建一個類,這個類實現ApplicationContextAware,並重寫setApplicationContext方法。具體請見下面原始碼: import org.springframework.beans.BeansException; import org