成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

MyBatis在Spring環(huán)境下的事務(wù)管理

joywek / 572人閱讀

摘要:對(duì)于第二個(gè)問題,本文將嘗試通過分析源代碼和實(shí)驗(yàn)找到它的,主要涉及到以下內(nèi)容問題描述與分析在環(huán)境下的載入過程在環(huán)境下事務(wù)的管理實(shí)驗(yàn)驗(yàn)證項(xiàng)目環(huán)境整個(gè)系統(tǒng)是微服務(wù)架構(gòu),這里討論的項(xiàng)目是指一個(gè)多帶帶的服務(wù)。

MyBatis的設(shè)計(jì)思想很簡(jiǎn)單,可以看做是對(duì)JDBC的一次封裝,并提供強(qiáng)大的動(dòng)態(tài)SQL映射功能。但是由于它本身也有一些緩存、事務(wù)管理等功能,所以實(shí)際使用中還是會(huì)碰到一些問題——另外,最近接觸了JFinal,其思想和Hibernate類似,但要更簡(jiǎn)潔,和MyBatis的設(shè)計(jì)思想不同,但有一點(diǎn)相同:都是想通過簡(jiǎn)潔的設(shè)計(jì)最大限度地簡(jiǎn)化開發(fā)和提升性能——說到性能,前段時(shí)間碰到兩個(gè)問題:

在一個(gè)上層方法(DAO方法的上層)內(nèi)刪除一條記錄,然后再插入一條相同主鍵的記錄時(shí),會(huì)報(bào)主鍵沖突的錯(cuò)誤。

某些項(xiàng)目中的DAO方法平均執(zhí)行時(shí)間會(huì)是其他一些項(xiàng)目中的 2倍 。

第一個(gè)問題是偶爾會(huì)出現(xiàn),在實(shí)驗(yàn)環(huán)境無論如何也重現(xiàn)不了,經(jīng)過分析MyBatis的邏輯,估計(jì)是兩個(gè)DAO分別拿到了兩個(gè)不同的Connection,第二個(gè)語句比第一個(gè)更早的被提交,導(dǎo)致了主鍵沖突,有待進(jìn)一步的分析和驗(yàn)證。對(duì)于第二個(gè)問題,本文將嘗試通過分析源代碼和實(shí)驗(yàn)找到它的root cause,主要涉及到以下內(nèi)容:

問題描述與分析

MyBatis在Spring環(huán)境下的載入過程

MyBatis在Spring環(huán)境下事務(wù)的管理

實(shí)驗(yàn)驗(yàn)證

項(xiàng)目環(huán)境

整個(gè)系統(tǒng)是微服務(wù)架構(gòu),這里討論的「項(xiàng)目」是指一個(gè)多帶帶的服務(wù)。單個(gè)項(xiàng)目的框架基本是Spring+MyBatis,具體版本如下:

Spring 3.2.9/4.3.5 + Mybatis 3.2.6 + mybatis-spring 1.2.2 + mysql connector 5.1.20 + commons-dbcp 1.4

與MyBatis和事務(wù)相關(guān)的配置如下:

//代碼1

 
        
        
         //在這里設(shè)置是否自動(dòng)提交
        
  

  
        
        
  

  
        
  

  
        
        
  
 
  
問題描述與分析

一倍的時(shí)間差挺嚴(yán)重的,平均到每次調(diào)用,正常的大約在6到10幾 ms,慢的要近20 ms,由于調(diào)用次數(shù)很多,導(dǎo)致整體性能會(huì)有很大的差別。經(jīng)過仔細(xì)比對(duì)這幾個(gè)項(xiàng)目,發(fā)現(xiàn)DAO執(zhí)行慢的項(xiàng)目的數(shù)據(jù)源配置(bean#1)中 defaultAutoCommit的配置都是 false。而且將此配置改為 true之后就恢復(fù)了正常。

由此推斷是在MyBatis在執(zhí)行「非自動(dòng)提交」語句時(shí),進(jìn)行等待,或者多提交了一次,導(dǎo)致實(shí)際調(diào)用數(shù)據(jù)庫(kù)API次數(shù)增多。但是這個(gè)推斷也有個(gè)問題,由于整個(gè)項(xiàng)目是在Spring環(huán)境中運(yùn)行的,而且也開啟了Spring的事務(wù)管理,所以還是需要詳細(xì)的看一下MyBatis到底是如何裝配DAO方法與管理事務(wù)的,才能徹底解開謎團(tuán)。

問題重現(xiàn)

首先寫一個(gè)Service,其中調(diào)用了同一個(gè)mapper類的兩個(gè)方法分別2次, insertModelList()會(huì)在數(shù)據(jù)庫(kù)中插入兩條記錄, delModels()方法會(huì)刪除這兩條記錄,代碼如下:

//代碼2
//@Transactional
public void testIS(){
    List models= new ArrayList<>();
    //省略一些數(shù)據(jù)工作。。。
    modelMapper.insertModelList(50001l, models);
    modelMapper.delModels(50001);
    if (CollectionUtils.isNotEmpty(models))
        modelMapper.insertModelList(50001, models);
    modelMapper.delModels(50001);
}
public void testOther(){
    System.out.println("加載類:");
    System.out.println(modelMapper.getClass().getClassLoader());
    modelMapper.delModels(50001);
}

實(shí)際項(xiàng)目中使用cat來進(jìn)行執(zhí)行時(shí)間的統(tǒng)計(jì),這里也仿照cat,使用一個(gè)多帶帶的AOP類實(shí)現(xiàn)時(shí)間的計(jì)算:

//代碼3
public class DaoTimeAdvice {

  private long time = 0;
  private long num = 0;

  public Object calcTime(ProceedingJoinPoint joinPoint) throws Throwable {
    long then = System.nanoTime();
    Object object = joinPoint.proceed();
    long now = System.nanoTime();
    setTime(getTime() + (now-then));
    setNum(getNum() + 1);
    return object;
  }
  //省略getter & setter。。。
  public void printInfo() {
    System.out.println("總共次數(shù):" + num);
    System.out.println("總共時(shí)間:" + time);
    System.out.println("平均時(shí)間:" + time / num);
  }
}

測(cè)試代碼:

//代碼4
public static void test(){
    System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date())
            + " 開始測(cè)試!");
    for (int i = 0; i < TEST_NUM; i++) {
        ItemStrategyServiceTest ist = (ItemStrategyServiceTest) context.getBean("isTS");
        ist.testIS();
        if (i % 1000 == 0) {
            System.out.println("1000次");
        }
    }
    DaoTimeAdvice ad = (DaoTimeAdvice) context.getBean("daoTimeAdvice");
    ad.printInfo();
    ItemStrategyServiceTest ist = (ItemStrategyServiceTest) context.getBean("isTS");
    ist.testOther();
    System.exit(1);
}

測(cè)試結(jié)果:

defaultAutoCommit 循環(huán)次數(shù) 共消耗時(shí)間(ns) 平均時(shí)間(ns)
true 40000 17831088316 445777
true 40000 17881589992 447039
false 40000 27280458229 682011
false 40000 27237413893 680935

defaultAutoCommit為 false時(shí)的執(zhí)行時(shí)間是 true的近1.5倍,并沒有重現(xiàn)2倍的時(shí)間消耗,估計(jì)是在cat統(tǒng)計(jì)或者其他AOP方法的執(zhí)行時(shí)還有其他消耗,從而擴(kuò)大了 false true之間的區(qū)別。

MyBatis在Spring環(huán)境下的載入過程

按照第一節(jié)中的配置文件,整個(gè)MyBatis中DAO的bean的裝配應(yīng)該是這樣的:

先使用BasicDataSource裝配一個(gè)數(shù)據(jù)源的bean(bean#1),名字叫做 dataSource。

這個(gè)bean很簡(jiǎn)單,就是實(shí)例化并注冊(cè)到Spring的上下文中。

使用 dataSource來創(chuàng)建 sqlSessionFactory(bean#2),這個(gè)bean創(chuàng)建時(shí)會(huì)掃描MyBatis的語句映射文件并解析。

在MyBatis中,真正的數(shù)據(jù)庫(kù)讀寫操作是通過SqlSession的實(shí)例來實(shí)現(xiàn)的,而SqlSession要通過SQLSessionFactory來管理。這里的 org.mybatis.spring.SqlSessionFactoryBean實(shí)現(xiàn)了FactoryBean類(這個(gè)類比較特殊,與主題無關(guān),這里不再贅述),Spring會(huì)從這個(gè)bean中會(huì)獲取真正的SQLSessionFactory的實(shí)例,源代碼中顯示,實(shí)際返回的對(duì)象是DefaultSqlSessionFactory的實(shí)例。

使用 sqlSessionFactory這個(gè)工廠類來創(chuàng)建mapper掃描器(bean#4),并創(chuàng)建含有DAO方法的實(shí)例。

為了讓上層方法可以通過普通的方法調(diào)用來使用DAO方法,需要往Spring上下文里注冊(cè)相應(yīng)的bean,而在MyBatis的普通使用場(chǎng)景中是沒有mapper的實(shí)現(xiàn)類的(具體的SQL語句映射通過注解或者XML文件來實(shí)現(xiàn)),只有接口,在MyBatis中這些接口是通過動(dòng)態(tài)代理實(shí)現(xiàn)的。這里使用的類是 org.mybatis.spring.mapper.MapperScannerConfigurer,它實(shí)現(xiàn)了 org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor接口,所以會(huì)在Spring中「所有的bean定義全部注冊(cè)完成,但還沒有實(shí)例化」之前,調(diào)用方法向Spring上下文注冊(cè)mapper實(shí)現(xiàn)類(動(dòng)態(tài)代理的對(duì)象)。具體代碼如下:

 //代碼5
 @Override
 public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) {
   if (this.processPropertyPlaceHolders) {
     processPropertyPlaceHolders();
   }

   ClassPathMapperScanner scanner = new ClassPathMapperScanner(registry);
   //設(shè)置一些屬性

   scanner.scan(StringUtils.tokenizeToStringArray(this.basePackage, ConfigurableApplicationContext.CONFIG_LOCATION_DELIMITERS));
 }

 /**
* Perform a scan within the specified base packages.
* @param basePackages the packages to check for annotated classes

*/

public int scan(String... basePackages) {
  int beanCountAtScanStart = this.registry.getBeanDefinitionCount();

  doScan(basePackages);

  // Register annotation config processors, if necessary.
  if (this.includeAnnotationConfig) {
    AnnotationConfigUtils.registerAnnotationConfigProcessors(this.registry);
  }

  return (this.registry.getBeanDefinitionCount() - beanCountAtScanStart);
}
在源代碼里可以看到,真正的mapper實(shí)現(xiàn)類是             ` org.mybatis.spring.mapper.MapperFactoryBean`,具體的邏輯在方法             ` org.mybatis.spring.mapper.ClassPathMapperScanner.processBeanDefinitions(Set)`里。最后,每一個(gè)方法的執(zhí)行,最終落入了             ` org.mybatis.spring.SqlSessionTemplate`的某個(gè)方法中,并被如下這個(gè)攔截器攔截:         

//代碼6
  /**
   * Proxy needed to route MyBatis method calls to the proper SqlSession got
   * from Spring"s Transaction Manager
   * It also unwraps exceptions thrown by {@code Method#invoke(Object, Object...)} to
   * pass a {@code PersistenceException} to the {@code PersistenceExceptionTranslator}.
   */
private class SqlSessionInterceptor implements InvocationHandler {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
  SqlSession sqlSession = getSqlSession(
      SqlSessionTemplate.this.sqlSessionFactory,
      SqlSessionTemplate.this.executorType,
      SqlSessionTemplate.this.exceptionTranslator);
  try {
    Object result = method.invoke(sqlSession, args);
    if (!isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
      // force commit even on non-dirty sessions because some databases require
      // a commit/rollback before calling close()
      sqlSession.commit(true);
    }
    return result;
  } catch (Throwable t) {
    //省略一些錯(cuò)誤處理
    throw unwrapped;
  } finally {
    if (sqlSession != null) {
      closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
    }
  }
}
}
4. MyBatis在Spring環(huán)境下事務(wù)的管理         

從源代碼中知道真正的SqlSessionFactory使用的是             ` org.apache.ibatis.session.defaults.DefaultSqlSessionFactory`的實(shí)例,同時(shí),事務(wù)管理使用             ` org.mybatis.spring.transaction.SpringManagedTransactionFactory`。但是在代碼1的配置中,還添加了Spring事務(wù)管理的配置,就是在某個(gè)Service方法(或某個(gè)其他可被掃描到的方法)上加上             ` @Transactional`注解,那么Spring的事務(wù)管理會(huì)自動(dòng)創(chuàng)建事務(wù),那么它和MyBatis的事務(wù)之間是怎么協(xié)作的呢?         

可以看到在代碼6中的方法             ` isSqlSessionTransactional()`,它會(huì)返回上層代碼中是否有Spring的事務(wù),如果有,將不會(huì)執(zhí)行下邊的             ` commit()`。在我的項(xiàng)目中的實(shí)際情況是沒有Spring事務(wù),所以肯定是走到了下面的             ` commit()`,這個(gè)方法最終落到了             ` SpringManagedTransactionFactory`中的             ` commit()`,看代碼:         
//代碼7
private void openConnection() throws SQLException {
  this.connection = DataSourceUtils.getConnection(this.dataSource);
  this.autoCommit = this.connection.getAutoCommit();
  this.isConnectionTransactional = DataSourceUtils.isConnectionTransactional(this.connection, this.dataSource);

}
public void commit() throws SQLException {
  if (this.connection != null && !this.isConnectionTransactional && !this.autoCommit) {
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("Committing JDBC Connection [" + this.connection + "]");
    }
    this.connection.commit();
  }
}
可以看到,此處是否要執(zhí)行             ` commit()`操作是由3個(gè)變量決定的,如果DataSource的             ` autoCommit`是             ` false`,則其結(jié)果一定為             ` true`,控制臺(tái)也會(huì)看到一行日志:             ` Committing JDBC Connection [xxxxxx]`,剛好與項(xiàng)目中遇到的情況相同。這個(gè)提交動(dòng)作是需要和數(shù)據(jù)庫(kù)交互的,比較耗時(shí)。         

### 實(shí)驗(yàn)驗(yàn)證 

由上一節(jié)分析得出,造成DAO方法執(zhí)行時(shí)間變長(zhǎng)的原因是會(huì)多執(zhí)行一次提交,那么如果上層方法被Spring事務(wù)管理器托管(或者數(shù)據(jù)源的     ` defaultAutoCommit`為     ` true`,這個(gè)條件已經(jīng)在剛開始的問題重現(xiàn)被驗(yàn)證),則不會(huì)執(zhí)行MyBatis的提交動(dòng)作,DAO方法應(yīng)該相應(yīng)的執(zhí)行時(shí)間會(huì)變短。于是將Service方法加上     ` @transactional`注解,分別測(cè)試     ` true`和     ` false`的情況。結(jié)果: 

![](https://ws1.sinaimg.cn/large/005BVorrgy1g5iw155o3oj31b007q0ui.jpg)

文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址:http://systransis.cn/yun/75707.html

相關(guān)文章

  • SpringBoot 入門簡(jiǎn)介

    摘要:這里使用的是數(shù)據(jù)庫(kù)啟動(dòng)類上加上注解在啟動(dòng)類中添加對(duì)包掃描掃描多個(gè)包下的可以有以下幾種方法掃描會(huì)自動(dòng)加載相關(guān)配置,數(shù)據(jù)源就會(huì)自動(dòng)注入到中,會(huì)自動(dòng)注入到中,可以直接使用。有配置文件下的使用掃描多個(gè)包下的可以有以下幾種方法掃描 Spring-Boot 學(xué)習(xí)筆記 1 Spring-Boot 介紹 1.1 什么是Spring-Boot Spring-Boot是由Pivotal團(tuán)隊(duì)提供的全新框架...

    chuyao 評(píng)論0 收藏0
  • Maven管理SpringBoot Profile

    摘要:的配置文件默認(rèn)為或,此外僅以配置為說明。的由的標(biāo)簽管理。管理由于構(gòu)建是基于或,此處僅以說明。管理分五步,以下詳細(xì)介紹。并且為表示,會(huì)將文件內(nèi)容的替換為相應(yīng)的變量如文件中的會(huì)替換為屬性值。 1. Spring Profile Spring可使用Profile決定程序在不同環(huán)境下執(zhí)行情況,包含配置、加載Bean、依賴等。 Spring的Profile一般項(xiàng)目包含:dev(開發(fā)), test...

    wenzi 評(píng)論0 收藏0
  • SSM : 環(huán)境搭建

    摘要:這個(gè)文件包含對(duì)對(duì)數(shù)據(jù)訪問進(jìn)行封裝的所有類。為等提供的一致的聲明式和編程式事務(wù)管理。 SSM 環(huán)境搭建 目錄創(chuàng)建 pom.xml SSM 逐層配置 一、目錄 1.1 src/main/java 目錄下的包(以下包要放在項(xiàng)目包下,如:com.imooc.項(xiàng)目名) entity: 存放實(shí)體類 web: 存放controller,相當(dāng)于Struts中的action service: 業(yè)務(wù)...

    MonoLog 評(píng)論0 收藏0
  • mybatis-spring原理解析

    摘要:創(chuàng)建出的是對(duì)象,持有這個(gè)對(duì)象。根據(jù)接口名和方法名從對(duì)象的中檢查并獲取方法對(duì)應(yīng)的語句解析成的對(duì)象,保存它的和命令類型。實(shí)現(xiàn)類攔截映射接口的自定義方法,讓去處理方法對(duì)應(yīng)的解析成的。 前言 Mybatis是目前主流的Java ORM框架之一。mybatis-spring包則是為了讓Mybatis更好得整合進(jìn)Spring的衍生產(chǎn)品。本文就從Mybatis和mybatis-spring源碼著手,...

    why_rookie 評(píng)論0 收藏0
  • SpringBoot非官方教程 | 第七篇:SpringBoot開啟聲明式事務(wù)

    摘要:準(zhǔn)備階段以上一篇文章的代碼為例子,即整合,上一篇文章是基于注解來實(shí)現(xiàn)的數(shù)據(jù)訪問層,這篇文章基于的來實(shí)現(xiàn),并開啟聲明式事務(wù)。創(chuàng)建實(shí)體類數(shù)據(jù)訪問層接口層用戶減塊用戶加塊,聲明事務(wù),并設(shè)計(jì)一個(gè)轉(zhuǎn)賬方法,用戶減塊,用戶加塊。 springboot開啟事務(wù)很簡(jiǎn)單,只需要一個(gè)注解@Transactional 就可以了。因?yàn)樵趕pringboot中已經(jīng)默認(rèn)對(duì)jpa、jdbc、mybatis開啟了事事...

    tyheist 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<