Quartz是完全由java开发的一个开源的任务日程管理系统,任务进度管理器就是一个在预先确定的时间到达时,负责执行(或者通知)一段程序或功能的系统,即定时执行某个任务
。
Quartz用一个小Java库发布文件(.jar文件),这个库文件包含了所有Quartz核心功能。这些功能的主要接口(API)是Scheduler接口。它提供了简单的操作,例如:将任务纳入日程或者从日程中取消,开始/停止/暂停日程进度。
上图是quartz服务涉及的11张表, 下面这个图是maven中引入的quartz依赖包
Quartz的jar包下载、SpringBoot项目整合Quartz安装及具体的使用方法本站已经有很多,但是还是建议参考W3CSchool的官方文档 Quartz快速入门指南
官方文档地址: https://www.w3cschool.cn/quartz_doc/quartz_doc-2put2clm.html
假如我开发环境已经配置好,我们只关注具体业务实现。实际上做项目的过程中也很少会让开发自己去集成组件,通常都是开发环境已经配置好了,如果需要配置的话还是像上面说的,看官方文档吧。
现在有个需求是每天凌晨把某个登记表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("数据同步失败,error:"+e.getMessage());
}catch (Exception e) {
e.printStackTrace();
logger.error("数据同步失败,error:"+e.getMessage());
}
}
}
//assetServiceImpl.java的代码 实现了IassetService接口
@Service
public class IdleAssetServiceImpl implements IaAssetService{
@Resource
private IdleAssetMapper idleAssetMapper;
/**
* 拉取增量闲置资产数据
*/
@Override
@Transactional
public void initIdleAssetList(){
// 处理闲置数据
List 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("设备仪器表闲置资产数据获取完成");
RefreshTableJob.java就是定时任务执行的入口,它的主要逻辑是调用service实现类中的initIdleAssetList方法,调用Mybatis的mapper文件查询数据库表A的增量数据,循环处理后刷入B表,配置的cron表达式是 0 0 2 1/1 * * (每天两天执行一次)。
org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'com.bjsasc.openshare.idleasset.service.IassetService' available
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.