Transactional注解导致Spring Bean定时任务失效的解决方法_Java

背景

业务需要定时捞取数据库中新增的数据做数据处理及分析，更新状态，处理结束。而我们不能随意定义线程池，规定使用统一的标准规范来定义线程池。如在配置文件中配置线程池的属性：名称，线程核心数等，任务属性：任务名称，任务处理类，延迟信息等等。定义好这些信息后，启动系统时，线程池就会初始化并开始执行任务。

业务实现

spring监听器
使用spring容器启动结束发布的applicationreadyevent事件来初始化线程池。

	@eventlistener
    public void onapplicationreadyevent(applicationreadyevent event) {
        log.info("监听器启动线程池。。。");
        jobmanager.start();
    }

线程池统一处理类

public void start() {
       abstractjob job = context.getautowirecapablebeanfactory().createbean(businessjob.class);
       threadpool.schedulewithfixeddelay(job, 1000, 1000, timeunit.milliseconds);
   }

任务处理抽象类
所有任务都会继承这个抽象类，它定义了一些公共的行为，比如看门狗监视任务是否正常执行。看门口属性被定义为这个抽象类的属性，它是直接导致任务失效的直接原因

    @override
    public void run() {
        log.info("==========abstractjob start===========");
        try {
            work();
            watchdog.print();
        } catch (throwable t) {
            logger.log(level.warning, "aaa bbb ccc", t);
        }
        log.info("==========abstractjob end=============");
    }

    protected abstract void work();

任务处理类（继承上面的抽象类）
该类被定义为spring bean对象

	@override
    public void work() {
        log.info("job start.");
        handle();
        log.info("job end.");
    }
    
    public void handle(){
        // 处理业务
    }

新需求

由于某种原因业务提出新需求，而这个需求需要支持事务，于是根据以前学过的知识，直接在任务处理类中定义@transactional注解的方法，通过spring循环依赖，注入了自己。

	@override
    public void work() {
        log.info("job start.");
        handle();
        // job
        job.testtransaction();
        log.info("job end.");
    }
	
	@transactional
    public void testtransaction() {
        log.info("execute transaction.");
        jdbctemplate.execute("update user set name='rick1' where id = 3");
//        jdbctemplate.execute("insert into user values('1', 'rick')");
        log.info("execute transaction end.");
    }

本地测试发现执行正常，提交代码。
万万没想到，测试反馈，定时任务只跑了一次就停止了，也没有异常信息
也是本地重新启动发现确实跑了一次任务就停了。于是将@transactional注解干掉，任务正常的执行。所以将事务方法重新定义一个类，加上@component注解，通过bean对象引入到任务类中。
至此，业务是开发完了，但是出现这种问题的原因还没有分析清楚，随后就有了上面的demo复现问题。

猜测

@transactional注解原理是生成一个代理对象包裹原生创建的bean对象，是不是启动时生成的代理对象将原来传递到线程池的任务被丢弃了。于是把所有涉及的源码开始分析起来

获取任务添加到线程池
从spring容器中获取的bean对象是个代理对象，所以线程池里面执行的任务是个代理对象

在这里插入图片描述

scheduledthreadpoolexecutor线程池
执行schedulewithfixeddelay()方法
检验
封装任务
调用delayedexecute()方法执行任务，最终调用threadpoolexecutor类ensureprestart()方法，将任务提交到线程池执行

在这里插入图片描述

线程池启动线程执行的是scheduledthreadpoolexecutor内部类的scheduledfuturetask类run()方法

在这里插入图片描述

第一次执行任务时调用的是runandreset()方法，如果任务执行成功，则返回true，通过reexecuteperiodic()将任务重新添加到线程池去执行；如果任务执行失败抛异常，则返回false，任务就被丢弃了，也就是跑一次，后面就不跑了。

在这里插入图片描述

顺着这个思路返回去看任务执行过程，如果抛异常了，那就证明这个迷就解开了。c.call()就会调用我们定义的任务抽象类，它又会调用work()方法，而从日志得知work()正常执行完成，所以问题极大可能出现在抽象类里面，work()执行完了以后调用watchdog对象的方法，此时debug发现watchdog对象为空，也就出现了空指针异常，这个异常会被捕获，并打印出来，此时又离谱的事来了，任务类的代理对象的logger属性又是空的，所以又出现了空指针异常抛出去了，导致任务停止执行。