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

先做网站后备案吗广告外链购买交易平台

先做网站后备案吗,广告外链购买交易平台,上海58同城官网,互联网网站备案表Spring 声明式事务 1.Spring 事务管理概述1.1 事务管理的重要性1.2 Spring事务管理的两种方式1.2.1 编程式事务管理1.2.2 声明式事务管理 1.3 为什么选择声明式事务管理 2. 声明式事务管理2.1 基本用法2.2 常用属性2.2.1 propagation(传播行为)2.2.2 iso…

Spring 声明式事务

    • 1.Spring 事务管理概述
      • 1.1 事务管理的重要性
      • 1.2 Spring事务管理的两种方式
        • 1.2.1 编程式事务管理
        • 1.2.2 声明式事务管理
      • 1.3 为什么选择声明式事务管理
    • 2. 声明式事务管理
      • 2.1 基本用法
      • 2.2 常用属性
        • 2.2.1 propagation(传播行为)
        • 2.2.2 isolation(隔离级别)
        • 2.2.3 readOnly(只读事务)
        • 2.2.4 timeout(超时时间)
        • 2.2.5 rollbackFor(回滚异常)
    • 3. Spring事务失效
    • 4. 案例
      • 4.1 前期准备
        • 4.1.1 依赖引入
        • 4.1.2 数据库建表语句
        • 4.1.3 实体类以及相关代码
      • 4.2 转账案例
        • 4.2.1 测试成功
        • 4.2.2 测试回滚
        • 4.2.3 测试受检异常
        • 4.2.4 测试 rollBackFor 属性
        • 4.2.5 测试隔离级别

Spring 提供了两个事务管理方式一种是编程式(很少用),一种是声明式事务。声明式事务管理将事务管理的代码从业务逻辑中分离出来,使得代码更清晰、可维护。使得开发者可以通过配置而不是编写大量的代码来管理事务。

使用这里我们只介绍声明式事务

1.Spring 事务管理概述

1.1 事务管理的重要性

在应用程序中,事务管理是确保数据操作的一致性、隔离性、持久性和原子性的关键机制。当多个数据库操作必须作为一个不可分割的单元执行时,事务管理变得至关重要。对于复杂的业务逻辑,事务能够确保在并发和异常情况下,数据库始终保持一致性。

1.2 Spring事务管理的两种方式

Spring框架提供了两种主要的事务管理方式,分别是编程式事务管理和声明式事务管理。

1.2.1 编程式事务管理

编程式事务管理要求开发者通过编写代码来管理事务的开始、提交和回滚。虽然具有灵活性,但容易导致代码冗余和可读性差。

try {// 开始事务transactionManager.beginTransaction();// 执行业务逻辑// 提交事务transactionManager.commit();
} catch (Exception e) {// 发生异常,回滚事务transactionManager.rollback();throw e;
}
1.2.2 声明式事务管理

相比之下,声明式事务管理通过配置文件或注解的方式实现事务控制,将事务逻辑从业务代码中分离出来。这种方式更加简洁、可维护,并提供更好的可读性。

@Transactional
public void performBusinessLogic() {// 业务逻辑
}

1.3 为什么选择声明式事务管理

选择声明式事务管理有以下优势:

  • 简洁性: 通过注解或XML配置,开发者无需编写冗长的事务管理代码,使代码更加简洁清晰。
  • 可维护性: 事务逻辑与业务逻辑分离,易于维护和理解。
  • 可读性: 使用注解或XML配置,事务逻辑与业务逻辑在代码中更易于辨认,提高代码的可读性。
  • 一致性: 通过统一的配置方式,整个应用程序可以保持一致的事务管理策略,减少错误和不一致性。
  • 集成性: 声明式事务更好地与Spring的其他特性(如AOP)集成,提供更全面的解决方案。

综合而言,声明式事务管理是Spring中推荐的事务管理方式,它能够提高代码的可维护性、可读性,并与其他Spring特性协同工作,使得开发者能够更专注于业务逻辑的实现而不是事务的管理。

2. 声明式事务管理

声明式事务管理建立在AOP之上,其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,执行完目标方法之后根据执行的情况提交或者回滚。

Spring 根据类或者方法上是否有@transactional注解来判断是否开启事务。

2.1 基本用法

在类上使用

@Transactional
public class TestService {// 类中所有方法都将使用默认的事务配置
}

在方法上使用

public class TestService {@Transactionalpublic void method1() {// 这个方法将使用默认的事务配置}@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED)public void method2() {// 这个方法将使用指定的事务配置}
}

2.2 常用属性

2.2.1 propagation(传播行为)

@Transactional 注解的 propagation 属性用于定义事务的传播行为,它指定在方法被调用时,当前方法的事务如何与现有的事务进行交互。

@Transactional(propagation = Propagation.*)
public void method1() {// ...
}

定义事务的传播行为,包括 :

  • REQUIRED:默认,如果当前存在事务,则加入该事务,如果不存在事务,则新建一个事务。
  • REQUIRES_NEW:无论当前是否存在事务,都会创建一个新的事务,如果存在事务,则将其挂起。
  • SUPPORTS:如果当前存在事务,则加入该事务,如果不存在事务,则以非事务的方式执行。
  • MANDATORY:该传播行为要求当前方法必须在一个事务中执行,否则将抛出异常。
  • NOT_SUPPORTED:以非事务的方式执行,如果当前存在事务,则将其挂起。
  • NEVER:以非事务的方式执行,如果当前存在事务,则抛出异常。
  • NESTED:如果当前存在事务,则创建一个嵌套事务,并在嵌套事务内执行。嵌套事务是外部事务的一部分,但有独立的提交和回滚。
2.2.2 isolation(隔离级别)

@Transactional 注解中的 isolation 属性用于指定事务的隔离级别。隔离级别定义了多个事务并发执行时,彼此之间的可见性和影响的程度。

@Transactional(isolation = Isolation.*)
public void method1() {// ...
}

Spring 支持以下五个隔离级别:

  • DEFAULT:默认,使用底层数据库的默认隔离级别。通常为数据库的默认配置,比如 MySQL 默认的是 REPEATABLE_READ,而 Oracle 默认的是 READ_COMMITTED

  • READ_UNCOMMITTED(读未提交): 允许一个事务读取另一个事务未提交的数据。这是最低的隔离级别,可能导致脏读、不可重复读和幻读的问题。

  • READ_COMMITTED(读已提交):保证一个事务提交后才能被其他事务读取。这是大多数数据库的默认隔离级别,可以避免脏读,但仍可能存在不可重复读和幻读的问题。

  • REPEATABLE_READ(可重复读): 对相同字段的多次读取结果是一致的,除非自己进行了数据更新。避免了不可重复读的问题,但仍可能存在幻读的问题。

  • SERIALIZABLE(串行化): 最高的隔离级别,确保每个事务都完全看不到其他事务的操作,包括读取和写入。可以避免脏读、不可重复读和幻读的问题,但也降低了并发性能。

2.2.3 readOnly(只读事务)

标识事务是否为只读,可以提高事务的性能。

@Transactional(readOnly = true)
public void method1() {// ...
}
2.2.4 timeout(超时时间)

指定事务的超时时间,单位为秒。

@Transactional(timeout = 60)
public void method1() {// ...
}
2.2.5 rollbackFor(回滚异常)

指定哪些异常触发事务回滚。@Transactional 注解默认只对运行时异常进行事务回滚,对检查时异常不回滚。

@Transactional(rollbackFor = {SQLException.class, MyCustomException.class})
public void method1() {// ...
}

3. Spring事务失效

哪些情况下会导致Spring事务失效,对应的原因是什么?

  • 1.方法内的自调用:Spring事务是基于AOP的,只要使用代理对象调用某个方法时,Spring事务才能生效,而在一个方法中调用使用this.xxxO调用方法时,this并不是代理对象,所以会导致事务失效。

    • 解决办法1:将需要在同一事务中执行的方法抽取到一个独立的Bean中,通过依赖注入的方式调用该Bean。确保方法调用经过代理对象,从而激活事务。

    • 解决办法2:在类内部通过依赖注入的方式,将当前类注入到自己中,然后通过注入的对象调用方法。这样确保调用经过代理对象,从而使事务生效。

    • 解决办法3:使用AopContext.currentProxy()获取当前代理对象,通过这个代理对象调用方法。结合@EnableAspectJAutoProxy(exposeProxy=true)注解开启对当前代理对象的暴露,确保事务能够正确地被激活。

  • 2.方法是private的:Spring事务会基于CGLIB来进行AOP,而CGLIB会基于父子类来失效,子类是代理类,父类是被代理类,如果父类中的某个方法是private的,那么子类就没有办法重写它,也就没有办法额外增加Spring事务的逻辑。

  • 3.方法是final的:原因和private是了样的,也是由于子类不能重写父类中的final的方法

  • 4.单独的线程调用方法:当Mybatis或JdbcTemplate执行SQL时,会从ThreadLocal中去获取数据库连接对象,如果开启事务的线程和执行SQL的线程是同一个,那么就能拿到数据库连接对象,如果不是同一个线程,那就拿到不到数据库连接对象,这样,Mybatis或JdbcTemplate就会自己去新建一个数据库连接用来执行SQL,此数据库连接的autocommit为true,那么执行完SQL就会提交,后续再抛异常也就不能再回滚之前已经提交了的SQL了。

  • 5.没加@Configuration注解:如果用SpringBoot基本没有这个问题,但是如果用的Spring,那么可能会有这个问题,这个问题的原因其实也是由于Mybatis或JdbcTemplate会从ThreadLocal中去获取数据库连接,但是ThreadLocal中存储的是一个MAP,MAP的key为DataSource对象,value为连接对象,而如果我们没有在AppConfig上添加@Configuration注解的话,会导致MAP中存的DataSource对象和Mybatis和JdbcTemplate中的DataSource对象不相等,从而也拿不到数据库连接,导致自己去创建数据库连接了。

  • 6.异常被吃掉:如果Spring事务没有捕获到异常,那么也就不会回滚了,默认情况下Spring会捕获RuntimeException和Error。

  • 7.类没有被Spring管理

  • 8.数据库不支持事务

4. 案例

4.1 前期准备

4.1.1 依赖引入
    <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.16</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!-- 使用Plus 简化开发 --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.17</version></dependency></dependencies>
4.1.2 数据库建表语句
CREATE TABLE `users`  (`id` int NOT NULL AUTO_INCREMENT,`user_name` varchar(18)  NOT NULL,`balance` decimal(10, 2) NULL DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE
)
4.1.3 实体类以及相关代码

User

@Data
public class User {private int id;private String userName;private Double balance;
}

UserMapper

@Mapper
public interface UserMapper extends BaseMapper<User> {
}

UserService

public interface UserService extends IService<User> {
}

UserServiceImpl

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}

application.yml

Spring:datasource:url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8driver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: 120125hzy.type:  com.alibaba.druid.pool.DruidDataSource
mybatis-plus: # MyBatis Plus配置configuration: map-underscore-to-camel-case: true # 驼峰下划线转换
logging: # 控制台打印 SQLlevel:com:example:mapper: debug

4.2 转账案例

在Spring中,你可以使用@Transactional注解来实现声明式事务。这个注解可以应用于类级别或方法级别,具体取决于你想要控制事务的粒度。

接口编写

    /*** 测试转账*/String Transfer(Integer fromId, Integer toId, Double money);

生成单元测试,每次测试前两人余额都调整为 10000.00

