先来讲讲脏读 不可重复读 和 幻读。
脏读:我们在并发编程中是很熟悉的,通俗的讲就是你读得数据已经被修改了,已经过时失去意义了。
不可重复读: 同一个事务里面多次读取同一行数据,却返回不同的结果。
幻读:同样一笔查询在整个事务过程中多次执行后,查询所得的结果集不一样。
要求事务所包含的全部操作是一个不可分割的整体,如果有一步发生异常,则全部不提交。
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管理。
publicinterfacePlatformTransactionManager{// 通过Transation定义 获取TransationTransactionStatusgetTransaction(@NullableTransactionDefinitionvar1)throwsTransactionException;// 提交事务voidcommit(TransactionStatusvar1)throwsTransactionException;// 回滚事务voidrollback(TransactionStatusvar1)throwsTransactionException;}
可以看到它里面引用到了TransactionDefinition和TransactionStatus。
它里面包含了事务的定义。
publicinterfaceTransactionDefinition{// 传播机制intPROPAGATION_REQUIRED=0;intPROPAGATION_SUPPORTS=1;intPROPAGATION_MANDATORY=2;intPROPAGATION_REQUIRES_NEW=3;intPROPAGATION_NOT_SUPPORTED=4;intPROPAGATION_NEVER=5;intPROPAGATION_NESTED=6;// 隔离级别intISOLATION_DEFAULT=-1;intISOLATION_READ_UNCOMMITTED=1;intISOLATION_READ_COMMITTED=2;intISOLATION_REPEATABLE_READ=4;intISOLATION_SERIALIZABLE=8;intTIMEOUT_DEFAULT=-1;intgetPropagationBehavior();// 获取隔离级别intgetIsolationLevel();intgetTimeout();booleanisReadOnly();@NullableStringgetName();}
事务的状态。
publicinterfaceTransactionStatusextendsSavepointManager,Flushable{booleanisNewTransaction();booleanhasSavepoint();voidsetRollbackOnly();booleanisRollbackOnly();voidflush();booleanisCompleted();}
@AutowiredprivatePlatformTransactionManagertransactionManager;publicvoidtestTX(){DefaultTransactionDefinitiondefinition=newDefaultTransactionDefinition();TransactionStatusstatus=transactionManager.getTransaction(definition);try{// 业务逻辑// ...// 提交事务transactionManager.commit(status);}catch(Exceptione){// 发生异常,事务回滚transactionManager.rollback(status);}}
@TransactionalvoidtestTX2(){// 业务逻辑 ...}
这不是玄学,它的底层是依靠AOP动态代理实现,其实重新渲染出的代码和第一个使用方式类似,不过大大减少了开发复杂度。
@Target({ElementType.METHOD,ElementType.TYPE})@Retention(RetentionPolicy.RUNTIME)@Inherited@Documentedpublic@interfaceTransactional{//指定使用的事务管理器@AliasFor("transactionManager")Stringvalue()default"";@AliasFor("value")StringtransactionManager()default"";// 可选的事务传播行为设置Propagationpropagation()defaultPropagation.REQUIRED;// 可选的事务隔离级别设置Isolationisolation()defaultIsolation.DEFAULT;// 事务超时时间设置inttimeout()default-1;// 读写或只读事务,默认读写booleanreadOnly()defaultfalse;// 导致事务回滚的异常类数组Class<?extendsThrowable>[]rollbackFor()default{};// 导致事务回滚的异常类名字数组String[]rollbackForClassName()default{};// 不会导致事务回滚的异常类数组Class<?extendsThrowable>[]noRollbackFor()default{};// 不会导致事务回滚的异常类名字数组String[]noRollbackForClassName()default{};}
非入门选手下面的demo可能会引起你的不适(浪费时间)。
假设我要完成一个功能,当删除用户的时候,将与该用户有关的所有数据行都删除。
publicvoiddelUser(IntegeruserId){// 删除和用户相关的信息otherRepository.deleteByUserId(userId);// 删除用户userRepository.deleteById(userId);}
这样的写法一般来讲,会成功的完成任务。但是如果这样一段代码:
publicvoiddelUser(IntegeruserId){// 删除和用户相关的信息otherRepository.deleteByUserId();if(true){thrownewRuntimeException("xxx");}// 删除用户userRepository.deleteById(userId);}
结果会是:deleteByUserId()执行成功,deleteById()执行失败,不满足数据的一致性。
所以我们需要事务来限制:要么全部执行,要么全部不执行(方法中有异常就自动回滚)。那怎么实现呢,只需要在方法上加一个注解:@Transactional
@TransactionalpublicvoiddelUser(IntegeruserId){// 删除和用户相关的信息otherRepository.deleteByUserId();if(true){thrownewRuntimeException("xxx");}// 删除用户userRepository.deleteById(userId);}
比如我有个需求(接着上次的强票系统II),要求信息不能丢失,要用到RabbitMQ的事务管理,那怎么去加载到Spring的事务管理器中呢?
@BeanpublicConnectionFactoryconnectionFactory(){CachingConnectionFactoryconnectionFactory=newCachingConnectionFactory();returnconnectionFactory;}@BeanpublicRabbitTransactionManagerrabbitTransactionManager(ConnectionFactoryconnectionFactory){returnnewRabbitTransactionManager(connectionFactory);}
我们只需要这样做便可以使的使用@Transactional注解来实现对RabbitMQ的事务管理,其它框架也类似。