投稿
  1. 首页
  2. 随笔

MyBatis——缓存机制

贴吧推广 • 2022-12-17 • 随笔 • 阅读 40

MyBatis——缓存机制,第1张

MyBatis——缓存机制 缓存机制

文章目录
  • 缓存机制
    • 1、一级缓存
      • 1.1、一级缓存演示
      • 1.2、一级缓存失效的四种情况
    • 2、二级缓存
      • 2.1、缓存相关设置
    • 3、缓存原理图示
    • 4、第三方缓存整合原理 & ehcache

MyBatis 包含一个非常强大的查询缓存特性，它可以非常方便地配置和定制。缓存可以极大的提升查询效率。

MyBatis系统中默认定义了两级缓存：一级缓存和二级缓存。

  1. 默认情况下，只有一级缓存（SqlSession 级别的缓存，也称为本地缓存）开启；
  2. 二级缓存需要手动开启和配置，他是基于 namespace 级别的缓存；
  3. 为了提高扩展性。 MyBatis 定义了缓存接口 Cache。我们可以通过实现 Cache 接口来自定义二级缓存。
1、一级缓存

一级缓存（local cache），即本地缓存, 作用域默认为 sqlSession。当 Session flush 或 close 后, 该 Session 中的所有 Cache 将被清空。

本地缓存不能被关闭，但可以调用 clearCache() 来清空本地缓存，或者改变缓存的作用域。

在 mybatis3.1 之后, 可以配置本地缓存的作用域。在 mybatis.xml 中配置：

localCacheScopeMyBatis利用本地缓存机制防止循环引用和加速重复嵌套查询。默认值为 SESSION，这种情况下会缓存一个会话中执行的所有查询。若设置值为 STATEMENT，本地会话仅用在语句执行上，对相同 SqlSession 的不同调用将不会共享数据。 1.1、一级缓存演示 
@Test
public void testFirstLevelCache() throws IOException {
    SqlSessionFactory sqlSessionFactory = getSqlSessionFactory();
    SqlSession sqlSession = sqlSessionFactory.openSession(true);

    try{
        EmployeeMapper mapper = sqlSession.getMapper(EmployeeMapper.class);
        Employee empById01 = mapper.getEmpById(1);

        System.out.println(empById01);


        //xxx

        Employee empById02 = mapper.getEmpById(1);

        System.out.println(empById02);

        System.out.println(empById01 == empById02); //true
    }finally {
        sqlSession.close();
    }
}

DEBUG 12-29 21:07:48,871 ==>  Preparing: select id,last_name lastName,email,gender from tbl_employee where id = ?  (baseJdbcLogger.java:137) 
DEBUG 12-29 21:07:48,924 ==> Parameters: 1(Integer)  (baseJdbcLogger.java:137) 
DEBUG 12-29 21:07:48,954 <==      Total: 1  (baseJdbcLogger.java:137) 
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}
true

在查询结果中可以看到，sql 语句只传递了一次。empById01 对象和 empById02 对象的地址相同，是同一个对象。

同一次会话期间只要查询过的数据都会保存在当前 SqlSession 的一个 Map 中。

1.2、一级缓存失效的四种情况

一级缓存失效的四种情况：

  1. 不同的 SqlSession 对应不同的一级缓存；
  2. 同一个 SqlSession 但是查询条件不同；
  3. 同一个 SqlSession 两次查询期间执行了任何一次增删改 *** 作；
  4. 同一个 SqlSession 两次查询期间手动清空了缓存。
@Test
public void testFirstLevelCache() throws IOException {
    SqlSessionFactory sqlSessionFactory = getSqlSessionFactory();
    SqlSession sqlSession = sqlSessionFactory.openSession(true);

    try{
        EmployeeMapper mapper = sqlSession.getMapper(EmployeeMapper.class);
        Employee empById01 = mapper.getEmpById(1);

        System.out.println(empById01);
        

        System.out.println("---------------1、sqlSession不同---------------");
        //1、sqlSession不同
        SqlSession sqlSession1 = sqlSessionFactory.openSession(true);
        EmployeeMapper mapper1 = sqlSession1.getMapper(EmployeeMapper.class);
        Employee empById02 = mapper1.getEmpById(1);

        System.out.println(empById02);
        

        System.out.println(empById01 == empById02); //false

        sqlSession1.close();

        System.out.println("---------------2、sqlSession相同，查询条件不同---------------");
        //2、sqlSession相同，查询条件不同
        Employee empById03 = mapper.getEmpById(3);
        System.out.println(empById03);
        

        System.out.println(empById01 == empById03); //true


        System.out.println("---------------3、sqlSession相同，两次查询之间执行了增删改 *** 作---------------");
        //3、sqlSession相同，两次查询之间执行了增删改 *** 作
        mapper.addEmp(new Employee(null, "testCache", "cache", "1"));
        
        System.out.println("数据添加成功！");

        Employee empById04 = mapper.getEmpById(1);
        System.out.println(empById04);
        

        System.out.println(empById01 == empById04); //false


        System.out.println("---------------4、sqlSession相同，手动清除了一级缓存---------------");
        //4、sqlSession相同，手动清除了一级缓存
        sqlSession.clearCache();

        Employee empById05 = mapper.getEmpById(1);
        System.out.println(empById05);
        

        System.out.println(empById01 == empById05); //false
    }finally {
        sqlSession.close();
    }
}
2、二级缓存

二级缓存（second level cache），全局作用域缓存。二级缓存默认不开启，需要手动配置。MyBatis 提供二级缓存的接口以及实现，缓存实现要求 POJO 实现 Serializable 接口。二级缓存在 SqlSession 关闭或提交之后才会生效。

二级缓存：（全局缓存）：基于 namespace 级别的缓存，一个 namespace 对应一个二级缓存：

工作机制：

  1. 一个会话，查询一条数据；这个数据就会被放在当前会话的一级缓存中；

  2. 如果当前会话关闭，一级缓存的数据会被保存到二级缓存中；新的会话查询信息，就可以参照二级缓存；

  3. sqlSession === EmployeeMapper ==> Employee

    ​ DepartmentMapper ==> Department

    不同 namespace 查出的数据会放在自己对应的缓存中（不同的 map）

使用：

  1. 开启全局二级缓存的配置：；
  2. 去 xxxmapper.xml 中配置使用二级缓存：
  3. 我们的 POJO 需要实现序列化接口

mybatis-config.xml：

EmployeeMapper.xml：

缓存相关属性：

属性描述eviction：缓存回收策略LRU – 最近最少使用的：移除最长时间不被使用的对象
FIFO – 先进先出：按对象进入缓存的顺序来移除它们
SOFT – 软引用：移除基于垃圾回收器状态和软引用规则的对象
WEAK – 弱引用：更积极地移除基于垃圾收集器状态和弱引用规则的对象
默认的是 LRUflushInterval：刷新间隔，单位毫秒默认情况是不设置，也就是没有刷新间隔，缓存仅仅调用语句时刷新size：引用数目，正整数代表缓存最多可以存储多少个对象，太大容易导致内存溢出readOnly：只读true：只读缓存；会给所有调用者返回缓存对象的相同实例。 因此这些对象不能被修改。这提供了很重要的性能优势。
false：读写缓存； 会返回缓存对象的拷贝（通过序列化）。这会慢一些，但是安全，因此默认是 false。type：指定自定义缓存类名，实现 cache 接口即可自定义缓存

Employee.java：

public class Employee implements Serializable {

测试：

	
@Test
public void testSecondLevelTest() throws IOException {
    SqlSessionFactory sqlSessionFactory = getSqlSessionFactory();
    SqlSession sqlSession01 = sqlSessionFactory.openSession(true);
    SqlSession sqlSession02 = sqlSessionFactory.openSession(true);

    try {
        //1.
        EmployeeMapper mapper01 = sqlSession01.getMapper(EmployeeMapper.class);

        EmployeeMapper mapper02 = sqlSession02.getMapper(EmployeeMapper.class);

        Employee empById01 = mapper01.getEmpById(1);
        System.out.println(empById01);
        sqlSession01.close();

        //第二次查询是从二级缓存中拿到的数据，并没有发送新的sql
        Employee empById02 = mapper02.getEmpById(1);
        System.out.println(empById02);

        sqlSession01.close();
        sqlSession02.close();
    }finally {

    }
}

DEBUG 12-30 10:17:48,578 Cache Hit Ratio [mybatis.dao.EmployeeMapper]: 0.0  (LoggingCache.java:60) 
DEBUG 12-30 10:17:48,585 ==>  Preparing: select id,last_name lastName,email,gender from tbl_employee where id = ?  (baseJdbcLogger.java:137) 
DEBUG 12-30 10:17:48,614 ==> Parameters: 1(Integer)  (baseJdbcLogger.java:137) 
DEBUG 12-30 10:17:48,632 <==      Total: 1  (baseJdbcLogger.java:137) 
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}
WARN  12-30 10:17:48,650 As you are using functionality that deserializes object streams, it is recommended to define the JEP-290 serial filter. Please refer to https://docs.oracle.com/pls/topic/lookup?ctx=javase15&id=GUID-8296D8E8-2B93-4B9A-856E-0A65AF9B8C66  (SerialFilterChecker.java:45) 
DEBUG 12-30 10:17:48,653 Cache Hit Ratio [mybatis.dao.EmployeeMapper]: 0.5  (LoggingCache.java:60) 
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}
2.1、缓存相关设置

  1. 全局 setting 的 cacheEnable

    配置二级缓存的开关。一级缓存一直是打开的。

  2. select 标签的 useCache 属性

    配置这个 select 是否使用二级缓存。一级缓存一直是使用的。

  3. sql 标签的 flushCache 属性

    增删改默认 flushCache=true。 sql 执行以后，会同时清空一级和二级缓存。查询默认 flushCache=false。

  4. sqlSession.clearCache()

    只是用来清除一级缓存。

  5. localCacheScope

    当在某一个作用域（一级缓存 Session/二级缓存 Namespaces）进行了 C/U/D *** 作后，默认该作用域下所有 select 中的缓存将被 clear。

3、缓存原理图示

4、第三方缓存整合原理 & ehcache

下载：https://github.com/mybatis/ehcache-cache/releases

EhCache 是一个纯 Java 的进程内缓存框架，具有快速、精干等特点，是 Hibernate 中默认的 CacheProvider ：MyBatis 定义了Cache 接口方便我们进行自定义扩展 。

步骤：

  1. 导入ehcache 包，以及整合包，日志包：

    ehcache-core-2.6.8.jar、mybatis-ehcache-1.0.3.jar 、slf4j-api-1.6.1.jar、slf4j-log4j12-1.6.2.jar

  2. 编写 ehcache.xml 配置文件；

  3. 配置 cache 标签：

参照缓存： 若想在命名空间中共享相同的缓存配置和实例。可以使用 cache-ref 元素来引用另外一个缓存。

ehcache.xml：

EmployeeMapper.xml

测试：

DEBUG 12-30 11:04:22,803 Configuring ehcache from ehcache.xml found in the classpath: file:/G:/work/coding/java/MyBatis/MyBatis_05_cache/out/production/MyBatis_01_HelloWorld/ehcache.xml  (ConfigurationFactory.java:132) 
DEBUG 12-30 11:04:22,806 Configuring ehcache from URL: file:/G:/work/coding/java/MyBatis/MyBatis_05_cache/out/production/MyBatis_01_HelloWorld/ehcache.xml  (ConfigurationFactory.java:98) 
DEBUG 12-30 11:04:22,807 Configuring ehcache from InputStream  (ConfigurationFactory.java:150) 
DEBUG 12-30 11:04:22,830 Ignoring ehcache attribute xmlns:xsi  (BeanHandler.java:271) 
DEBUG 12-30 11:04:22,831 Ignoring ehcache attribute xsi:nonamespaceSchemaLocation  (BeanHandler.java:271) 
DEBUG 12-30 11:04:22,833 Disk Store Path: D:44ehcache  (DiskStoreConfiguration.java:141) 
DEBUG 12-30 11:04:22,845 Creating new CacheManager with default config  (CacheManager.java:1036) 
DEBUG 12-30 11:04:22,851 propertiesString is null.  (PropertyUtil.java:88) 
DEBUG 12-30 11:04:22,862 No CacheManagerEventListenerFactory class specified. Skipping...  (ConfigurationHelper.java:185) 
DEBUG 12-30 11:04:23,331 No BootstrapCacheLoaderFactory class specified. Skipping...  (Cache.java:955) 
DEBUG 12-30 11:04:23,334 CacheWriter factory not configured. Skipping...  (Cache.java:929) 
DEBUG 12-30 11:04:23,336 No CacheExceptionHandlerFactory class specified. Skipping...  (ConfigurationHelper.java:96) 
DEBUG 12-30 11:04:23,358 Initialized net.sf.ehcache.store.MemoryStore for mybatis.dao.EmployeeMapper  (MemoryStore.java:152) 
DEBUG 12-30 11:04:23,365 Using diskstore path D:44ehcache  (DiskStorePathManager.java:169) 
DEBUG 12-30 11:04:23,366 Holding exclusive lock on D:44ehcache.ehcache-diskstore.lock  (DiskStorePathManager.java:170) 
DEBUG 12-30 11:04:23,366 Failed to delete file mybatis%002edao%002e%0045mployee%004dapper.data  (DiskStorageFactory.java:860) 
DEBUG 12-30 11:04:23,366 Failed to delete file mybatis%002edao%002e%0045mployee%004dapper.index  (DiskStorageFactory.java:860) 
DEBUG 12-30 11:04:23,373 Matching data file missing (or empty) for index file. Deleting index file D:44ehcachemybatis%002edao%002e%0045mployee%004dapper.index  (DiskStorageFactory.java:168) 
DEBUG 12-30 11:04:23,373 Failed to delete file mybatis%002edao%002e%0045mployee%004dapper.index  (DiskStorageFactory.java:860) 
DEBUG 12-30 11:04:23,378 Initialised cache: mybatis.dao.EmployeeMapper  (Cache.java:1165) 
DEBUG 12-30 11:04:23,378 CacheDecoratorFactory not configured for defaultCache. Skipping for 'mybatis.dao.EmployeeMapper'.  (ConfigurationHelper.java:354) 
DEBUG 12-30 11:04:23,412 Cache Hit Ratio [mybatis.dao.EmployeeMapper]: 0.0  (LoggingCache.java:60) 
DEBUG 12-30 11:04:23,419 ==>  Preparing: select id,last_name lastName,email,gender from tbl_employee where id = ?  (baseJdbcLogger.java:137) 
DEBUG 12-30 11:04:23,447 ==> Parameters: 1(Integer)  (baseJdbcLogger.java:137) 
DEBUG 12-30 11:04:23,463 <==      Total: 1  (baseJdbcLogger.java:137) 
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}
DEBUG 12-30 11:04:23,477 put added 0 on heap  (Segment.java:425) 
DEBUG 12-30 11:04:23,480 Cache Hit Ratio [mybatis.dao.EmployeeMapper]: 0.5  (LoggingCache.java:60) 
Employee{id=1, lastName='Admin', email='[email protected]', gender='0', dept=null}

引用缓存 DepartmentMapper.xml：

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/zaji/5685498.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
贴吧推广 贴吧推广 一级用户组
0 0
上一篇 2022-12-17
下一篇 2022-12-17

发表评论

登录后才能评论

评论列表（0条）

保存