致命问题多数据源引发SpringBatch多事物

文章目录

一、如何查看SpringBatch原数据和业务数据是一个事物
二、多数据源如何引发SpringBatch多事物

写在前面：我是「境里婆娑」。我还是从前那个少年，没有一丝丝改变，时间只不过是考验，种在心中信念丝毫未减，眼前这个少年，还是最初那张脸，面前再多艰险不退却。
写博客的目的就是分享给大家一起学习交流，如果您对 Java感兴趣，可以关注我，我们一起学习。

前言：我们项目在运行的时候出现了多事物问题，SpringBatch原数据表提交和业务表数据提交用的不是一个事物，这在项目运行中是一个非常致命的问题。在极端情况下断点续跑可能会出现丢失数据，所以解决这个问题迫在眉睫。

一、如何查看SpringBatch原数据和业务数据是一个事物

SpringBatch源代码TaskletStep这个类的doInTransaction这个方法时保存业务数据和SpringBatch源数据表。

保存业务数据
result = tasklet.execute(contribution, chunkContext);
保存SpringBatch上下文表
getJobRepository().updateExecutionContext(stepExecution);
保存SpringBatch step表
getJobRepository().update(stepExecution);

为了验证保存业务数据和保存SpringBatch源数据是使用一个事物提交，我们可以通过debug方式分别把断点打到这三行代码上。

result = tasklet.execute(contribution, chunkContext);
getJobRepository().updateExecutionContext(stepExecution);
getJobRepository().update(stepExecution);

查询SpringBatch业务表和源数据表断点走完业务表无数据、batch上下文表，batch_step_execution表都是最初是状态则说明是一个事物。

select * from batch_step_execution ORDER BY STEP_EXECUTION_ID desc;
select * from batch_step_execution_context order by STEP_EXECUTION_ID desc;
select * from cat;

batch_step_execution_context初始状态

159  {"batch.taskletType":"org.springframework.batch.core.step.item.ChunkOrientedTasklet","FlatFileItemReader.read.count":0,"batch.stepType":"org.springframework.batch.core.step.tasklet.TaskletStep"}

batch_step_execution初始状态

187  3   cafeCatStep 1015    2020-11-25 10:02:05 2020-11-25 10:03:03 STARTING 0  0   0   0   0   0   0   0   UNKNOWN 2020-11-25 10:03:03

SpringBatch源码TaskletStep类doInTransaction方法

public RepeatStatus doInTransaction(TransactionStatus status) {TransactionSynchronizationManager.registerSynchronization(this);RepeatStatus result = RepeatStatus.CONTINUABLE;//代码省略.......result = tasklet.execute(contribution, chunkContext);//代码省略...stepExecutionUpdated = true;getJobRepository().updateExecutionContext(stepExecution);getJobRepository().update(stepExecution);//代码省略...return result;}

二、多数据源如何引发SpringBatch多事物

项目中使用了多数据源，而且重写了BasicBatchConfigurer这个类的这个initialize方法。而且这个类中重新new了一个新的数据源，通过各种排查确定出原因是这个new的新数据源导致多事物问题。

详细代码如下：

总结：我们最好不去修改原生态的SpringBatch代码，否则会出现意想不到的结果。