ToB企服应用市场:ToB评测及商务社交产业平台

标题: Spring Data JPA系列4——Spring声明式数事务处理与多数据源支持 [打印本页]
作者: 玛卡巴卡的卡巴卡玛    时间: 2022-8-13 01:19
标题: Spring Data JPA系列4——Spring声明式数事务处理与多数据源支持


大家好，又见面了。
到这里呢，已经是本SpringData JPA系列文档的第四篇了，先来回顾下前面三篇：
本篇在前面几篇的基础上，再来聊一下数据库相关操作经常会涉及的事务问题与多数据源支持问题。
在大部分涉及到数据库操作的项目里面，事务控制、事务处理都是一个无法回避的问题。得益于Spring框架的封装，业务代码中进行事务控制操作起来也很简单，直接加个@Transactional注解即可，大大简化了对业务代码的侵入性。那么对@Transactional事务注解了解的够全面吗？知道有哪些场景可能会导致@Transactional注解并不会如你预期的方式生效吗？知道应该怎么使用@Transactional才能保证对性能的影响最小化吗？
下面我们一起探讨下这些问题。
先看下JDBC的事务处理

基于JDBC进行数据库操作的时候，如果需要进行事务的控制与处理，整体的一个处理流程如下图所示：

其中蓝色的部分为需要开发人员去进行实现的，也即JDBC场景下的事务保护与处理，整个事务过程的处理都是需要开发人员进行关注与处理的。
按照这个流程的逻辑，写一下对应的实现代码：
  1. public void testJdbcTransactional(DataSource dataSource) {
  2.     Connection conn = null;
  3.     int result = 0;
  4.     try {
  5.         // 获取链接
  6.         conn = dataSource.getConnection();
  7.         // 禁用自动事务提交，改为手动控制
  8.         conn.setAutoCommit(false);
  9.         // 设置事务隔离级别
  10.         conn.setTransactionIsolation(
  11.             TransactionIoslationLevel.READ_COMMITTED.getLevel()
  12.         );
  14.         // 执行SQL
  15.         PreparedStatement ps =
  16.             conn.prepareStatement("insert into user (id, name) values (?, ?)");
  17.         ps.setString(1, "123456");
  18.         ps.setString(2, "Tom");
  19.         result = ps.executeUpdate();
  21.         // 执行成功，手动提交事务
  22.         conn.commit();
  23.     } catch (Exception e) {
  24.         // 出现异常，手动回滚事务
  25.         if (conn != null) {
  26.             try {
  27.                 conn.rollback();
  28.             } catch (Exception e) {
  29.                 // write log...
  30.             }
  31.         }
  32.     } finally {
  33.         // 执行结束，最终不管成功还是失败，都要释放资源，断开连接
  34.         try {
  35.             if (conn != null && !conn.isClosed()) {
  36.                 conn.close();
  37.             }
  38.         } catch (Exception e) {
  39.              // write log...
  40.         }
  41.     }
  42. }
复制代码
Spring声明式事务处理机制

Spring数据库事务约定处理逻辑流程如下：

对比上一章节的JDBC的事务处理，Spring场景下，事务的处理操作交给了Spring框架处理，开发人员仅需要实现自己的业务逻辑即可，大大简化了事务方面的处理投入。
基于Spring事务机制，实现上述DB操作事务控制的代码，可以按照如下方式：
  1. @Transactional
  2. public void insertUser() {
  3.     userDao.insertUser();
  4. }
复制代码
与JDBC事务实现代码相比，基于Spring的方式只需要添加一个@Transactional注解即可，代码中只需要实现业务逻辑即可，实现了事务控制机制对业务代码的低侵入性。
Spring支持的基于Spring AOP实现的声明式事务功能，所谓声明式事务，即使用@Transactional注解进行声明标注，告诉Spring框架在什么地方启用数据库事务控制能力。@Transactional注解，可以添加在类或者方法上。如果其添加在类上时，表明此类中所有的public非静态方法都将启用事务控制能力。
@Transactional注解说明


主要可选配置

readOnly

