AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

130.【Spring注解_AOP】（二）

2023-09-25 98
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS PostgreSQL，高可用系列 2核4GB
云数据库 RDS MySQL，高可用系列 2核4GB
简介： 130.【Spring注解_AOP】

(三)、声明式事务

1.声明式事务 - 环境搭建

(1).导入依赖
<!--    Spring包  ->IOC  -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.12.RELEASE</version>
        </dependency>
                <!--     C3P0数据包 ->数据源  -->
        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <!--    Spring切面的包   ->aop -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>4.3.12.RELEASE</version>
        </dependency>
        <!--    Spring-JDBC -> jdbcTemplate   -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>4.3.12.RELEASE</version>
        </dependency>
(2).实体类和业务层

1.实体类

package com.jsxs.bean;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:27
 * @PackageName:com.jsxs.bean
 * @ClassName: Admin
 * @Description: TODO
 * @Version 1.0
 */
public class Admin {
    private int id;
    private String name;
    private String password;
    public Admin() {
    }
    public Admin(int id, String name, String password) {
        this.id = id;
        this.name = name;
        this.password = password;
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    @Override
    public String toString() {
        return "Admin{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", password='" + password + '\'' +
                '}';
    }
}

2.Dao层：

package com.jsxs.mapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import javax.annotation.Resource;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:28
 * @PackageName:com.jsxs.mapper
 * @ClassName: AdminMapper
 * @Description: TODO
 * @Version 1.0
 */
@Repository
public class AdminMapper {
    @Resource
    private JdbcTemplate jdbcTemplate;
    public void add(){
        String sql="insert into admin(name,password) values(?,?)";
        int i = jdbcTemplate.update(sql,222,222);  // 后面的是参数也就是占位符，占位符有几个，参数也就有几个
        if (i>0){
            System.out.println("添加数据成功!!");
        }else {
            System.out.println("添加数据失败!!");
        }
    }
}

3.业务层

package com.jsxs.service;
import com.jsxs.mapper.AdminMapper;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:30
 * @PackageName:com.jsxs.service
 * @ClassName: AdminServer
 * @Description: TODO
 * @Version 1.0
 */
@Service
public class AdminServer {
    @Resource
    AdminMapper adminMapper;
    public void insert(){
        adminMapper.add();
    }
}

4.配置类

package com.jsxs.tx;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
import java.beans.PropertyVetoException;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:06
 * @PackageName:com.jsxs.tx
 * @ClassName: TxConfig
 * @Description: TODO  声明式事务
 * 1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate)
 * 2.配置数据源，JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库
 * @Version 1.0
 */
@Configuration
@ComponentScan(value = "com.jsxs")
@PropertySource(value = "classpath:db.properties")
public class TxConfig {
    // 1.配置我们的数据源
    @Bean
    public DataSource dataSource() throws PropertyVetoException {
        // 1.1.c3p0数据源
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1");
        dataSource.setUser("root");
        dataSource.setPassword("121788");
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        return dataSource;
    }
    // 2.我们设置JDBC的模板，又因为这个模板需要数据源，所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的，所以我们直接设置成参数即可。
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        return new JdbcTemplate(dataSource);
    }
}

5.测试

package com.jsxs.Test;
import com.jsxs.service.AdminServer;
import com.jsxs.tx.TxConfig;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:45
 * @PackageName:com.jsxs.Test
 * @ClassName: AOP_TX
 * @Description: TODO
 * @Version 1.0
 */
public class AOP_TX {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class);
        for (String beanDefinitionName : applicationContext.getBeanDefinitionNames()) {
            System.out.println(beanDefinitionName);
        }
        AdminServer server = applicationContext.getBean(AdminServer.class);
        server.insert();
    }
}

2.声明式事务 - 测试成功

(1).遇见问题
*                      1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate)
 *                      2.配置数据源，JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库
 *                 ⭐     3.给方法上标注@Transactional 表示当前方法是一个事务方法.
 *                 ⭐    4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务
 *                 ⭐     5.添加PlatformTransactionManager这个组件

我们在插入的方法中故意设置一个异常的操作，然后我们执行这个方法但是我们发现我们并不会发生事务回滚(即 失败都失败，成功都成功!);

