springBoot項(xiàng)目集成quartz開發(fā)定時任務(wù)案例及注意事項(xiàng)
quartz下載、安裝
Quartz是完全由java開發(fā)的一個開源的任務(wù)日程管理系統(tǒng),任務(wù)進(jìn)度管理器就是一個在預(yù)先確定的時間到達(dá)時,負(fù)責(zé)執(zhí)行(或者通知)一段程序或功能的系統(tǒng),即定時執(zhí)行某個任務(wù)。
Quartz用一個小Java庫發(fā)布文件(.jar文件),這個庫文件包含了所有Quartz核心功能。這些功能的主要接口(API)是Scheduler接口。它提供了簡單的操作,例如:將任務(wù)納入日程或者從日程中取消,開始/停止/暫停日程進(jìn)度。

上圖是quartz服務(wù)涉及的11張表, 下面這個圖是maven中引入的quartz依賴包

Quartz的jar包下載、SpringBoot項(xiàng)目整合Quartz安裝及具體的使用方法本站已經(jīng)有很多,但是還是建議參考W3CSchool的官方文檔 Quartz快速入門指南
官方文檔地址: https://www.w3cschool.cn/quartz_doc/quartz_doc-2put2clm.html
實(shí)戰(zhàn)案例
假如我開發(fā)環(huán)境已經(jīng)配置好,我們只關(guān)注具體業(yè)務(wù)實(shí)現(xiàn)。實(shí)際上做項(xiàng)目的過程中也很少會讓開發(fā)自己去集成組件,通常都是開發(fā)環(huán)境已經(jīng)配置好了,如果需要配置的話還是像上面說的,看官方文檔吧。
現(xiàn)在有個需求是每天凌晨把某個登記表A的信息篩選后刷到B表中,先貼上代碼:
//RefreshTableJob.java的代碼
@Component("RefreshTableJob")
public class RefreshTableJob {
private static final Logger logger = LoggerFactory.getLogger(RefreshIdleAssetJob.class);
public void PullData(){
try{
SpringUtils.getBean(IassetService.class).initIdleAssetList();
} catch (RestClientResponseException e) {
logger.error("數(shù)據(jù)同步失敗,error:"+e.getMessage());
}catch (Exception e) {
e.printStackTrace();
logger.error("數(shù)據(jù)同步失敗,error:"+e.getMessage());
}
}
}
//assetServiceImpl.java的代碼 實(shí)現(xiàn)了IassetService接口
@Service
public class IdleAssetServiceImpl implements IaAssetService{
@Resource
private IdleAssetMapper idleAssetMapper;
/**
* 拉取增量閑置資產(chǎn)數(shù)據(jù)
*/
@Override
@Transactional
public void initIdleAssetList(){
// 處理閑置數(shù)據(jù)
List<HashMap> initList = idleAssetMapper.selectIdleList(null);
while (initList != null && initList.size() > 0){
for(HashMap data : initList){
HashMap paramMap = new HashMap();
String uuid = UUID.randomUUID().toString().trim();
paramMap.put("UPDATETIME", DateUtils.getNowDate());
paramMap.put("UPDATEUSER", "");
paramMap.put("STATUS", data.get("A_STATUS"));
// 。。。。這里省略了很多字段
paramMap.put("USAGESECRET", data.get("A_USAGESECRET"));
paramMap.put("BELONGENTITYID", data.get("A_ID"));
idleAssetMapper.saveIdleAsset(paramMap);
}
initList = idleAssetMapper.selectEquipIdleList(null);
}
logger.info("設(shè)備儀器表閑置資產(chǎn)數(shù)據(jù)獲取完成");
RefreshTableJob.java就是定時任務(wù)執(zhí)行的入口,它的主要邏輯是調(diào)用service實(shí)現(xiàn)類中的initIdleAssetList方法,調(diào)用Mybatis的mapper文件查詢數(shù)據(jù)庫表A的增量數(shù)據(jù),循環(huán)處理后刷入B表,配置的cron表達(dá)式是 0 0 2 1/1 * ? * (每天兩天執(zhí)行一次)。
常見問題及解決方案
org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'com.bjsasc.openshare.idleasset.service.IassetService' available
原因:定時任務(wù)類RefreshTableJob中找不到IassetService這個類
解決方法:
在系統(tǒng)的啟動類的main方法中加上這么一行配置信息,僅本地調(diào)試的時候加哦,這行代碼不用提交,生產(chǎn)環(huán)境沒有這個問題,不知道為啥子
System.setProperty(“spring.devtools.restart.enabled”, “false”);

java.lang.IllegalStateException: No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request. 直接原因:我在插入B表的時候看到有個創(chuàng)建人字段,想獲取系統(tǒng)中的當(dāng)前登錄用戶信息,結(jié)果獲取不到request相關(guān)對象

相信查過資料的朋友看到了網(wǎng)上說的設(shè)置request子線程共享或者重新實(shí)現(xiàn)RequestAttributes接口的方式了,這倆方案只是屏蔽報錯的,如果只是想屏蔽報錯,那直接刪掉出錯位置的代碼或者寫個自定義接口實(shí)現(xiàn)類判斷一下requestAttributes 為空時new一個就完了。
那怎么獲取當(dāng)前登錄用戶呢?
答案是獲取不到,定時任務(wù)可以在不登陸系統(tǒng)的情況下運(yùn)行,對于在controller層調(diào)用service方法(WEB訪問方式)中使用RequestContextHolder或者WebApplicationContext對象獲取上下文的情況完全沒有問題。但是除了controller層外,調(diào)度任務(wù)等也可能調(diào)用service層的方法(非web方式根本不存在request對象),這種情況下不能使用上下文對象獲取其中的用戶信息。
如果你非要娶,可以提前把用戶登錄信息存到redis或者其他渠道,看起來有點(diǎn)麻煩,真有這樣的需求嗎,showme探討一下。
到此這篇關(guān)于springBoot項(xiàng)目集成quartz開發(fā)定時任務(wù)案例及注意事項(xiàng)的文章就介紹到這了,更多相關(guān)springBoot集成quartz開發(fā)定時任務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- 淺談SpringBoot集成Quartz動態(tài)定時任務(wù)
- SpringBoot與Quartz集成實(shí)現(xiàn)分布式定時任務(wù)集群的代碼實(shí)例
- SpringBoot集成Quartz實(shí)現(xiàn)定時任務(wù)的方法
- Spring集成Quartz的簡單配置的方法
- 詳解Quartz 與 Spring框架集成的三種方式
- Spring Boot集成Quartz注入Spring管理的類的方法
- SpringBoot集成quartz實(shí)現(xiàn)定時任務(wù)詳解
- SpringBoot2.6.3集成quartz的方式
- Quartz與Spring集成的兩種方法示例
- 可視化定時任務(wù)quartz集成解析全過程
相關(guān)文章
Redis實(shí)現(xiàn)延遲隊(duì)列的全流程詳解
Redisson是Redis服務(wù)器上的分布式可伸縮Java數(shù)據(jù)結(jié)構(gòu),這篇文中主要為大家介紹了Redisson實(shí)現(xiàn)的優(yōu)雅的延遲隊(duì)列的方法,需要的可以參考一下2023-03-03
Java實(shí)現(xiàn)字符串倒序輸出的四種方法匯總
這篇文章主要介紹了Java實(shí)現(xiàn)字符串倒序輸出的四種方法匯總,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-06-06

