当前位置: 首页 > news >正文

厦门英文网站建设合肥网络推广

厦门英文网站建设,合肥网络推广,wordpress主题授权方式,同行做的好的网站在业务方法上使用Transactional开启声明式事务时,很有可能由于使用方式有误,导致事务没有生效。 环境准备 表结构 CREATE TABLE admin (id bigint(20) unsigned NOT NULL AUTO_INCREMENT,username varchar(255) DEFAULT NULL,password varchar(255) …

在业务方法上使用@Transactional开启声明式事务时,很有可能由于使用方式有误,导致事务没有生效。

环境准备

表结构

CREATE TABLE `admin` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,`username` varchar(255)  DEFAULT NULL,`password` varchar(255)  DEFAULT NULL,`name` varchar(255)  DEFAULT NULL,`phone` int(11) DEFAULT NULL,`power` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB;

实体类

@Entity
@Data
public class Admin {@Id@GeneratedValue(strategy = GenerationType.IDENTITY)private  Long id;private  String  username;private  String  password;private  String  name;private  Integer phone;private  Integer power;
}

DAO 层

@Repository
public interface AdminRepository extends JpaRepository<Admin,Long> {List<Admin> findByName(String name);
}

上面这些类都是不变的,主要是 service 类。

事务失效

非 public

当被@Transactional注解修饰的方法为非public时,事务将失效。

@Service
@Slf4j
public class AdminService {@Autowiredprivate AdminRepository adminRepository;@Transactionalprotected void saveAdmin(Admin admin) {adminRepository.save(admin);if (admin.getName().contains("@")) {throw new RuntimeException("不合法");}}
}

在同包下新建一个测试类。

@Autowired
private AdminService adminService;@GetMapping("/addAdminWrong")
public void add(@RequestParam("name") String name) {Admin admin = new Admin();admin.setName(name);adminService.saveAdmin(admin);
}

测试接口发现,即使用户名不合法,用户也能创建成功。

@Transactional 生效原则(一):只有定义在 public 方法上的 @Transactional 才能生效。原因是,Spring 默认通过动态代理的方式实现 AOP,对目标方法进行增强,private 方法无法代理到,Spring 自然也无法动态增强事务处理逻辑。

所以,将 saveAdmin 方法,修改为 public,就可以了。

自调用

saveAdmin 方法是 public时,事务一定能生效吗?

答案是不一定,比如下面这个例子。

@Service
@Slf4j
public class AdminService {@Autowiredprivate AdminRepository adminRepository;public int addAdminWrong(String name) {Admin admin = new Admin();admin.setName(name);try {/*** 一些其他业务处理*/this.saveAdmin(admin);} catch (Exception e) {log.error("添加失败:{}",e);}return adminRepository.findByName(name).size();}@Transactionalpublic void saveAdmin(Admin admin) {adminRepository.save(admin);if (admin.getName().contains("@")) {throw new RuntimeException("不合法");}}
}

在上面代码中,我们新定义了一个addAdminWrong方法,并在它内部调用了本类的saveAdmin方法。

测试代码如下:

@GetMapping("/addAdminWrong")
public void add(@RequestParam("name") String name) {adminService.addAdminWrong(name);
}

测试后发现,不合法的用户,还是被创建成功了。

Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT

观察日志发现,自调用因为没有走代理,事务没有在 saveAdmin 方法上生效,只在 SimpleJpaRepository 上的 save 方法层面生效。


最简单的修改方案是,在AdminService类中,自己注入自己,比如:

@Autowired
private AdminService self;

然后通过 self 实例去调用 self.saveAdmin(admin)


还有一种优雅的方案,是通过AopContext在代理对象中获取自身。

比如:

AdminService adminService = (AdminService) AopContext.currentProxy();
adminService.saveAdmin(admin);

然后就会发现一个异常:

Cannot find current proxy: Set 'exposeProxy' property on Advised to 'true' to make it available, and ensure that AopContext.currentProxy() is invoked in the same thread as the AOP invocation context.

它的意思是:没有开启一个 exposeProxy 的属性,导致无法暴露出代理对象,从而无法获取。

所以我们在启动类上加上这个注解 @EnableAspectJAutoProxy(exposeProxy=true)即可。

@SpringBootApplication
@EnableAspectJAutoProxy(exposeProxy=true) //暴露代理对象
public class StarterDemoApplication {public static void main(String[] args) {SpringApplication.run(StarterDemoApplication.class, args);}
}

然后,再观察日志,发现事务在AdminService.saveAdmin方法上生效了

Creating new transaction with name [com.starter.demo.controller.AdminService.saveAdmin]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT

@Transactional 生效原则(二):需要确保方法调用是通过Spring的代理对象进行的,而不是直接在类内部调用。

异常处理不当

上面的两个例子,是由于事务失效导致回滚失败。

接下来,我们来看下,即使事务生效也会回滚失败的场景。

(一):被@Transactional注解标记的方法抛出了异常,事务才会回滚。

意思就是说,得把异常抛出来才行。

在 Spring 的 TransactionAspectSupport.invokeWithinTransaction 方法中,可以找到处理事务的逻辑,可以看到只有捕获到异常才能进行后续事务处理。

在这里插入图片描述

比如这段代码,虽然在方法中抛出了异常,但又被它自己给捕获了。

 @Transactionalpublic void saveAdminWrong1(String name) {Admin admin = new Admin();admin.setName(name);try {adminRepository.save(admin);throw new RuntimeException("模拟错误");} catch (Exception e) {log.error("save admin error:",e);}}

同时再次观察日志可以发现,虽然事务在AdminService.saveAdminWrong1上是生效的,但由于异常没有被传播出去,所以无法回滚。

Creating new transaction with name [com.starter.demo.controller.AdminService.saveAdminWrong1]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT

我们可以手动回滚当前事务,在 catch 代码块中加上TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

通过日志可以看到回滚的信息。

2024-11-22 17:13:08.537 DEBUG 7219 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Transactional code has requested rollback
2024-11-22 17:13:08.537 DEBUG 7219 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Initiating transaction rollback
2024-11-22 17:13:08.537 DEBUG 7219 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Rolling back JPA transaction on EntityManager [SessionImpl(1495642341<open>)]

(二):默认情况下,出现 RuntimeException 或 Error 的时候,Spring 才会回滚事务。

追踪completeTransactionAfterThrowing方法,可以看到,它是根据异常的类型来决定是否回滚的。

在这里插入图片描述

点进 rollbackOn 方法,可以看到,它只会在RuntimeExceptionError 的时候返回 true。

在这里插入图片描述

比如这段代码,我们希望保存用户的时候,同时去加载一个文件,如果加载文件失败,则事务需要回滚。

@Transactional
public void saveAdminWrong2(String name) throws IOException {Admin admin = new Admin();admin.setName(name);adminRepository.save(admin);otherTask(); //额外的操作}private void otherTask() throws IOException{Files.readAllLines(Paths.get("admin.txt"));}

同时观察日志可以发现,虽然事务在AdminService.saveAdminWrong2上是生效的,也没有去捕获异常,但是由于传播出去的是 checked exception,所以事务也不会回滚。

Creating new transaction with name [com.starter.demo.controller.AdminService.saveAdminWrong2]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT

可以在注解中声明,希望遇到所有的 Exception 都回滚事务。

@Transactional(rollbackFor = Exception.class)
public void saveAdminWrong2(String name) throws IOException {Admin admin = new Admin();admin.setName(name);adminRepository.save(admin);otherTask(); //额外的操作}private void otherTask() throws IOException{Files.readAllLines(Paths.get("test.sql"));
}

同时观察日志可以发现,事务在AdminService.saveAdminWrong2上是生效的,还看到了回滚的日志信息。

2024-11-22 17:29:24.846 DEBUG 7560 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Creating new transaction with name [com.starter.demo.controller.AdminService.saveAdminWrong2]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT,-java.lang.Exception
2024-11-22 17:29:24.948 DEBUG 7560 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Initiating transaction rollback
2024-11-22 17:29:24.948 DEBUG 7560 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Rolling back JPA transaction on EntityManager [SessionImpl(1844074856<open>)]

事务传播行为不当

比如,在插入用户信息的时候,也插入一份扩展信息,但由于扩展信息不是很重要,即使它失败了,也不要影响到我们的主逻辑(把插入扩展信息的操作当成一个独立的事务)。

@Service
@Slf4j
public class AdminService {@Autowiredprivate AdminRepository adminRepository;@Autowiredprivate AddressService addressService;@Transactionalpublic void saveAdminWrong3(String name) {//1.保存用户信息saveAdmin(name);//2.保存扩展信息addressService.saveAddress(name);}private void saveAdmin(String name) {Admin admin = new Admin();admin.setName(name);adminRepository.save(admin);log.info("save admin success");}
}
@Service
@Slf4j
public class AddressService {@Autowiredprivate AddressRepository addressRepository;@Transactionalpublic void saveAddress(String name) {Address address = new Address();address.setName(name);log.info("saveAddress start");addressRepository.save(address);throw new RuntimeException("模拟 save address 失败");}
}

可以看到,saveAddress的操作是失败的,按照我们的期望,saveAdmin方法不能受到影响,能够正常插入成功。

测试执行后发现,saveAdmin方法出现了回滚,不符合我们的预期。

2024-11-22 18:02:18.171 DEBUG 8251 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Rolling back JPA transaction on EntityManager [SessionImpl(809976208<open>)]
2024-11-22 18:02:18.188 DEBUG 8251 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Not closing pre-bound JPA EntityManager after transaction
2024-11-22 18:02:18.188 ERROR 8251 --- [nio-8080-exec-1] c.s.demo.controller.TestController       : 模拟 save address 失败
2024-11-22 18:02:18.205 DEBUG 8251 --- [nio-8080-exec-1] o.j.s.OpenEntityManagerInViewInterceptor : Closing JPA EntityManager in OpenEntityManagerInViewInterceptor

我们来猜想一下,是不是因为saveAddress抛出的异常,没有在saveAdminWrong3中捕获,而saveAdminWrong3也会接着往上层抛,导致被回滚了呢?

所以呢,我们先在saveAdminWrong3方法中捕获一下saveAddress抛出的异常试试。

@Transactional
public void saveAdminWrong3(String name) {//1.保存用户信息saveAdmin(name);//2.保存扩展信息try {addressService.saveAddress(name);} catch (Exception e) {log.error("save address error:{}",e.getMessage());}
}

运行程序,再次观察日志:

2024-11-22 18:39:41.741 DEBUG 8496 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Creating new transaction with name [com.starter.demo.service.AdminService.saveAdminWrong3]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT2024-11-22 18:39:41.850 DEBUG 8496 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Participating transaction failed - marking existing transaction as rollback-only2024-11-22 18:39:41.851 ERROR 8496 --- [nio-8080-exec-1] com.starter.demo.service.AdminService    : save address error:模拟 save address 失败2024-11-22 18:39:41.851 DEBUG 8496 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Committing JPA transaction on EntityManager [SessionImpl(98155953<open>)]2024-11-22 18:39:41.884 ERROR 8496 --- [nio-8080-exec-1] c.s.demo.controller.TestController       : org.springframework.transaction.UnexpectedRollbackException: Transaction silently rolled back because it has been marked as rollback-only

通过日志,可以发现:

  1. AdminService.saveAdminWrong3上开启了事务处理;
  2. 当前事务被标记为了回滚;
  3. saveAdminWrong3中打印出了saveAddress的异常信息;
  4. 主方法已经提交了事务;
  5. TestController中打印了一个UnexpectedRollbackException,提示这个事务要静默回滚了。

UnexpectedRollbackException 是 Spring 框架抛出的一个异常,表明事务由于某些原因被静默地标记为只能回滚(rollback-only),意味着事务不会正常提交,而是会在结束时被回滚。

saveAdminWrong3方法中并没有出现异常,所以在事务提交时,发现当前事务已经被子方法设置成了回滚,导致无法正常提交,进而证实了saveAdminWrong3saveAddress使用了同一个事务。

@Transactional注解中,propagation 属性决定了事务的传播行为,默认是REQUIRED

REQUIRED:如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务。

所以,这也说明了saveAddress方法不会开启一个新事务,而是会加入到saveAdminWrong3的事务中。

所以,需要将propagation 设置为 REQUIRES_NEW

REQUIRES_NEW:它会创建一个新事务,如果当前存在事务,把当前事务挂起,直到新事务完成。这种传播行为适用于需要独立于当前事务的场景。

修改AddressService的代码,其他不变。

@Service
@Slf4j
public class AddressService {@Autowiredprivate AddressRepository addressRepository;@Transactional(propagation = Propagation.REQUIRES_NEW)public void saveAddress(String name) {Address address = new Address();address.setName(name);log.info("saveAddress start");addressRepository.save(address);throw new RuntimeException("模拟 save address 失败");}
}

再次执行,查看日志:

2024-11-22 19:13:56.643 DEBUG 9201 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Creating new transaction with name [com.starter.demo.service.AdminService.saveAdminWrong3]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT2024-11-22 19:13:56.734  INFO 9201 --- [nio-8080-exec-1] com.starter.demo.service.AdminService    : save admin success2024-11-22 19:13:56.734 DEBUG 9201 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Suspending current transaction, creating new transaction with name [com.starter.demo.service.AddressService.saveAddress]2024-11-22 19:13:56.781 DEBUG 9201 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Initiating transaction rollback2024-11-22 19:13:56.833 DEBUG 9201 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Resuming suspended transaction after completion of inner transaction2024-11-22 19:13:56.833 ERROR 9201 --- [nio-8080-exec-1] com.starter.demo.service.AdminService    : save address error:模拟 save address 失败2024-11-22 19:13:56.834 DEBUG 9201 --- [nio-8080-exec-1] o.s.orm.jpa.JpaTransactionManager        : Committing JPA transaction on EntityManager [SessionImpl(1073120187<open>)]

通过日志可以看到

  1. AdminService.saveAdminWrong3上开启了事务处理;
  2. admin 创建完成;
  3. 主事务挂起了,在AddressService.saveAddress上开启了一个新的子事务;
  4. 子事务回滚了;
  5. 子事务完成,继续被挂起的主事务;
  6. 捕获到了saveAddress的异常;
  7. 主事务提交了,没有看到静默回滚的异常。
http://www.khdw.cn/news/56796.html

相关文章:

  • jspajax网站开发典型实例宁波网站建设方案推广
  • 北京自助企业建站模板推广产品引流的最佳方法
  • 什么是建设网站的主题免费发布平台
  • 磁力网站怎么做的源码百度招聘网最新招聘信息
  • 义乌小商品市场网seo顾问是什么
  • 上海免费网站建站模板松松软文
  • python建设购物网站上海疫情最新情况
  • 简单的做图网站百度seo一本通
  • 网站建设加工天津天狮网络营销课程
  • wordpress商业模板个人正规seo排名外包
  • 网站广告用ps如何做小程序定制开发
  • 河北做网站哪家公司好超级外链吧外链代发
  • 百度网站的设计风格如何进行关键词优化工作
  • 网站百度排名怎么做快今天发生的重大新闻5条
  • 做易经网站长尾关键词挖掘工具
  • 合肥建设银行官网招聘网站网站推广计划方法
  • 国内优秀网站欣赏seo专员是什么
  • 重庆泡沫字制作seo课程培训入门
  • 福建省住房和城乡建设局网站公司网站建设服务
  • 无锡网站建设推广谷歌seo技巧
  • ps如何做网站横幅免费网站建设
  • 徐州网站开发信息seo软件哪个好
  • 网站设计公司 龙岗站长平台官网
  • 安徽智能网站建设制作最新的疫情防控政策和管理措施
  • 网站开发与实践题库新开网店自己如何推广
  • 做网站需要什么样的电脑配置英雄联盟世界排名
  • 展示型网站建设流程百度经验官方网站登录入口
  • 北京高端品牌网站建设企业网站建设规划
  • o元做网站推广网站免费
  • 注册网站域名要多少钱seo关键词分析表