Spring事物的傳播特性詳解
一、事務(wù)的傳播性
研究的是多個(gè)事務(wù)存在時(shí)的處理策略
1）REQUIRED：如果存在一個(gè)事務(wù)，則支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就新建一個(gè)事務(wù)。這是最常見(jiàn)的選擇。
2）SUPPORTS：如果存在一個(gè)事務(wù)，支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就以非事務(wù)方式執(zhí)行。
3）MANDATORY：如果存在一個(gè)事務(wù)，支持當(dāng)前事務(wù)，如果當(dāng)前沒(méi)有事務(wù)，就拋出異常。
4）REQUIRES_NEW：新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起。
5）NOT_SUPPORTED：以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。
6）NEVER：以非事務(wù)方式執(zhí)行，如果當(dāng)前存在事務(wù)，則拋出異常。
7）NESTED：支持當(dāng)前事務(wù)，新增Savepoint點(diǎn)，與當(dāng)前事務(wù)同步提交或回滾。
二、測(cè)試前準(zhǔn)備
2.1、準(zhǔn)備好數(shù)據(jù)庫(kù)表
數(shù)據(jù)庫(kù)transaction_propagation
賬號(hào)表account、書(shū)本表book、庫(kù)存表book_stock
SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for account -- ---------------------------- DROP TABLE IF EXISTS `account`; CREATE TABLE `account` ( `user_id` int(11) NOT NULL AUTO_INCREMENT, `user_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `balance` double(11, 2) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`user_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic STORAGE MEMORY; -- ---------------------------- -- Records of account -- ---------------------------- INSERT INTO `account` VALUES (1, 'Albert', 100.00); -- ---------------------------- -- Table structure for book -- ---------------------------- DROP TABLE IF EXISTS `book`; CREATE TABLE `book` ( `book_id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `price` double(11, 2) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`book_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 1003 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of book -- ---------------------------- INSERT INTO `book` VALUES (1001, '基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)', 60.00); INSERT INTO `book` VALUES (1002, '數(shù)據(jù)庫(kù)設(shè)計(jì)', 50.00); -- ---------------------------- -- Table structure for book_stock -- ---------------------------- DROP TABLE IF EXISTS `book_stock`; CREATE TABLE `book_stock` ( `book_id` int(11) NOT NULL AUTO_INCREMENT, `stock` int(11) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`book_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 1003 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of book_stock -- ---------------------------- INSERT INTO `book_stock` VALUES (1001, 100); INSERT INTO `book_stock` VALUES (1002, 100); SET FOREIGN_KEY_CHECKS = 1;
2.2、初始化spring項(xiàng)目
導(dǎo)入一些基本依賴包：jdbc、mysql驅(qū)動(dòng)包、測(cè)試模塊;
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
2.3、數(shù)據(jù)庫(kù)連接信息配置
#jdbc
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost/transaction_propagation?useUnicode=true&characterEncoding=utf-8
username: root
password: 123456
2.4、Service、Dao
這里只使用測(cè)試調(diào)用，省略controller以及entity等層構(gòu)；
1、首先Dao類(lèi)，編寫(xiě)一個(gè)購(gòu)買(mǎi)的簡(jiǎn)單操作：查詢單價(jià)、更新庫(kù)存、更新賬戶余額；
@Repository
public class BookShopDao {
@Autowired
private JdbcTemplate jdbcTemplate = new JdbcTemplate();
public double getPriceById(Integer bookId) {
String sql = "SELECT price FROM BOOK WHERE book_id = ?";
double price = jdbcTemplate.query(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setInt(1, bookId);
}
}, new ResultSetExtractor<Double>() {
@Override
public Double extractData(ResultSet resultSet) throws SQLException, DataAccessException {
double p = 0.0;
while (resultSet.next()) {
p = resultSet.getDouble("price");
}
return p;
}
});
return price;
}
public void updateBookStock(Integer bookId, int num) {
String sql = "UPDATE book_stock SET stock = stock - ? WHERE book_id = ?";
jdbcTemplate.update(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setInt(1, num);
preparedStatement.setInt(2, bookId);
}
});
}
public void updateBalance(Integer userId, double balance) {
//修改金額
String sql = "UPDATE account SET balance = balance - ? WHERE user_id = ?";
jdbcTemplate.update(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setDouble(1, balance);
preparedStatement.setInt(2, userId);
}
});
}
}
2、研究事務(wù)傳播學(xué)性其實(shí)就是研究?jī)蓚€(gè)以上的事務(wù)在嵌套時(shí)的應(yīng)用方式，所以這里需要寫(xiě)兩個(gè)Service進(jìn)行嵌套調(diào)用；接口類(lèi)此處省略BookShopServiceImpl 中的purchase用@Transactional是指一個(gè)購(gòu)買(mǎi)單進(jìn)來(lái)必須保證（1、2、3）的原子性；
@Service
public class BookShopServiceImpl implements BookShopService {
@Autowired
private BookShopDao bookShopDao;
@Transactional
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
}
CashierServiceImpl 中buy方法中的@Transactional是指一個(gè)訂單中出現(xiàn)多個(gè)購(gòu)買(mǎi)單進(jìn)來(lái)必須保證的原子性；
因?yàn)橐粋€(gè)訂單可能包含幾種商品的購(gòu)買(mǎi)。
@Service
public class CashierServiceImpl implements CashierService {
@Autowired
private BookShopService bookShopService;
@Transactional
@Override
public void buy(List<Map<String,Object>> buys){
for (Map map : buys){
//購(gòu)買(mǎi)
bookShopService.purchase((Integer) map.get("userId"),(Integer)map.get("bookId"),(int)map.get("num"));
}
}
}
2.5、測(cè)試類(lèi)
@SpringBootTest
public class TestBuy {
@Autowired
private CashierService cashierService;
@Test
void testBookShop(){
List<Map<String,Object>> list = new ArrayList<>();
Map<String,Object> map = new HashMap<>();
map.put("userId",1);
map.put("bookId",1001);
map.put("num",1);
list.add(map);
map = new HashMap<>();
map.put("userId",1);
map.put("bookId",1002);
map.put("num",1);
list.add(map);
try {
cashierService.buy(list);
}catch (Exception e){
e.printStackTrace();
}
System.out.println("購(gòu)買(mǎi)成功！");
}
}
2.6、說(shuō)明
以上是使用spring默認(rèn)的事務(wù)傳播：REQUIRED，purchase使用同一個(gè)事務(wù)提交。那就會(huì)出現(xiàn)這樣的問(wèn)題：賬戶上有100塊錢(qián)，現(xiàn)在提交訂單是買(mǎi)一本60塊錢(qián)的《基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)》以及一本50塊錢(qián)的《數(shù)據(jù)庫(kù)設(shè)計(jì)》；那么訂單總金額是110元，顯然賬戶上余額是不足夠購(gòu)買(mǎi)的，在第一次事務(wù)購(gòu)買(mǎi)60塊錢(qián)的《基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)》是成功的，但再提交50塊錢(qián)的《數(shù)據(jù)庫(kù)設(shè)計(jì)》的時(shí)候就會(huì)拋出異常，那這時(shí)在CashierServiceImpl 的外層事務(wù)中就會(huì)異常并回滾。
三、使用其他傳播性
3.1、REQUIRES_NEW
在purchase事務(wù)中聲明(propagation = Propagation.REQUIRES_NEW)；那么在每一次調(diào)用purchase時(shí)都會(huì)開(kāi)啟一個(gè)新的事務(wù)去提交；那么此時(shí)進(jìn)行購(gòu)買(mǎi)測(cè)試結(jié)果：第一本書(shū)就會(huì)購(gòu)買(mǎi)成功，第二本書(shū)購(gòu)買(mǎi)失??；因?yàn)楫惓；貪L的是第二次調(diào)用的purchase事務(wù)。
@Transactional(propagation = Propagation.REQUIRES_NEW)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
3.2、MANDATORY
會(huì)強(qiáng)制要求一個(gè)事務(wù)提交，否則拋出異常，測(cè)試結(jié)果與REQUIRED一樣，回滾整個(gè)訂單。
@Transactional(propagation = Propagation.MANDATORY)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
如果外層沒(méi)有事務(wù)就拋出異常
** No existing transaction found for transaction marked with propagation ‘mandatory'**
3.3、SUPPORTS
如果外層存在事務(wù)則以事務(wù)提交，測(cè)試結(jié)果與REQUIRED一樣，回滾整個(gè)訂單。
@Transactional(propagation = Propagation.SUPPORTS)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
如果外層不存在事務(wù)，則不以事務(wù)提交，將可以成功購(gòu)買(mǎi)一本書(shū)；
3.4、NOT_SUPPORTED
以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。即外層是否有事務(wù)都不會(huì)影響結(jié)果：有一本書(shū)可購(gòu)買(mǎi)成功。
@Transactional(propagation = Propagation.NOT_SUPPORTED)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
3.5、NEVER
強(qiáng)制要求不能存在事務(wù)，否則拋出異常
@Transactional(propagation = Propagation.NEVER)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
存在事務(wù)則拋出異常：
Existing transaction found for transaction marked with propagation ‘never'
3.6、NESTED
支持當(dāng)前事務(wù)，新增Savepoint點(diǎn)，與當(dāng)前事務(wù)同步提交或回滾。 結(jié)果與REQUIRES一樣，回滾整個(gè)訂單。
@Transactional(propagation = Propagation.NESTED)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購(gòu)買(mǎi)的圖書(shū)價(jià)格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書(shū)庫(kù)存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
到此這篇關(guān)于Spring事物的傳播性詳解的文章就介紹到這了,更多相關(guān)Spring事物的傳播性內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
springboot集成Swagger的方法(讓你擁有屬于自己的api管理器)
在大型的項(xiàng)目中，如果你有非常多的接口需要統(tǒng)一管理，或者需要進(jìn)行接口測(cè)試，那么我們通常會(huì)在繁雜地api中找到需要進(jìn)行測(cè)試或者管理的接口,接下來(lái)通過(guò)本文給大家介紹springboot集成Swagger的方法讓你擁有屬于自己的api管理器，感興趣的朋友一起看看吧2021-11-11
hashMap是非常重要的容器類(lèi),本文主要介紹了Java中hashMap遍歷的9種方式,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-06-06
SpringCloud集成Eureka并實(shí)現(xiàn)負(fù)載均衡的過(guò)程詳解
這篇文章主要給大家詳細(xì)介紹了SpringCloud集成Eureka并實(shí)現(xiàn)負(fù)載均衡的過(guò)程,文章通過(guò)代碼示例和圖文講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的參考價(jià)值,需要的朋友可以參考下2023-11-11
Java實(shí)現(xiàn)發(fā)送短信驗(yàn)證碼功能
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)發(fā)送短信驗(yàn)證碼功能，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-11-11
join方法的功能就是使異步執(zhí)行的線程變成同步執(zhí)行。也就是說(shuō)，當(dāng)調(diào)用線程實(shí)例的start方法后，這個(gè)方法會(huì)立即返回，如果在調(diào)用start方法后后需要使用一個(gè)由這個(gè)線程計(jì)算得到的值，就必須使用join方法2014-01-01
Java實(shí)現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫(kù)的方法
這篇文章主要介紹了Java實(shí)現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫(kù)的方法,結(jié)合實(shí)例形式分析了java使用JDBC實(shí)現(xiàn)針對(duì)mysql數(shù)據(jù)庫(kù)的連接、查詢、輸出等相關(guān)操作技巧,需要的朋友可以參考下2017-12-12
spring cglib 與 jdk 動(dòng)態(tài)代理
本篇文章主要介紹了spring cglib與jdk動(dòng)態(tài)代理的相關(guān)知識(shí)，具有很好的參考價(jià)值。下面跟著小編一起來(lái)看下吧2017-05-05
這篇文章主要介紹了Java中static的五種用法：修飾成員變量，修飾成員方法，修飾內(nèi)部類(lèi)，靜態(tài)代碼塊，靜態(tài)導(dǎo)包，想詳細(xì)了解的小伙伴可以參考閱讀本文2023-03-03
在IDEA中實(shí)現(xiàn)同時(shí)運(yùn)行2個(gè)相同的java程序
這篇文章主要介紹了在IDEA中實(shí)現(xiàn)同時(shí)運(yùn)行2個(gè)相同的java程序，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-02-02
arthas排查jvm中CPU占用過(guò)高問(wèn)題解決
這篇文章主要介紹了arthas排查jvm中CPU占用過(guò)高問(wèn)題解決,有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-09-09