2. 程式人生 > 其它 >spring方法呼叫導致事務失效原因及解決方案

spring方法呼叫導致事務失效原因及解決方案

阿新 • • 發佈：2021-02-09

技術標籤：踩坑記錄springjava

spring方法呼叫導致事務失效原因及解決方案

1、事務失效場景復現

  • 背景

我們在平時的工作中寫業務邏輯的時候，有可能會遇到這麼一個場景：在一個迴圈中處理事務問題。在使用宣告式事務的情況下我們有兩種選擇，要麼把@Transanal註解放在整個迴圈的方法上，這樣的話每次迴圈的事務都會被管理到，缺點是使用了長事務，會導致鎖表問題，影響效率。另一種方案是將每一次迴圈抽出一個方法，然後把@Transanal註解加在這個方法上。這樣spring只管理了本次迴圈的事務，解決了長事務問題，但是有事務失效的風險。下面我將會模擬這個場景，這種事務失效也是工作中最常遇到的情況。

  • 場景模擬
    某公司要給疫情期間不回家過年的員工補貼。每個人發放1000元到員工的賬戶
  • 使用技術棧
    spring-boot 2.2.2.RELEASE
    jpa、mysql、lombok 1.18.10

實體類Employee，代表公司的員工：

import lombok.Data;
import javax.persistence.*;
@Data
@Entity
@Table(name = "employee")
public class Employee {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
 

    private Long id;
    private String name;
    /**
     * 補貼是否已發放
     */
    private Boolean hasGiveOut;
}

實體類EmployeeAccount代表員工的賬戶：

import javax.persistence.*;
import java.math.BigDecimal;

@Data
@Entity
@Table(name = "employee_account")
public class EmployeeAccount {
    @Id
    @GeneratedValue
 
(strategy = GenerationType.IDENTITY)
    private Long id;
    private Long employeeId;
    @Column(name = "account")
    private BigDecimal employeeAccount;
}

下面是兩個實體類對應的DAO：

import org.springframework.data.jpa.repository.JpaRepository;

public interface EmployeeRepository extends JpaRepository<Employee, Long> {
}

import org.springframework.data.jpa.repository.JpaRepository;

public interface EmployeeAccountRepository extends JpaRepository<EmployeeAccount, Long> {
    EmployeeAccount findByEmployeeId(Long employeeId);
}

下面是業務處理方法：

因為要保證錢發放到賬戶之後才能將employee的狀態改為已發放，所以要使用事務。我們選擇使用spring的宣告式事務。

@Service
@AllArgsConstructor
public class EmployeeServiceImpl {
    private EmployeeRepository employeeRepository;
    private EmployeeAccountRepository employeeAccountRepository;
    /**
     * 方案1：將事件整個方法作為一個事務，保證了一致性
     * 但是當員工很多的時候，是一個長事務，有效率問題。不推薦
     */
    @Transactional(rollbackFor = Exception.class)
    public void giveOutBonusForAllEmployees(){
        final List<Employee> allEmployees = employeeRepository.findAll();
        for (Employee employee : allEmployees) {

            employee.setHasGiveOut(true);
            employeeRepository.save(employee);

            final EmployeeAccount account = employeeAccountRepository.findByEmployeeId(employee.getId());
            account.setEmployeeAccount(account.getEmployeeAccount().add(new BigDecimal("1000")));
            employeeAccountRepository.save(account);

        }
    }
}

測試方法：

	@Autowired
    private EmployeeServiceImpl employeeService;
    @Test
    public void testTransaction(){
        employeeService.giveOutBonusForAllEmployees();
    }

方案一可以被spring事務管理，朋友們可以自行驗證。為了解決長事務，我們將業務處理方法抽出來，單獨做成一個短事務。

package com.jack.transaction;

import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;

@Service
@AllArgsConstructor
public class EmployeeServiceImpl {
    private EmployeeRepository employeeRepository;
    private EmployeeAccountRepository employeeAccountRepository;

    public void giveOutBonusForAllEmployees(){
        final List<Employee> allEmployees = employeeRepository.findAll();
        for (Employee employee : allEmployees) {
            try{
                giveOutOne(employee, new BigDecimal("1000"));
            }catch (Exception e){
                //一個出錯了不管，繼續發放其他的
            }
        }
    }

    @Transactional(rollbackFor = Exception.class)
    public void giveOutOne(Employee employee, BigDecimal money){
        employee.setHasGiveOut(true);
        employeeRepository.save(employee);

        final EmployeeAccount account = employeeAccountRepository.findByEmployeeId(employee.getId());
        account.setEmployeeAccount(account.getEmployeeAccount().add(money));
        // 模擬丟擲異常
        if ("jack".equals(employee.getName())){
            throw new RuntimeException("儲存失敗了");
        }
        employeeAccountRepository.save(account);
    }
}

下面我們來驗證結果：

  • 原始資料：
select employee.name,employee.has_give_out,ea.account from employee join employee_account ea on employee.id = ea.employee_id;

在這裡插入圖片描述呼叫測試方法之後的資料：
在這裡插入圖片描述事務失效了！！！jack損失了1000塊大洋

