写点什么

Spring 数据库事务典型错误用法剖析

发布于: 8 小时前

数据事务是企业应用关注的核心内容,也是开发者最容易犯错的地方。


本文就来讲解一些使用中的不良习惯,注意,它们可以避免一些错误和性能的丢失。


错误使用 Service 互联网往往采用模型—视图—控制器(Model View Controller,MVC)来搭建开发环境,因此在 Controller 中使用 Service 是十分常见的。


为了方便测试,角色服务(roleService)和角色列表(RoleListService)进行测。假设我们想在一个 Controller 中插入两个角色,并且两个角色需要在同一个事务中处理,下面先给出错误使用 Service 的 Controller,代码如下。package com.learn.ssm.chapter14.controller;/****************** imports ******************/@Controller


public class RoleController {@Autowiredprivate RoleService roleService = null;


@Autowiredprivate RoleListService roleListService = null;
// 方法无事务public void errerUseServices() { Role role1 = new Role(); role1.setRoleName("role_name_1"); role1.setNote("role_note_1"); // 带事务方法 roleService.insertRole(role1); Role role2 = new Role(); role2.setRoleName("role_name_2"); role2.setNote("role_note_2"); // 带事务方法 roleService.insertRole(role2);}
复制代码


}类似的代码在工作中常常出现,甚至拥有多年开发经验的开发人员也会犯这类错误。这里存在的问题是两个 insertRole 方法根本不在同一个事务里的问题。


当一个 Controller 使用 Service 方法时,如果这个 Service 方法标注有 @Transactional,那么它就会启用一个事务,而一个 Service 方法完成后,它就会释放该事务,所以前后两个 insertRole 的方法是在两个不同的事务中完成的。


下面是笔者测试这段代码的日志,可以清晰地看出它们并不存在于同一个事务中。


