Transactional注解导致Spring Bean定时任务失效

背景

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

业务实现

  • 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代理对象所有属性都为空,只有被代理对象的属性有值。可以参考这篇文章

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/444850.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

04-SpringBootWeb案例(中)

3. 员工管理 完成了部门管理的功能开发之后,我们进入到下一环节员工管理功能的开发。 基于以上原型,我们可以把员工管理功能分为: 分页查询(今天完成)带条件的分页查询(今天完成)删除员工&am…

Linux_kernel内核定时器14

一、内核定时器 1、内核定时器 使用方法: 2、系统时钟中断处理函数 1)更新时间 2)检查当前时间片是否耗尽 Linux操作系统是基于时间片轮询的,属于抢占式的内核 3)jiffies 3、基本概念 1)HZ HZ决定了1秒钟产…

OCP迎来新版本,让OceanBase的运维管理更高效

近期,OceanBase的OCP发布了新版本,全面支持 OceanBase 内核 4.3.2 及更低版本。新版本针对基础运维、性能监控、运维配置、外部集成等多个方面实现了 20余项的优化及强化措施,增强产品的易用性和稳定性,从而帮助用户更加高效地管理…

中国地级市生态韧性数据及城市生态韧性数据(2000-2022年)

一测算方式: 参考C刊《管理学刊》楚尔鸣(2023)老师的做法,城市生态韧性主要衡量一个城市在面临生态环境系统压力或突发冲击时,约束污染排放、维护生态环境状态和治理能力提升的综合水平。 参考郭海红和刘新民的研究&a…

Redis持久化机制(RDBAOF详解)

目录 一、Redis持久化介绍二、Redis持久化方式1、RDB持久化(1) 介绍(2) RDB持久化触发机制(3) RDB优点和缺点(4) RDB流程 2、AOF(append only file)持久化(1) 介绍(2) AOF优点和缺点(3) AOF文件重写(4) AOF文件重写流程 三、AOF和RDB持久化注意事项 一、Redis持久化介绍 Redis…

【小工具分享】下载保存指定网页的所有图片

一、保存百度首页所有的图片 先看一下保存的图片情况 二、思路 1、打开网页 2、获取所有图片 3、依次下载保存图片到指定路径 三、完整代码 from selenium import webdriver from selenium.webdriver.common.by import By b webdriver.Firefox() import urllib.request…

C++系统教程004-数据类型(03)

一 .变量 变量是指在程序运行期间其值可以发生改变的量。每个变量都必须有一个名称作为唯一的标识,且具有一个特定的数据类型。变量使用之前,一定要先进行声明或定义。 1.变量的声明和定义 C中,变量声明是指为变量提供一个名称&#xff0c…

嵌入式面试——FreeRTOS篇(七) 软件定时器

本篇为:FreeRTOS 软件定时器篇 一、软件定时器的简介 1、定时器介绍 答: 定时器:从指定的时刻开始,经过一个指定时间,然后触发一个超时事件,用户可以自定义定时器周期。 硬件定时器:芯片本…

基于差分进化灰狼混合优化的SVM(DE-GWO-SVM)数据预测算法matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.本算法原理 4.1 DE优化 4.2 GWO优化 5.完整程序 1.程序功能描述 基于差分进化灰狼混合优化的SVM(DE-GWO-SVM)数据预测算法matlab仿真,对比SVM和GWO-SVM。 2.测试软件版本以及运行结果展示…

论文阅读:Split-Aperture 2-in-1 Computational Cameras (二)

Split-Aperture 2-in-1 Computational Cameras (一) Coded Optics for High Dynamic Range Imaging 接下来,文章介绍了二合一相机在几种场景下的应用,首先是高动态范围成像,现有的快照高动态范围(HDR)成像工作已经证…

自然语言处理(NLP)论文数量的十年趋势:2014-2024

引言 近年来,自然语言处理(NLP)已成为人工智能(AI)和数据科学领域中的关键技术之一。随着数据规模的不断扩大和计算能力的提升,NLP技术从学术研究走向了广泛的实际应用。通过观察过去十年(2014…

处理 Vue3 中隐藏元素刷新闪烁问题

一、问题说明 页面刷新,原本隐藏的元素会一闪而过。 效果展示: 页面的导航栏通过路由跳转中携带的 meta 参数控制导航栏的 显示/隐藏,但在实践过程中发现,虽然元素隐藏了,但是刷新页面会出现闪烁的问题。 项目源码&…

ros2:从github上下载源码进行编译

首先,创建工作空间 # 1. 递归创建工作空间目录 mkdir -p catkin_ws/src # 2. 进入src目录 cd catkin_ws/src然后如果你没有安装git,需要 sudo apt install git然后输入。 git clone https://github.com/6-robot/wpr_simulation.git这时候,…

MYSQL 常见锁机制详解,常见锁问题排查及分析

1,锁分类 锁冲突是影响数据库性能的重要指标,本章节介绍MYSQL常见锁,及各种说的常用示例,mysql锁的分类如下: 从操作类型分类:读锁、写锁; 从操作粒度分类:表锁、页锁、行锁&#x…

文献阅读Prov-GigaPath模型--相关知识点罗列

文章链接:A whole-slide foundation model for digital pathology from real-world data | NatureDigital pathology poses unique computational challenges, as a standard gigapixel slide may comprise tens of thousands of image tiles1–3. Prior models hav…

Java中的二维数组

二维数组 使用方式1:动态初始化1.语法:2.比如:3.二维数组在内存的存在形式 使用方式2:动态初始化使用方法3:动态初始化--列数不确定使用方式4:静态初始化1.定义2.使用 使用方式1:动态初始化 1.…

HiRT | 异步控制策略,告别VLA时延问题

论文:HiRT: Enhancing Robotic Control with Hierarchical Robot Transformers 前言:HiRT 通过异步处理的策略,将 VLM 作为低频慢思考过程,将轻量的动作策略模型作为高频快响应过程 ,以此解决 VLA 驱动带来的控制时延问…

RNN经典案例——构建人名分类器

RNN经典案例——人名分类器 一、数据处理1.1 去掉语言中的重音标记1.2 读取数据1.3 构建人名类别与人名对应关系字典1.4 将人名转换为对应的onehot张量 二、构建RNN模型2.1 构建传统RNN模型2.2 构建LSTM模型2.3 构建GRU模型 三、构建训练函数并进行训练3.1 从输出结果中获得指定…

TON生态小游戏开发:推广、经济模型与UI设计的建设指南

随着区块链技术的快速发展,基于区块链的Web3游戏正引领行业变革。而TON生态小游戏,借助Telegram庞大的用户基础和TON(The Open Network)链上技术,已成为这一领域的明星之一。国内外开发者正迅速涌入,开发和…

基于SpringBoot+Vue的船舶监造系统(带1w+文档)

基于SpringBootVue的船舶监造系统(带1w文档) 基于SpringBootVue的船舶监造系统(带1w文档) 大概在20世纪90年代,我国才开始研发船舶监造系统,与一些发达国家相比,系统研发起步比较晚。当时的计算机技术刚开始发展起来,国家经济力量…