先来讲讲脏读 不可重复读 和 幻读。
要求事务所包含的全部操作是一个不可分割的整体，如果有一步发生异常，则全部不提交。
A给B转钱，A减和B增这两个操作必须保持一致。
事务会将一部分数据与其他事务隔离，防止脏读等。
事务的结果被写到持久化存储器中。
隔离级别越高，则性能相对越低，反之亦然。
最低的隔离级别，跟你直译的意思一样：可以读取其它事务未完成的结果。(脏读)
很明显，脏读 不可重复读 和 幻读这三个问题它都有。
大部分数据库采用的默认隔离级别，比上一个隔离级别多了限定：在该事务完成后，才能读取该事务的数据更新后的结果。
它可以避免脏读，但是也有不可重复读取和幻读的问题。
可以保证在整个事务的过程中，对同一笔数据的读取结果是相同的，不管其他事务是否同时在对同一笔数据进行更新，也不管其他事务对同一笔数 据的更新提交与否。
Repeatable Read隔离级别避免了脏读和不可重复读取的问题，但无法避免幻读。
最为严格的隔离级别，所有的事务操作都必须依次顺序执行，可以避免其他隔离级别遇到的所有问题，是最为安全的隔离级别， 但同时也是性能最差的隔离级别。
通常情况下，我们会使用其他隔离级别加上相应的并发锁的机制来控制对数据的访问，这样既保证 了系统性能不会损失太大，也能够一定程度上保证数据的一致性。
事务传播行为 | 含义 |
PROPAGATION_REQUIRED(默认) | 必须在事务中执行，如果没有，就新new一个新事务 |
PROPAGATION_SUPPORTS | 谁调用我我就在谁的事务中执行，没有的话就没有 |
PROPAGATION_MANDATORY | 必须要有事务，没有就报错 |
PROPAGATION_REQUIRED_NEW | 不管调用我的方法有没有事务，我都new一个事务 |
PROPAGATION_NOT_SUPPORTED | 调用我的方法有事务，但我不在事务中执行 |
PROPAGATION_NEVER | 不允许在事务中运行，有事务则报错 |
PROPAGATION_NESTED | 有事务则嵌套，没有则new一个新事务 |
我们都知道，JDBC给我们提供了事务。
try{ con.setAutoCommit(false);//开启事务 ...... con.commit();//try的最后提交事务 } catch（） { con.rollback();//回滚事务}获取事务隔离级别。
Connection.getTransactionIsolation()设置事务隔离级别。
con.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);Spring并不会直接管理事务，而是提供了事务管理器，将事务管理的职责委托给JPA JDBC JTA DataSourceTransaction JMSTransactionManager 等框架提供的事务来实现。
那么，Spring提供的事务管理器是什么呢?
是
PlatformTransactionManager.java接口:
Spring提供的事务管理器。不同的事务遵循该事务管理器的API，便能很轻松的交给Spring管理。
public interface PlatformTransactionManager { // 通过Transation定义 获取Transation TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException; // 提交事务 void commit(TransactionStatus var1) throws TransactionException; // 回滚事务 void rollback(TransactionStatus var1) throws TransactionException;}可以看到它里面引用到了TransactionDefinition和TransactionStatus。
它里面包含了事务的定义。
public interface TransactionDefinition { // 传播机制 int PROPAGATION_REQUIRED = 0; int PROPAGATION_SUPPORTS = 1; int PROPAGATION_MANDATORY = 2; int PROPAGATION_REQUIRES_NEW = 3; int PROPAGATION_NOT_SUPPORTED = 4; int PROPAGATION_NEVER = 5; int PROPAGATION_NESTED = 6; // 隔离级别 int ISOLATION_DEFAULT = -1; int ISOLATION_READ_UNCOMMITTED = 1; int ISOLATION_READ_COMMITTED = 2; int ISOLATION_REPEATABLE_READ = 4; int ISOLATION_SERIALIZABLE = 8; int TIMEOUT_DEFAULT = -1; int getPropagationBehavior(); // 获取隔离级别 int getIsolationLevel(); int getTimeout(); boolean isReadOnly(); @Nullable String getName();}事务的状态。
public interface TransactionStatus extends SavepointManager, Flushable { boolean isNewTransaction(); boolean hasSavepoint(); void setRollbackOnly(); boolean isRollbackOnly(); void flush(); boolean isCompleted();}@Autowiredprivate PlatformTransactionManager transactionManager;public void testTX(){ DefaultTransactionDefinition definition = new DefaultTransactionDefinition(); TransactionStatus status = transactionManager.getTransaction(definition); try { // 业务逻辑 // ... // 提交事务 transactionManager.commit(status); }catch (Exception e){ // 发生异常，事务回滚 transactionManager.rollback(status); }}@Transactionalvoid testTX2(){ // 业务逻辑 ...}这不是玄学，它的底层是依靠AOP动态代理实现，其实重新渲染出的代码和第一个使用方式类似，不过大大减少了开发复杂度。
@Target({ElementType.METHOD, ElementType.TYPE})@Retention(RetentionPolicy.RUNTIME)@Inherited@Documentedpublic @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 {};}非入门选手下面的demo可能会引起你的不适(浪费时间)。
假设我要完成一个功能，当删除用户的时候，将与该用户有关的所有数据行都删除。
public void delUser(Integer userId) { // 删除和用户相关的信息 otherRepository.deleteByUserId(userId); // 删除用户 userRepository.deleteById(userId);}这样的写法一般来讲，会成功的完成任务。但是如果这样一段代码：
public void delUser(Integer userId) { // 删除和用户相关的信息 otherRepository.deleteByUserId(); if (true) { throw new RuntimeException("xxx"); } // 删除用户 userRepository.deleteById(userId);}结果会是：deleteByUserId()执行成功，deleteById()执行失败，不满足数据的一致性。
所以我们需要事务来限制：要么全部执行，要么全部不执行(方法中有异常就自动回滚)。那怎么实现呢，只需要在方法上加一个注解：@Transactional
@Transactionalpublic void delUser(Integer userId) { // 删除和用户相关的信息 otherRepository.deleteByUserId(); if (true) { throw new RuntimeException("xxx"); } // 删除用户 userRepository.deleteById(userId);}比如我有个需求(接着上次的强票系统II)，要求信息不能丢失，要用到RabbitMQ的事务管理，那怎么去加载到Spring的事务管理器中呢？
@Beanpublic ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); return connectionFactory;}@Beanpublic RabbitTransactionManager rabbitTransactionManager(ConnectionFactory connectionFactory) { return new RabbitTransactionManager(connectionFactory);}我们只需要这样做便可以使的使用@Transactional注解来实现对RabbitMQ的事务管理,其它框架也类似。
本文链接：http://www.28at.com/showinfo-26-12417-0.htmlSpring事务管理—快速入门
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
