架构实战篇:MyBatis一级、二级,并整合ehcache分布式缓存的使用,附演示实例

浅殇忆流年 2018-09-20 15:31:36 ⋅ 170 阅读

作者:优妹儿
分享链接:https://www.toutiao.com/i6595705901288522243

1.查询缓存

为什么要用缓存?如果缓存中有数据就不用从数据库中获取,大大提高系统性能。mybatis提供一级缓存和二级缓存(查询缓存),用于减轻数据库压力,提高数据库性能。

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

  • 一级缓存是SqlSession级别的缓存。在操作数据库时需要构造sqlSession对象,在对象中有一个数据结构(HashMap)用于存储缓存数据。不同的sqlSession之间的缓存数据区域(HashMap)是互相不影响的。

  • 二级缓存是mapper级别的缓存,多个sqlSession去操作同一个Mapper的sql语句,多个sqlSession可以共用二级缓存,二级缓存是跨sqlSession的。

2.一级缓存

1)一级缓存工作原理

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

第一次发起查询用户id为1的用户信息,先去找缓存中是否有id为1的用户信息,如果没有,从数据库查询用户信息。得到用户信息,将用户信息存储到一级缓存中。

如果sqlSession去执行commit操作(执行插入、更新、删除),清空sqlSession中的一级缓存,这样做的目的为了让缓存中存储的是最新的信息,避免脏读。

第二次发去查询用户id为1的用户信息,先去找缓存中是否有id为1的用户信息,缓存中有,直接从缓存中获取用户信息。

2)一级缓存测试

mybatis默认支持一级缓存,不需要在配置文件去配置。

按照上边一级缓存原理步骤去测试。

@Test
 public void testCache1() throws Exception{
 SqlSession sqlSession=sqlSessionFactory.openSession();
 UserMapper userMapper=sqlSession.getMapper(UserMapper.class); //下边查询使用一个SqlSession
 //第一次发起请求,查询id为1的用户
 User user1=userMapper.findUserById(1);
 System.out.println(user1); //如果sqlSession去执行commit操作(执行插入、更新、删除),清空sqlSession中的一级缓存,
 //这样做的目的是为了让缓存中存储的是最新的信息,避免脏读。
 //更新user1的信息
 user1.setUsername("测试用户22");
 userMapper.updateUser(user1); //执行commit操作去清空缓存
 sqlSession.commit(); //第二次发起请求,查询id为1的用户
 User user2=userMapper.findUserById(1);
 System.out.println(user2);
 sqlSession.close();
 }

3)一级缓存应用

正式开发,是将mybatis和spring进行整合开发,事务控制在service中。

一个service方法中包括很多Mapper方法调用。

service{

//开始执行时,开启事务,创建SqlSession对象

//第一次调用mapper的方法findUserById(1)

//第二次调用mapper的方法findUserById(1),从一级缓存中取数据

//方法结束,sqlSession关闭

}

如果是执行两次service调用查询相同的用户信息,不走一级缓存,因为session方法结束,sqlSession就关闭,一级缓存就清空。

3.二级缓存

1)二级缓存原理

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

首先开启mybatis的二级缓存。

sqlSession1去查询用户id为1的用户信息,查询到用户信息后悔讲查询数据存储到二级缓存中。

如果sqlSession3去执行相同mapper下的sql,执行commit提交,会清空该mapper下的二级缓存区域的数据。

sqlSession2去查询用户id为1的用户信息,去缓存中找是否存在数据,如果存在直接从缓存中取出数据。

二级缓存与一级缓存区别:二级缓存的范围更大,多个sqlSession可以共享一个UserMapper的二级缓存区域。UserMapper有一个二级缓存区域(按namespace分),其它mapper也有自己的二级缓存区域(按namespace分)。

每个namespace的mapper都有一个二级缓存区域,两个mapper的namespace如果相同,这两个mapper执行sql查询到的数据将存在相同的二级缓存区域中。

2)开启二级缓存

mybatis的二级缓存是mapper范围级别,除了在SqlMapConfig.xml设置二级缓存的总开关,还要在具体的mapper.xml中开启二级缓存。

在核心配置文件SqlMapConfig.xml中加入:

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

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

在UserMapper.xml中开启二级缓存,UserMapper.xml下的sql执行完成后存储在它的缓存区域(HashMap)。

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

3)调用pojo类实现序列化接口

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

为了将缓存数据取出执行反序列划操作,因为二级缓存数据存储介质多种多样,不一定在内存。可能在硬盘、远程等。

4)测试方法

 @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 user1=userMapper1.findUserById(1);
 System.out.println(user1); //这里执行关闭操作,将sqlSession中的数据写到二级缓存区域
 sqlSession1.close(); //使用sqlSession3执行commit()操作
 User user=userMapper3.findUserById(1);
 user.setUsername("Joanna");
 userMapper3.updateUser(user); //执行提交,清空UserMapper下边的二级缓存
 sqlSession3.commit();
 sqlSession3.close(); //第二次发起请求,查询id为1的用户
 User user2=userMapper2.findUserById(1);
 System.out.println(user2);
 sqlSession2.close();
 }

5)禁用二级缓存

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

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

6)刷新缓存(就是清空缓存)

在mapper的同一个namespace中,如果有其它insert、update、delete操作数据后需要刷新缓存,如果不执行刷新缓存会出现脏读。

设置statement配置中的flushCache="true"属性,默认情况下为true即刷新缓存,如果改成false则不会刷新。使用缓存时如果手动修改数据库表中的查询数据会出现脏读。

<insert id="insertUser" parameterType="cn.itcast.mybatis.po.User" flushCache="true">

总结:一般情况下执行完commit操作都需要刷新缓存,flushCache=true表示刷新缓存,这样可以避免数据库脏读。

7) Mybatis Cache参数

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

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

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

如下例子:

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

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

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

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

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

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

4.mybatis整合ehcache

ehcache是一个纯Java的进程内缓存框架,是一种广泛使用的开源Java分布式缓存,具有快速、精干等特点,是Hibernate中默认的CacheProvider。

1)分布式缓存

为了提高系统并发、性能,一般会系统进行分布式部署(集群部署方式)

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

不使用分布式缓存,缓存的数据在各个服务单独存储,不方便系统开发。所以要使用分布式缓存对缓存数据进行集中管理。

mybatis的特长是sql操作,缓存数据的管理不是mybatis的特长。mybatis无法实现分布式缓存,需要和其它分布式缓存框架进行整合,如:redis、memcached、ehcache等。

2)整合方法(掌握)

mybatis提供了一个cache接口,如果要实现自己的缓存逻辑,实现cache接口开发即可。

mybatis和ehcache整合,mybatis和ehcache整合包中提供了一个cache接口的实现类。

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

mybatis默认的cache实现类是:

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

3)加入ehcache包

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

4)整合ehcache

配置mapper中cache中的type为ehcache对cache接口的实现类型。

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

架构实战篇:MyBatis一级、二级和ehcache分布式缓存的使用,附演示实例

5)加入ehcache的配置文件

在classpath下配置ehcache.xml

<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:noNamespaceSchemaLocation="../config/ehcache.xsd"> <diskStore path="F:developehcache" /> <defaultCache maxElementsInMemory="1000" maxElementsOnDisk="10000000" eternal="false" overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskExpiryThreadIntervalSeconds="120" memoryStoreEvictionPolicy="LRU"> </defaultCache></ehcache>

属性说明:

diskStore:指定数据在磁盘中的存储位置。

defaultCache:当借助CacheManager.add(“demoCache”)创建Cache时,EhCache便会采用<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(先进先出)。

6)测试程序

同3.4

7)二级缓存应用场景

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

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

8)二级缓存局限性

mybatis二级缓存对细粒度的数据级别的缓存实现不好,比如如下需求:对商品信息进行缓存,由于商品信息查询访问量大,但是要求用户每次都能查询最新的商品信息,此时如果使用mybatis的二级缓存就无法实现当一个商品变化时只刷新该商品的缓存信息而不刷新其它商品的信息,因为mybatis的二级缓存区域以mapper为单位划分,当一个商品信息变化会将所有商品信息的缓存数据全部清空。解决此类问题需要再业务层根据需求对数据有针对性缓存。

---------------END----------------

后续的内容同样精彩

长按关注“IT实战联盟”哦



全部评论: 0

    我有话说:

    架构实战使用MyBatis延迟加载模式为数据库减压,演示实例

    MyBatis延迟加载,也称为懒加载,是指在进行关联查询时,按照设置延迟规则推迟对关联对象select查询。延迟加载可以有效减少数据库压力......

    精品推荐:缓存架构实战演练Elastic Job定时实现redis缓存预热、缓存更新

    缓存预热就是系统上线后,将相关缓存数据直接加载到缓存系统。这样就可以避免在用户请求时候,先查询数据库,然后再将数据缓存问题!用户直接查询事先被预热缓存数据!

    架构实战(十四):Spring Boot 多缓存实战

    多场景下不同缓存策略解决方案

    架构实战一个可供中小团队参考微服务架构技术栈

    作者近年一直一线互联网公司(携程,拍拍贷等)开展微服务架构实践,根据我个人一线实践经验和我平时对Spring Cloud调研,我认为Spring Cloud技术栈中有些组件离生产级开发尚有

    架构实战(十二):Spring Boot 分布式Session共享Redis

    分布式Web网站一般都会碰到集群session共享问题,小编整理了一套解决方案,内GitHub 源码地址哦~~~

    架构实战(二)-Spring Boot整合Swagger,让你API可视化

    你还在跟前端对接上花费很多时间而没有效果吗?你还在为写接口文档而烦恼吗?今天就教大家一个接口对接神器...

    架构实战(六):Spring Boot RestTemplate使用

    RestTemplate是Spring提供用于访问Rest服务客户端,RestTemplate提供了多种便捷访问远程Http服务方法,能够大大提高客户端编写效率。

    精品推荐:微服务架构下静态数据通用缓存机制

    分布式系统中,特别是最近很火微服务架构下,有没有或者能不能总结出一个业务静态数据通用缓存处理机制或方案,这文章将结合一些实际研发经验,尝试理清其中存在关键问题以及探寻通用解决之道。

    架构实战(十七):Spring Boot Assembly 整合 thymeleaf

    如何让服务器上 sprig boot 项目升级变方便快捷

    高性能缓存架构设计(超实用

    缓存虽然能够大大减轻存储系统压力,但同时也给架构引入了更多复杂性。

    架构实战(一)-Spring Boot+MyBatis基础架构搭建

    Spring追求一定是简单点简单点,让java开发变得更加简单、容易。瞧瞧告诉你们直接copy就能用哦~~~

    架构实战(三)-Spring Boot架构搭建RESTful API案例

    之前分享了Spring Boot 整合Swagger 让API可视化和前后端分离架构 受到了大家一致好评 ,本节就接着上节代码做了详细查询代码补充和完善搭建RESTful API架构案例。

    SpringBoot+zk+dubbo架构实践(五):搭建微服务电商架构(内GitHub地址)

    集成了mybatis和swagger让接口可视化完成了一些增删改查基础业务,对了还有个分页查询!

    缓存架构设计要点

    缓存典型应用场景和设计要点

    架构实战:认识一下微服务架构

    微服务是一个新兴软件架构,就是把一个大型单个应用程序和服务拆分为数十个支持微服务。

    SpringBoot+zk+dubbo架构实践(四):sb+zk+dubbo框架搭建(内源码GitHub地址)

    案例模拟了一个provider服务提供方和PC、Web两个服务消费方内GitHub源码......

    架构实战(四):Spring Boot整合 Thymeleaf

    Thymeleaf 是一种模板语言。那模板语言或模板引擎是什么?