关键词:
1. 一级缓存测试用例
(1) 默认开启,不需要有什么配置
(2) 示意图
(3) 测试代码
- package com.sohu.tv.cache;
- import org.apache.ibatis.session.SqlSession;
- import org.junit.After;
- import org.junit.Before;
- import org.junit.Test;
- import com.sohu.tv.bean.Player;
- import com.sohu.tv.mapper.PlayerDao;
- import com.sohu.tv.test.mapper.BaseTest;
- /**
- * 一级缓存测试
- *
- * @author leifu
- * @Date 2015-8-3
- * @Time 下午9:51:00
- */
- public class FirstCacheTest extends BaseTest {
- private SqlSession sqlSession;
- private SqlSession sqlSessionAnother;
- @Before
- public void before() {
- sqlSession = sessionFactory.openSession(false);
- sqlSessionAnother = sessionFactory.openSession(false);
- }
- @After
- public void after() {
- sqlSession.close();
- sqlSessionAnother.close();
- }
- @Test
- public void test1() throws Exception {
- PlayerDao playerDao = sqlSession.getMapper(PlayerDao.class);
- Player player = playerDao.getPlayerById(1);
- System.out.println(player);
- playerDao = sqlSession.getMapper(PlayerDao.class);
- player = playerDao.getPlayerById(1);
- System.out.println(player);
- playerDao = sqlSessionAnother.getMapper(PlayerDao.class);
- player = playerDao.getPlayerById(1);
- System.out.println(player);
- }
- @Test
- public void test2() throws Exception {
- PlayerDao playerDao = sqlSession.getMapper(PlayerDao.class);
- Player player = playerDao.getPlayerById(1);
- System.out.println(player);
- //1. session清除或者提交
- // sqlSession1.commit();
- // sqlSession.clearCache();
- //2. 增删改查
- // playerDao.savePlayer(new Player(-1, "abcd", 13));
- // playerDao.updatePlayer(new Player(4, "abcd", 13));
- playerDao.deletePlayer(4);
- player = playerDao.getPlayerById(1);
- System.out.println(player);
- }
- }
2、二级缓存(自带 PerpetualCache)
(0) 示意图
(1) 二级缓存需要开启
总配置文件中,二级缓存也是开启的,不需要设置
- <setting name="cacheEnabled" value="true"/>
mapper级别的cache需要开启,在对应的mapper.xml写入
- <!--开启本mapper的二级缓存-->
- <cache/>
(2) 实体类在二级缓存中需要进行序列化,所以所有实体类需要实现Serializable
(3) 示例:
- package com.sohu.tv.cache;
- import org.apache.ibatis.session.SqlSession;
- import org.junit.After;
- import org.junit.Before;
- import org.junit.Test;
- import com.sohu.tv.bean.Player;
- import com.sohu.tv.mapper.PlayerDao;
- import com.sohu.tv.test.mapper.BaseTest;
- /**
- * 二级缓存测试
- *
- * @author leifu
- * @Date 2015-8-3
- * @Time 下午10:10:34
- */
- public class SecondCacheTest extends BaseTest {
- private SqlSession sqlSession1 = sessionFactory.openSession();
- private SqlSession sqlSession2 = sessionFactory.openSession();
- private SqlSession sqlSession3 = sessionFactory.openSession();
- private PlayerDao playerDao1;
- private PlayerDao playerDao2;
- private PlayerDao playerDao3;
- @Before
- public void before() {
- sqlSession1 = sessionFactory.openSession(false);
- sqlSession2 = sessionFactory.openSession(false);
- sqlSession3 = sessionFactory.openSession(false);
- playerDao1 = sqlSession1.getMapper(PlayerDao.class);
- playerDao2 = sqlSession2.getMapper(PlayerDao.class);
- playerDao3 = sqlSession3.getMapper(PlayerDao.class);
- }
- @After
- public void after() {
- sqlSession1.close();
- sqlSession2.close();
- sqlSession3.close();
- }
- @Test
- public void test1() throws Exception {
- int targetId = 1;
- //session1 查询并提交
- Player player1 = playerDao1.getPlayerById(targetId);
- System.out.println("player1: " + player1);
- sqlSession1.commit();
- //session2 命中后,更新并提交清空缓存
- Player player2 = playerDao2.getPlayerById(targetId);
- System.out.println("player2: " + player2);
- player2.setAge(15);
- playerDao2.update(player2);
- sqlSession2.commit();
- //session3 不命中
- Player player3 = playerDao3.getPlayerById(targetId);
- System.out.println("player3: " + player3);
- }
- @Test
- public void test2() throws Exception {
- int one = 1;
- int two = 2;
- //session1 查询并提交
- Player player1 = playerDao1.getPlayerById(one);
- playerDao1.getPlayerById(two);
- System.out.println("player1: " + player1);
- sqlSession1.commit();
- //session2 命中后,更新并提交清空缓存
- Player player2 = playerDao2.getPlayerById(one);
- System.out.println("player2: " + player2);
- player2.setAge(15);
- playerDao2.updatePlayer(player2);
- sqlSession2.commit();
- //session3 不命中
- Player player3 = playerDao3.getPlayerById(two);
- System.out.println("player3: " + player3);
- }
- }
(4) 重要日志:
3、二级缓存(Redis版)
(1) redis使用一个简单的单点实例作为数据源:
引入jedis pom依赖:
- <jedis.version>2.8.0</jedis.version>
- <protostuff.version>1.0.8</protostuff.version>
- <dependency>
- <groupId>redis.clients</groupId>
- <artifactId>jedis</artifactId>
- <version>${jedis.version}</version>
- </dependency>
- <dependency>
- <groupId>com.dyuproject.protostuff</groupId>
- <artifactId>protostuff-runtime</artifactId>
- <version>${protostuff.version}</version>
- </dependency>
- <dependency>
- <groupId>com.dyuproject.protostuff</groupId>
- <artifactId>protostuff-core</artifactId>
- <version>${protostuff.version}</version>
- </dependency>
jedis获取工具(使用jedispool)
- package com.sohu.tv.redis;
- import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import redis.clients.jedis.JedisPool;
- /**
- * jedisPool获取工具
- *
- * @author leifu
- * @Date 2015年8月4日
- * @Time 上午9:01:45
- */
- public class RedisStandAloneUtil {
- private final static Logger logger = LoggerFactory.getLogger(RedisStandAloneUtil.class);
- /**
- * jedis连接池
- */
- private static JedisPool jedisPool;
- /**
- * redis-host
- */
- private final static String REDIS_HOST = "10.10.xx.xx";
- /**
- * redis-port
- */
- private final static int REDIS_PORT = 6384;
- static {
- try {
- jedisPool = new JedisPool(new GenericObjectPoolConfig(), REDIS_HOST, REDIS_PORT);
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- }
- }
- public static JedisPool getJedisPool() {
- return jedisPool;
- }
- public static void main(String[] args) {
- System.out.println(RedisStandAloneUtil.getJedisPool().getResource().info());
- }
- }
(2) 如果自己实现mybatis的二级缓存,需要实现org.apache.ibatis.cache.Cache接口,已经实现的有如下:
序列化相关工具代码:
- package com.sohu.tv.redis.serializable;
- import com.dyuproject.protostuff.LinkedBuffer;
- import com.dyuproject.protostuff.ProtostuffIOUtil;
- import com.dyuproject.protostuff.Schema;
- import com.dyuproject.protostuff.runtime.RuntimeSchema;
- import java.util.concurrent.ConcurrentHashMap;
- public class ProtostuffSerializer {
- private static ConcurrentHashMap<Class<?>, Schema<?>> cachedSchema = new ConcurrentHashMap<Class<?>, Schema<?>>();
- public <T> byte[] serialize(final T source) {
- VO<T> vo = new VO<T>(source);
- final LinkedBuffer buffer = LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE);
- try {
- final Schema<VO> schema = getSchema(VO.class);
- return serializeInternal(vo, schema, buffer);
- } catch (final Exception e) {
- throw new IllegalStateException(e.getMessage(), e);
- } finally {
- buffer.clear();
- }
- }
- public <T> T deserialize(final byte[] bytes) {
- try {
- Schema<VO> schema = getSchema(VO.class);
- VO vo = deserializeInternal(bytes, schema.newMessage(), schema);
- if (vo != null && vo.getValue() != null) {
- return (T) vo.getValue();
- }
- } catch (final Exception e) {
- throw new IllegalStateException(e.getMessage(), e);
- }
- return null;
- }
- private <T> byte[] serializeInternal(final T source, final Schema<T> schema, final LinkedBuffer buffer) {
- return ProtostuffIOUtil.toByteArray(source, schema, buffer);
- }
- private <T> T deserializeInternal(final byte[] bytes, final T result, final Schema<T> schema) {
- ProtostuffIOUtil.mergeFrom(bytes, result, schema);
- return result;
- }
- private static <T> Schema<T> getSchema(Class<T> clazz) {
- @SuppressWarnings("unchecked")
- Schema<T> schema = (Schema<T>) cachedSchema.get(clazz);
- if (schema == null) {
- schema = RuntimeSchema.createFrom(clazz);
- cachedSchema.put(clazz, schema);
- }
- return schema;
- }
- }
- package com.sohu.tv.redis.serializable;
- import java.io.Serializable;
- public class VO<T> implements Serializable {
- private T value;
- public VO(T value) {
- this.value = value;
- }
- public VO() {
- }
- public T getValue() {
- return value;
- }
- @Override
- public String toString() {
- return "VO{" +
- "value=" + value +
- ‘}‘;
- }
- }
Redis需要自己来实现,代码如下:
- package com.sohu.tv.redis;
- import java.util.concurrent.locks.ReadWriteLock;
- import java.util.concurrent.locks.ReentrantReadWriteLock;
- import org.apache.ibatis.cache.Cache;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import redis.clients.jedis.Jedis;
- import redis.clients.jedis.serializable.ProtostuffSerializer;
- /**
- * mybatis redis实现
- *
- * @author leifu
- * @Date 2015年8月4日
- * @Time 上午9:12:37
- */
- public class MybatisRedisCache implements Cache {
- private static Logger logger = LoggerFactory.getLogger(MybatisRedisCache.class);
- private String id;
- private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
- private final ProtostuffSerializer protostuffSerializer = new ProtostuffSerializer();
- public MybatisRedisCache(final String id) {
- if (logger.isInfoEnabled()) {
- logger.info("============ MybatisRedisCache id {} ============", id);
- }
- if (id == null) {
- throw new IllegalArgumentException("Cache instances require an ID");
- }
- this.id = id;
- }
- @Override
- public String getId() {
- return this.id;
- }
- @Override
- public int getSize() {
- Jedis jedis = null;
- int size = -1;
- try {
- jedis = RedisStandAloneUtil.getJedisPool().getResource();
- size = Integer.valueOf(jedis.dbSize().toString());
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- return size;
- }
- @Override
- public void putObject(Object key, Object value) {
- if (logger.isInfoEnabled()) {
- logger.info("============ putObject key: {}, value: {} ============", key, value);
- }
- Jedis jedis = null;
- try {
- jedis = RedisStandAloneUtil.getJedisPool().getResource();
- byte[] byteKey = protostuffSerializer.serialize(key);
- byte[] byteValue = protostuffSerializer.serialize(value);
- jedis.set(byteKey, byteValue);
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- }
- @Override
- public Object getObject(Object key) {
- if (logger.isInfoEnabled()) {
- logger.info("============ getObject key: {}============", key);
- }
- Object object = null;
- Jedis jedis = null;
- try {
- jedis = RedisStandAloneUtil.getJedisPool().getResource();
- byte[] bytes = jedis.get(protostuffSerializer.serialize(key));
- if (bytes != null) {
- object = protostuffSerializer.deserialize(bytes);
- }
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- return object;
- }
- @Override
- public Object removeObject(Object key) {
- if (logger.isInfoEnabled()) {
- logger.info("============ removeObject key: {}============", key);
- }
- String result = "success";
- Jedis jedis = null;
- try {
- jedis = RedisStandAloneUtil.getJedisPool().getResource();
- jedis.del(String.valueOf(key));
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- return result;
- }
- @Override
- public void clear() {
- if (logger.isInfoEnabled()) {
- logger.info("============ start clear cache ============");
- }
- String result = "fail";
- Jedis jedis = null;
- try {
- jedis = RedisStandAloneUtil.getJedisPool().getResource();
- result = jedis.flushAll();
- } catch (Exception e) {
- logger.error(e.getMessage(), e);
- } finally {
- if (jedis != null) {
- jedis.close();
- }
- }
- if (logger.isInfoEnabled()) {
- logger.info("============ end clear cache result is {}============", result);
- }
- }
- @Override
- public ReadWriteLock getReadWriteLock() {
- return readWriteLock;
- }
- }
(3) mapper配置中加入自定义redis二级缓存:
- <cache type="com.sohu.tv.redis.MybatisRedisCache"/>
(4) 单元测试同第二节
mybatis缓存专题-一文彻底搞懂mybatis一级缓存(代码片段)
...不能使用2.什么是一级缓存3.什么情况下会命中一级缓存4.Mybatis的一级缓存机制详解5.MyBatis关闭一级缓存6.Mybatis的一级缓存机制源码分析7.Mybatis的一级缓存机制源码分析图解总结8.一级缓存什么时候被清空?9.一级缓存key是什... 查看详情
java面试题_简单说明hibernatestruts2springspringmvcmybatis的执行流程或者原理_5_mybatis
系列文章目录文章目录系列文章目录一、MyBatis简介工作流程面试题mybatis的基本工作流程讲下MyBatis的缓存1.spring和mybatis整合之后为什么一级缓存会失效?2.二级缓存中要注意的事情?4.#和$的区别5.MyBatis与Hibernate有哪些不... 查看详情
mybatis的二级缓存
文章目录MyBatis的二级缓存MyBatis默认是开启一级缓存的开启MyBatis的二级缓存为什么要开启二级缓存在mybatis的配置文件中进行配置在对应的mapper映射文件中声明相关的DO对象需要实现序列化测试动态代理接口执行更新方法后会清空... 查看详情
mybatis中的缓存
Mybatis中的缓存1.什么是缓存存在于内存中的临时数据。2.为什么使用缓存减少和数据库的交互次数,提高执行效率。3.什么样的数据可以使用缓存经常查询并且不经常改变的数据,数据的正确与否对结果影响不大的。4.什么样的数... 查看详情
mybatis是啥以及mybatis和jdbc的关系?
参考技术AMybatis是什么mybatis是一个持久层ORM框架。它内部封装了jdbc,使得开发更简洁,更高效。MyBatis可以通过xml或注解完成ORM映射关系配置。Mybatis和JDBC的关系JDBC是Java提供的一个操作数据库的API;MyBatis是一个持久层ORM框架,... 查看详情
mybatis入门
标题目录 1.mybatis简单介绍 2.mybatis与hibernate的区别 3.搭建mybatis框架环境 4.基于ssm逆向工程的使用(IDEA) 5.Mybatis增删改查案例 1.m 查看详情
mybatis基础系列——关联查询延迟加载一级缓存与二级缓存
关本文是Mybatis基础系列的第四篇文章,点击下面链接可以查看前面的文章:mybatis基础系列(三)——动态sqlmybatis基础系列(二)——基础语法、别名、输入映射、输出映射mybatis基础系列(一)——mybatis入门关联查询在进行表... 查看详情
ssm框架mybatis的基本使用(代码片段)
Mybatis的基本使用目录Mybatis的基本使用学习目标一、认识Mybatis1.简介2.原理3.为什么使用Mybatis原生jdbc连接4.Mybatis的优点5.Mybatis的核心6.如何获取mybatis二、Mybatis入门1.环境搭建2.创建一个模块,编写MyBatis核心配置文件3.编写MyBati... 查看详情
mybatis学习笔记(代码片段)
文章目录1.MyBatis简介1.1MyBatis历史1.2MyBatis特性1.3和其它持久化层技术对比2.搭建MyBatis2.1开发环境2.2创建maven工程2.3创建MyBatis的核心配置文件2.4创建mapper接口2.5创建MyBatis的映射文件2.6通过junit测试功能2.7加入log4j日志功能3.核心配置... 查看详情
mybatis(代码片段)
...述 1.什么是框架 2.三层架构 3.持久层技术解决方案 4.mybatis概述 5.mybatis的环境搭建 6.mybatis入门案例自定义Mybatis框架Mybatis框架快速入门框架概述 1.什么是框架 它是我们软件开发中的一套解决方案,不同的框架解决... 查看详情
mybatis学习笔记(代码片段)
文章目录1.MyBatis简介1.1MyBatis历史1.2MyBatis特性1.3和其它持久化层技术对比2.搭建MyBatis2.1开发环境2.2创建maven工程2.3创建MyBatis的核心配置文件2.4创建mapper接口2.5创建MyBatis的映射文件2.6通过junit测试功能2.7加入log4j日志功能3.核心配置... 查看详情
mybatis概念性面试题整理汇总(代码片段)
MyBatis概念性面试题整理汇总MyBatis常见的概念性面试题一、概念性填空题1、#和$的区别是什么?#是_____,$是_____。2、四个核心接口是()用于执行CRUD操作、()处理SQL的参数、()处理返回结果集、()用于执行SQL语句。3、MyBa... 查看详情
mybatis批量插入数据性能测试(代码片段)
目录1、准备2、普通for循环批量插入数据测试3、使用MyBatis提供的BATCH模式4、mybatis中直接使用foreach插入数据5、mybatis如何开启batch模式for循环测试批量插入和更新数据,myabtis的Batch模式,mybatis中直接使用foreachsql拼接插入... 查看详情
关于框架mybatis------浅谈基础知识(代码片段)
浅谈Mybatis1.什么是Mybatis2.Mybatis的快速入门2.1MyBatis开发步骤2.2环境搭建3.MyBatis的映射文件概述4.MyBatis的增删改查操作4.1MyBatis的插入数据操作4.2MyBatis的修改数据操作4.3MyBatis的删除数据操作5.MyBatis核心配置文件概述5.1MyBatis核心配置... 查看详情
mybatis的二级缓存讲解(代码片段)
...个应用,所以必须限制二级缓存的容量,在这里mybatis使用的是溢出淘汰机制。而一级缓存是会话级的生命周期非常短暂是没有必要实现这些功能的。相比较之下,二级缓存机制更加完善。 3、二级缓存的结构二级缓... 查看详情
mybatis系列目录篇
《Mybatis系列(一)入门》《Mybatis系列(二)配置》《Mybatis系列(三)简单示例》《Mybatis系列(四)映射文件》《Mybatis系列(五)动态SQL》《Mybatis系列(六)接口式编程》《Mybatis... 查看详情
mybatis系列目录篇
《Mybatis系列(一)入门》《Mybatis系列(二)配置》《Mybatis系列(三)简单示例》《Mybatis系列(四)映射文件》《Mybatis系列(五)动态SQL》《Mybatis系列(六)接口式编程》《Mybatis... 查看详情
十mybatis缓存系统解析(代码片段)
本文从以下几个方面介绍:1、如何开启Mybatis的缓存2、缓存的核心接口以及底层实现3、一级缓存的实现过程4、二级缓存的实现过程5、缓存的装饰器前言为了提高查询速度,减少数据库压力;Mybatis提供了缓存功能ÿ... 查看详情