指定当前事务是否为一个只读事务。设置为true标识此事务是个只读事务，默认情况为false。
只读事务
在多条查询语句一起执行的场景里面会涉及到的概念。表示在事务设置的那一刻开始，到整个事务执行结束的过程中，其他事务所提交的写操作数据，对该事务都不可见。
举个例子：
现在有一个复合查询操作，包含2条SQL查询操作：先获取用户表count数，再获取用户表中所有数据。
执行过程：
(1) 先执行完获取用户表count数，得到结果10
(2) 在还没开始执行后一条语句的时候，另一个进程操作了DB并往用户表中插入一条新数据
(3) 复合操作的第二条SQL语句，获取用户列表的操作被执行，返回了11条记录
很明显，复合操作中的两条SQL语句获取的数据结果无法匹配上。
为了避免此情况的发生，可以给复合查询操作添加上只读事务，这样事务控制范围内，事务外的写操作就不可见，这样就保证了事务内多条查询语句执行结果的一致性。

那为什么要设置为只读事务、而不是常规的事务呢？
主要是从执行效率角度的考虑。因为这个里的操作都是一些只读操作，所以设置为只读事务，数据库会为只读事务提供一些优化手段，比如不启动回滚段、不记录回滚log之类的。
rollbackFor & rollbackForClassName

用于指定需要回滚的特定异常类型，可以指定一个或者多个。当指定rollbackFor或者rollbackForClassName之后，方法执行逻辑中只有抛出指定的异常类型，才会触发事务回滚。
  1. // 指定单个异常
  2. @Transactional(rollbackFor = DemoException.class)
  3. public void insertUser() {
  4.     // do something here
  5. }
  7. // 指定多个异常
  8. @Transactional(rollbackFor = {DemoException.class, DemoException2.class})
  9. public void insertUser2() {
  10.     // do something here
  11. }
复制代码
rollbackFor和rollbackForClassName作用相同，只是提供了2个不同的指定方法，允许执行Class类型或者ClassName字符串。
  1. // 指定异常名称
  2. @Transactional(rollbackForClassName = {"DemoException"})
  3. public void insertUser() {
  4.     // do something here
  5. }
复制代码
noRollbackFor & noRollbackForClassName

用于指定不需要进行回滚的异常类型，当方法中抛出指定类型的异常时，不进行事务回滚。
timeout

用于设置事务的超时秒数，默认值为-1，表示永不超时。
propagation

用于指定此事务对应的传播类型。所谓的事务传播类型，即当前已经在一个事务的上下文中时，又需要开始一个事务，这个时候来处理这个将要开启的新事务的处理策略。
主要有7种类型的事务传播类型：

实际编码的时候，可以通过@Transactional注解中的propagation参数来指定具体的传播类型，取值由org.springframework.transaction.annotation.Propagation枚举类提供。如果不指定，则默认取值为Propagation.REQUIRED，也即如果当前存在事务，则加入该事务，如果当前没有事务，则创建一个新的事务。
  1. /**
  2. * The transaction propagation type.
  3. * <p>Defaults to {@link Propagation#REQUIRED}.
  4. * @see org.springframework.transaction.interceptor.TransactionAttribute#getPropagationBehavior()
  5. */
  6. Propagation propagation() default Propagation.REQUIRED;
  7.    
复制代码
@Transactional失效场景避坑


同一个类中方法间调用

Spring的事务实现原理是AOP，而AOP的原理是动态代理。
在类内部方法之间相互调用的时候，本质上是类对象自身的调用，而不是使用代理对象去调用，也就不会触发AOP，这样其实Spring也就无法将事务控制的代码逻辑织入到调用代码流程中，所以这里的事务控制就无法生效。
所以遇到同一个类中多个方法之间相互调用，且调用的方法需要做事务控制的时候需要特别注意下这个问题。解决方式，可以建2个不同的类，然后将方法放到两个类中，这样跨类调用，Spring事务机制就可以生效。
添加在非public方法上

如果将@Transactional注解添加在protected、private修饰的方法上，虽然代码不会有任何的报错，但是实际上注解是不会生效的。
方法内部Try Catch吞掉相关异常

