首頁  >  文章  >  Java  >  mybatis關於快取的實例詳解

mybatis關於快取的實例詳解

Y2J
Y2J原創
2017-05-13 10:40:541541瀏覽

這篇文章主要介紹了mybatis教程之查詢快取(一級快取二級快取和整合ehcache),具有一定的參考價值,有興趣的小夥伴們可以參考一下

# 1 快取的意義

將使用者經常查詢的資料放在快取(記憶體)中,使用者去查詢資料就不用從磁碟上(關係型資料庫資料檔案)查詢,從快取中查詢,從而提高查詢效率,解決了高並發系統的效能問題。

2 mybatis持久層快取

mybatis提供一級快取和二級快取

mybatis一級快取是一個SqlSession級別,sqlsession只能存取自己的一級快取的數據,二級快取是跨sqlSession,是mapper級別的緩存,對於mapper層級的快取不同的sqlsession是可以共享的。

3 一級快取

#3.1 原理

第一次發出一個查詢sql,sql查詢結果寫入sqlsession的一級快取中,快取使用的資料結構是一個mape6fd748e50e82e7bde0d1e0efd3285df

key:hashcode+ sql+sql輸入參數+輸出參數(sql的唯一標識)

value:用戶資訊

同一個sqlsession再次發出相同的sql,就從快取中取不走資料庫。如果兩次中間出現commit作業(修改、新增、刪除),本sqlsession中的一級快取區域全部清空,下次再去快取中查詢不到所以要從資料庫查詢,從資料庫查詢到再寫入快取。

每次查詢都先從快取中查詢:


 

如果快取中查詢到則會快取資料直接回傳。

如果快取中查詢不到就從資料庫查詢:

3.2 一層快取配置

mybatis預設支援一級快取不需要配置。

注意:mybatis和spring整合後進行mapper代理開發,不支援一級緩存,mybatis和spring整合,spring依照mapper的模板去產生mapper代理物件,模板中在最後統一關閉sqlsession。

3.3 一級快取測試


#
//一级缓存 
  @Test 
  public void testCache1() throws Exception { 
 
    SqlSession sqlSession = sqlSessionFactory.openSession(); 
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class); 
     
    //第一次查询用户id为1的用户 
    User user = userMapper.findUserById(1); 
    System.out.println(user); 
     
    //中间修改用户要清空缓存,目的防止查询出脏数据 
    /*user.setUsername("测试用户2"); 
    userMapper.updateUser(user); 
    sqlSession.commit();*/ 
     
    //第二次查询用户id为1的用户 
    User user2 = userMapper.findUserById(1); 
    System.out.println(user2); 
     
    sqlSession.close(); 
     
 
  }

4 二級快取

4.1 原則

#二級快取的範圍是mapper層級(mapper同一個命名空間),mapper以命名空間為單位建立快取資料結構,結構是mapc62d37832d7d646d27b17f5f3a5fca1f。

每次查詢先看是否開啟二級緩存,如果開啟從二級快取的資料結構中取緩存數據,

## 

#如果從二級快取沒有取到,再從一級快取找,如果一級快取也沒有,從資料庫查詢。


4.2 mybatis二級快取設定

#在核心

設定檔SqlMapConfig.xml中加入


<setting name="cacheEnabled" value="true"/>

要在你的Mapper映射檔中新增一行:  8b0f252edde2ed6702a65a8dd34c5e13 ,表示此mapper開啟二級快取。

4.3 查詢結果對映的pojo序列化

mybatis二級快取需要查詢結果對映的pojo實作Java.io.serializable

介面,如果不實作則拋出例外

org.apache.ibatis.cache.CacheException: Error serializing object.  Cause: java.io.NotSerializableException: com .sihai.mybatis.po.User


二級快取可以將記憶體的資料寫到磁碟,存在物件的序列化和反序列化,所以要實作java.io.serializable介面。


如果結果對應的pojo中也包含了pojo,都要實作java.io.serializable介面。


4.4 二级缓存禁用

对于变化频率较高的sql,需要禁用二级缓存:

在statement中设置useCache=false可以禁用当前select语句的二级缓存,即每次查询都会发出sql去查询,默认情况是true,即该sql使用二级缓存。


<select id="findOrderListResultMap" resultMap="ordersUserMap" useCache="false">

4.5 刷新缓存

如果sqlsession操作commit操作,对二级缓存进行刷新(全局清空)。

设置statement的flushCache是否刷新缓存,默认值是true。

4.6 测试代码


//二级缓存的测试 
  @Test 
  public void testCache2() throws Exception { 
 
    SqlSession sqlSession1 = sqlSessionFactory.openSession(); 
    SqlSession sqlSession2 = sqlSessionFactory.openSession(); 
    SqlSession sqlSession3 = sqlSessionFactory.openSession(); 
    UserMapper userMapper1 = sqlSession1.getMapper(UserMapper.class); 
    UserMapper userMapper2 = sqlSession2.getMapper(UserMapper.class); 
    UserMapper userMapper3 = sqlSession3.getMapper(UserMapper.class); 
     
    //第一次查询用户id为1的用户 
    User user = userMapper1.findUserById(1); 
    System.out.println(user); 
    sqlSession1.close(); 
     
    //中间修改用户要清空缓存,目的防止查询出脏数据 
    /*user.setUsername("测试用户2"); 
    userMapper3.updateUser(user); 
    sqlSession3.commit(); 
    sqlSession3.close();*/ 
     
     
    //第二次查询用户id为1的用户 
    User user2 = userMapper2.findUserById(1); 
    System.out.println(user2); 
     
    sqlSession2.close(); 
     
 
  }