@SpringBootTest
class UserServiceImplTest {@Autowiredprivate UserService userService;@Testvoid transfer() {String  ans =  userService.Transfer(1,2,600.0);assert ans.equals("转账成功");}
}
4.2.1 测试成功
 @Override@Transactionalpublic String Transfer(Integer fromId, Integer toId, Double money) {try {// 查询转出账户User fromUser = getById(fromId);if (fromUser == null) {throw new RuntimeException("转出账户不存在");}// 查询转入账户User toUser = getById(toId);if (toUser == null) {throw new RuntimeException("转入账户不存在");}// 检查余额是否足够if (fromUser.getBalance() < money) {throw new RuntimeException("余额不足");}// 更新转出账户余额fromUser.setBalance(fromUser.getBalance() - money);updateById(fromUser);// 更新转入账户余额toUser.setBalance(toUser.getBalance() + money);updateById(toUser);log.info("转账成功");return "转账成功";} catch (Exception e) {throw new RuntimeException("转账失败: " + e.getMessage());}}

测试通过

在这里插入图片描述

数据库也成功修改

在这里插入图片描述

4.2.2 测试回滚
   @Override@Transactionalpublic String Transfer(Integer fromId, Integer toId, Double money) {try {// 查询转出账户User fromUser = getById(fromId);if (fromUser == null) {throw new RuntimeException("转出账户不存在");}// 查询转入账户User toUser = getById(toId);if (toUser == null) {throw new RuntimeException("转入账户不存在");}// 检查余额是否足够if (fromUser.getBalance() < money) {throw new RuntimeException("余额不足");}// 更新转出账户余额fromUser.setBalance(fromUser.getBalance() - money);updateById(fromUser);// 手动抛出异常,测试事务回滚if (1 == 1) throw new RuntimeException("转账异常,事务回滚");// 更新转入账户余额toUser.setBalance(toUser.getBalance() + money);updateById(toUser);log.info("转账成功");return "转账成功";} catch (Exception e) {throw new RuntimeException("转账失败: " + e.getMessage());}}

测试未通过

在这里插入图片描述

数据库也没有改变

4.2.3 测试受检异常
    @Override@Transactionalpublic String Transfer(Integer fromId, Integer toId, Double money) throws SQLException {try {// 查询转出账户User fromUser = getById(fromId);if (fromUser == null) {throw new RuntimeException("转出账户不存在");}// 查询转入账户User toUser = getById(toId);if (toUser == null) {throw new RuntimeException("转入账户不存在");}// 检查余额是否足够if (fromUser.getBalance() < money) {throw new RuntimeException("余额不足");}// 更新转出账户余额fromUser.setBalance(fromUser.getBalance() - money);updateById(fromUser);// 手动抛出异常,测试事务回滚if (1 == 1) throw new RuntimeException("转账异常,事务回滚");// 更新转入账户余额toUser.setBalance(toUser.getBalance() + money);updateById(toUser);log.info("转账成功");return "转账成功";} catch (Exception e) {throw new SQLException("转账失败: " + e.getMessage());}}

测试未通过

在这里插入图片描述

事务未回滚

在这里插入图片描述

4.2.4 测试 rollBackFor 属性
@Transactional(rollbackFor = SQLException.class)

这次成功回滚了。

在这里插入图片描述

4.2.5 测试隔离级别

添加一个接口

    /***  测试付款*/String payment(Integer id,Double money);
    @Override@Transactional()public String payment(Integer id, Double money) {try {User user = getById(id);if (user == null) {throw new RuntimeException("支付账户不存在");}// 更新转出账户余额user.setBalance(user.getBalance()-money);updateById(user);Thread.sleep(5000);if (1 == 1) throw new RuntimeException("转账异常,事务回滚");log.info("支付成功");}catch (RuntimeException e){throw new RuntimeException("支付失败");}catch (Exception e){}return "支付成功";}

修改 Transfer()

@Override@Transactional(isolation = Isolation.READ_UNCOMMITTED)public String Transfer(Integer fromId, Integer toId, Double money){try {// 查询转出账户User fromUser = getById(fromId);if (fromUser == null) {throw new RuntimeException("转出账户不存在");}log.info("id: {}的余额:{}",fromUser.getId(),fromUser.getBalance());// 查询转入账户User toUser = getById(toId);if (toUser == null) {throw new RuntimeException("转入账户不存在");}// 检查余额是否足够if (fromUser.getBalance() < money) {throw new RuntimeException("余额不足");}// 更新转出账户余额fromUser.setBalance(fromUser.getBalance() - money);updateById(fromUser);// 更新转入账户余额toUser.setBalance(toUser.getBalance() + money);updateById(toUser);log.info("转账成功");return "转账成功";} catch (Exception e) {throw new RuntimeException("转账失败: " + e.getMessage());}}

测试函数

    @Testvoid test() throws InterruptedException {Thread t1 = new Thread(()->{userService.payment(1,500.0);});t1.start();Thread.sleep(2000);userService.Transfer(1,2,600.0);}

在这里插入图片描述

转账接口读取到了支付接口修改的数据,最终转账成功。而支付接口支付失败,但是张三还是少了1100

在这里插入图片描述

http://www.hkea.cn/news/366816/

相关文章:

  • 最新政府网站建设理念广州头条新闻最新
  • 济宁网站建设神华线上推广的三种方式
  • 我要表白网站在线制作如何做网站的教程
  • 福州论坛建站模板策划网络营销活动
  • 网站建设 天津百度市场应用官方app
  • 动态网站制作流程友情链接的定义
  • 企业网站开发方案免费建立一个网站
  • 网站引导页面制作的四个任务名称推广引流的10个渠道
  • 南宁网站建设制作后台网站关键词优化价格
  • 微信小程序商城制作公司宁波seo推广服务
  • 响应式购物网站公司seo是什么意思
  • 360未经证实的网站如何做电商运营方案
  • 网站建设类公司排名营销方案范文100例
  • 郑州网站设计 郑州网站开发网络优化有前途吗
  • 黑河做网站首页关键词排名优化
  • 网站二级域名怎么解析公司网络搭建
  • wordpress做网店win10优化大师是官方的吗
  • 弄个做网站公司产品宣传
  • 商品房建设信息网站googleplay商店
  • 菏泽 网站建设优化工具箱
  • 网站建设找哪家公司百度搜索热度
  • 网页设计论文引言北海百度seo
  • 网站空间哪家做的好网络营销的常用工具
  • 网站开发具体问题优化营商环境
  • wordpress4.5 火车头廊坊seo培训
  • 怎么做多个网站单点登录艺考培训
  • 网站怎么做双语种seo关键词如何设置
  • 用java做的游戏下载网站有哪些内容成都网络推广优化
  • 慈溪市网站建设google官网
  • 网站建设计划seo网站排名优化软件是什么