这个其实很容易理解，业务代码中将所有的异常给catch并吞掉了，等同于业务代码认为被捕获的异常不需要去触发回滚。对框架而言，因为异常被捕获了，业务逻辑执行都在正常往下运行，所以也不会触发异常回滚机制。
  1. // catch了可能的异常，导致DB操作失败的时候事务不会触发回滚
  2. @Transactional
  3. public void insertUser() {
  4.     try {
  5.         // do something here...
  6.         userRepository.save(user);
  7.     } catch (Exception e) {
  8.         log.error("failed to create user");
  10.         // 直接吞掉了异常，这样不会触发事务回滚机制
  11.     }
  12. }
复制代码
在业务处理逻辑中，如果确实需要知晓并捕获相关处理的异常进行一些额外的业务逻辑处理，如果要保证事务回滚机制生效，最后需要往外抛出RuntimeException异常，或者是继承RuntimeException实现的业务自定义异常。如下：
  1. // catch了可能的异常，对外抛出RuntimeException或者其子类,可触发事务回滚
  2. @Transactional
  3. public void insertUser() {
  4.     try {
  5.         // do something here...
  6.         userRepository.save(user);
  7.     } catch (Exception e) {
  8.         log.error("failed to create user");
  10.         // @Transactional没有指定rollbackFor，所以抛出RuntimeException或者其子类，可触发事务回滚机制
  11.         throw new RuntimeException(e);
  12.     }
  13. }
复制代码
当然，如果@Transactional注解指定了rollbackFor为某个具体的异常类型，则最终需要保证异常时对外抛出相匹配的异常类型，才可以触发事务处理逻辑。如下：
  1. // catch了指定异常，对外抛出对应类型的异常,可触发事务回滚
  2. @Transactional(rollbackFor = DemoException.class)
  3. public void insertUser() {
  4.     try {
  5.         // do something here...
  6.         userRepository.save(user);
  7.     } catch (Exception e) {
  8.         log.error("failed to create user");
  9.         // @Transactional有指定rollbackFor，抛出异常要与rollbackFor指定异常类型一致
  10.         throw new DemoException();
  11.     }
  12. }
复制代码
对应数据库引擎类型不支持事务

以MySQL数据库而言，常见的数据库引擎有InnoDB和Myisam等类型，但是MYISAM引擎类型是不支持事务的。所以如果建表时设置的引擎类型设置为MYISAM的话，即使代码里面添加了@Transactional最终事务也不会生效的。
@Transactional使用策略


因为事务处理对性能会有一定的影响，所以事务也不是说任何地方都可以随便添加的。对于一些性能敏感场景，需要注意几点：
（1）不含有DB操作相关，无需添加事务控制
（2）单条查询语句，没必要添加事务控制
（3）仅有查询操作的多条SQL执行场景，可以添加只读事务控制
（4）单条insert/update/delete语句，其实也不需要添加@Transactional事务处理，因为单条语句执行其实数据库有隐性事务控制机制，如果执行失败，是属于SQL报错，数据不会更新成功，自然也无需回滚。
主要从性能层面考虑，事务机制，类似于并发场景的加锁处理，范围越大对性能影响越明显
也是从性能层面考虑，尽量将耗时的逻辑放到事务控制之外执行，事务内仅保留与DB操作切实相关的逻辑
DataSource数据源配置


DataSource整体情况

SpringBoot为DataSource提供了两种最为常见的默认配置：
至于具体使用哪一个，主要是看项目pom.xml中引入了哪个jar了。
对于使用SpringBoot默认配置的项目而言，SpringBoot默认使用的是Tomcat容器，所以默认情况也是使用的Tomcat的JDBC的DataSource及其连接池。
看一下配置数据加载类DataSourceProperties的写法：

所以我们的数据源配置信息，相关配置项需要以spring.datasource开头，如下：
  1. spring.datasource.url=jdbc:mysql://<ip>:<port>/vzn-demo?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai
  2. spring.datasource.username=vzn-demo
  3. spring.datasource.password=<password>