4.7 mybatis的cache参数

mybatis的cache参数只适用于mybatis维护缓存。

flushInterval(刷新间隔)可以被设置为任意的正整数,而且它们代表一个合理的毫秒形式的时间段。默认情况是不设置,也就是没有刷新间隔,缓存仅仅调用语句时刷新。

size(引用数目)可以被设置为任意正整数,要记住你缓存的对象数目和你运行环境的可用内存资源数目。默认值是1024。

readOnly(只读)属性可以被设置为true或false。只读的缓存会给所有调用者返回缓存对象的相同实例。因此这些对象不能被修改。这提供了很重要的性能优势。可读写的缓存会返回缓存对象的拷贝(通过序列化)。这会慢一些,但是安全,因此默认是false。

如下例子:


<cache eviction="FIFO" flushInterval="60000" size="512" readOnly="true"/>

这个更高级的配置创建了一个 FIFO 缓存,并每隔 60 秒刷新,存数结果对象或列表的 512 个引用,而且返回的对象被认为是只读的,因此在不同线程中的调用者之间修改它们会导致冲突。可用的收回策略有, 默认的是 LRU:

1. LRU – 最近最少使用的:移除最长时间不被使用的对象。

2. FIFO – 先进先出:按对象进入缓存的顺序来移除它们。

3. SOFT – 软引用:移除基于垃圾回收器状态和软引用规则的对象。

4. WEAK – 弱引用:更积极地移除基于垃圾收集器状态和弱引用规则的对象。

5 mybatis和ehcache缓存框架整合

mybatis二级缓存通过ehcache维护缓存数据。

5.1 分布缓存

将缓存数据数据进行分布式管理。

5.2 mybatis和ehcache思路

通过mybatis和ehcache框架进行整合,就可以把缓存数据的管理托管给ehcache。

在mybatis中提供一个cache接口,只要实现cache接口就可以把缓存数据灵活的管理起来。

mybatis中默认实现:

5.3 下载和ehcache整合的jar包

 

ehcache对cache接口的实现类:

5.4 配置ehcache.xml


<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xsi:noNamespaceSchemaLocation="../config/ehcache.xsd"> 
  <!--diskStore:缓存数据持久化的目录 地址 --> 
  <diskStore path="F:\develop\ehcache" /> 
  <defaultCache  
    maxElementsInMemory="1000"  
    maxElementsOnDisk="10000000" 
    eternal="false"  
    overflowToDisk="false"  
    diskPersistent="true" 
    timeToIdleSeconds="120" 
    timeToLiveSeconds="120"  
    diskExpiryThreadIntervalSeconds="120" 
    memoryStoreEvictionPolicy="LRU"> 
  </defaultCache> 
</ehcache>

5.5 整合测试

在mapper.xml添加ehcache配置:


<!-- 开启二级缓存 --> 
  <!-- 单位:毫秒 --> 
  <cache type="org.mybatis.caches.ehcache.EhcacheCache"> 
    <property name="timeToIdleSeconds" value="12000"/> 
    <property name="timeToLiveSeconds" value="3600"/> 
    <!-- 同ehcache参数maxElementsInMemory --> 
    <property name="maxEntriesLocalHeap" value="1000"/> 
    <!-- 同ehcache参数maxElementsOnDisk --> 
    <property name="maxEntriesLocalDisk" value="10000000"/> 
    <property name="memoryStoreEvictionPolicy" value="LRU"/> 
  </cache>

6 二级缓存的应用场景

对查询频率高,变化频率低的数据建议使用二级缓存。

对于访问多的查询请求且用户对查询结果实时性要求不高,此时可采用mybatis二级缓存技术降低数据库访问量,提高访问速度,业务场景比如:耗时较高的统计分析sql、电话账单查询sql等。

实现方法如下:通过设置刷新间隔时间,由mybatis每隔一段时间自动清空缓存,根据数据变化频率设置缓存刷新间隔flushInterval,比如设置为30分钟、60分钟、24小时等,根据需求而定。

7 mybatis局限性

mybatis二級快取對細粒度的資料層級的快取實現不好,例如如下需求:對商品資訊進行緩存,由於商品資訊查詢訪問量大,但是要求用戶每次都能查詢最新的商品信息,此時如果使用mybatis的二級快取就無法實現當一個商品變化時只刷新該商品的緩存信息而不刷新其它商品的信息,因為mybaits的二級緩存區域以mapper為單位劃分,當一個商品資訊變化會將所有商品資訊的快取資料全部清空。解決此類問題需要在業務層根據需求對資料有針對性快取。

【相關推薦】

1. 特別推薦「php程式設計師工具箱」V0.1版本下載

2. Java免費影片教學

3. 全面解析Java註解

以上是mybatis關於快取的實例詳解的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn