首页 > 其他分享 >【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解

时间:2023-12-20 12:04:30浏览次数:36  
标签:事务管理 事务 jdbc String 示例 Spring class money public


欢迎大家回到《Java教程之Spring30天快速入门》,本教程所有示例均基于Maven实现,如果您对Maven还很陌生,请移步本人的博文《如何在windows11下安装Maven并配置以及 IDEA配置Maven环境》,本文的上一篇为《AOP(面对切面编程)知识总结》

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_spring

1 相关概念介绍

  • 事务作用:在数据层保障一系列的数据库操作同成功同失败
  • Spring事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败

数据层有事务我们可以理解,为什么业务层也需要处理事务呢?
举个简单的例子,

  • 转账业务会有两次数据层的调用,一次是加钱一次是减钱
  • 把事务放在数据层,加钱和减钱就有两个事务
  • 没办法保证加钱和减钱同时成功或者同时失败
  • 这个时候就需要将事务放在业务层进行处理。

Spring为了管理事务,提供了一个平台事务管理器PlatformTransactionManager

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_后端_02


commit是用来提交事务,rollback是用来回滚事务。

PlatformTransactionManager只是一个接口,Spring还为其提供了一个具体的实现:

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_spring_03


从名称上可以看出,我们只需要给它一个DataSource对象,它就可以帮你去在业务层管理事务。其内部采用的是JDBC的事务。所以说如果你持久层采用的是JDBC相关的技术,就可以采用这个事务管理器来管理你的事务。而Mybatis内部采用的就是JDBC的事务,所以后期我们Spring整合Mybatis就采用的这个DataSourceTransactionManager事务管理器。

2 转账案例-需求分析

接下来通过一个案例来学习下Spring是如何来管理事务的。
先来分析下需求:
需求: 实现任意两个账户间转账操作
需求微缩: A账户减钱,B账户加钱
为了实现上述的业务需求,我们可以按照下面步骤来实现下:
①:数据层提供基础操作,指定账户减钱(outMoney),指定账户加钱(inMoney)
②:业务层提供转账操作(transfer),调用减钱与加钱的操作
③:提供2个账号和操作金额执行转账操作
④:基于Spring整合MyBatis环境搭建上述操作

3 转账案例-环境搭建

步骤1:准备数据库表
之前我们在整合Mybatis的时候已经创建了这个表,可以直接使用

create database spring_db character set utf8;
use spring_db;
create table tbl_account(
	id int primary key auto_increment,
	name varchar(35),
	money double
);
insert into tbl_account values(1,'Tom',1000);
insert into tbl_account values(2,'Jerry',1000);

步骤2:创建项目导入jar包
项目的pom.xml添加相关依赖

<dependencies>
	<dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-context</artifactId>
		<version>5.2.10.RELEASE</version>
	</dependency>
	<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>druid</artifactId>
		<version>1.1.16</version>
	</dependency>
	<dependency>
		<groupId>org.mybatis</groupId>
		<artifactId>mybatis</artifactId>
		<version>3.5.6</version>
	</dependency>
	<dependency>
		<groupId>mysql</groupId>
		<artifactId>mysql-connector-java</artifactId>
		<version>5.1.47</version>
	</dependency>
	<dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-jdbc</artifactId>
		<version>5.2.10.RELEASE</version>
	</dependency>
	<dependency>
		<groupId>org.mybatis</groupId>
		<artifactId>mybatis-spring</artifactId>
		<version>1.3.0</version>
	</dependency>
	<dependency>
		<groupId>junit</groupId>
		<artifactId>junit</artifactId>
		<version>4.12</version>
		<scope>test</scope>
	</dependency>
	<dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-test</artifactId>
		<version>5.2.10.RELEASE</version>
	</dependency>
</dependencies>

步骤3:根据表创建模型类

public class Account implements Serializable {
	private Integer id;
	private String name;
	private Double money;
	//setter...getter...toString...方法略
}

步骤4:创建Dao接口

