Spring中使用事務搭建轉賬環境 轉賬操作一個賬戶要減少資金操作一個賬戶要增加資金操作,如果在兩個操作間出現異常轉賬失敗 所以要使用事務

来源:https://www.cnblogs.com/qingyundian/archive/2017/12/28/8138025.html
-Advertisement-
Play Games

演示不使用事務出現異常情況 Dao層兩個方法lessMoney()和moreMoney() Service層調用兩個方法 但是兩個操作減與加之間,如果出現異常,則會導致轉賬錢已經轉了,但對方卻沒有到賬的bug,可能伺服器突然故障等引起 解決添加事務,出現異常進行回滾操作 下麵使用配置文件的方法進行事 ...


演示不使用事務出現異常情況

Dao層兩個方法lessMoney()和moreMoney()

package com.swift;

import org.springframework.jdbc.core.JdbcTemplate;

public class AccountDao {
    private JdbcTemplate jdbcTemplate;
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    //少錢的方法
    public void lessMoney(String from,double number) {
        String sql="update account set money=money-? where username=?";
        jdbcTemplate.update(sql, number,from);
        
    }
    //多錢的方法
    public void moreMoney(String to,double number) {
        String sql="update account set money=money+? where username=?";
        jdbcTemplate.update(sql, number,to);
    }
}

Service層調用兩個方法

package com.swift;

public class AccountService {
    private AccountDao accountDao;
    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }
    
    public void moneyTransfer(String from,String to,double number) {
        accountDao.lessMoney(from,number);
        int i=10/0;
        accountDao.moreMoney(to,number);
    }
}

但是兩個操作減與加之間,如果出現異常,則會導致轉賬錢已經轉了,但對方卻沒有到賬的bug,可能伺服器突然故障等引起


 

解決添加事務,出現異常進行回滾操作

下麵使用配置文件的方法進行事務管理

沒有改變的測試類

package com.swift;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

@WebServlet("/test")
public class ServletTest extends HttpServlet {
    private static final long serialVersionUID = 1L;
       
    public ServletTest() {
        super();
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        response.setCharacterEncoding("utf-8");
        response.setContentType("text/html;charset=utf-8");
        response.getWriter().append("Served at: ").append(request.getContextPath());
        
        //使用JdbcTemplat的queryForObject方法
        ApplicationContext context=new ClassPathXmlApplicationContext("c3p0.xml");
        AccountService accountService= (AccountService) context.getBean("accountService");
        accountService.moneyTransfer("傭兵組織", "高揚", 100000);
    }

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }

}

使用配置文件進行事務處理步驟如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!-- c3p0連接池得到dataSource -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/sw_database"></property>
        <property name="user" value="root"></property>
        <property name="password" value="root"></property>
    </bean>

    <!-- 第一步 配置事務管理器 -->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!-- 註入dataSource -->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 第二步 配置事務增強 -->
    <tx:advice id="txadvice" transaction-manager="transactionManager">
        <!-- 做事務操作 -->
        <tx:attributes>
            <!-- 事務操作的方法匹配規則 -->
            <tx:method name="money*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>
    
    <!-- 第三步 配置切麵 -->
    <aop:config>
    <!-- 切入點 -->
    <aop:pointcut expression="execution(* com.swift.AccountService.*(..))" id="pointcut1"/>
    <!-- 切麵 -->
    <aop:advisor advice-ref="txadvice" pointcut-ref="pointcut1"/>
    </aop:config>

    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <bean id="accountDao" class="com.swift.AccountDao">
        <property name="jdbcTemplate" ref="jdbcTemplate"></property>
    </bean>

    <bean id="accountService" class="com.swift.AccountService">
        <property name="accountDao" ref="accountDao"></property>
    </bean>

</beans>

分三個步驟 管理 增強和切麵

雖然還是會有異常,但是資料庫中不會出錯,不會錢轉出了,卻沒有到賬

工具類Account

package com.swift;

public class Account {
    
    private int id;
    private String username;
    private String money;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getMoney() {
        return money;
    }
    public void setMoney(String money) {
        this.money = money;
    }
    public Account(int id, String username, String money) {
        this.id = id;
        this.username = username;
        this.money = money;
    }
    public Account() {
        super();
        // TODO Auto-generated constructor stub
    }
    @Override
    public String toString() {
        return "Account [id=" + id + ", username=" + username + ", money=" + money + "]";
    }
    
}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Jackson相關:使用Jackson相關的註解時一定要註意自己定義的屬性命名是否規範。 命名不規範時會失去效果。(例如Ename ,Eage 為不規範命名。“nameE”,“ageE”為規範命名)。如果使用@JsonIgnore註解不起效時請註意一下你的屬性名字是否規範。 1、@JsonIgnor ...
  • 以d:\a目錄為例,假設D:\a目錄內的結構如下: 4.1 示例1:列出整個目錄中的文件(遞歸) 思路:1.遍歷目錄d:\a。2.每遍歷到d:\a中的一個目錄就遍歷這個子目錄。因此需要判斷每個遍歷到的元素是否是目錄。 以下是從普通代碼到遞歸代碼前的部分代碼: 對重覆的代碼部分進行封裝,於是使用遞歸方 ...
  • Django框架基礎 這是我學習北京理工大學嵩天老師的《Python雲端系統開發入門》課程的筆記,在此我特別感謝老師的精彩講解和對我的引導。 1、Django簡介與安裝 Django是一個免費、開源的Web應用框架,由Python寫成。採用了MTV(Model-Template-View)的框架模式 ...
  • #裡面內容沒有見過,可能會比較難懂,需要找資料。我只是記錄了視頻中的用法,其他理解的東西,我直接理解,就沒有寫下來了。下麵內容是視頻演示過程 import hashlibm = hashlib.md5()print(m) # 只是一個加密對象m.update('aiq'.encode('utf-8' ...
  • 為了和python解釋器交互,控制台執行腳本後面添加變數import sysprint(sys.argv) def post(): print('upload')def download(): print('download')if sys.argv[1] == 'post': post()elif ...
  • 關於《Head First Python》一書中print_lol()函數的思考 在《Head First Python》第一章中,講述到Python處理複雜數據(以電影數據列表為例),首先將電影數據創建為Python列表,由於Python的變數標識符沒有類型,列表中的每一個數據項可以是任何類型的數 ...
  • Struts的簡單搭建(入門) 過程摘要:(struts2下載:https://struts.apache.org/) (軟體要求:安裝好eclipse/myeclipse和tomcat) 具體流程: 創建一個新的project,選擇動態web工程: (註意:若此時出現.jsp頁面找不到java b ...
  • 本文算是副產品,正品是利用FFmpeg從任意視頻中生成GIF片段的小程式,寫完了就發。 因為要對視頻畫面進行框選,再生成GIF,所以得有個框選的控制項,可Delphi里沒有啊,只好自己寫一個了。 聲明 本文參考的是盒子網的 "RectTracker" ,原作者署名xwwaw,發佈於2007年5月28日 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...