springBoot项目集成quartz开发定时任务案例及注意事项

quartz下载、安装

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<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("设备仪器表闲置资产数据获取完成");

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
原因：定时任务类RefreshTableJob中找不到IassetService这个类
解决方法：
在系统的启动类的main方法中加上这么一行配置信息，仅本地调试的时候加哦，这行代码不用提交，生产环境没有这个问题，不知道为啥子
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表的时候看到有个创建人字段，想获取系统中的当前登录用户信息，结果获取不到request相关对象

相信查过资料的朋友看到了网上说的设置request子线程共享或者重新实现RequestAttributes接口的方式了，这俩方案只是屏蔽报错的，如果只是想屏蔽报错，那直接删掉出错位置的代码或者写个自定义接口实现类判断一下requestAttributes 为空时new一个就完了。

那怎么获取当前登录用户呢?
答案是获取不到，定时任务可以在不登陆系统的情况下运行，对于在controller层调用service方法（WEB访问方式）中使用RequestContextHolder或者WebApplicationContext对象获取上下文的情况完全没有问题。但是除了controller层外，调度任务等也可能调用service层的方法（非web方式根本不存在request对象），这种情况下不能使用上下文对象获取其中的用户信息。
如果你非要娶，可以提前把用户登录信息存到redis或者其他渠道，看起来有点麻烦，真有这样的需求吗，showme探讨一下。

到此这篇关于springBoot项目集成quartz开发定时任务案例及注意事项的文章就介绍到这了,更多相关springBoot集成quartz开发定时任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

最新评论