手写 Spring 框架准备工做之 Spring 核心事务管理

时间  2019-12-16
标签 手写 spring 框架 准备 核心 事务管理 栏目 Spring 繁體版
原文   原文链接

事务

事务的特性

  • 原子性(atomicity)
    一个事务必须被视为一个不可分割的最小工做单元, 整个事务中的全部操做要么所有执行成功, 要么所有失败回滚, 对于一个事务来讲, 不可能只执行其中的一部分操做.
  • 一致性(consistency)
    事务必须使数据库从一个一致性的状态变换到另外一个一致性的状态, 也就是说一个事务执行以前和执行以后都必须处于一致性的状态. 拿转帐来讲, 假设用户A和用户B二者的钱加起来一共是5000, 那么无论A和B之间如何转帐, 转几回帐, 事务结束后两个用户的钱相加起来应该还得是5000, 这就是事务的一致性.
  • 隔离性(isolation)
    并发的事务之间是相互隔离的, 一个事务所作的修改在最终提交以前, 对其余事务是不可见的. 例如, 帐户A有5000元存款, 执行完转帐语句(-500), 只要该事务没有提交, 对其余事务来讲帐户余额仍是5000元.
  • 持久性(durability)
    事务一旦提交, 其对数据库的修改就是永久性的, 即便系统崩溃, 修改的数据也不会丢失.

并发事务带来的问题

  • 更新丢失(Lost Update)
    多个事务修改同一行记录(都未提交), 后面的修改覆盖了前面的修改.
  • 脏读(Dirty Reads)
    一个事务能够读取另外一个事务未提交的数据.
  • 不可重复读(Non-Repeatable Reads)
    同一个事务中执行两次相同的查询, 可能获得不同的结果. 这是由于在查询间隔内，另外一个事务修改了该记录并提交了事务.
  • 幻读(Phantom Reads)
    当某个事务在读取某个范围内的记录时, 另外一个事务又在该范围内插入了新的记录, 当以前的事务再次读取该范围的记录时, 会产生幻行.

隔离级别

在MySQL经常使用的存储引擎中, 只有InnoDB支持事务, 因此这里说的隔离级别指的是InnoDB下的事务隔离级别.java

  • READ UNCOMMITTED(读未提交)
    在该隔离级别, 事务中的修改即便没有提交, 对其余事务也都是可见的. 避免了更新丢失的发生.
  • READ COMMITTED(读已提交)
    在该隔离级别, 一个事务只能看见已经提交的事务所作的修改. 避免了更新丢失和脏读.
  • REPEATABLE READ(可重复读)
    MySQL默认的隔离级别, 该级别保证了在同一个事务中屡次读取一样的记录的结果是一致的. 避免了更新丢失、脏读、不可重复读和幻读. (注意看MySQL官网, RR隔离级别下解决了幻读问题)
  • SERIALIZABLE(可串行化)
    SERIALIZABLE是最高的隔离级别, 它经过强制事务串行化执行, 避免了并发事务带来的问题.
隔离级别 读数据一致性 更新丢失 脏读 不可重复读 幻读
读未提交 最低级别, 只能保证不读取物理上损坏的数据 × √ √ √
读已提交 语句级 × × √ √
可重复读 事务级 × × × ×
可串行化 最高级别, 事务级 × × × ×

Spring事务管理

下面是Spring事务注解的源代码, 从中能够看到Spring事务管理的四个属性: Propagation, Isolation, timeout, readOnly.mysql

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {
    @AliasFor("transactionManager")
    String value() default "";

    @AliasFor("value")
    String transactionManager() default "";

    Propagation propagation() default Propagation.REQUIRED;

    Isolation isolation() default Isolation.DEFAULT;

    int timeout() default -1;

    boolean readOnly() default false;

    Class<? extends Throwable>[] rollbackFor() default {};

    String[] rollbackForClassName() default {};

    Class<? extends Throwable>[] noRollbackFor() default {};

    String[] noRollbackForClassName() default {};
}
复制代码

事务传播行为spring

public enum Propagation {
    REQUIRED(0),
    SUPPORTS(1),
    MANDATORY(2),
    REQUIRES_NEW(3),
    NOT_SUPPORTED(4),
    NEVER(5),
    NESTED(6);

    private final int value;

    private Propagation(int value) {
        this.value = value;
    }

    public int value() {
        return this.value;
    }
}
复制代码

事务传播行为是指方法之间事务的传播. 好比, 在方法A中调用了方法B:sql

  • REQUIRED
    若是A有事务就使用当前事务, 若是A没有事务, 就建立一个新事务.
  • SUPPORTS
    若是A有事务就使用当前事务, 若是A没有事务, 就以非事务执行.
  • MANDATORY
    若是A有事务就使用当前事务, 若是A没有事务, 就抛异常.
  • REQUIRES_NEW
    无论A有没有事务都建立一个新事务.
  • NOT_SUPPORTED
    无论A有没有事务都以非事务执行.
  • NEVER
    若是A有事务就抛异常, 若是A没有事务, 就以非事务执行.
  • NESTED
    若是A没有事务就建立一个事务, 若是A有事务, 就在当前事务中嵌套其余事务. 事务隔离级别
public enum Isolation {
    DEFAULT(-1),
    READ_UNCOMMITTED(1),
    READ_COMMITTED(2),
    REPEATABLE_READ(4),
    SERIALIZABLE(8);

    private final int value;

    private Isolation(int value) {
        this.value = value;
    }

    public int value() {
        return this.value;
    }
}
复制代码

其中 DEFAULT 表示使用数据库的隔离级别.数据库

事务超时

为了解决事务执行时间太长, 消耗太多资源的问题, 咱们能够给事务设置一个超时时间, 若是事务执行时间超过了超时时间, 就回滚事务.编程

只读事务

一些不须要事务的方法, 好比读取数据, 就能够设置为只读事务, 这样能够有效地提升一些性能.后端

手动管理事务

Spring使用 TransactionTemplate 事务模板来管理事务.bash

（1）dao层架构

public interface AccountDao {
	 //汇款
	public void out(String outer , Integer money);
	
	//收款
	public void in(String inner , Integer money);
}

public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {

	public void out(String outer, Integer money) {
		this.getJdbcTemplate().update("update account set money = money - ? where username = ?", money,outer);
	}

	public void in(String inner, Integer money) {
		this.getJdbcTemplate().update("update account set money = money + ? where username = ?", money,inner);
	}
}
复制代码

（2）Service层并发

public interface AccountService {
	//转帐
	public void transfer(String outer ,String inner ,Integer money);
}

public class AccountServiceImpl implements AccountService {

    private AccountDao accountDao;

	private TransactionTemplate transactionTemplate;

    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }	
    
    public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
        this.transactionTemplate = transactionTemplate;
    }

    public void transfer(final String outer, final String inner, final Integer money) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {

            @Override
            protected void doInTransactionWithoutResult(TransactionStatus arg0) {
                accountDao.out(outer, money);
                //模拟故障
                int i = 1/0;
                accountDao.in(inner, money);
            }
        });
    }
}
复制代码

（3）Spring配置

<beans>
    <!-- 一、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/test"></property>
        <property name="user" value="root"></property>
        <property name="password" value="123"></property>
    </bean>

    <!-- 二、dao  -->
    <bean id="accountDao" class="org.tx.dao.impl.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!-- 三、service -->
    <bean id="accountService" class="org.tx.service.impl.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"></property>
        <property name="transactionTemplate" ref="transactionTemplate"></property>
    </bean>

    <!-- 四、建立事务模板 -->
    <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
        <property name="transactionManager" ref="txManager"></property>
    </bean>

    <!-- 五、配置事务管理器 ,管理器须要事务，事务从Connection得到，链接从链接池DataSource得到 -->
    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
</beans>
复制代码

（4）测试代码

@Test
public void demo(){
	String xmlPath = "applicationContext.xml";
	ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xmlPath);
	AccountService accountService =  (AccountService) applicationContext.getBean("accountService");
	accountService.transfer("jack", "rose", 1000);
}
复制代码

Spring事务代理

（1）Service层

public interface AccountService {
	//转帐
	public void transfer(String outer ,String inner ,Integer money);
}

public class AccountServiceImpl implements AccountService {

	private AccountDao accountDao;

	public void setAccountDao(AccountDao accountDao) {
		this.accountDao = accountDao;
	}
	
	public void transfer(String outer, String inner, Integer money) {
		accountDao.out(outer, money);
		//模拟故障
		int i = 1/0;
		accountDao.in(inner, money);
	}
}
复制代码

（2）Spring配置文件

<beans>
	<!-- 一、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/test"></property>
		<property name="user" value="root"></property>
		<property name="password" value="123"></property>
	</bean>
	
	<!-- 二、dao  -->
	<bean id="accountDao" class="org.tx.dao.impl.AccountDaoImpl">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	
	<!-- 三、service -->
	<bean id="accountService" class="org.tx.service.impl.AccountServiceImpl">
		<property name="accountDao" ref="accountDao"></property>
	</bean>
	
	<!-- 四、service 代理对象 
		4.1 proxyInterfaces 接口 
		4.2 target 目标类
		4.3 transactionManager 事务管理器
		4.4 transactionAttributes 事务属性（事务详情）
			prop.key ：肯定哪些方法使用当前事务配置
			prop.text:用于配置事务详情
				格式：PROPAGATION，ISOLATION，readOnly，-Exception，+Exception
					传播行为		隔离级别		是否只读		异常回滚		异常提交
				例如：
					<prop key="transfer">PROPAGATION_REQUIRED,ISOLATION_DEFAULT</prop> 默认传播行为，和隔离级别
					<prop key="transfer">PROPAGATION_REQUIRED,ISOLATION_DEFAULT,readOnly</prop> 只读
					<prop key="transfer">PROPAGATION_REQUIRED,ISOLATION_DEFAULT,+java.lang.ArithmeticException</prop>  有异常扔提交
	-->
	<bean id="proxyAccountService" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
		<property name="proxyInterfaces" value="org.tx.service.AccountService"></property>
		<property name="target" ref="accountService"></property>
		<property name="transactionManager" ref="txManager"></property>
		<property name="transactionAttributes">
			<props>
				<prop key="transfer">PROPAGATION_REQUIRED,ISOLATION_DEFAULT</prop>
			</props>
		</property>
	</bean>
	
	<!-- 五、配置事务管理器  -->
	<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
</beans>
复制代码

（3）测试代码

@Test
public void demo(){
	String xmlPath = "applicationContext.xml";
	ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xmlPath);
	AccountService accountService =  (AccountService) applicationContext.getBean("proxyAccountService");
	accountService.transfer("jack", "rose", 1000);
}
复制代码

Spring + AspectJ

基于xml配置

（1）Service层

public interface AccountService {
	//转帐
	public void transfer(String outer ,String inner ,Integer money);
}

public class AccountServiceImpl implements AccountService {

	private AccountDao accountDao;
	public void setAccountDao(AccountDao accountDao) {
		this.accountDao = accountDao;
	}
	
	public void transfer(String outer, String inner, Integer money) {
		accountDao.out(outer, money);
		//模拟故障
		int i = 1/0;
		accountDao.in(inner, money);
	}
}
复制代码

（2）Spring配置文件

<beans>
	<!-- 一、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/test"></property>
		<property name="user" value="root"></property>
		<property name="password" value="123"></property>
	</bean>
	
	<!-- 二、dao  -->
	<bean id="accountDao" class="org.tx.dao.impl.AccountDaoImpl">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	
	<!-- 三、service -->
	<bean id="accountService" class="org.tx.service.impl.AccountServiceImpl">
		<property name="accountDao" ref="accountDao"></property>
	</bean>
	
	<!-- 四、事务管理器 -->
	<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	
	<!-- 五、事务通知 
		<tx:attributes> 用于配置事务详情（事务属性）	
	-->
	<tx:advice id="txAdvice" transaction-manager="txManager">
		<tx:attributes>
			<tx:method name="transfer" propagation="REQUIRED" isolation="DEFAULT"/>
		</tx:attributes>
	</tx:advice>
	
	<!-- 六、AOP编程 -->
	<aop:config>
		<aop:advisor advice-ref="txAdvice" pointcut="execution(* org.tx.service.*.*(..))"/>
	</aop:config>
</beans>
复制代码

（3）测试代码

@Test
public void demo(){
	String xmlPath = "applicationContext.xml";
	ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xmlPath);
	AccountService accountService =  (AccountService) applicationContext.getBean("accountService");
	accountService.transfer("jack", "rose", 1000);
}
复制代码

基于注解

（1）Service层

@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT)
public class AccountServiceImpl implements AccountService {

	private AccountDao accountDao;
	public void setAccountDao(AccountDao accountDao) {
		this.accountDao = accountDao;
	}
	
	//或者 @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT)
	public void transfer(String outer, String inner, Integer money) {
		accountDao.out(outer, money);
		//模拟故障
		int i = 1/0;
		accountDao.in(inner, money);
	}
}
复制代码

（2）Spring配置文件

<beans>
		<!-- 一、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/test"></property>
			<property name="user" value="root"></property>
			<property name="password" value="123"></property>
		</bean>
		
		<!-- 二、dao  -->
		<bean id="accountDao" class="org.tx.dao.impl.AccountDaoImpl">
			<property name="dataSource" ref="dataSource"></property>
		</bean>
		
		<!-- 三、service -->
		<bean id="accountService" class="org.tx.service.impl.AccountServiceImpl">
			<property name="accountDao" ref="accountDao"></property>
		</bean>
		
		<!-- 四、事务管理器 -->
		<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
			<property name="dataSource" ref="dataSource"></property>
		</bean>
		
		<!-- 五、将事务管理器交予Spring -->
		<tx:annotation-driven transaction-manager="txManager"/>
</beans>
复制代码

（3）测试代码

@Test
public void demo(){
	String xmlPath = "applicationContext.xml";
	ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xmlPath);
	AccountService accountService =  (AccountService) applicationContext.getBean("accountService");
	accountService.transfer("jack", "rose", 1000);
}
复制代码

来源: blog.csdn.net/litianxiang…

相关文章

开源项目推荐

做者的开源项目推荐：

  • Pre 基于 Spring Boot 、Spring Security 、Vue 的先后端分离的的 RBAC 权限管理系统
  • Prex 基于 Spring Cloud、Oauth2 、Vue 的先后端分离的微服务架构 RBAC 权限管理系统

关注公众号回复开源项目便可获取

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程