网站导航
> 文章列表 > 【Mybatis】5—缓存

【Mybatis】5—缓存

网友: 文章列表 2024-03-21 17:28:46

【Mybatis】5—缓存

⭐⭐⭐⭐⭐⭐
Github主页👉https://github.com/A-BigTree
笔记链接👉https://github.com/A-BigTree/Code_Learning
⭐⭐⭐⭐⭐⭐

如果可以，麻烦各位看官顺手点个star~😊

如果文章对你有所帮助，可以点赞👍收藏⭐支持一下博主~😆

文章目录

  • 6 缓存
    • 6.1 简介
      • 6.1.1 缓存机制介绍
      • 6.1.2 一级缓存和二级缓存
        • 使用顺序
        • 效用范围
    • 6.2 整合EHCache
      • 6.2.1 EHCache简介
      • 6.2.2 整合操作
        • Mybatis环境
        • 添加依赖
        • 整合EHCache
      • 6.2.3 EHCache配置文件说明
    • 6.3 缓存的的基本原理
      • 6.3.1 Cache接口
        • Cache接口的重要地位
        • Cache接口中的方法
        • 缓存的本质
      • 6.3.2 PepetualCache
      • 6.3.3 一级缓存机制
        • `query()`方法
        • `queryFromDatabase()`方法
      • 6.3.4 二级缓存机制

6 缓存

6.1 简介

6.1.1 缓存机制介绍

在这里插入图片描述

6.1.2 一级缓存和二级缓存

使用顺序

在这里插入图片描述

查询的顺序是：

  • 先查询二级缓存，因为二级缓存中可能会有其他程序已经查出来的数据，可以拿来直接使用；
  • 如果二级缓存没有命中，再查询一级缓存；
  • 如果一级缓存也没有命中，则查询数据库；
  • SqlSession关闭之前，一级缓存中的数据会写入二级缓存；

效用范围

  • 一级缓存：SqlSession级别；

  • 二级缓存：SqlSessionFactory级别；

在这里插入图片描述

6.2 整合EHCache

6.2.1 EHCache简介

官网地址：https://www.ehcache.org/

Ehcache is an open source, standards-based cache that boosts performance, offloads your database, and simplifies scalability. It’s the most widely-used Java-based cache because it’s robust, proven, full-featured, and integrates with other popular libraries and frameworks. Ehcache scales from in-process caching, all the way to mixed in-process/out-of-process deployments with terabyte-sized caches.

6.2.2 整合操作

Mybatis环境

在Mybatis环境下整合EHCache，前提当然是要先准备好Mybatis的环境。

添加依赖

<!-- Mybatis EHCache整合包 -->
<dependency><groupId>org.mybatis.caches</groupId><artifactId>mybatis-ehcache</artifactId><version>1.2.1</version>
</dependency>

整合EHCache

创建EHCache配置文件ehcache.xml：

<?xml version="1.0" encoding="utf-8" ?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:noNamespaceSchemaLocation="../config/ehcache.xsd"><!-- 磁盘保存路径 --><diskStore path="D:\\atguigu\\ehcache"/><defaultCachemaxElementsInMemory="1000"maxElementsOnDisk="10000000"eternal="false"overflowToDisk="true"timeToIdleSeconds="120"timeToLiveSeconds="120"diskExpiryThreadIntervalSeconds="120"memoryStoreEvictionPolicy="LRU"></defaultCache>
</ehcache>

在查询操作所在的Mapper配置文件中，找到之前的cache标签：

<cache type="org.mybatis.caches.ehcache.EhcacheCache"/>

6.2.3 EHCache配置文件说明

当借助CacheManager.add("缓存名称")创建Cache时，EhCache便会采用<defalutCache/>指定的的管理策略。

defaultCache标签各属性说明：

属性名 是否必须 作用
maxElementsInMemory 是 在内存中缓存的element的最大数目
maxElementsOnDisk 是 在磁盘上缓存的element的最大数目，若是0表示无穷大
eternal 是 设定缓存的elements是否永远不过期。
如果为true，则缓存的数据始终有效，
如果为false那么还要根据timeToIdleSeconds、timeToLiveSeconds判断
overflowToDisk 是 设定当内存缓存溢出的时候是否将过期的element缓存到磁盘上
timeToIdleSeconds 否 当缓存在EhCache中的数据前后两次访问的时间超过timeToIdleSeconds的属性取值时，
这些数据便会删除，默认值是0,也就是可闲置时间无穷大
timeToLiveSeconds 否 缓存element的有效生命期，默认是0.,也就是element存活时间无穷大
diskSpoolBufferSizeMB 否 DiskStore(磁盘缓存)的缓存区大小。默认是30MB。每个Cache都应该有自己的一个缓冲区
diskPersistent 否 在VM重启的时候是否启用磁盘保存EhCache中的数据，默认是false。
diskExpiryThreadIntervalSeconds 否 磁盘缓存的清理线程运行间隔，默认是120秒。每个120s，
相应的线程会进行一次EhCache中数据的清理工作
memoryStoreEvictionPolicy 否 当内存缓存达到最大，有新的element加入的时候， 移除缓存中element的策略。
默认是LRU（最近最少使用），可选的有LFU（最不常使用）和FIFO（先进先出）

LFU：Least Frequently Used，最不经常使用。在执行缓存回收时，删除访问数量最低的数据。Bug是访问量先高后低的数据无法删除；

LRU：Least Recently Used：

  • 最近最少使用。在执行缓存回收时，删除近期访问数量最低的数据。典型案例：HashMap；
  • 最近最久使用。在执行缓存回收时，删除近期闲置时间最长的数据。典型案例：Redis；

FIFO：First In First Out，先进先出。使用队列维护缓存数据，先存入的数据会被先删除；

6.3 缓存的的基本原理

6.3.1 Cache接口

Cache接口的重要地位

org.apache.ibatis.cache.Cache接口：所有缓存都必须实现的顶级接口

在这里插入图片描述

Cache接口中的方法

方法名 作用
putObject(Object, Object) 将对象存入缓存
getObject(Object) 从缓存中取出对象
removeObject(Object) 从缓存中删除对象

缓存的本质

根据Cache接口中方法的声明我们能够看到，缓存的本质是一个Map。

6.3.2 PepetualCache

在这里插入图片描述

org.apache.ibatis.cache.impl.PerpetualCache是Mybatis的默认缓存，也是Cache接口的默认实现。Mybatis一级缓存和自带的二级缓存都是通过PerpetualCache来操作缓存数据的。但是这就奇怪了，同样是PerpetualCache这个类，怎么能区分出来两种不同级别的缓存呢？

其实很简单，调用者不同。

  • 一级缓存：由BaseExecutor调用PerpetualCache；
  • 二级缓存：由CachingExecutor调用PerpetualCache，而CachingExecutor可以看做是对BaseExecutor的装饰；

6.3.3 一级缓存机制

在这里插入图片描述

org.apache.ibatis.executor.BaseExecutor类中的关键方法：

query()方法

public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());if (closed) {throw new ExecutorException("Executor was closed.");}if (queryStack == 0 && ms.isFlushCacheRequired()) {clearLocalCache();}List<E> list;try {queryStack++;// 尝试从本地缓存中获取数据list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;if (list != null) {handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);} else {// 如果本地缓存中没有查询到数据，则查询数据库list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);}} finally {queryStack--;}if (queryStack == 0) {for (org.apache.ibatis.executor.BaseExecutor.DeferredLoad deferredLoad : deferredLoads) {deferredLoad.load();}// issue #601deferredLoads.clear();if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {// issue #482clearLocalCache();}}return list;
}

queryFromDatabase()方法

private <E> List<E> queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {List<E> list;localCache.putObject(key, EXECUTION_PLACEHOLDER);try {// 从数据库中查询数据list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);} finally {localCache.removeObject(key);}// 将数据存入本地缓存localCache.putObject(key, list);if (ms.getStatementType() == StatementType.CALLABLE) {localOutputParameterCache.putObject(key, parameter);}return list;
}

6.3.4 二级缓存机制

在这里插入图片描述

网络标签：

相关问题