public interface AccountDao {
	@Update("update tbl_account set money = money + #{money} where name = #
	{name}")
	void inMoney(@Param("name") String name, @Param("money") Double money);
	@Update("update tbl_account set money = money - #{money} where name = #
	{name}")
	void outMoney(@Param("name") String name, @Param("money") Double money);
}

步骤5:创建Service接口和实现类

public interface AccountService {
	/**
	* 转账操作
	* @param out 传出方
	* @param in 转入方
	* @param money 金额
	*/
	public void transfer(String out,String in ,Double money) ;
}
	@Service
public class AccountServiceImpl implements AccountService {
	@Autowired
	private AccountDao accountDao;
	public void transfer(String out,String in ,Double money) {
		accountDao.outMoney(out,money);
		accountDao.inMoney(in,money);
	}
}

步骤6:添加jdbc.properties文件

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false
jdbc.username=root
jdbc.password=root

步骤7:创建JdbcConfig配置类

public class JdbcConfig {
	@Value("${jdbc.driver}")
	private String driver;
	@Value("${jdbc.url}")
	private String url;
	@Value("${jdbc.username}")
	private String userName;
	@Value("${jdbc.password}")
	private String password;
	@Bean
	public DataSource dataSource(){
		DruidDataSource ds = new DruidDataSource();
		ds.setDriverClassName(driver);
		ds.setUrl(url);
		ds.setUsername(userName);
		ds.setPassword(password);
		return ds;
	}
}

步骤8:创建MybatisConfig配置类

public class MybatisConfig {
@Bean
	public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){
	SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
	ssfb.setTypeAliasesPackage("com.itheima.domain");
	ssfb.setDataSource(dataSource);
	return ssfb;
	}
	@Bean
	public MapperScannerConfigurer mapperScannerConfigurer(){
		MapperScannerConfigurer msc = new MapperScannerConfigurer();
		msc.setBasePackage("com.itheima.dao");
		return msc;
	}
}

步骤9:创建SpringConfig配置类

@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public class SpringConfig {
}

步骤10:编写测试类

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = SpringConfig.class)
public class AccountServiceTest {
	@Autowired
	private AccountService accountService;
	@Test
	public void testTransfer() throws IOException {
		accountService.transfer("Tom","Jerry",100D);
	}
}

最终创建好的项目结构如下:

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_后端_04

4 事务管理

上述环境,运行单元测试类,会执行转账操作,Tom的账户会减少100,Jerry的账户会加100。这是正常情况下的运行结果,但是如果在转账的过程中出现了异常,如:

@Service
public class AccountServiceImpl implements AccountService {
	@Autowired
	private AccountDao accountDao;
	public void transfer(String out,String in ,Double money) {
		accountDao.outMoney(out,money);
		int i = 1/0;
		accountDao.inMoney(in,money);
	}
}

这个时候就模拟了转账过程中出现异常的情况,正确的操作应该是转账出问题了,Tom应该还是900,Jerry应该还是1100,但是真正运行后会发现,并没有像我们想象的那样,Tom账户为800而Jerry还是1100,100块钱凭空消息了,银行乐疯了。如果把转账换个顺序,银行就该哭了。

不管哪种情况,都是不允许出现的,对刚才的结果我们做一个分析:

①:程序正常执行时,账户金额A减B加,没有问题
②:程序出现异常后,转账失败,但是异常之前操作成功,异常之后操作失败,整体业务失败

当程序出问题后,我们需要让事务进行回滚,而且这个事务应该是加在业务层上,而Spring的事务管理就是用来解决这类问题的。

Spring事务管理具体的实现步骤为:

步骤1:在需要被事务管理的方法上添加注解

public interface AccountService {
/**
* 转账操作
* @param out 传出方
* @param in 转入方
* @param money 金额
*/
//配置当前接口方法具有事务
public void transfer(String out,String in ,Double money) ;
}
@Service
public class AccountServiceImpl implements AccountService {
	@Autowired
	private AccountDao accountDao;
	@Transactional
	public void transfer(String out,String in ,Double money) {
		accountDao.outMoney(out,money);
		int i = 1/0;
		accountDao.inMoney(in,money);
	}
}

注意:

@Transactional可以写在接口类上、接口方法上、实现类上和实现类方法上

  • 写在接口类上,该接口的所有实现类的所有方法都会有事务
  • 写在接口方法上,该接口的所有实现类的该方法都会有事务
  • 写在实现类上,该类中的所有方法都会有事务
  • 写在实现类方法上,该方法上有事务
  • 建议写在实现类或实现类的方法上

步骤2:在JdbcConfig类中配置事务管理器

public class JdbcConfig {
	@Value("${jdbc.driver}")
	private String driver;
	@Value("${jdbc.url}")
	private String url;
	@Value("${jdbc.username}")
	private String userName;
	@Value("${jdbc.password}")
	private String password;
	@Bean
	public DataSource dataSource(){
		DruidDataSource ds = new DruidDataSource();
		ds.setDriverClassName(driver);
		ds.setUrl(url);
		ds.setUsername(userName);
		ds.setPassword(password);
		return ds;
	}
	//配置事务管理器,mybatis使用的是jdbc事务
	@Bean
	public PlatformTransactionManager transactionManager(DataSource
		dataSource){
		DataSourceTransactionManager transactionManager = new
		DataSourceTransactionManager();
		transactionManager.setDataSource(dataSource);
		return transactionManager;
	}
}