org.mybatis.logging.Logger: Creating a new SqlSessionorg.mybatis.logging.Logger: Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@53f0a4cb]org.mybatis.logging.Logger: JDBC Connection [1746570062, URL=jdbc:mysql://localhost:3306/ssm, UserName=root@localhost, MySQL Connector Java] will be managed by Springorg.apache.ibatis.logging.jdbc.BaseJdbcLogger: ==> Preparing: insert into t_role(role_name, note) values (?, ?)org.apache.ibatis.logging.jdbc.BaseJdbcLogger: ==> Parameters: role_name_1(String), role_note_1(String)org.apache.ibatis.logging.jdbc.BaseJdbcLogger: <== Updates: 1org.mybatis.logging.Logger: Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@53f0a4cb]org.mybatis.logging.Logger: Transaction synchronization committing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@53f0a4cb]org.mybatis.logging.Logger: Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@53f0a4cb]org.mybatis.logging.Logger: Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@53f0a4cb]org.mybatis.logging.Logger: Creating a new SqlSessionorg.mybatis.logging.Logger: Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@640f11a1]org.mybatis.logging.Logger: JDBC Connection [2059592603, URL=jdbc:mysql://localhost:3306/ssm, UserName=root@localhost, MySQL Connector Java] will be managed by Springorg.apache.ibatis.logging.jdbc.BaseJdbcLogger: ==> Preparing: insert into t_role(role_name, note) values (?, ?)org.apache.ibatis.logging.jdbc.BaseJdbcLogger: ==> Parameters: role_name_2(String), role_note_2(String)org.apache.ibatis.logging.jdbc.BaseJdbcLogger: <== Updates: 1org.mybatis.logging.Logger: Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@640f11a1]这样如果第一个插入成功了,而第二个插入失败了,就会使数据库数据不完全同时成功或者失败,可能产生严重的数据不一致的问题,给生产带来严重的损失。


这个例子明确地告诉大家使用带有事务的 Service 方法时,应该只有一个入口,然后使用传播行为来定义事务策略。


如果错误地进行多次调用,就不会在同一个事务中,这会造成不同时提交或回滚的数据一致性问题。


每一个 Java EE 开发者都要注意这类问题,以避免一些不必要的错误。


过长时间占用事务在企业的生产系统中,数据库事务资源是最宝贵的资源之一,使用了数据库事务之后,要及时释放数据库事务资源,甚至要评估数据库事务处理业务的耗时。


换言之,我们应该尽可能地缩短使用数据库事务资源的时间去完成所需工作,为此我们需要区分哪些业务是需要事务的,哪些又是不需要的,而不需要的耗时又如何?比如,在工作中需要使用到文件、对外连接调用等操作,而这些操作往往会占用较长时间,且不需要事务,在这样的场景下,如果开发者不注意细节,就很容易出现系统宕机的问题。假设在插入角色后还需要操作一个文件,那么我们要改造 insertRole 方法,如代码如下。


@Override@Transactional(propagation = Propagation.REQUIRED,isolation= Isolation.READ_COMMITTED)public int insertRole(Role role) {int result = roleMapper.insertRole(role);// 操作一些与数据库无关的文件操作 doSomethingForFile();return result;}假设 doSomethingForFile 方法是一个与数据库事务无关的操作,比如处理图片的上传之类的操作,但是笔者必须告诉读者这是一段糟糕的代码。


当 insertRole 方法结束后,Spring 才会释放数据库事务资源,也就是说在运行 doSomethingForFile 方法时,Spring 并没有释放数据库事务资源,而等到 doSomethingForFile 方法运行完成返回 result 后,才会关闭数据库资源。


在大型互联网系统中,一个数据库的链接可能也就是 50 条左右,然而同时并发的请求则可能是成百上千。


而其中大部分的并发请求都在等待这 50 条占有数据库连接资源的文件操作,假如平均一个 doSomethingForFile 的操作需要 1 秒,对于同时出现 1 000 条并发请求的网站,就会出现请求卡顿的状况。


因为大部分的请求都在等待数据库事务资源的分配,这是一个糟糕的结果,如图 1 所示。



图 1 在事务中的文件操作


从图 1 可以看出,当操作文件这步占用较长时间时,数据库事务将长期得不到释放,这个时候如果发生高并发的情况,会造成大量的并发请求得不到数据库的事务资源而导致的系统宕机。


对此,应该修改为在 Controller 层中操作文件,代码如下。


@Autowiredprivate RoleService roleService = null;


public Role addRole(Role role) {// 带事务方法 roleService.insertRole(role);// 不需事务方法 doSomethingForFile();return role;}注意,当程序运行完 insertRole 方法后,Spring 会释放数据库事务资源。


对于 doSomethingForFile 方法而言,已经在一个没有事务的环境中运行了,这样当前的请求就不会长期占用数据库事务资源,使得其他并发的请求被迫等待其释放了,这个改写分析如图 2 所示。



图 2 不在事务中的文件操作


从图 2 可以看出,在操作文件时,事务早已被关闭了,这时操作文件就避免了数据库事务资源被当前请求占用,从而导致其他请求得不到事务的情况发生了。


其实,不仅是文件操作,还有一些系统之间的通信及一些可能需要花费较长时间的操作,都要注意这个问题。


错误捕捉异常模拟一段购买商品的代码,其中 ProductService 是产品服务类,而 TransactionService 是记录交易信息,需求显然就是产品减库存和保存交易在同一个事务里面,要么同时成功,要么同时失败,并且假设减库存和保存交易的传播行为都为 REQUIRED,现在让我们来看如下代码。


@Autowiredprivate PrudoctService prudoctService;


@AutowiredPrivate TransactionService transactionService;


@Override@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)public int doTransaction(TransactionBean trans) {int resutl = 0;try {// 减少库存 int result = prudoctService.decreaseStock(trans.getProductId, trans.getQuantity());// 如果减少库存成功则保存记录 if (result >0) {transactionService.save(trans);}} catch(Exception ex) {// 自行处理异常代码// 记录异常日志 log.info(ex);}return result;}这里的问题是方法已经存在异常了,由于开发者不了解 Spring 的事务约定,在两个操作的方法里面加入了自己的 try...catch...语句。


这样实际也没有什么错误,只是显得冗余,之前我们分析过当 PrudoctService 的 decreaseStock 方法没有异常,而 TransactionService 的 save 方法发生异常时,也会发生事务的回滚,只是它会抛出“Transaction rolled back because it has been marked as rollback-only(事务看起来已经标注了只能回滚)”的异常,对于一些初级开发者可能就难以找到发生异常的原因了。


在那些需要处理大量异常的代码中,我们要小心这样的问题,避免代码复杂化,让定位问题出现很大的困难。有时候也确实需要我们自己处理异常,为此对上述代码进行改造,代码如下。


@Autowiredprivate PrudoctService prudoctService;


@AutowiredPrivate TransactionService transactionService;


@Override@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)public int doTransaction(TransactionBean trans) {int resutl = 0;try {// 减少库存 int result = prudoctService.decreaseStock(trans.getProductId, trans.getQuantity());// 如果减少库存成功则保存记录 if (result >0) {transactionService.save(trans);}} catch(Exception ex) {// 自行处理异常代码// 记录异常日志 log.info(ex);// 自行抛出异常,让 Spring 事务管理流程获取异常,进行事务管理 throw new RuntimeException(ex);}return result;}注意,它抛出了一个运行异常,这样在 Spring 的事务流程中,就会捕捉到抛出的这个异常,进行事务回滚。这样在发生异常时,会更有利于定位,这才是合适使用数据库事务的方式。



以上内容来自曾引领数万人学会 SSM+Redis 整合开发的技术畅销书升级版《Java EE 互联网轻量级框架整合开发:SSM+Redis+Spring 微服务(上下册)》。


前版读者评论










京东满 100 减 50


快快扫码抢购吧!



用户头像

还未添加个人签名 2019.10.21 加入

还未添加个人简介

评论

发布
暂无评论
Spring数据库事务典型错误用法剖析