Springboot中多线程数据库操作下的事务一致性问题的解决方案

文章目录

1 代码实现
- 1.1 正常情况
- 1.2 异常情况
- 总结

1 代码实现

1.1 正常情况

我们采用手动开启事务的方式

    public void add(CountDownLatch countDownLatch) {executor.submit(() -> {TransactionStatus transaction = dataSourceTransactionManager.getTransaction(transactionDefinition);try {ThreadTest obj = new ThreadTest();obj.setColumnName("threadTest");log.info("开始插入");threadTestMapper.insert(obj);countDownLatch.countDown();// throw new RuntimeException("故意抛出错误测试是否会进行回滚");} catch (Exception e) {log.info("出现异常了开始回滚");dataSourceTransactionManager.rollback(transaction);} finally {dataSourceTransactionManager.commit(transaction);}});}

insert方法中插入100条测试数据到数据库，通过手动开启事务的方式在每个子线程中开启各自的事务。注意注释的位置，首先测试没有错误的情况。

完整代码

@Service
@RequiredArgsConstructor
@Slf4j
public class ThreadTestServiceImplTwo extends ServiceImpl<ThreadTestMapper, ThreadTest>implements ThreadTestService{private final DataSourceTransactionManager dataSourceTransactionManager;private final TransactionDefinition transactionDefinition;private final ThreadTestMapper threadTestMapper;privatestatic final ThreadPoolTaskExecutor executor;static {executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10);executor.setMaxPoolSize(15);executor.setQueueCapacity(100);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());executor.setKeepAliveSeconds(60);executor.initialize();}public void add(CountDownLatch countDownLatch) {executor.submit(() -> {TransactionStatus transaction = dataSourceTransactionManager.getTransaction(transactionDefinition);try {ThreadTest obj = new ThreadTest();obj.setColumnName("threadTest");log.info("开始插入");threadTestMapper.insert(obj);countDownLatch.countDown();// throw new RuntimeException("故意抛出错误测试是否会进行回滚");} catch (Exception e) {log.info("出现异常了开始回滚");dataSourceTransactionManager.rollback(transaction);} finally {dataSourceTransactionManager.commit(transaction);}});}public void insert() {CountDownLatch countDownLatch = new CountDownLatch(100);for (int i = 0; i < 100; i++) {add(countDownLatch);}try {countDownLatch.await();} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

测试类中测试insert方法

    @Testvoid testInsert() {threadTestService.insert();}

结果
正常插入100条数据
在这里插入图片描述

1.2 异常情况

把1.1中的方法 // throw new RuntimeException("故意抛出错误测试是否会进行回滚");取消注释即可，测试手动错误数据插入情况

   public void insert() {CountDownLatch countDownLatch = new CountDownLatch(100);for (int i = 0; i < 100; i++) {add(countDownLatch);}try {countDownLatch.await();} catch (InterruptedException e) {throw new RuntimeException(e);}}public void add(CountDownLatch countDownLatch) {executor.submit(() -> {TransactionStatus transaction = dataSourceTransactionManager.getTransaction(transactionDefinition);try {ThreadTest obj = new ThreadTest();obj.setColumnName("threadTest");log.info("开始插入");threadTestMapper.insert(obj);countDownLatch.countDown();// 手动错误throw new RuntimeException("故意抛出错误测试是否会进行回滚");} catch (Exception e) {log.info("出现异常了开始回滚");dataSourceTransactionManager.rollback(transaction);} finally {dataSourceTransactionManager.commit(transaction);}});}