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


    文章目录

    quartz下载、安装

    Quartz是完全由java开发的一个开源的任务日程管理系统,任务进度管理器就是一个在预先确定的时间到达时,负责执行(或者通知)一段程序或功能的系统,即定时执行某个任务
    Quartz用一个小Java库发布文件(.jar文件),这个库文件包含了所有Quartz核心功能。这些功能的主要接口(API)是Scheduler接口。它提供了简单的操作,例如:将任务纳入日程或者从日程中取消,开始/停止/暂停日程进度。
    quartz服务涉及的11张表
    上图是quartz服务涉及的11张表, 下面这个图是maven中引入的quartz依赖包
    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("设备仪器表闲置资产数据获取完成");
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45

    RefreshTableJob.java就是定时任务执行的入口,它的主要逻辑是调用service实现类中的initIdleAssetList方法,调用Mybatis的mapper文件查询数据库表A的增量数据,循环处理后刷入B表,配置的cron表达式是 0 0 2 1/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”);
      在这里插入图片描述
    2. 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探讨一下。
  • 相关阅读:
    Unix Network Programming Episode 77
    电影评分数据分析案例-Spark SQL
    约数相关问题
    var let const 区别
    吃透这份“腾讯限量版”Java架构笔记,要个40k不过分吧
    JUC并发编程 wait notify详解
    【Java面试】@Resource 和 @Autowired 的区别
    白酒:中国的酒文化的传承与发扬
    Python爬虫eval混淆,爬虫进阶实战系列
    【仿牛客网笔记】 Kafka,构建TB级异步消息系统——发送系统通知、显示系统通知
  • 原文地址:https://blog.csdn.net/bsegebr/article/details/126041561