2、宣告式事務失效原因

有很多類似的部落格貼出了原始碼來解釋這個問題。筆者表達能力有限，不想用太多原始碼來說明這個原因。我想盡量用自己的語言將這個事務失效的原因告訴讀者，原始碼還是要靠自己去深究。

我們都知道，spring宣告式事務是通過AOP實現的。簡單點說，所有在方法上加了@Transactional註解的方法，已經被spring代理了，成為了有事務能力的代理方法，只有真正呼叫到了這個代理方法才能實現事務。而我們程式碼中的方法呼叫giveOutOne(employee, new BigDecimal("1000"));實際上是this.giveOutOne(employee, new BigDecimal("1000"));，它呼叫的僅僅是原物件的原方法，並沒有呼叫到代理方法，自然也就沒有事務能力了。

3、解決方案

事務失效的原因大概清楚了，那麼解決事務失效的方法的思路也就很清楚了，只要想辦法呼叫到這個代理方法即可。

  • 方法一：從容器中取出代理類，呼叫它的代理方法。當然也也可以使用@Autowired注入EmployeeServiceImpl，但是這樣會顯得很奇怪。
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;

@Service
public class EmployeeServiceImpl implements ApplicationContextAware {

    private EmployeeRepository employeeRepository;
    private EmployeeAccountRepository employeeAccountRepository;
    public EmployeeServiceImpl(EmployeeRepository employeeRepository, EmployeeAccountRepository employeeAccountRepository) {
        this.employeeRepository = employeeRepository;
        this.employeeAccountRepository = employeeAccountRepository;
    }

    private ApplicationContext applicationContext;

    public void giveOutBonusForAllEmployees(){
        final EmployeeServiceImpl employeeService = applicationContext.getBean(EmployeeServiceImpl.class);
        final List<Employee> allEmployees = employeeRepository.findAll();
        for (Employee employee : allEmployees) {
            try{
                employeeService.giveOutOne(employee, new BigDecimal("1000"));
            }catch (Exception e){
                //一個出錯了不管，繼續發放其他的
            }
        }
    }

    @Transactional(rollbackFor = Exception.class)
    public void giveOutOne(Employee employee, BigDecimal money){
        employee.setHasGiveOut(true);
        employeeRepository.save(employee);

        final EmployeeAccount account = employeeAccountRepository.findByEmployeeId(employee.getId());
        account.setEmployeeAccount(account.getEmployeeAccount().add(money));
        // 模擬丟擲異常
        if ("jack".equals(employee.getName())){
            throw new RuntimeException("儲存失敗了");
        }
        employeeAccountRepository.save(account);
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}

將資料復原，再跑一次測試方法看看：
在這裡插入圖片描述

  • 方法二：使用AOP暴露出來的代理物件，其本質也跟上面的一樣。
    第一步：在啟動類上加註解EnableAspectJAutoProxy，指定使用AspectJ作動態代理，並將代理物件暴露出來exposeProxy = true。
@SpringBootApplication
@EnableAspectJAutoProxy(exposeProxy = true)
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }
}

第二步：在程式碼中使用AopContext獲取代理物件

import lombok.AllArgsConstructor;
import org.springframework.aop.framework.AopContext;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;

@Service
@AllArgsConstructor
public class EmployeeServiceImpl{

    private EmployeeRepository employeeRepository;
    private EmployeeAccountRepository employeeAccountRepository;
    
    public void giveOutBonusForAllEmployees(){
        final List<Employee> allEmployees = employeeRepository.findAll();
        for (Employee employee : allEmployees) {
            try{
                ((EmployeeServiceImpl)AopContext.currentProxy()).giveOutOne(employee, new BigDecimal("1000"));
            }catch (Exception e){
                //一個出錯了不管，繼續發放其他的
            }
        }
    }
    @Transactional(rollbackFor = Exception.class)
    public void giveOutOne(Employee employee, BigDecimal money){
        employee.setHasGiveOut(true);
        employeeRepository.save(employee);
        final EmployeeAccount account = employeeAccountRepository.findByEmployeeId(employee.getId());
        account.setEmployeeAccount(account.getEmployeeAccount().add(money));
        // 模擬丟擲異常
        if ("jack".equals(employee.getName())){
            throw new RuntimeException("儲存失敗了");
        }
        employeeAccountRepository.save(account);
    }
}

驗證結果：
在這裡插入圖片描述

4、總結

這個問題在面試中經常會問到的，而且也是工作中時常會發生的。程式設計師需要學的東西很多，時間久了會遺忘很多之前遇到過的坑，然後再踩一遍，所以以後在工作或學習中遇到一些問題，記錄下來，自己偶爾看看。作為同行，如果我的經驗有幫助到你，我也很開心，本人才疏學淺，如果文章中有錯誤的地方，還望大神不吝指教。

相關推薦

spring方法呼叫導致事務失效原因及解決方案

技術標籤：踩坑記錄springjava spring方法呼叫導致事務失效原因及解決方案 1、事務失效場景復現