**注意:**事务管理器要根据使用技术进行选择,Mybatis框架使用的是JDBC事务,可以直接使用DataSourceTransactionManager

步骤3:开启事务注解
在SpringConfig的配置类中开启

@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class
//开启注解式事务驱动
@EnableTransactionManagement
public class SpringConfig {
}

步骤4:运行测试类
会发现在转换的业务出现错误后,事务就可以控制回顾,保证数据的正确性。

5 知识点总结

知识点1:@EnableTransactionManagement

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_事务管理_05


知识点2:@Transactional

【Spring教程21】Spring框架实战:Spring事务简介、AOP事务管理、代码示例全面详解_java_06


标签:事务管理,事务,jdbc,String,示例,Spring,class,money,public
From: https://blog.51cto.com/u_12948819/8905246

相关文章

  • 【Spring教程16】Spring框架实战:详解解读AOP配置管理中AOP切入点表达式和通知类型
    目录1AOP切入点表达式1.1语法格式1.2通配符1.3书写技巧2AOP通知类型2.1类型介绍欢迎大家回到《Java教程之Spring30天快速入门》,本教程所有示例均基于Maven实现,如果您对Maven还很陌生,请移步本人的博文《如何在windows11下安装Maven并配置以及IDEA配置Maven环境》,本文的......
  • 在Spring Cloud使用Hystrix核心组件,并注册到Eureka注册中心去
    其实吧,写SpringCloud系列,我有时候觉得也挺难受的,因为SpringCloud的微服务启动都需要一个一个来,并且在IDea中也需要占用比较大的内存,并且我本来可以一篇写完5大核心组件的,但是我却分了三篇,起初我交代过,这个系列,我将会慢慢来,因为我希望,将模块查分,这样我自己去理的时候也蛮清楚,别人......
  • 在Spring Cloud中使用组件Ribbon和Feign,并分别创建子模块注册到Eureka中去
    ok,在上篇文章中我们讲了在Springcloud中使用Zuul网关,这篇文章我们将SpringCloud的五大核心组件的Ribbon和Feign分别创建一个微服务模块。题外话,本篇博客就是配置子模块,或者说是微服务,然后将微服务正式启动之前,将所有的服务注册到Eureka注册中心去,方便我们查看我们的微服务是否正......
  • es使用示例
    记录是否存在res=es.exists(index="ncbi_gene",id=_id)插入记录es_res=self.es.index(index="ncbi_gene",id=my_data['GeneID'],body=my_data)ifes_res['result']in['created','updated']:logging.......
  • 使用阿里云oss报错:com.alibaba.cloud:aliyun-oss-spring-boot-starter:jar:unknown wa
    根据阿里云OSS的案例文档,在springboot项目中配置pom时报错https://github.com/alibaba/aliyun-spring-boot/tree/master/aliyun-spring-boot-samples/aliyun-oss-spring-boot-sampledemo中的配置:<dependency><groupId>com.alibaba.cloud</groupId>......
  • springcloud集成 openfeign报错
    集成openfeign做远程调用和负载均衡如果没有学feign的同学,可以使用restTemplate来做出处有坑步骤回显引入openfeign的依赖<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></depende......
  • 玩转Spring状态机 | 京东云技术团队
    说起Spring状态机,大家很容易联想到这个状态机和设计模式中状态模式的区别是啥呢?没错,Spring状态机就是状态模式的一种实现,在介绍Spring状态机之前,让我们来看看设计模式中的状态模式。1.状态模式状态模式的定义如下:状态模式(StatePattern)是一种行为型设计模式,它允许对象在内部状态发......
  • SpringBoot入门三十四,自定义Springboot Starter
    1.前言SpringBootStarter是一种用于简化SpringBoot应用程序配置的机制。通过自定义Starter,我们可以将一组相关的配置、依赖和自动配置打包成一个可重用的模块,使得其他开发者可以轻松地集成和使用。本篇文章将引导你创建一个简单的自定义SpringBootStarter,并演示如何在应用程序......
  • 玩转Spring状态机
    说起Spring状态机,大家很容易联想到这个状态机和设计模式中状态模式的区别是啥呢?没错,Spring状态机就是状态模式的一种实现,在介绍Spring状态机之前,让我们来看看设计模式中的状态模式。1.状态模式状态模式的定义如下:状态模式(StatePattern)是一种行为型设计模式,它允许对象在内部状......
  • Spring对象创建的两种方式
    Spring作为Java企业级应用的领先框架,其对象创建机制无疑是其核心特性之一。在本文中,我们将专注于Spring中的两种对象创建方式,并深入探讨它们的原理和应用场景。简单对象的创建:构造方法与反射1.1构造方法与对象创建在日常Java开发中,对象通常是通过其构造方法进行创建的。这种......