mybatis二级缓存使用步骤,springboot mybatis缓存

  mybatis二级缓存使用步骤,springboot mybatis缓存

  00-1010前言mybatis的一级缓存和二级缓存的概念pom介绍依赖于application.properties文件配置映射器. xml文件配置cache-ref完整示例代码踩坑参考

  00-1010以下内容大部分来自网上相关帖子和官网。我简单写了一个demo,体验了一下。个人感觉mybatis的缓存不太合适。

  查询缓存时,发生更新操作时会刷新缓存,尤其是查询多个表时,会很难控制。那些需要缓存的热数据应该提取出来放在redis上。

  00-1010之所以叫“L2缓存”,是相对于“L1缓存”而言的。既然有一级缓存,为什么还要提供二级缓存?众所周知,在一级缓存中,当不同的会话进行相同的SQL查询时,它们会对数据库进行两次查询。这显然是一种浪费。因为SQL查询是相同的,所以没有必要再次检查数据库。直接用缓存的数据就行了。这个想法是我的巴蒂斯L2缓存的初衷。

  另外,Spring和MyBatis集成时,每次查询后必须关闭sqlsession,关闭后数据会被清除。所以MyBatis和Spring整合后,一级缓存就没有意义了。如果打开二级缓存,在sqlsession关闭后,sqlsession的一级缓存中的数据将被添加到mapper命名空间的二级缓存中。这样,sqlsession关闭后缓存仍然存在。

  

目录

依赖项依赖项groupIdorg.mybatis.spring.boot/groupId artifactId mybatis-spring-boot-starter/artifactId version 2 . 2 . 2/version/dependency依赖项groupId MySQL/groupId artifactId MySQL-connector-Java/artifactId scope runtime/scope/dependency依赖项

 

  

前言

Spring . data source . type=com . zax xer . hikari . hikari data source # Spring JDBC数据源的配置需要mysql-connector-java驱动程序依赖Spring . data source . driver-class-name=com . MySQL . CJ . JDBC . driver Spring . data source . URL=JDBC 3360 MySQL 3360//127 . 0 . 0 . 133603306/ge frm?use unicode=true character encoding=utf-8 use SSL=false useinformationschema=true server time zone=Asia/Shanghai autore connect=truefailOverReadOnly=false spring . data source . username=root spring . data source . password=123456 # Mybatis配置Mybatis . mapper-locations=class path 3360 mapper/* . XML Mybatis . type-aliases-package=com . example . Mybatis _ cache . beanmybatis . configuration . map-下划线-to-camel-case=true# Mybatis

 

  

mybatis 一级缓存和二级缓存的概念

?xml版本=1.0 编码=UTF-8 ?DOCTYPE mapper PUBLIC -//my batis . org//DTD

 

  Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.example.mybatis_cache.mapper.BscDictInfoTestMapper">    <!-- 这个cache 是关键 -->    <cache eviction="LRU" flushInterval="100000" readOnly="true" size="1024"/>    <!--可以通过设置useCache来规定这个sql是否开启缓存,ture是开启,false是关闭,刷新缓存:flushCache="true"  useCache="true"-->    <select id="selectAll" resultType="com.example.mybatis_cache.bean.BscDictInfoTestDO">        select *        from bsc_dict_info_test    </select>    <!-- 多个命名空间缓存共享 级联标签 cache-ref 指定namespace即可 -->    <!--<cache-ref namespace=""/> --></mapper>默认情况下,只启用了本地的会话缓存,它仅仅对一个会话中的数据进行缓存。 要启用全局的二级缓存,只需要在你的 SQL 映射文件中(XXXMapper.xml)添加一行:<cache/>这个简单语句的效果如下:

  映射语句文件中的所有 select 语句的结果将会被缓存。映射语句文件中的所有 insert、update 和 delete 语句会刷新缓存。缓存会使用最近最少使用算法(LRU, Least Recently Used)算法来清除不需要的缓存。缓存不会定时进行刷新(也就是说,没有刷新间隔)。缓存会保存列表或对象(无论查询方法返回哪种)的 1024 个引用。缓存会被视为读/写缓存,这意味着获取到的对象并不是共享的,可以安全地被调用者修改,而不干扰其他调用者或线程所做的潜在修改。

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

这个更高级的配置创建了一个 FIFO 缓存,每隔 60 秒刷新,最多可以存储结果对象或列表的 512 个引用,而且返回的对象被认为是只读的,因此对它们进行修改可能会在不同线程中的调用者产生冲突。

 

  可用的清除策略有:

  LRU – 最近最少使用:移除最长时间不被使用的对象。 FIFO – 先进先出:按对象进入缓存的顺序来移除它们。 SOFT – 软引用:基于垃圾回收器状态和软引用规则移除对象。 WEAK –弱引用:更积极地基于垃圾收集器状态和弱引用规则移除对象。 默认的清除策略是 LRU。

  flushInterval(刷新间隔)属性可以被设置为任意的正整数,设置的值应该是一个以毫秒为单位的合理时间量。 默认情况是不设置,也就是没有刷新间隔,缓存仅仅会在调用语句时刷新。

  size(引用数目)属性可以被设置为任意正整数,要注意欲缓存对象的大小和运行环境中可用的内存资源。默认值是 1024。

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

  提示:二级缓存是事务性的。这意味着,当 SqlSession 完成并提交时,或是完成并回滚,但没有执行 flushCache=true 的 insert/delete/update 语句时,缓存会获得更新。

  

 

  

cache-ref

回想一下上一节的内容,对某一命名空间的语句,只会使用该命名空间的缓存进行缓存或刷新。 但你可能会想要在多个命名空间中共享相同的缓存配置和实例。要实现这种需求,你可以使用 cache-ref 元素来引用另一个缓存。

 

  

<cache-ref namespace="com.someone.application.data.SomeMapper"/>

 

  

完整示例代码

数据库表结构

 

  

/* Navicat Premium Data Transfer Source Server         : localhost_3306 Source Server Type    : MySQL Source Server Version : 80015 Source Host           : localhost:3306 Source Schema         : gefrm Target Server Type    : MySQL Target Server Version : 80015 File Encoding         : 65001 Date: 17/05/2022 16:02:21*/SET NAMES utf8mb4;SETFOREIGN_KEY_CHECKS = 0;-- ------------------------------ Table structure for bsc_dict_info_test-- ----------------------------DROP TABLE IF EXISTS `bsc_dict_info_test`;CREATE TABLE `bsc_dict_info_test`(    `dict_id`        varchar(10) CHARACTER SET utf8 COLLATE utf8_general_ci   NOT NULL DEFAULT COMMENT 字典标识,    `dict_name`      varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci  NOT NULL DEFAULT COMMENT 字典名称,    `dict_sitm_id`   varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci   NOT NULL DEFAULT COMMENT 字典子项标识,    `dict_sitm_name` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci  NOT NULL DEFAULT COMMENT 字典子项名称,    `suse_flag`      char(1) CHARACTER SET utf8 COLLATE utf8_general_ci       NOT NULL DEFAULT 0 COMMENT 启用标志,    `disp_orde`      int(11) NOT NULL DEFAULT 0 COMMENT 展示顺序,    `memo`           varchar(4000) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT COMMENT 备注) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;-- ------------------------------ Records of bsc_dict_info_test-- ----------------------------INSERT INTO `bsc_dict_info_test`VALUES (bbbbbtest, 担保人/被担保人与上市公司关联关系, 999, 无关联关系, 0, 190, 1);INSERT INTO `bsc_dict_info_test`VALUES (aaaaatest, 担保人/被担保人与上市公司关联关系, 999, 无关联关系, 0, 190, 1);INSERT INTO `bsc_dict_info_test`VALUES (bbbbbtest, 担保人/被担保人与上市公司关联关系, 999, 无关联关系, 0, 190, 1);INSERT INTO `bsc_dict_info_test`VALUES (aaaaatest, 担保人/被担保人与上市公司关联关系, 999, 无关联关系, 0, 190, 1);INSERT INTO `bsc_dict_info_test`VALUES (bbbbbtest, 担保人/被担保人与上市公司关联关系, 999, 无关联关系, 0, 190, );SETFOREIGN_KEY_CHECKS = 1;

bean 类

 

  

package com.example.mybatis_cache.bean;import lombok.Builder;import lombok.Data;import java.io.Serializable;/** * @author 起凤 * @description: TODO * @date 2022/4/15 */@Data@Builderpublic class BscDictInfoTestDO implements Serializable {    private String dictId;    private String dictName;    private String dictSitmId;    private String dictSitmName;    private String suseFlag;    private String dispOrde;    private String memo;}

mapper

 

  

package com.example.mybatis_cache.mapper;import com.example.mybatis_cache.bean.BscDictInfoTestDO;import org.apache.ibatis.annotations.Mapper;import java.util.List;/** * @author 起凤 * @description: TODO * @date 2022/4/15 */@Mapperpublic interface BscDictInfoTestMapper {    /**     * 查询所有     *     * @return     */    List<BscDictInfoTestDO> selectAll();}

service

 

  

package com.example.mybatis_cache.service;/** * 测试服务 * * @author 起凤 * @description: TODO * @date 2022/4/15 */public interface BscDictService {    void info(String name, int age);}

impl

 

  

package com.example.mybatis_cache.service.impl;import com.example.mybatis_cache.bean.BscDictInfoTestDO;import com.example.mybatis_cache.mapper.BscDictInfoTestMapper;import com.example.mybatis_cache.service.BscDictService;import lombok.extern.slf4j.Slf4j;import org.springframework.stereotype.Component;import javax.annotation.Resource;import java.util.List;/** * @author 起凤 * @description: TODO * @date 2022/4/15 */@Slf4j@Componentpublic class BscDictServiceImpl implements BscDictService {    @Resource    BscDictInfoTestMapper mapper;    @Override    public void info(String name, int age) {        log.warn("name:{}, age:{}", name, age);        List<BscDictInfoTestDO> list = mapper.selectAll();        list.forEach(item -> {            log.error("{}", item);        });    }}

测试类

 

  

package com.example.mybatis_cache.service.impl;import com.example.mybatis_cache.service.BscDictService;import com.mysql.cj.xdevapi.SessionFactory;import lombok.extern.slf4j.Slf4j;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import static org.junit.jupiter.api.Assertions.*;/** * @author 起凤 * @description: TODO * @date 2022/5/16 */@Slf4j@SpringBootTestclass BscDictServiceImplTest {    @Autowired    private BscDictService dictService;    @Test    void levelOneCacheTest() {        dictService.info("a", 1);        log.warn("======================== 分割线  ======================");        dictService.info("a", 2);    }    @Test    void testRawLevelOne() {    }}

测试结果

 

  执行2次查询,只执行了一次,第二次命中的是缓存

  

 

  

 

  

踩坑

启动抛异常:

 

  

Error creating bean with name 'cacheAutoConfigurationValidator' defined in class path resource [org/springframework/boot/autoconfigure/cache/CacheAutoConfiguration.class]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: No cache manager could be auto-configured, check your configuration (caching type is 'EHCACHE')

 

  

解决 添加依赖 spring-boot-starter-cache

 

  

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-cache</artifactId></dependency>

启动抛异常:

 

  

Error creating bean with name 'cacheManager' defined in class path resource [org/springframework/boot/autoconfigure/cache/EhCacheCacheConfiguration.class]: Unsatisfied dependency expressed through method 'cacheManager' parameter 1; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'ehCacheCacheManager' defined in class path resource [org/springframework/boot/autoconfigure/cache/EhCacheCacheConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [net.sf.ehcache.CacheManager]: Factory method 'ehCacheCacheManager' threw exception; nested exception is java.lang.IllegalArgumentException: Cache configuration does not exist 'ServletContext resource [/ehcache.xml]'

 

  

解决:注意classpath:不能少

 

  

spring.cache.ehcache.config=classpath:ehcache.xml

 

  

参考资料

MyBatis二级缓存介绍mybatis官网中文MyBatis 二级缓存全详解Spring Cache和EhCache实现缓存管理第四篇:SpringBoot中Cache缓存的使用

 

  到此这篇关于Springboot整合mybatis开启二级缓存的实现示例的文章就介绍到这了,更多相关Springboot mybatis二级缓存内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT!

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: