背景
业务需要定时捞取数据库中新增的数据做数据处理及分析,更新状态,处理结束。而我们不能随意定义线程池,规定使用统一的标准规范来定义线程池。如在配置文件中配置线程池的属性:名称,线程核心数等,任务属性:任务名称,任务处理类,延迟信息等等。定义好这些信息后,启动系统时,线程池就会初始化并开始执行任务。
业务实现
- Spring监听器
使用Spring容器启动结束发布的ApplicationReadyEvent事件来初始化线程池。
@EventListenerpublic 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);}
- 任务处理抽象类
所有任务都会继承这个抽象类,它定义了一些公共的行为,比如看门狗监视任务是否正常执行。看门口属性被定义为这个抽象类的属性,它是直接导致任务失效的直接原因
@Overridepublic 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对象
@Overridepublic void work() {log.info("job start.");handle();log.info("job end.");}public void handle(){// 处理业务}
新需求
由于某种原因业务提出新需求,而这个需求需要支持事务,于是根据以前学过的知识,直接在任务处理类中定义@Transactional注解的方法,通过Spring循环依赖,注入了自己。
@Overridepublic void work() {log.info("job start.");handle();// jobjob.testTransaction();log.info("job end.");}@Transactionalpublic 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属性又是空的,所以又出现了空指针异常抛出去了,导致任务停止执行。
为什么代理对象的属性都为空呢
Spring代理对象所有属性都为空,只有被代理对象的属性有值。可以参考这篇文章