Spring_four

2020-12-13 04:52

阅读：411

标签：mono 编程 activemq strong toc initial 解决方案资源分层

Spring_four

基于XML的AOP实现事务控制

坐标xml



 
 org.springframework
 spring-context
 5.0.2.RELEASE
 
 
 org.springframework
 spring-test
 5.0.2.RELEASE
 
 
 commons-dbutils
 commons-dbutils
 1.4
 

 
 mysql
 mysql-connector-java
 5.1.6
 

 
 c3p0
 c3p0
 0.9.1.2
 

 
 junit
 junit
 4.12
 

 
 org.aspectj
 aspectjweaver
 1.8.7

技术图片

删除AccountServiceTest测试类上的@Qualifier的注解，不产生代理对象


/**
* 使用Junit单元测试：测试我们的配置
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class AccountServiceTest {

 @Autowired
 private AccountService as;

 @Test
 public void testTransfer(){
        as.transfer("aaa","bbb",100f);
 }

}

此时事务没有控制住

【配置文件】添加spring的aop

applicationContext.xml


xml version="1.0" encoding="UTF-8"?>
xmlns="http://www.springframework.org/schema/beans"
 xmlns:aop="http://www.springframework.org/schema/aop"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">

 
 id="accountService" class="com.it.service.impl.AccountServiceImpl">
 
 name="accountDao" ref="accountDao">
 
 

 
 id="accountDao" class="com.it.dao.impl.AccountDaoImpl">
 
 name="runner" ref="runner">
 
 name="connectionUtils" ref="connectionUtils">
 

 
 id="runner" class="org.apache.commons.dbutils.QueryRunner" scope="prototype">
 
 

 
 id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
 
 name="driverClass" value="com.mysql.jdbc.Driver">
 name="jdbcUrl" value="jdbc:mysql://localhost:3306/itcastspring">
 name="user" value="root">
 name="password" value="root">
 

 
 id="connectionUtils" class="com.it.utils.ConnectionUtils">
 
 name="dataSource" ref="dataSource">
 

 
 id="txManager" class="com.it.utils.TransactionManager">
 
 name="connectionUtils" ref="connectionUtils">
 

 
 id="pc" expression="execution(* com.it.service..*.*(..))">
 ref="txManager">
 
 method="beginTransaction" pointcut-ref="pc">
 
 method="commitTransaction" pointcut-ref="pc">
 
 method="rollbackTransaction" pointcut-ref="pc">
 
 method="closeTransaction" pointcut-ref="pc">

【注解】添加spring的aop

可以使用【前置通知】、【后置通知】、【异常通知】、【最终通知】

坐标



 
 org.springframework
 spring-context
 5.0.2.RELEASE
 
 
 org.springframework
 spring-test
 5.0.2.RELEASE
 
 
 commons-dbutils
 commons-dbutils
 1.4
 

 
 mysql
 mysql-connector-java
 5.1.6
 

 
 c3p0
 c3p0
 0.9.1.2
 

 
 junit
 junit
 4.12
 
 
 org.aspectj
 aspectjweaver
 1.8.7

配置AccountServiceImpl.java的注解


@Service
public class AccountServiceImpl implements AccountService {

 @Autowired
 private AccountDao accountDao;
}

配置AccountDaoImpl.java的注解


@Repository
public class AccountDaoImpl implements AccountDao {

 @Autowired
 private QueryRunner runner;
 @Autowired
 private ConnectionUtils connectionUtils;
}

配置ConnectionUtils.java的注解


@Component
public class ConnectionUtils {

 private ThreadLocalConnection> tl = new ThreadLocalConnection>();

 @Autowired
 private DataSource dataSource;
}

配置TransactionManager.java的注解


@Component
@Aspect // 切面
public class TransactionManager {

 @Autowired
 private ConnectionUtils connectionUtils;

 @Pointcut(value = "execution(* com.it.service..*.*(..))") // 切入点
 public void pc(){};

 /**
     * 开启事务
     */
 @Before(value = "pc()")
 public void beginTransaction(){
 try {
 System.out.println("前置通知");
            connectionUtils.getThreadConnection().setAutoCommit(false);
 }catch (Exception e){
            e.printStackTrace();
 }
 }

 /**
     * 提交事务
     */
 @AfterReturning(value = "pc()")
 public void commit(){
 try {
 System.out.println("后置通知");
            connectionUtils.getThreadConnection().commit();
 }catch (Exception e){
            e.printStackTrace();
 }
 }

 /**
     * 回滚事务
     */
 @AfterThrowing(value = "pc()")
 public void rollback(){
 try {
 System.out.println("异常通知");
            connectionUtils.getThreadConnection().rollback();
 }catch (Exception e){
            e.printStackTrace();
 }
 }


 /**
     * 释放连接
     */
 @After(value = "pc()")
 public void release(){
 try {
 System.out.println("最终通知");
            connectionUtils.getThreadConnection().close();//把连接还回连接池中
            connectionUtils.removeConnection();
 }catch (Exception e){
            e.printStackTrace();
 }
 }
}

配置spring容器

配置applicationContext.xml