(2).解决问题 -> 事务型(成功全成功_失败全失败)
package com.jsxs.service;
import com.jsxs.mapper.AdminMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:30
 * @PackageName:com.jsxs.service
 * @ClassName: AdminServer
 * @Description: TODO
 * @Version 1.0
 */
@Service
public class AdminServer {
    @Resource
    AdminMapper adminMapper;
    @Transactional  // 声明标注事务的注解⭐
    public void insert(){
        adminMapper.add();
        // 2.故意制造异常 ⭐⭐
        System.out.println(1/0);
    }
}
  1. 基于XML文件的

  1. 基于注解

1.业务层添加上事务注解

package com.jsxs.service;
import com.jsxs.mapper.AdminMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:30
 * @PackageName:com.jsxs.service
 * @ClassName: AdminServer
 * @Description: TODO
 * @Version 1.0
 */
@Service
public class AdminServer {
    @Resource
    AdminMapper adminMapper;
    @Transactional
    public void insert(){
        adminMapper.add();
        System.out.println(1/0);
    }
}

2.需要在配置类上开启注解支持

package com.jsxs.tx;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
import java.beans.PropertyVetoException;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:06
 * @PackageName:com.jsxs.tx
 * @ClassName: TxConfig
 * @Description: TODO  声明式事务
 *                      1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate)
 *                      2.配置数据源，JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库
 *                      3.给方法上标注@Transactional 表示当前方法是一个事务方法.
 *                      4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务
 * @Version 1.0
 */
@Configuration
@ComponentScan(value = "com.jsxs")
@PropertySource(value = "classpath:db.properties")
@EnableTransactionManagement  ⭐
public class TxConfig {
    // 1.配置我们的数据源
    @Bean
    public DataSource dataSource() throws PropertyVetoException {
        // 1.1.c3p0数据源
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1");
        dataSource.setUser("root");
        dataSource.setPassword("121788");
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        return dataSource;
    }
    // 2.我们设置JDBC的模板，又因为这个模板需要数据源，所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的，所以我们直接设置成参数即可。
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        return new JdbcTemplate(dataSource);
    }
}

3.进行测试的操作

package com.jsxs.Test;
import com.jsxs.service.AdminServer;
import com.jsxs.tx.TxConfig;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:45
 * @PackageName:com.jsxs.Test
 * @ClassName: AOP_TX
 * @Description: TODO
 * @Version 1.0
 */
public class AOP_TX {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class);
        for (String beanDefinitionName : applicationContext.getBeanDefinitionNames()) {
            System.out.println(beanDefinitionName);
        }
        AdminServer server = applicationContext.getBean(AdminServer.class);
        server.insert();
    }
}

4.结果我们发现缺少一个组件 PlatformTransactionManager

5. 给IOC容器中添加这个组件

package com.jsxs.tx;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jca.cci.connection.CciLocalTransactionManager;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
import java.beans.PropertyVetoException;
/**
 * @Author Jsxs
 * @Date 2023/8/22 14:06
 * @PackageName:com.jsxs.tx
 * @ClassName: TxConfig
 * @Description: TODO  声明式事务
 *                      1. 导入相关依赖 : 数据源、数据库驱动、Spring-JDBC->(提供了JDBCTemplate)
 *                      2.配置数据源，JDBCTemplate(Spring提供的简化数据库操作的工具)操作数据库
 *                      3.给方法上标注@Transactional 表示当前方法是一个事务方法.
 *                      4.@EnableTransactionManagement 需要放在配置类进行开启注解的事务
 *                      5.添加PlatformTransactionManager这个组件
 * @Version 1.0
 */
@Configuration
@ComponentScan(value = "com.jsxs")
@PropertySource(value = "classpath:db.properties")
@EnableTransactionManagement  // ⭐
public class TxConfig {
    // 1.配置我们的数据源
    @Bean
    public DataSource dataSource() throws PropertyVetoException {
        // 1.1.c3p0数据源
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/demo1");
        dataSource.setUser("root");
        dataSource.setPassword("121788");
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        return dataSource;
    }
    // 2.我们设置JDBC的模板，又因为这个模板需要数据源，所以我们要存放我们的数据源。又因为在配置类中的参数是先从IOC容器中拿取的，所以我们直接设置成参数即可。
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        return new JdbcTemplate(dataSource);
    }
    @Bean  // 在配置类中的@Bean注解的方法参数，参数默认是从IOC容器中赋值的 ⭐⭐
    public PlatformTransactionManager platformTransactionManager(DataSource dataSource){
        return new DataSourceTransactionManager(dataSource);
    }
}

3.声明式事务原理

*   2.事务原理
 *                      (1).@EnableTransactionManagement
 *                              利用 TransactionManagementConfigurationSelector 给容器中会导入批量组件
 *                              导入两个组件
 *                                  (1).AutoProxyRegistrar (2).ProxyTransactionManagementConfiguration
 *                      (2).细聊 AutoProxyRegistrar
 *                              给容器中注入一个组件，利用后置处理器机制在对象创建以后，包装对象，返回一个代理对象(增强器)，代理方法执行方法利用拦截器链进行调用
 *
 *                      (3).细聊 ProxyTransactionManagementConfiguration
 *                              1.给事务注册一个事务增强器->事务增强器要用事务注解的信息
 *                              2.事务拦截器
 *                                  (1).先获取事务相关的属性
 *                                  (2).在获取PlatformTransactionManager,如果事务先没有添加指定任何
 *                                      最终会从容器中按照类型获取一个PlateFormTransactionManager;
 *                                  (3).执行目标方法
 *                                      如果异常，获取到事务管理器，利用事务管理回滚操作
 *                                      如果正常，利用事务管理器，提交事务控制

文章标签：
云数据库 RDS MySQL 版
Java
Spring
容器
数据格式
XML
关键词：
Spring注解
注解aop
Spring注解aop
Spring AOP
aop注解
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
吉士先生
目录
相关文章
varin
|
12天前
|
缓存 监控 Java
SpringBoot @Scheduled 注解详解
使用`@Scheduled`注解实现方法周期性执行，支持固定间隔、延迟或Cron表达式触发，基于Spring Task，适用于日志清理、数据同步等定时任务场景。需启用`@EnableScheduling`，注意线程阻塞与分布式重复问题，推荐结合`@Async`异步处理，提升任务调度效率。
varin
274 127
HELLO程序员
|
27天前
|
XML 安全 Java
使用 Spring 的 @Aspect 和 @Pointcut 注解简化面向方面的编程 (AOP)
面向方面编程（AOP）通过分离横切关注点，如日志、安全和事务，提升代码模块化与可维护性。Spring 提供了对 AOP 的强大支持，核心注解 `@Aspect` 和 `@Pointcut` 使得定义切面与切入点变得简洁直观。`@Aspect` 标记切面类，集中处理通用逻辑；`@Pointcut` 则通过表达式定义通知的应用位置，提高代码可读性与复用性。二者结合，使开发者能清晰划分业务逻辑与辅助功能，简化维护并提升系统灵活性。Spring AOP 借助代理机制实现运行时织入，与 Spring 容器无缝集成，支持依赖注入与声明式配置，是构建清晰、高内聚应用的理想选择。
HELLO程序员
271 0
HELLO程序员
|
1月前
|
Java 测试技术 API
将 Spring 的 @Embedded 和 @Embeddable 注解与 JPA 结合使用的指南
Spring的@Embedded和@Embeddable注解简化了JPA中复杂对象的管理，允许将对象直接嵌入实体，减少冗余表与连接操作，提升数据库设计效率。本文详解其用法、优势及适用场景。
HELLO程序员
214 126
蓝易云
|
14天前
|
XML Java 数据格式
常用SpringBoot注解汇总与用法说明
这些注解的使用和组合是Spring Boot快速开发和微服务实现的基础，通过它们，可以有效地指导Spring容器进行类发现、自动装配、配置、代理和管理等核心功能。开发者应当根据项目实际需求，运用这些注解来优化代码结构和服务逻辑。
蓝易云
111 12
HELLO程序员
|
26天前
|
Java 测试技术 数据库
使用Spring的@Retryable注解进行自动重试
在现代软件开发中，容错性和弹性至关重要。Spring框架提供的`@Retryable`注解为处理瞬时故障提供了一种声明式、可配置的重试机制，使开发者能够以简洁的方式增强应用的自我恢复能力。本文深入解析了`@Retryable`的使用方法及其参数配置，并结合`@Recover`实现失败回退策略，帮助构建更健壮、可靠的应用程序。
HELLO程序员
106 1
使用Spring的@Retryable注解进行自动重试
HELLO程序员
|
26天前
|
传感器 Java 数据库
探索Spring Boot的@Conditional注解的上下文配置
Spring Boot 的 `@Conditional` 注解可根据不同条件动态控制 Bean 的加载，提升应用的灵活性与可配置性。本文深入解析其用法与优势，并结合实例展示如何通过自定义条件类实现环境适配的智能配置。
HELLO程序员
77 0
探索Spring Boot的@Conditional注解的上下文配置
HELLO程序员
|
26天前
|
智能设计 Java 测试技术
Spring中最大化@Lazy注解，实现资源高效利用
本文深入探讨了 Spring 框架中的 `@Lazy` 注解，介绍了其在资源管理和性能优化中的作用。通过延迟初始化 Bean，`@Lazy` 可显著提升应用启动速度，合理利用系统资源，并增强对 Bean 生命周期的控制。文章还分析了 `@Lazy` 的工作机制、使用场景、最佳实践以及常见陷阱与解决方案，帮助开发者更高效地构建可扩展、高性能的 Spring 应用程序。
HELLO程序员
50 0
Spring中最大化@Lazy注解，实现资源高效利用
HELLO程序员
|
27天前
|
安全 IDE Java
Spring 的@FieldDefaults和@Data：Lombok 注解以实现更简洁的代码
本文介绍了如何在 Spring 应用程序中使用 Project Lombok 的 `@Data` 和 `@FieldDefaults` 注解来减少样板代码，提升代码可读性和可维护性，并探讨了其适用场景与限制。
HELLO程序员
82 0
Spring 的@FieldDefaults和@Data：Lombok 注解以实现更简洁的代码
HELLO程序员
|
27天前
|
缓存 监控 安全
Spring Boot 的执行器注解：@Endpoint、@ReadOperation 等
Spring Boot Actuator 提供多种生产就绪功能，帮助开发者监控和管理应用。通过注解如 `@Endpoint`、`@ReadOperation` 等，可轻松创建自定义端点，实现健康检查、指标收集、环境信息查看等功能，提升应用的可观测性与可管理性。
HELLO程序员
88 0
Spring Boot 的执行器注解：@Endpoint、@ReadOperation 等

热门文章

最新文章

  • 1
    【Spring】原理解析：Spring Boot 自动配置
  • 2
    基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
  • 3
    spring boot2升级boot3指南
  • 4
    微服务配置管理：Spring Cloud Config 实践指南
  • 5
    Spring Boot四层架构深度解析
  • 6
    使用 Spring 的 @Aspect 和 @Pointcut 注解简化面向方面的编程 (AOP)
  • 7
    Spring 微服务和多租户：处理多个客户端
  • 8
    SpringBoot @Scheduled 注解详解
  • 9
    【Spring】原理：Bean的作用域与生命周期
  • 10
    构建基于Java的AI智能体：使用LangChain4j与Spring AI实现RAG应用
  • 1
    构建企业级AI智能体（Spring AI Alibaba + JManus实战）
    1167
  • 2
    京东二面：说下spring中常用的设计模式？ （一个 深入骨髓的答案， 面试官跪下了）
    311
  • 3
    基于Java 17 + Spring Boot 3.2 + Flink 1.18的智慧实验室管理系统核心代码
    262
  • 4
    Spring boot 使用mybatis generator 自动生成代码插件
    639
  • 5
    Java 21 与 Spring Boot 3.2 微服务开发从入门到精通实操指南
    424
  • 6
    Spring Boot 3.x 现代化应用开发实战技巧与最佳实践
    372
  • 7
    Spring AI Alibaba 1.0 GA 正式发布，Java 智能体开发进入新时代
    1667
  • 8
    📨 Spring Boot 3 整合 MQ 构建聊天消息存储系统
    395
  • 9
    Spring Boot 项目实操入门完整教程
    1085
  • 10
    Spring AI Alibaba 1.0 GA 正式发布，Java智能体开发进入新时代
    1021

    • 相关课程

    更多
  • 全面讲解Spring Cloud Alibaba技术栈（知识精讲+项目实战）第四阶段
  • 精通Spring Cloud Alibaba
  • 微服务框架 Spring Cloud 快速入门
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库
    • 下一篇
    阿里云免费云服务器:个人用户每月750小时免费