Spring AOP
- 概念部分：
- 代码实现部分：
-
- ①
- ②注解方式实现AOP：
- ③xml配置方式实现AOP
- ④事务回滚
- 异常：
概念部分：
代码实现部分：
①
代码整体布局：
运行结果：
代码部分：
IZuFuang :
package com.test1;
public interface IZuFuang {
void zf();
}
Master :
package com.test1;
public class Master implements IZuFuang{
@Override
public void zf() {
System.out.println("房东租房，800/月");
}
}
ZhongJie :
package com.test1;
public class ZhongJie implements IZuFuang{
private Master master;
public ZhongJie(Master master) {
this.master = master;
}
@Override
public void zf() {
System.out.println("收取20%的回扣");
this.master.zf();
}
}
Test :
package com.test1;
public class Test {
public static void main(String[] args) {
Master master=new Master();
ZhongJie zhongJie=new ZhongJie(master);
zhongJie.zf();
}
}
②注解方式实现AOP：
代码整体布局：
运行结果：
代码部分：
pom.xml:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>Aop_0914_SecondStage</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<name>Aop_0914_SecondStage Maven Webapp</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<servlet.version>4.0.1</servlet.version>
<jsp.version>2.2</jsp.version>
<jstl.version>1.2</jstl.version>
<spring.version>5.3.14</spring.version>
<commons-dbcp.version>1.4</commons-dbcp.version>
<mybatis.version>3.4.6</mybatis.version>
<mybatis-spring.version>1.3.3</mybatis-spring.version>
<mysql-connector-java.version>8.0.11</mysql-connector-java.version>
<fastjson.version>1.2.78</fastjson.version>
</properties>
<dependencies>
<!-- 添加javaEE支持 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>${servlet.version}</version>
<!-- provided只在编译时支持，发布时不拷贝文件 -->
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>${jsp.version}</version>
<!-- provided只在编译时支持，发布时不拷贝文件 -->
<scope>provided</scope>
</dependency>
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>${jstl.version}</version>
</dependency>
<!-- 引入spring基础模块 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<!--dbcp连接池 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>${commons-dbcp.version}</version>
</dependency>
<!--mybatis-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>
<!-- mybatis spring整合 -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>${mybatis-spring.version}</version>
</dependency>
<!-- mybatis插件PageHelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.1.0</version>
</dependency>
<!--通用mapper插件-->
<dependency>
<groupId>com.github.abel533</groupId>
<artifactId>mapper</artifactId>
<version>3.0.1</version>
</dependency>
<!-- mysql驱动类 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql-connector-java.version}</version>
</dependency>
<!-- fastjson处理json数据 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<!-- lombok 简化实体内容 -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.24</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.11.2</version>
</dependency>
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>javax.mail</artifactId>
<version>1.5.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.30</version>
</dependency>
<dependency>
<groupId>com.github.xuwei-k</groupId>
<artifactId>html2image</artifactId>
<version>0.1.0</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.9.8</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.25</version>
</dependency>
</dependencies>
</project>
spring.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
<bean id="userService" class="com.service.impl.UserServiceImpl"/>
<context:component-scan base-package="com.service.impl,com.advise"/>
<aop:aspectj-autoproxy proxy-target-class="true"/>
</beans>
LogAdvise :
package com.advise;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;
@Component
@Aspect
public class LogAdvise {
@Pointcut("execution(* com.service.impl.*.*(..))")
public void pc(){
}
//@Before("execution(* com.service.impl.*.*(..))")
@Before("pc()")
public void bf(){
System.out.println("前置通知：开始记录日志");
}
//@AfterThrowing("execution(* com.service.impl.*.*(..))")
@AfterThrowing("pc()")
public void af(){
System.out.println("后置通知：结束记录日志");
}
//@Around("execution(* com.service.impl.*.*(..))")
@Around("pc()")
public void hr(ProceedingJoinPoint jp) throws Throwable{
System.out.println("环绕通知：开始记录日志");
System.out.println("业务方法:"+jp.getSignature());
System.out.println("业务类："+jp.getTarget());
jp.proceed();
System.out.println("环绕通知：结束记录日志");
}
@AfterThrowing("pc()")
public void yc(){
System.out.println("异常通知:记录日志");
}
}
User :
package com.entity;
public class User {
private Integer userId;
private String userName;
}
IUserService :
package com.service;
import com.entity.User;
import java.util.List;
public interface IUserService {
List<User> list();
Integer insert(User user);
Integer update(User user);
Integer delete(Integer userId);
}
UserServiceImpl :
package com.service.impl;
import com.entity.User;
import com.service.IUserService;
import java.util.ArrayList;
import java.util.List;
public class UserServiceImpl implements IUserService {
@Override
public List<User> list() {
System.out.println("业务处理：查询业务");
return new ArrayList<>();
}
@Override
public Integer insert(User user) {
System.out.println("业务处理:插入业务");
return 1;
}
@Override
public Integer update(User user) {
System.out.println("业务处理：更新业务");
return 1;
}
@Override
public Integer delete(Integer userId) {
System.out.println("业务处理：删除业务");
return 1;
}
}
TestAop :
package com.test2;
import com.entity.User;
import com.service.IUserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class TestAop {
public static void main(String[] args) {
ApplicationContext ac=new ClassPathXmlApplicationContext("spring-1.xml");
//获取业务对象
//IUserService userService = ac.getBean(IUserService.class);
IUserService userService=(IUserService) ac.getBean("userService");
userService.list();
userService.update(new User());
userService.insert(new User());
}
}
③xml配置方式实现AOP
知识点：
代码整体布局：
运行结果：
添加代码部分（以②为基础）：
TestAop2 :
package com.test2;
import com.entity.User;
import com.service.IUserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class TestAop2 {
public static void main(String[] args) {
ApplicationContext ac=new ClassPathXmlApplicationContext("spring-2.xml");
//获取业务对象
IUserService userService = ac.getBean(IUserService.class);
userService.list();
userService.update(new User());
userService.insert(new User());
}
}
spring-2.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- 1.配置对象 -->
<bean id="userService" class="com.service.impl.UserServiceImpl"/>
<bean id="logAdvise" class="com.advise.LogAdvise"/>
<!-- 2.配置aop操作 -->
<aop:config>
<!-- 2.1 配置切入点 -->
<aop:pointcut id="p1" expression="execution(* com.service.impl.UserServiceImpl.*(..))"/>
<!-- 2.2配置切面 把增强应用到方法上的过程 ref:指定增强类 -->
<aop:aspect ref="logAdvise" >
<!-- 配置增强类型 method:增强类使用哪个方法作为增强-->
<!-- 前置通知 -->
<aop:before method="bf" pointcut-ref="p1"/>
<!-- 后置通知 -->
<aop:after method="af" pointcut-ref="p1"/>
<!-- 环绕通知 -->
<aop:around method="hr" pointcut-ref="p1"/>
</aop:aspect>
</aop:config>
</beans>
④事务回滚
代码/数据库整体布局：
运行结果：
test1：
test2:
test3:
test4:
代码部分 ：
数据库：
#创建数据库
create database 70915_db
default character set utf8mb4 #设置字符集
default collate utf8mb4_general_ci #设置排序规则
数据表：
#创建部门表
create table tbl_dept
(
dept_id int primary key auto_increment comment '部门编号',
dept_name varchar(20) comment '部门名字',
dept_desc varchar(200) comment '描述'
);
select * from tbl_dept;
insert into tbl_dept
(dept_name,dept_desc)
select '财务部','管钱的' union
select '后勤部','搞物业' union
select 'IT部门','编程序';
#创建角色表
create table tbl_role
(
role_id int primary key auto_increment comment '员工编号',
role_name varchar(20) comment '员工姓名',
role_desc varchar(200) comment '描述'
);
drop table tbl_role;
select * from tbl_role;
select * from tbl_dept;
insert into tbl_role
(role_name,role_desc)
select '张三','描述1' union
select '李四','描述2' union
select '王五','描述3' union
select '赵六','描述4';
pom.xml :
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>Aop_0914_SecondStage</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<name>Aop_0914_SecondStage Maven Webapp</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<servlet.version>4.0.1</servlet.version>
<jsp.version>2.2</jsp.version>
<jstl.version>1.2</jstl.version>
<spring.version>5.3.14</spring.version>
<commons-dbcp.version>1.4</commons-dbcp.version>
<mybatis.version>3.4.6</mybatis.version>
<mybatis-spring.version>1.3.3</mybatis-spring.version>
<mysql-connector-java.version>8.0.11</mysql-connector-java.version>
<fastjson.version>1.2.78</fastjson.version>
</properties>
<dependencies>
<!-- 添加javaEE支持 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>${servlet.version}</version>
<!-- provided只在编译时支持，发布时不拷贝文件 -->
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>${jsp.version}</version>
<!-- provided只在编译时支持，发布时不拷贝文件 -->
<scope>provided</scope>
</dependency>
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>${jstl.version}</version>
</dependency>
<!-- 引入spring基础模块 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<!--dbcp连接池 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>${commons-dbcp.version}</version>
</dependency>
<!--mybatis-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>
<!-- mybatis spring整合 -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>${mybatis-spring.version}</version>
</dependency>
<!-- mybatis插件PageHelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.1.0</version>
</dependency>
<!--通用mapper插件-->
<dependency>
<groupId>com.github.abel533</groupId>
<artifactId>mapper</artifactId>
<version>3.0.1</version>
</dependency>
<!-- mysql驱动类 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql-connector-java.version}</version>
</dependency>
<!-- fastjson处理json数据 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<!-- lombok 简化实体内容 -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.24</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.11.2</version>
</dependency>
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>javax.mail</artifactId>
<version>1.5.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.30</version>
</dependency>
<dependency>
<groupId>com.github.xuwei-k</groupId>
<artifactId>html2image</artifactId>
<version>0.1.0</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.9.8</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.slf4j</groupId>-->
<!-- <artifactId>slf4j-simple</artifactId>-->
<!-- <version>1.7.25</version>-->
<!-- </dependency>-->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.13.2.2</version>
</dependency>
<!--logback记录文件日志-->
<dependency>
<groupId>org.logback-extensions</groupId>
<artifactId>logback-ext-spring</artifactId>
<version>0.1.4</version>
</dependency>
<!--数据校验-->
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-validator</artifactId>
<version>6.1.0.Final</version>
</dependency>
<!--文件生成-->
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>3.17</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.17</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml-schemas -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml-schemas</artifactId>
<version>3.17</version>
</dependency>
<!--发送邮件-->
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>jakarta.mail</artifactId>
<version>1.6.7</version>
</dependency>
</dependencies>
</project>
db.properties:
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/70915_db?useSSL=false&serverTimezone=UTC&characterEncoding=utf8&allowPublicKeyRetrieval=true
jdbc.username=root
jdbc.password=123456
logback.xml:
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<!-- Where are log files
LOG_HOME: ./ 表示日志生成的文件创建在当前项目所在磁盘的根目录下
-->
<property name="LOG_HOME" value="./" />
<!-- Console log output -->
<appender name="Console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<!-- 格式化输出：%d:表示日期 %thread:表示线程名 %-5level:级别从左显示5个字符宽度-->
<pattern>%d{HH:mm:ss.SSS} [%thread] > %green(%-5level) %cyan(%logger{35}) - %m%n</pattern>
</encoder>
</appender>
<!-- Log file debug output -->
<appender name="File" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!--
<fileNamePattern>D:/logs/%d{yyyy-MM-dd}.log.zip</fileNamePattern>
-->
<fileNamePattern>/aaalogs/%d{yyyy-MM-dd}.aaa.log.zip</fileNamePattern>
<!--日志最大保存时间-->
<maxHistory>365</maxHistory>
</rollingPolicy>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} > %-5level %X{X-B3-TraceId:-} ${springAppName:-} %logger{35} %m%n</pattern>
</encoder>
</appender>
<!--debug:级别最高级别 开发
info: 信息
error:错误级别 项目上线
-->
<root level="info">
<appender-ref ref="Console"/>
<appender-ref ref="File"/>
</root>
</configuration>
mybatis-config.xml:
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<settings>
<!-- 配置日志工具 -->
<setting name="logImpl" value="SLF4J"/>
<!--配置将下划线字段转为小驼峰-->
<setting name="mapUnderscoreToCamelCase" value="true"/>
</settings>
<!--配置分页插件和通用Mapper插件-->
<plugins>
<!--拦截器-->
<plugin interceptor="com.github.pagehelper.PageInterceptor">
<property name="offsetAsPageNum" value="true"/>
<!--配置数据库方言 4.0版本以后不用写-->
<!--<property name="helperDialect" value="mysql"/>-->
<!--是否做count查询-->
<property name="rowBoundsWithCount" value="true"/>
<!--合理化分页-->
<property name="reasonable" value="true"/>
</plugin>
<plugin interceptor="com.github.abel533.mapperhelper.MapperInterceptor">
<!--主键自增回写方法,默认值MYSQL -->
<!--<property name="IDENTITY" value="MYSQL" />-->
<!--通用Mapper默认接口，我们定义的Mapper需要实现该接口 -->
<property name="mappers" value="com.github.abel533.mapper.Mapper" />
</plugin>
</plugins>
</configuration>
spring-mvc.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd">
<!--扫描controller包，管理其中定义的controller类-->
<context:component-scan base-package="com.aaa.hr.controller"/>
<!--启用注解方式配置 springMVC请求使用的相关组件
处理器映射器，处理器适配器，处理器(Controller...其他注解)
-->
<mvc:annotation-driven/>
<!--视图解析器-->
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<!--配置视图前缀-->
<property name="prefix" value="/WEB-INF/page/"/>
<!--配置视图后缀-->
<property name="suffix" value=".jsp"/>
</bean>
<!--配置拦截器集合-->
<mvc:interceptors>
<!--配置一个具体的拦截器-->
<mvc:interceptor>
<!--配置要拦截的请求地址-->
<mvc:mapping path="/**"/>
<!--配置要放行的请求-->
<mvc:exclude-mapping path="/index.jsp"/>
<mvc:exclude-mapping path="/forward/toLogin"/>
<mvc:exclude-mapping path="/emp/login"/>
<!--放行静态资源-->
<mvc:exclude-mapping path="/assets/**"/>
<mvc:exclude-mapping path="/assets/img/*.jpeg"/>
<!--配置拦截器类-->
<bean class="com.interceptor.LoginCheckInterceptor"/>
</mvc:interceptor>
</mvc:interceptors>
<!--配置DefaultServlet处理其他请求(静态资源)-->
<mvc:default-servlet-handler/>
</beans>
spring-mybatis.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
<!--配置spring扫描包-->
<context:component-scan base-package="com.service"/>
<!--通过spring配置数据库的连接属性文件-->
<context:property-placeholder location="classpath:db.properties"/>
<!--通过spring来配置数据库连接池的数据源对象-->
<bean id="ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<!--配置连接池数据源需要使用四大金刚(数据库连接属性)-->
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<!--通过spring来配置mybatis的会话工厂和其他相关配置
原来的时候，mybatis的会话工厂由程序员来创建，现在通过spring来创建管理
这个就体现了Spring的IoC特征(控制反转)
-->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<!--配置SqlSession依赖的数据源对象-->
<property name="dataSource" ref="ds"/>
<!--配置mybatis要使用的类型别名定义-->
<property name="typeAliasesPackage" value="com.entity"/>
<!--配置mybatis的主配置文件的路径,spring会自动加载mybatis的配置文件-->
<property name="configLocation" value="classpath:mybatis-config.xml"/>
<!--配置mybatis的Mapper文件的路径:spring中Mapper接口和Mapper文件路径可以由区别-->
<property name="mapperLocations" value="classpath:mapper/*.xml"/>
</bean>
<!--通过spring来配置Mybatis的Mapper接口
通过包扫描的方式进行配置
-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<!--配置Mybatis的Mapper接口-->
<property name="basePackage" value="com.mapper"/>
<!--配置可以创建Mapper接口对象的SqlSession使用的SqlSessionFactory对象的名字-->
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>
<!--配置spring的声明式事务
定义spring数据源的事务管理器
-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="ds"/>
</bean>
<!--配置spring事务增强-->
<tx:advice id="txAdvice" transaction-manager="dataSourceTransactionManager">
<tx:attributes>
<!--针对什么业务方法，什么样的异常进行回滚处理-->
<tx:method name="insert" rollback-for="java.lang.ArithmeticException"/>
</tx:attributes>
</tx:advice>
<!--配置aop，用于将切面和切入点关联起来-->
<aop:config proxy-target-class="true">
<!--配置切入点:目的是针对哪些业务方法进行事务管理-->
<aop:pointcut id="p1" expression="execution(* com.service.impl.*.*(..))"/>
<!--advisor是一种特殊的切面方式，能够将增强功能和切入点关联起来-->
<aop:advisor advice-ref="txAdvice" pointcut-ref="p1"/>
</aop:config>
<!--开启aop注解驱动-->
<aop:aspectj-autoproxy proxy-target-class="true"/>
</beans>
spring-mybatis2.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
<!--配置spring扫描包-->
<context:component-scan base-package="com.service"/>
<!--通过spring配置数据库的连接属性文件-->
<context:property-placeholder location="classpath:db.properties"/>
<!--通过spring来配置数据库连接池的数据源对象-->
<bean id="ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<!--配置连接池数据源需要使用四大金刚(数据库连接属性)-->
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<!--通过spring来配置mybatis的会话工厂和其他相关配置
原来的时候，mybatis的会话工厂由程序员来创建，现在通过spring来创建管理
这个就体现了Spring的IoC特征(控制反转)
-->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<!--配置SqlSession依赖的数据源对象-->
<property name="dataSource" ref="ds"/>
<!--配置mybatis要使用的类型别名定义-->
<property name="typeAliasesPackage" value="com.entity"/>
<!--配置mybatis的主配置文件的路径,spring会自动加载mybatis的配置文件-->
<property name="configLocation" value="classpath:mybatis-config.xml"/>
<!--配置mybatis的Mapper文件的路径:spring中Mapper接口和Mapper文件路径可以由区别-->
<property name="mapperLocations" value="classpath:mapper/*.xml"/>
</bean>
<!--通过spring来配置Mybatis的Mapper接口
通过包扫描的方式进行配置
-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<!--配置Mybatis的Mapper接口-->
<property name="basePackage" value="com.mapper"/>
<!--配置可以创建Mapper接口对象的SqlSession使用的SqlSessionFactory对象的名字-->
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>
<!--配置spring的声明式事务
定义spring数据源的事务管理器
-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="ds"/>
</bean>
<!--配置spring事务以注解驱动方式实现-->
<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
<!--开启aop注解驱动-->
<aop:aspectj-autoproxy proxy-target-class="true"/>
</beans>
Dept :
package com.entity;
import lombok.Data;
@Data
public class Dept {
private Integer deptId;
private String deptName;
private String deptDesc;
public Dept(){}
public Dept(String deptName,String deptDesc){
this.deptName=deptName;
this.deptDesc=deptDesc;
}
}
Role:
package com.entity;
import lombok.Data;
@Data
public class Role {
private Integer roleId;
private String roleName;
private String roleDesc;
public Role(){}
public Role(String roleName,String roleDesc){
this.roleName=roleName;
this.roleDesc=roleDesc;
}
}
DeptMapper :
package com.mapper;
import com.entity.Dept;
import org.apache.ibatis.annotations.Insert;
public interface DeptMapper {
@Insert("insert into tbl_dept(dept_name,dept_desc)values(#{deptName},#{deptDesc})")
Integer insert(Dept dept);
}
RoleMapper :
package com.mapper;
import com.entity.Role;
import org.apache.ibatis.annotations.Insert;
public interface RoleMapper {
@Insert("insert into tbl_role(role_name,role_desc) values(#{roleName},#{roleDesc})")
Integer insert(Role role);
}
IDeptService :
package com.service;
import com.entity.Dept;
public interface IDeptService {
Integer insert(Dept dept);
}
IRoleService :
package com.service;
import com.entity.Role;
public interface IRoleService {
Integer insert(Role role);
}
DeptServiceImpl :
package com.service.impl;
import com.entity.Dept;
import com.mapper.DeptMapper;
import com.service.IDeptService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
@Service
//REQUIRES_NEW:对于当前业务总是创建新的事务，不受外部事务的影响。
// 外部事务回滚不会影响当前事务。当前事务回滚同时会回滚外部事务
@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRES_NEW) //针对当前业务类进行事务管理
public class DeptServiceImpl implements IDeptService {
@Resource
private DeptMapper deptMapper;
@Override
public Integer insert(Dept dept) {
Integer count = deptMapper.insert(dept);
System.out.println(1/0);
return count;
}
}
RoleServiceImpl :
package com.service.impl;
import com.entity.Dept;
import com.entity.Role;
import com.mapper.RoleMapper;
import com.service.IDeptService;
import com.service.IRoleService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
@Service
@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
public class RoleServiceImpl implements IRoleService {
@Resource
private RoleMapper roleMapper;
@Resource
private IDeptService deptService;
@Override
public Integer insert(Role role) {
System.out.println("插入角色");
Integer count = roleMapper.insert(role);
System.out.println("插入部门");
deptService.insert(new Dept("d12","d12"));
System.out.println("插入完成");
return count;
}
}
Test1 :
package com.test3;
import com.entity.Dept;
import com.entity.Role;
import com.service.IDeptService;
import com.service.IRoleService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test1 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("spring-mybatis.xml");
IRoleService roleService = ac.getBean(IRoleService.class);
roleService.insert(new Role("r1","r1"));
IDeptService deptService = ac.getBean(IDeptService.class);
deptService.insert(new Dept("d1","d1"));
}
}
Test2 :
package com.test3;
import com.entity.Dept;
import com.service.IDeptService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test2 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("spring-mybatis.xml");
IDeptService deptService = ac.getBean(IDeptService.class);
//此时已经针对业务方法配置spring事务，我们要观察当业务方法出错时，业务处理是否回滚
deptService.insert(new Dept("d3","d3"));
}
}
Test3 :
package com.test3;
import com.entity.Dept;
import com.service.IDeptService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test3 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("spring-mybatis2.xml");
IDeptService deptService = ac.getBean(IDeptService.class);
//此时已经针对业务方法配置spring事务，我们要观察当业务方法出错时，业务处理是否回滚
deptService.insert(new Dept("d5","d5"));
}
}
Test4 :
package com.test3;
import com.entity.Role;
import com.service.IRoleService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test4 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("spring-mybatis2.xml");
//事务传播特性
IRoleService ro = ac.getBean(IRoleService.class);
ro.insert(new Role("r12","r12"));
}
}
异常：
①SLF4J: Class path contains multiple SLF4J bindings.
参考：SLF4J: Class path contains multiple SLF4J bindings.错误解决https://blog.csdn.net/weixin_42181264/article/details/112168270
以上说明这是maven问题，两者冲突，找到目标所在文件，删除其中一个就好。
解决：
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/118034.html