xml version="1.0" encoding="UTF-8"?>
xmlns="http://www.springframework.org/schema/beans"
 xmlns:aop="http://www.springframework.org/schema/aop"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">
 
 base-package="com.it">
 
 

 
 id="runner" class="org.apache.commons.dbutils.QueryRunner" scope="prototype">
 
 

 
 id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
 
 name="driverClass" value="com.mysql.jdbc.Driver">
 name="jdbcUrl" value="jdbc:mysql://localhost:3306/itcastspring">
 name="user" value="root">
 name="password" value="root">

text


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class AccountServiceTest {

 @Autowired
 private AccountService as;

 @Test
 public void testTransfer(){
        as.transfer("aaa","bbb",100f);
 }

}

但是发现，抛出异常。

技术图片

因为注解的方式执行顺序是【前置通知】、【最终通知】、【异常通知】/【后置通知】

技术图片

我们需要使用环绕通知解决问题。

配置TransactionManager.java


@Component
@Aspect
public class TransactionManager {

 @Autowired
 private ConnectionUtils connectionUtils;

 @Pointcut(value = "execution(* com.it.service..*.*(..))")
 public void pc(){};

 /**
     * 开启事务
     */
 //@Before(value = "pc()")
 public void beginTransaction(){
 try {
 System.out.println("前置通知");
            connectionUtils.getThreadConnection().setAutoCommit(false);
 }catch (Exception e){
            e.printStackTrace();
 }
 }

 /**
     * 提交事务
     */
 //@AfterReturning(value = "pc()")
 public void commit(){
 try {
 System.out.println("后置通知");
            connectionUtils.getThreadConnection().commit();
 }catch (Exception e){
            e.printStackTrace();
 }
 }

 /**
     * 回滚事务
     */
 //@AfterThrowing(value = "pc()")
 public void rollback(){
 try {
 System.out.println("异常通知");
            connectionUtils.getThreadConnection().rollback();
 }catch (Exception e){
            e.printStackTrace();
 }
 }


 /**
     * 释放连接
     */
 //@After(value = "pc()")
 public void release(){
 try {
 System.out.println("最终通知");
            connectionUtils.getThreadConnection().close();//把连接还回连接池中
            connectionUtils.removeConnection();
 }catch (Exception e){
            e.printStackTrace();
 }
 }

 @Around(value="pc()")
 public Object around(ProceedingJoinPoint joinPoint){
 Object returnValue = null;
 try {
 this.beginTransaction(); // 开启事务
            returnValue = joinPoint.proceed(joinPoint.getArgs());
 this.commit(); // 提交事务
 } catch (Throwable throwable) {
            throwable.printStackTrace();
 this.rollback(); // 回滚事务
 }
 finally {
 this.release(); // 释放资源
 }
 return returnValue;
 }
}

Spring中的JdbcTemplate

1\dbcTemplate概述

它是spring框架中提供的一个对象，是对原始Jdbc API对象的简单封装。spring框架为我们提供了很多的操作模板类。

操作关系型数据的：

JdbcTemplate （操作JDBC，操作数据库）

HibernateTemplate （操作hibernate，操作数据库）

操作nosql数据库的： RedisTemplate（操作Redis，非关系型数据库）

操作消息队列（MQ）的： JmsTemplate （操作ActiveMQ，消息队列）

* 短信平台

* 邮件平台

操作索引库的：ElasticSearchTemplate（操作ElasticSearch，全文检索）

我们今天的主角在spring-jdbc-5.0.2.RELEASE.jar中，我们在导包的时候，除了要导入这个jar包外，还需要导入一个spring-tx-5.0.2.RELEASE.jar（它是和事务相关的）。

坐标xml



 
 org.springframework
 spring-context
 5.0.2.RELEASE
 

 
 org.springframework
 spring-jdbc
 5.0.2.RELEASE
 

 
 org.springframework
 spring-tx
 5.0.2.RELEASE
 

 
 mysql
 mysql-connector-java
 5.1.6

创建类Account.java


/**
* 账户的实体类
*/
public class Account implements Serializable {

 private Integer id;
 private String name;
 private Float money;
}

创建类JdbcTemplateDemo1.java

使用spring提供的数据源


/**
* JdbcTemplate的最基本用法
*/
public class JdbcTemplateDemo1 {

 public static void main(String[] args) {
 //准备数据源：spring的内置数据源
 DriverManagerDataSource ds = new DriverManagerDataSource();
        ds.setDriverClassName("com.mysql.jdbc.Driver");
        ds.setUrl("jdbc:mysql://localhost:3306/itcastspring");
        ds.setUsername("root");

上一篇：windows server 2008 r2 无线服务

下一篇：查看windosw服务器序列号，型号

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：Spring_four
文章链接：http://soscw.com/essay/30176.html

亲，登录后才可以留言！

Spring_four

Spring_four

基于XML的AOP实现事务控制

【配置文件】添加spring的aop

【注解】添加spring的aop

Spring中的JdbcTemplate

1\dbcTemplate概述

评论

热门文章

推荐文章

最新文章

置顶文章