vue 動態新增的路由頁面重新整理時失效的原因及解決方案

問題描述 昨天在做vue後臺管理系統有關許可權頁面動態新增到路由的功能時，遇到一個問題：動態新增的路由頁面，在頁面重新整理時出現了404的情況。

Java記憶體溢位實現原因及解決方案

1.JVM Heap（堆）溢位：java.lang.OutOfMemoryError: Java heap space JVM在啟動的時候會自動設定JVM Heap的值， 可以利用JVM提供的-Xmn -Xms -Xmx等選項可進行設定。Heap的大小是Young Generation 和Tenured Genera

java.lang.NullPointerException出現的幾種原因及解決方案

java.lang.NullPointerException出現的幾種原因： 1、字串變數未初始化 2、介面型別的物件沒有用具體的類初始化，比如：

Java併發統計變數值偏差原因及解決方案

1 問題描述 在一個專案中，需要對傳送的請求結果進行統計，開發同事定義了兩個全域性共享變數CommonUtil.ReqFailNum和ReqNum,分別記錄請求失敗數和傳送的請求數。並在每次傳送請求之前都假定該請求會處理失敗，先對

Redis快取穿透出現原因及解決方案

在併發式的專案當中，一定要考慮一個快取穿透的情況。那麼什麼是快取穿透呢？簡單的說來，就是當大量請求的key根本不在快取當中，所以導致了請求直接到了資料庫上，根本沒有經過快取這一層。比如一個黑客故意製造我們

vue 頁面首次載入緩慢原因及解決方案

第一次打包vue的專案部署到伺服器，發現首次載入特別的緩慢要幾十秒才加載出來，完全沒有在本地開發環境上那麼流暢。

PHP 502bad gateway原因及解決方案

nginx+php 出現502 bad gateway，一般這都不是nginx的問題，而是由於 fastcgi或者php的問題導致的，常見的有以下幾種。

OOM 常見原因及解決方案

當 JVM 記憶體嚴重不足時，就會丟擲 java.lang.OutOfMemoryError 錯誤。本文總結了常見的 OOM 原因及其解決方法，如下圖所示。如有遺漏或錯誤，歡迎補充指正。

關於Js中數字型別大於2^53(2的53次方)導致精度丟失問題及解決方案

技術標籤：JSjavascript 最近平臺接結構，通過版本號+機構號判斷跳轉相應的頁面，於是乎踩坑了.....

伺服器重啟後Docker無法啟動的原因及解決方案

技術標籤：環境配置與bug記錄docker 問題 伺服器reboot之後，重啟docker 服務時遇到以下bug

Bug_000_用Ajax請求來下載檔案失敗的原因及解決方案

用Ajax請求來下載檔案，失敗的原因，及解決方案 What 實習的第二週的週一，我被安排實現一個：把資料庫的資料，匯出到Excel並下載 的功能，然後做成公共呼叫的介面

Redis的快取穿透、快取擊穿、快取雪崩、熱點資料失效問題及解決方案（轉）

轉：https://zhuanlan.zhihu.com/p/152223694 ​ 在我們的平常的專案中多多少少都會使用到快取，因為一些資料我們沒有必要每次查詢的時候都去查詢到資料庫。特別是高 QPS 的系統，每次都去查詢資料庫，對於你的

ajax請求前端跨域問題原因及解決方案

目錄一、跨域是怎麼形成的二、導致跨域的根本原因三、解決方法1 、ONP2、 CORS3 、代www.cppcns.com理轉發一、跨域是怎麼形成的

JS跨域產生的原因及解決方案

跨域的由來 　跨域問題來源於JavaScript的同源策略，表示只有 協議+域名+埠號 (如存在)相同，即相同的域，則允許相互訪問。也就是說JavaScript只能訪問和操作自己域下的資源，不能訪問和操作其他域下的資源。

UnsupportedOperationException的原因及解決方案

探討UnsupportedOperationException的原因及解決方案 Arrays.asList()方法返回的是不可變集合

JS定時器不可靠的原因及解決方案

前言 在工作中應用定時器的場景非常多，但你會發現有時候定時器好像並沒有按照我們的預期去執行，比如我們常遇到的setTimeout(()=>{},0)它有時候並不是按我們預期的立馬就執行。想要知道為什麼會這樣，我們首先需

集合框架（併發修改異常產生的原因及解決方案）

我有一個集合，如下，請問，我想判斷裡面有沒有\"world\"這個元素，如果有，我就新增一個\"javaee\"元素，請寫程式碼實現。

高手總結的9種 OOM 常見原因及解決方案

當 JVM 記憶體嚴重不足時，就會丟擲 java.lang.OutOfMemoryError 錯誤。本文總結了常見的 OOM 原因及其解決方法，如下圖所示。如有遺漏或錯誤，歡迎補充指正。

mysql使用group by查詢報錯SELECT list is not in GROUP BY clause and contains nonaggregated column...原因及解決方案

在專案中需要用到group by進行聚合計算，在計算的同時也要查出一些其他欄位來返回給前端。於是就有了這個錯誤的出現。