复制代码
除了SpringBoot自带的DataSource类型，还有一些其他三方提供的DataSource。项目开发工作中比较常用的有AliDruid DataSource，这里也介绍下。
  1. <dependency>
  2.     <groupId>com.alibaba</groupId>
  3.     <artifactId>druid-spring-boot-starter</artifactId>
  4.     <version>1.1.22</version>
  5. </dependency>
复制代码
  1. # 数据库连接信息
  2. spring.datasource.druid.url=jdbc:mysql://<ip>:<port>/<db-name>?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai
  3. spring.datasource.druid.username=<userName>
  4. # 可以设置配置的密码是否加密
  5. spring.datasource.druid.connect-properties.config.decrypt=false
  6. spring.datasource.druid.password=<password>
复制代码
配置多数据源

在大型的项目中，可能会涉及到服务需要同时连接多个数据库进行数据操作的场景，这里就会涉及到多个DataSource的配置。
举个例子，现在有一个社交论坛服务，其发帖（Post）和评论（Comment）分别对应两个DB，使用AliDruidDataSource的情况下，应该如何配置呢？
前面内容有提过，所有的数据源相关配置项需要以spring.datasource开头。而我们使用AliDruid进行多个数据源的配置时，我们需要设定各个数据源的若干配置都以spring.datasource.druid.{xxx}开头。比如本例中，我们可以对发帖DB、评论DB两个数据源约定前缀分别为spring.datasource.druid.post以及spring.datasource.druid.comment。
在application.properties中配置两个数据源的信息：
  1. # Post数据源信息
  2. spring.datasource.druid.post.url=jdbc:mysql://<ip>:<port>/<db-name>?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai
  3. spring.datasource.druid.post.username=<userName>
  4. spring.datasource.druid.post.connect-properties.config.decrypt=false
  5. spring.datasource.druid.post.password=<password>
  7. # Comment数据源信息
  8. spring.datasource.druid.comment.url=jdbc:mysql://<ip>:<port>/<db-name>?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai
  9. spring.datasource.druid.comment.username=<userName>
  10. spring.datasource.druid.comment.connect-properties.config.decrypt=false
  11. spring.datasource.druid.comment.password=<password>
复制代码
接前面的例子，在application.properties中配置了两个数据源之后，需要实现两个JAVA类用于读取配置并做相关的配置处理。
针对Post数据源：
  1. @Configuration
  2. @EnableTransactionManagement
  3. @EnableConfigurationProperties(JpaProperties.class)
  4. @EnableJpaRepositories(
  5.         entityManagerFactoryRef="entityManagerFactoryPost",
  6.         transactionManagerRef="transactionManagerPost",
  7.         basePackages = {"com.vzn.demo.post.repository"} // 设置哪些package下面的repository使用此数据源
  8. )
  9. public class DataSourcePostConfig {
  10.     @Primary
  11.     @Bean
  12.     @ConfigurationProperties("spring.datasource.druid.post")
  13.     public DataSource dataSourcePost() {
  14.         return DruidDataSourceBuilder.create().build();
  15.     }
  17.     @Autowired
  18.     private DataSource dataSourcePost;
  20.     @Primary
  21.     @Bean
  22.     public LocalContainerEntityManagerFactoryBean entityManagerFactoryPost(EntityManagerFactoryBuilder builder) {
  23.         return builder
  24.             .dataSource(dataSourcePost)
  25.             .packages("com.vzn.demo.post.entity") // 设置哪些package下面的实体使用此数据源
  26.             .build();
  27.     }
  29.     @Primary
  30.     @Bean
  31.     public EntityManager entityManagerPost(EntityManagerFactoryBuilder builder) {
  32.         return entityManagerFactoryPost(builder).getObject().createEntityManager();
  33.     }
  35.     @Autowired
  36.     private JpaProperties jpaProperties;
  37.    
  38.     @Primary
  39.     @Bean
  40.     public PlatformTransactionManager transactionManagerPost(EntityManagerFactoryBuilder builder) {
  41.         return new JpaTransactionManager(entityManagerFactoryPost(builder).getObject());
  42.     }
  43. }
