spring事務(wù)里面開(kāi)啟線程插入報(bào)錯(cuò)了是否會(huì)回滾

更新時(shí)間：2023年04月13日 09:02:44 投稿：mrr

這篇文章主要介紹了spring事務(wù)里面開(kāi)啟線程插入，報(bào)錯(cuò)了是否會(huì)回滾?這是小編遇到一道面試題，題目大概是這個(gè)樣子，今天抽空通過(guò)示例代碼給大家分析下，需要的朋友可以參考下

1.前言

一道非常有意思的面試題目。大概是這樣子的，如果在一個(gè)事務(wù)中，開(kāi)啟線程進(jìn)行插入更新等操作，如果報(bào)錯(cuò)了，事務(wù)是否會(huì)進(jìn)行回滾。

2.代碼

示例1

@RequestMapping("/test/publish/submit")
public String testPublish1() {

	log.info("start...");
	transactionTemplate.execute(new TransactionCallback<String>() {
		@Override
		public String doInTransaction(TransactionStatus status)  {

			TElement element = new TElement();
			element.setfElementId(10L);
			element.setfElementName("111");
			mapper.insertSelective(element);


			element = new TElement();
			element.setfElementId(10L);
			element.setfElementName("222");
			mapper.insertSelective(element);

			return "OK";
		}
	});
	log.info("end...");

	return "ok";
}

示例2

@RequestMapping("/test/publish/submit2")
public String testPublish2() {

	log.info("start...");
	transactionTemplate.execute(new TransactionCallback<String>() {
		@Override
		public String doInTransaction(TransactionStatus status)  {
			es.submit(() -> {
				TElement element = new TElement();
				element.setfElementId(10L);
				element.setfElementName("111");
				mapper.insertSelective(element);
			});

			es.submit(() -> {
				TElement element = new TElement();
				element.setfElementId(10L);
				element.setfElementName("222");
				mapper.insertSelective(element);
			});

			return "OK";
		}
	});
	log.info("end...");

	return "ok";
}

3.結(jié)論

示例1

element.setfElementId(10L); 為主鍵。SQL在第一次插入id=10的時(shí)候是沒(méi)有問(wèn)題的，在第二次插入id=10的時(shí)候，由于主鍵沖突了，導(dǎo)致報(bào)錯(cuò)，然后整個(gè)事務(wù)都會(huì)進(jìn)行回滾，這是沒(méi)有問(wèn)題的。是spring的事務(wù)幫助我們來(lái)進(jìn)行回滾等操作的。我們可以看到如下代碼，他是對(duì)整個(gè)result = action.doInTransaction(status);進(jìn)行了try catch。如果拋異常，就會(huì)回滾

@Override
@Nullable
public <T> T execute(TransactionCallback<T> action) throws TransactionException {
	Assert.state(this.transactionManager != null, "No PlatformTransactionManager set");

	if (this.transactionManager instanceof CallbackPreferringPlatformTransactionManager) {
		return ((CallbackPreferringPlatformTransactionManager) this.transactionManager).execute(this, action);
	}
	else {
		TransactionStatus status = this.transactionManager.getTransaction(this);
		T result;
		try {
			result = action.doInTransaction(status);
		}
		catch (RuntimeException | Error ex) {
			// Transactional code threw application exception -> rollback
			rollbackOnException(status, ex);
			throw ex;
		}
		catch (Throwable ex) {
			// Transactional code threw unexpected exception -> rollback
			rollbackOnException(status, ex);
			throw new UndeclaredThrowableException(ex, "TransactionCallback threw undeclared checked exception");
		}
		this.transactionManager.commit(status);
		return result;
	}
}

示例2

示例2首先是transactionTemplate.execute是一個(gè)主main線程。然后在第一個(gè)子線程插入了一個(gè)數(shù)據(jù)，第二個(gè)子線程也插入了一個(gè)數(shù)據(jù)。那么現(xiàn)在就是有三個(gè)線程，一個(gè)是main線程，一個(gè)是A線程，一個(gè)是B線程。
main線程正常執(zhí)行不報(bào)錯(cuò)，A線程正常插入不報(bào)錯(cuò)，B線程由于主鍵沖突報(bào)錯(cuò)。
我們可以通過(guò)上面action.doInTransaction(status);看出來(lái)，他對(duì)這塊代碼進(jìn)行了try catch。也就是主線程進(jìn)行了try catch。那么也就是只要主線程沒(méi)有報(bào)錯(cuò)，這個(gè)事務(wù)就不會(huì)被捕獲，也就不會(huì)回滾了。無(wú)論你A，B還是CDEFG子線程出問(wèn)題了，只要不影響main線程，那事務(wù)就不會(huì)回滾呢？
因此我們可以得出一個(gè)結(jié)論，在示例2中，A線程會(huì)插入成功，B線程插入失敗，事務(wù)不會(huì)回滾，最終插入成功。這個(gè)其實(shí)與我們平常的想法所違背了。
因此如果想要主線程拋出異常，得讓主線程感知到子線程異常了，主動(dòng)地去throw異常。比如我們可以設(shè)置一個(gè)flag，子線程報(bào)錯(cuò)了 flag=true。主線程檢測(cè)到flag為true，就主動(dòng)拋出一個(gè)exception

4.最后

這道面試題非常有意思，起初以為會(huì)回滾，沒(méi)想到不會(huì)回滾。查看代碼得知，原來(lái)是catch住的是主線程，并不是子線程。同樣注解式事務(wù)類似。因此如果想要事務(wù)生效，盡量避免在事務(wù)中使用多線程來(lái)進(jìn)行插入更新等操作

到此這篇關(guān)于spring事務(wù)里面開(kāi)啟線程插入，報(bào)錯(cuò)了是否會(huì)回滾?的文章就介紹到這了,更多相關(guān)spring事務(wù)開(kāi)啟線程插入內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: