摘要:對于第二個問題,本文將嘗試通過分析源代碼和實驗找到它的,主要涉及到以下內容問題描述與分析在環境下的載入過程在環境下事務的管理實驗驗證項目環境整個系統是微服務架構,這里討論的項目是指一個多帶帶的服務。
MyBatis的設計思想很簡單,可以看做是對JDBC的一次封裝,并提供強大的動態SQL映射功能。但是由于它本身也有一些緩存、事務管理等功能,所以實際使用中還是會碰到一些問題——另外,最近接觸了JFinal,其思想和Hibernate類似,但要更簡潔,和MyBatis的設計思想不同,但有一點相同:都是想通過簡潔的設計最大限度地簡化開發和提升性能——說到性能,前段時間碰到兩個問題:
在一個上層方法(DAO方法的上層)內刪除一條記錄,然后再插入一條相同主鍵的記錄時,會報主鍵沖突的錯誤。
某些項目中的DAO方法平均執行時間會是其他一些項目中的 2倍 。
第一個問題是偶爾會出現,在實驗環境無論如何也重現不了,經過分析MyBatis的邏輯,估計是兩個DAO分別拿到了兩個不同的Connection,第二個語句比第一個更早的被提交,導致了主鍵沖突,有待進一步的分析和驗證。對于第二個問題,本文將嘗試通過分析源代碼和實驗找到它的root cause,主要涉及到以下內容:
問題描述與分析
MyBatis在Spring環境下的載入過程
MyBatis在Spring環境下事務的管理
實驗驗證
項目環境整個系統是微服務架構,這里討論的「項目」是指一個多帶帶的服務。單個項目的框架基本是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和事務相關的配置如下:
//代碼1問題描述與分析//在這里設置是否自動提交
一倍的時間差挺嚴重的,平均到每次調用,正常的大約在6到10幾 ms,慢的要近20 ms,由于調用次數很多,導致整體性能會有很大的差別。經過仔細比對這幾個項目,發現DAO執行慢的項目的數據源配置(bean#1)中 defaultAutoCommit的配置都是 false。而且將此配置改為 true之后就恢復了正常。
由此推斷是在MyBatis在執行「非自動提交」語句時,進行等待,或者多提交了一次,導致實際調用數據庫API次數增多。但是這個推斷也有個問題,由于整個項目是在Spring環境中運行的,而且也開啟了Spring的事務管理,所以還是需要詳細的看一下MyBatis到底是如何裝配DAO方法與管理事務的,才能徹底解開謎團。
問題重現首先寫一個Service,其中調用了同一個mapper類的兩個方法分別2次, insertModelList()會在數據庫中插入兩條記錄, delModels()方法會刪除這兩條記錄,代碼如下:
//代碼2 //@Transactional public void testIS(){ Listmodels= new ArrayList<>(); //省略一些數據工作。。。 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); }
實際項目中使用cat來進行執行時間的統計,這里也仿照cat,使用一個多帶帶的AOP類實現時間的計算:
//代碼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("總共次數:" + num); System.out.println("總共時間:" + time); System.out.println("平均時間:" + time / num); } }
測試代碼:
//代碼4 public static void test(){ System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date()) + " 開始測試!"); 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); }
測試結果:
defaultAutoCommit | 循環次數 | 共消耗時間(ns) | 平均時間(ns) |
---|---|---|---|
true | 40000 | 17831088316 | 445777 |
true | 40000 | 17881589992 | 447039 |
false | 40000 | 27280458229 | 682011 |
false | 40000 | 27237413893 | 680935 |
defaultAutoCommit為 false時的執行時間是 true的近1.5倍,并沒有重現2倍的時間消耗,估計是在cat統計或者其他AOP方法的執行時還有其他消耗,從而擴大了 false和 true之間的區別。
MyBatis在Spring環境下的載入過程按照第一節中的配置文件,整個MyBatis中DAO的bean的裝配應該是這樣的:
先使用BasicDataSource裝配一個數據源的bean(bean#1),名字叫做 dataSource。
這個bean很簡單,就是實例化并注冊到Spring的上下文中。
使用 dataSource來創建 sqlSessionFactory(bean#2),這個bean創建時會掃描MyBatis的語句映射文件并解析。
在MyBatis中,真正的數據庫讀寫操作是通過SqlSession的實例來實現的,而SqlSession要通過SQLSessionFactory來管理。這里的 org.mybatis.spring.SqlSessionFactoryBean實現了FactoryBean類(這個類比較特殊,與主題無關,這里不再贅述),Spring會從這個bean中會獲取真正的SQLSessionFactory的實例,源代碼中顯示,實際返回的對象是DefaultSqlSessionFactory的實例。
使用 sqlSessionFactory這個工廠類來創建mapper掃描器(bean#4),并創建含有DAO方法的實例。
為了讓上層方法可以通過普通的方法調用來使用DAO方法,需要往Spring上下文里注冊相應的bean,而在MyBatis的普通使用場景中是沒有mapper的實現類的(具體的SQL語句映射通過注解或者XML文件來實現),只有接口,在MyBatis中這些接口是通過動態代理實現的。這里使用的類是 org.mybatis.spring.mapper.MapperScannerConfigurer,它實現了 org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor接口,所以會在Spring中「所有的bean定義全部注冊完成,但還沒有實例化」之前,調用方法向Spring上下文注冊mapper實現類(動態代理的對象)。具體代碼如下:
//代碼5 @Override public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) { if (this.processPropertyPlaceHolders) { processPropertyPlaceHolders(); } ClassPathMapperScanner scanner = new ClassPathMapperScanner(registry); //設置一些屬性 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實現類是 ` org.mybatis.spring.mapper.MapperFactoryBean
//代碼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) { //省略一些錯誤處理 throw unwrapped; } finally { if (sqlSession != null) { closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory); } } } }
4. MyBatis在Spring環境下事務的管理 從源代碼中知道真正的SqlSessionFactory使用的是 ` org.apache.ibatis.session.defaults.DefaultSqlSessionFactory`的實例,同時,事務管理使用 ` org.mybatis.spring.transaction.SpringManagedTransactionFactory`。但是在代碼1的配置中,還添加了Spring事務管理的配置,就是在某個Service方法(或某個其他可被掃描到的方法)上加上 ` @Transactional`注解,那么Spring的事務管理會自動創建事務,那么它和MyBatis的事務之間是怎么協作的呢? 可以看到在代碼6中的方法 ` isSqlSessionTransactional()`,它會返回上層代碼中是否有Spring的事務,如果有,將不會執行下邊的 ` commit()`。在我的項目中的實際情況是沒有Spring事務,所以肯定是走到了下面的 ` commit()`,這個方法最終落到了 ` 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(); } }
可以看到,此處是否要執行 ` commit()`操作是由3個變量決定的,如果DataSource的 ` autoCommit`是 ` false`,則其結果一定為 ` true`,控制臺也會看到一行日志: ` Committing JDBC Connection [xxxxxx]`,剛好與項目中遇到的情況相同。這個提交動作是需要和數據庫交互的,比較耗時。 ### 實驗驗證 由上一節分析得出,造成DAO方法執行時間變長的原因是會多執行一次提交,那么如果上層方法被Spring事務管理器托管(或者數據源的 ` defaultAutoCommit`為 ` true`,這個條件已經在剛開始的問題重現被驗證),則不會執行MyBatis的提交動作,DAO方法應該相應的執行時間會變短。于是將Service方法加上 ` @transactional`注解,分別測試 ` true`和 ` false`的情況。結果: ![](https://ws1.sinaimg.cn/large/005BVorrgy1g5iw155o3oj31b007q0ui.jpg)
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/75707.html
摘要:這里使用的是數據庫啟動類上加上注解在啟動類中添加對包掃描掃描多個包下的可以有以下幾種方法掃描會自動加載相關配置,數據源就會自動注入到中,會自動注入到中,可以直接使用。有配置文件下的使用掃描多個包下的可以有以下幾種方法掃描 Spring-Boot 學習筆記 1 Spring-Boot 介紹 1.1 什么是Spring-Boot Spring-Boot是由Pivotal團隊提供的全新框架...
摘要:的配置文件默認為或,此外僅以配置為說明。的由的標簽管理。管理由于構建是基于或,此處僅以說明。管理分五步,以下詳細介紹。并且為表示,會將文件內容的替換為相應的變量如文件中的會替換為屬性值。 1. Spring Profile Spring可使用Profile決定程序在不同環境下執行情況,包含配置、加載Bean、依賴等。 Spring的Profile一般項目包含:dev(開發), test...
摘要:這個文件包含對對數據訪問進行封裝的所有類。為等提供的一致的聲明式和編程式事務管理。 SSM 環境搭建 目錄創建 pom.xml SSM 逐層配置 一、目錄 1.1 src/main/java 目錄下的包(以下包要放在項目包下,如:com.imooc.項目名) entity: 存放實體類 web: 存放controller,相當于Struts中的action service: 業務...
摘要:創建出的是對象,持有這個對象。根據接口名和方法名從對象的中檢查并獲取方法對應的語句解析成的對象,保存它的和命令類型。實現類攔截映射接口的自定義方法,讓去處理方法對應的解析成的。 前言 Mybatis是目前主流的Java ORM框架之一。mybatis-spring包則是為了讓Mybatis更好得整合進Spring的衍生產品。本文就從Mybatis和mybatis-spring源碼著手,...
摘要:準備階段以上一篇文章的代碼為例子,即整合,上一篇文章是基于注解來實現的數據訪問層,這篇文章基于的來實現,并開啟聲明式事務。創建實體類數據訪問層接口層用戶減塊用戶加塊,聲明事務,并設計一個轉賬方法,用戶減塊,用戶加塊。 springboot開啟事務很簡單,只需要一個注解@Transactional 就可以了。因為在springboot中已經默認對jpa、jdbc、mybatis開啟了事事...
閱讀 3708·2023-04-26 00:56
閱讀 2686·2021-09-30 10:01
閱讀 961·2021-09-22 15:30
閱讀 3915·2021-09-07 10:21
閱讀 1507·2021-09-02 15:40
閱讀 2750·2021-08-30 09:47
閱讀 1234·2021-08-16 10:57
閱讀 1862·2019-08-30 14:01