复制代码
针对Comment数据源：
  1. @Configuration
  2. @EnableTransactionManagement
  3. @EnableConfigurationProperties(JpaProperties.class)
  4. @EnableJpaRepositories(
  5.         entityManagerFactoryRef="entityManagerFactoryComment",
  6.         transactionManagerRef="transactionManagerComment",
  7.         basePackages = {"com.vzn.demo.comment.repository"} // 设置哪些package下面的repository使用此数据源
  8. )
  9. public class DataSourceCommentConfig {
  10.     @Primary
  11.     @Bean
  12.     @ConfigurationProperties("spring.datasource.druid.comment")
  13.     public DataSource dataSourceComment() {
  14.         return DruidDataSourceBuilder.create().build();
  15.     }
  17.     @Autowired
  18.     private DataSource dataSourceComment;
  20.     @Primary
  21.     @Bean
  22.     public LocalContainerEntityManagerFactoryBean entityManagerFactoryComment(EntityManagerFactoryBuilder builder) {
  23.         return builder
  24.             .dataSource(dataSourceComment)
  25.             .packages("com.vzn.demo.comment.entity") // 设置哪些package下面的实体使用此数据源
  26.             .build();
  27.     }
  29.     @Primary
  30.     @Bean
  31.     public EntityManager entityManagerComment(EntityManagerFactoryBuilder builder) {
  32.         return entityManagerFactoryComment(builder).getObject().createEntityManager();
  33.     }
  35.     @Autowired
  36.     private JpaProperties jpaProperties;
  37.    
  38.     @Primary
  39.     @Bean
  40.     public PlatformTransactionManager transactionManagerPost(EntityManagerFactoryBuilder builder) {
  41.         return new JpaTransactionManager(entityManagerFactoryPost(builder).getObject());
  42.     }
  43. }
复制代码
上述数据源配置类中，有指定了不同package下面的代码，使用对应不同的DataSource，所以具体使用的时候与正常情况无异，按照约定将不同数据源对应处理DAO类放到各自指定的package下即可，service层代码可以按照正常逻辑调用，无需感知DAO层的数据源差异。当然，如果某些例外场景下，可以通过@Transactional(rollbackFor = Exception.class, transactionManager= "transactionManagerPost")这种方式显式的指定要使用某个具体数据源。
虽然，对于多数据源有明确的处理与支持手段，但是多数据源加剧了代码维护的难度与开发过程中的复杂度，所以笔者认为代码架构层面需要多一些思考与优化，可以通过微服务化拆分的方式来尽量避免出现多数据源的场景。
小结，承上启下

好啦，本篇内容就介绍到这里。
通过本篇的内容，我们对Spring项目里面的数据库事务处理相关的概念有了一个相对全面的了解，也知道了一些可能导致Spring事务失效的因素。
通过前面的系列文档，我们一起对SpringData JPA从浅入深的进行了全方位的探讨。正所谓“工欲善其事、必先利其器”，面对一个优秀的框架，如果再结合一些外部的工具，其实可以让我们的开发效率与程序员开发过程的体验更上一层楼的。在下一篇文档里，我们将一起聊聊如何利用工具来让我们的开发过程进一步的简化。
如果对本文有自己的见解，或者有任何的疑问或建议，都可以留言，我们一起探讨、共同进步。
补充
Spring Data JPA作为Spring Data中对于关系型数据库支持的一种框架技术，属于ORM的一种，通过得当的使用，可以大大简化开发过程中对于数据操作的复杂度。
本文档隶属于《Spring Data JPA用法与技能探究》系列的第4篇。本系列文档规划对Spring Data JPA进行全方位的使用介绍，一共分为5篇文档，如果感兴趣，欢迎关注交流。
《Spring Data JPA用法与技能探究》系列涵盖内容：
我是悟道，聊技术、又不仅仅聊技术~
如果觉得有用，请点个关注，也可以关注下我的公众号【架构悟道】，获取更及时的更新。
期待与你一起探讨，一起成长为更好的自己。


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4