MyBatis 內建了一個強大的事務性查詢快取機制,它可以非常方便地設定和客製化。 為了使它更加強大而且易於設定,我們對 MyBatis 3 中的快取實現進行了許多改進。
Mybatis的一級快取(也叫本地快取/Local Cache)是指SqlSession級別的,作用域是SqlSession。
Mybatis預設開啟一級快取,在同一個SqlSession中,相同的Sql查詢的時候,第一次查詢的時候,就會從快取中取,如果發現沒有資料,那麼就從資料庫查詢出來,並且快取到HashMap中,如果下次還是相同的查詢,就直接從快取中查詢,就不在去查詢資料庫,對應的就不在去執行SQL語句。
當查詢到的資料,進行增刪改的操作的時候,快取將會失效。在spring容器管理中每次查詢都是建立一個新的sqlSession,所以在分散式環境中不會出現資料不一致的問題。
一級快取原理圖:
我們知道,一級快取是和SqlSession對談關聯的,一旦SqlSession關閉了,一級快取就會失效。測試如下:
//測試一級快取失效
@Test
public void level1CacheTest2() {
System.out.println("==========第1次查詢=========");
Monster monster = monsterMapper.getMonsterById(10);
System.out.println("monster=" + monster);
//關閉sqlSession,一級快取失效
if (sqlSession != null) {
sqlSession.close();
}
System.out.println("==========第2次查詢=========");
sqlSession = MybatisUtils.getSqlSession();//重新獲取SqlSession物件
monsterMapper = sqlSession.getMapper(MonsterMapper.class);//重新初始化
Monster monster2 = monsterMapper.getMonsterById(10);
System.out.println("monster2=" + monster2);
if (this.sqlSession != null) {
this.sqlSession.close();
}
}
結果:可以看到兩次查詢都發出了sql操作,說明如果SqlSession對談關閉了,第二次查詢依然回到資料庫查詢,一級快取失效。
當執行sqlSession.clearCache()時(手動清除快取),一級快取失效。
clearCache()方法底層執行如下:
測試方法如下:
//測試一級快取失效
@Test
public void level1CacheTest3() {
System.out.println("==========第1次查詢=========");
Monster monster = monsterMapper.getMonsterById(10);
System.out.println("monster=" + monster);
//手動清除快取,也會導致一級快取失效
sqlSession.clearCache();
System.out.println("==========第2次查詢=========");
Monster monster2 = monsterMapper.getMonsterById(10);
System.out.println("monster2=" + monster2);
if (this.sqlSession != null) {
this.sqlSession.close();
}
}
測試結果如下,查詢操作相同,且在同一個SqlSession對談內,但底層仍然到資料庫執行了兩次相同操作,這說明當手動清除快取後,一級快取也會失效。
在兩次相同的查詢中間進行update操作,是否會對一級快取產生影響?
//如果被查詢的資料進行了增刪改操作,會導致一級快取資料失效
@Test
public void level1CacheTest4() {
System.out.println("==========第1次查詢=========");
Monster monster = monsterMapper.getMonsterById(10);
System.out.println("monster=" + monster);
//對要查詢的資料id=10進行update操作
monster.setName("金蟬子");
monsterMapper.updateMonster(monster);
System.out.println("==========第2次查詢=========");
Monster monster2 = monsterMapper.getMonsterById(10);
System.out.println("monster2=" + monster2);
if (sqlSession != null) {
sqlSession.commit();//注意提交事務
sqlSession.close();
}
}
如下,在兩次相同查詢操作之間進行update操作,一級快取同樣失效了,因為第二次查詢操作仍然向資料庫發出sql語句。
二級快取原理圖:
開啟二級快取後,會使用CachingExecutor裝飾Executor,進入一級快取的查詢流程前,先在CachingExecutor進行二級快取的查詢,具體的工作流程如下所示。
二級快取開啟後,同一個namespace下的所有操作語句,都影響著同一個Cache,即二級快取被多個SqlSession共用,是一個全域性的變數。當開啟快取後,資料的查詢執行的流程就是 二級快取 -> 一級快取 -> 資料庫。
(1)mybatis-config.xml設定中開啟二級快取
設定名 | 描述 | 有效值 | 預設值 |
---|---|---|---|
cacheEnabled | 全域性性開啟或關閉所有對映器組態檔中已設定的任何快取 | true、false | true |
<settings>
<!--開啟二級快取,預設下值為true-->
<setting name="cacheEnabled" value="true"/>
</settings>
(2)使用二級快取時entity類實現序列化介面(serializable),因為二級快取可能使用到序列化技術
大部分情況下,二級快取不去置序列化也可以使用,只是有些二級快取產品可能用到序列化
(3)在對應的xxMapper.xml中設定二級快取的策略
<!--設定二級快取
FIFO:先進先出,按物件進入快取的順序來移除它們
flushInterval:重新整理間隔為60000ms,即60s
size:儲存結果物件或列表的 512 個參照,預設為1024
readOnly:唯讀屬性,如果只用於讀操作,建議設定成true,如果有修改操作,則設定為false(預設)
-->
<cache eviction="FIFO" flushInterval="60000" size="512" readOnly="true"/>
(4)測試
//測試二級快取
@Test
public void level2CacheTest() {
System.out.println("==========第一次查詢=========");
Monster monster = monsterMapper.getMonsterById(5);
System.out.println("monster=" + monster);
//關閉這個對談
if (sqlSession != null) {
sqlSession.close();
}
System.out.println("==========第二次查詢=========");
//獲取新的sqlSession對談
sqlSession = MybatisUtils.getSqlSession();
monsterMapper = sqlSession.getMapper(MonsterMapper.class);
Monster monster2 = monsterMapper.getMonsterById(5);
System.out.println("monster=" + monster2);
if (this.sqlSession != null) {
this.sqlSession.close();
}
}
測試結果:二級快取的作用域是全域性範圍,因此不同的sqlSession對談都有效
二級快取命中率 = 快取生效的次數 / 總查詢的次數
要啟用全域性的二級快取,只需要在你的 SQL 對映檔案中新增一行:
<cache/>
可以通過 cache 元素的屬性來修改你的策略。比如:
<cache
eviction="FIFO"
flushInterval="60000"
size="512"
readOnly="true"/>
設定建立了一個 FIFO 快取,每隔 60 秒重新整理,最多可以儲存結果物件或列表的 512 個參照,而且返回的物件被認為是唯讀的,因此對它們進行修改可能會在不同執行緒中的呼叫者產生衝突。
eviction:快取的回收策略。
flushInterval(重新整理間隔)屬性為任意的正整數,設定的值應該是一個以毫秒為單位時間。 預設情況是不設定,也就是沒有重新整理間隔,快取僅僅會在呼叫語句時重新整理。
size(參照數目)屬性為任意正整數,欲快取物件的大小和執行環境中可用的記憶體資源有關。預設值為 1024。
readOnly(唯讀)屬性可以為 true 或 false。唯讀快取會給所有呼叫者返回快取物件的相同範例。 因此這些物件不能被修改,從而使效能提升。而可讀寫的快取會(通過序列化)返回快取物件的拷貝。 速度上會慢一些,但是更安全,因此預設值是 false。
LRU
– 最近最少使用:移除最長時間不被使用的物件。(預設策略)FIFO
– 先進先出:按物件進入快取的順序來移除它們。SOFT
– 軟參照:基於垃圾回收器狀態和軟參照規則移除物件。WEAK
– 弱參照:更積極地基於垃圾收集器狀態和弱參照規則移除物件。(1)在mybatis-config.xml檔案的settings標籤中設定二級快取的開關。
注意這裡的設定只是和二級快取有關,和一級快取無關
<settings>
<!--全域性性開啟或關閉所有對映器組態檔中已經設定的任何快取,可以理解為二級快取的總開關,預設為true-->
<setting name="cacheEnabled" value="false"/>
</settings>
(2)二級快取的設定不僅要在組態檔中設定,還要在對應的對映檔案中設定才有效。因此如果要禁用二級快取,也可以在對應的對映檔案中登出cache元素,這時候二級快取對該對映檔案無效。
(3)或者使用控制力度更加精確的方法,直接在設定方法上指定
設定useCache="false"可以禁用當前select語句的二級快取,即每次查詢都會發出sql去查詢,預設情況為true
注意:一般不用去修改,使用預設的即可
insert,update,delete 運算元據後需要重新整理快取,如果不執行重新整理快取會出現髒讀:
預設情況下 flushCache 的值為true,一般不用修改。
快取的執行順序為:二級快取-->一級快取-->資料庫
測試:驗證快取的執行順序,我們事先開啟二級快取和一級快取。
//二級快取->一級快取->資料庫
@Test
public void cacheSeqTest() {
System.out.println("==========第1次查詢=========");
//Cache Hit Ratio: 0.0
Monster monster = monsterMapper.getMonsterById(8);
System.out.println(monster);
//當一級快取的對談被關閉時,一級快取的資料就會被放入二級快取,前提是二級快取是開啟的
sqlSession.close();
sqlSession = MybatisUtils.getSqlSession();
monsterMapper = sqlSession.getMapper(MonsterMapper.class);
System.out.println("==========第2次查詢=========");
//從二級快取獲取 id=8 的 monster資訊
//Cache Hit Ratio: 0.5
Monster monster2 = monsterMapper.getMonsterById(8);
System.out.println(monster2);
System.out.println("==========第3次查詢=========");
//這時一二級快取都有資料,但是由於先查詢二級快取,因此資料依然是從二級快取中獲取的
//Cache Hit Ratio: 0.6666666666666666
Monster monster3 = monsterMapper.getMonsterById(8);
System.out.println(monster3);
sqlSession.close();
}
注意事項:
不會出現一級快取和二級快取中有同一個資料,因為二級快取的資料是在一級快取關閉之後才有的。(當一級快取的對談被關閉時,如果二級快取開啟了,一級快取的資料就會被放入二級快取)
//分析執行順序,二級快取的資料是在一級快取被關閉之後才有的,不會出現一二級快取同時擁有相同資料的情況
@Test
public void cacheSeqTest2() {
System.out.println("==========第1次查詢=========");
//二級快取命中率 Cache Hit Ratio: 0.0,走資料庫
Monster monster = monsterMapper.getMonsterById(8);
System.out.println(monster);
System.out.println("==========第2次查詢=========");
//Cache Hit Ratio: 0.0
//拿的是一級快取的資料,不會發出sql
Monster monster2 = monsterMapper.getMonsterById(8);
System.out.println(monster2);
System.out.println("==========第3次查詢=========");
//Cache Hit Ratio: 0.0
//拿的是一級快取的資料,不會發出sql
Monster monster3 = monsterMapper.getMonsterById(8);
System.out.println(monster3);
if (sqlSession != null) {
sqlSession.close();
}
}
(1)加入相關依賴,修改pom.xml檔案
<dependencies>
<!--引入EhCache核心庫-->
<dependency>
<groupId>net.sf.ehcache</groupId>
<artifactId>ehcache-core</artifactId>
<version>2.6.11</version>
</dependency>
<!--引入需要使用的slf4j-->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.25</version>
</dependency>
<!--引入mybatis整合ehcache庫-->
<dependency>
<groupId>org.mybatis.caches</groupId>
<artifactId>mybatis-ehcache</artifactId>
<version>1.2.1</version>
</dependency>
</dependencies>
(2)確保mybatis-config.xml檔案開啟了二級快取
<settings>
<!--不設定也可以,因為二級快取預設是開啟的-->
<setting name="cacheEnabled" value="true"/>
</settings>
(3)在resource目錄下加入ehcache.xml 組態檔
Java Ehcache快取的timeToIdleSeconds和timeToLiveSeconds區別 - TaoBye
<?xml version="1.0" encoding="UTF-8"?>
<ehcache>
<!--diskStore:為快取路徑,ehcache分為記憶體和磁碟兩級,此屬性定義磁碟的快取位置。引數解釋如下:
user.home – 使用者主目錄
user.dir – 使用者當前工作目錄
java.io.tmpdir – 預設臨時檔案路徑 -->
<diskStore path="java.io.tmpdir/Tmp_EhCache"/>
<!--defaultCache:預設快取策略,當ehcache找不到定義的快取時,使用這個快取策略。只能定義一個-->
<!--name:快取名稱。
maxElementsInMemory:快取最大數目
maxElementsOnDisk:硬碟最大快取個數。
eternal:物件是否永久有效,一但設定了,timeout將不起作用。
overflowToDisk:是否儲存到磁碟,當系統宕機時
timeToIdleSeconds:設定物件在失效前的允許閒置時間(單位:秒)。僅當eternal=false物件不是永久有效時使用,可選屬性,預設值是0,也就是可閒置時間無窮大。
timeToLiveSeconds:設定物件在失效前允許存活時間(單位:秒)。最大時間介於建立時間和失效時間之間。僅當eternal=false物件不是永久有效時使用,預設是0,也就是物件存活時間無窮大。
diskPersistent:是否快取虛擬機器器重啟期資料 Whether the disk store persists between restarts of the Virtual Machine. The default value is false.
diskSpoolBufferSizeMB:這個引數設定DiskStore(磁碟快取)的快取區大小。預設是30MB。每個Cache都應該有自己的一個緩衝區。
diskExpiryThreadIntervalSeconds:磁碟失效執行緒執行時間間隔,預設是120秒。
memoryStoreEvictionPolicy:當達到maxElementsInMemory限制時,Ehcache將會根據指定的策略去清理記憶體。預設策略是LRU(最近最少使用)。你可以設定為FIFO(先進先出)或是LFU(較少使用)。
clearOnFlush:記憶體數量最大時是否清除。
memoryStoreEvictionPolicy:可選策略有:LRU(最近最少使用,預設策略)、FIFO(先進先出)、LFU(最少存取次數)。
FIFO,first in first out,這個是大家最熟的,先進先出。
LFU, Less Frequently Used,就是上面例子中使用的策略,直白一點就是講一直以來最少被使用的。如上面所講,快取的元素有一個hit屬性,hit值最小的將會被清出快取。
LRU,Least Recently Used,最近最少使用的,快取的元素有一個時間戳,當快取容量滿了,而又需要騰出地方來快取新的元素的時候,那麼現有快取元素中時間戳離當前時間最遠的元素將被清出快取。-->
<defaultCache
eternal="false"
maxElementsInMemory="10000"
overflowToDisk="false"
diskPersistent="false"
timeToIdleSeconds="1800"
timeToLiveSeconds="259200"
memoryStoreEvictionPolicy="LRU"/>
</ehcache>
(4)在XxxMapper.xml中啟用了EhCace,當然原來Mybatis自帶的快取設定需要登出
<!--啟用ehcache-->
<cache type="org.mybatis.caches.ehcache.EhcacheCache"/>
(5)測試
//測試二級快取
@Test
public void ehCacheTest() {
System.out.println("==========第1次查詢=========");
Monster monster = monsterMapper.getMonsterById(5);
System.out.println("monster=" + monster);
//關閉當前對談,一級快取資料失效,將資料放入二級快取(此時為 ehcache)
if (sqlSession != null) {
sqlSession.close();
}
//獲取新的sqlSession對談
sqlSession = MybatisUtils.getSqlSession();
monsterMapper = sqlSession.getMapper(MonsterMapper.class);
System.out.println("==========第2次查詢=========");
//從二級快取ehcache中獲取資料,不會發出sql
Monster monster2 = monsterMapper.getMonsterById(5);
System.out.println("monster=" + monster2);
System.out.println("==========第3次查詢=========");
//還是從二級快取獲取資料,不會發出sql
Monster monster3 = monsterMapper.getMonsterById(5);
System.out.println("monster=" + monster3);
if (this.sqlSession != null) {
this.sqlSession.close();
}
}
如何理解EhCache和Mybatis快取的關係?
MyBatis提供了一個Cache介面,只要實現了該Cache介面,就可以作為二級快取產品和MyBatis整合使用,EhCache就是實現了該介面。
MyBatis預設情況(即一級快取)是使用的PerpetualCache類實現Cache介面的,是核心類
當我們使用了EhCache後,就是EhcacheCache類實現Cache介面,它是核心類
快取的本質就是 Map<Object,Object>