Java程序员笔记——mybatis结合redis实战二级缓存

左手的ㄟ右手 2022-03-10 16:11 157阅读 0赞

JavaSpring高级进阶 2019-01-17 16:58:17

本章说的是：mybatis结合redis实战二级缓存

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEyNzcxMjM_size_16_color_FFFFFF_t_70][]

# 一：自定义mybatis缓存 #

我们知道**任何mybatis二级缓存都需要实现一个接口，这个接口就是org.apache.ibatis.cache.Cache,**代码如下：

package com.demo.spring.mybatis.cache;
    	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 com.demo.spring.mybatis.util.SerializeUtil;
    	import redis.clients.jedis.Jedis;
    	import redis.clients.jedis.JedisPool;
    	public class MybatisRedisCache implements Cache {
    		private static Logger logger = LoggerFactory.getLogger(MybatisRedisCache.class);
    		private Jedis redisClient = createReids();
    		private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    		private String id;
    		public MybatisRedisCache(final String id) {
    			if (id == null) {
    				throw new IllegalArgumentException("Cache instances require an ID");
    			}
    			logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>MybatisRedisCache:id=" + id);
    			this.id = id;
    		}
    		@Override
    		public String getId() {
    			return this.id;
    		}
    		@Override
    		public int getSize() {
    			return Integer.valueOf(redisClient.dbSize().toString());
    		}
    		@Override
    		public void putObject(Object key, Object value) {
    			logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>putObject:" + key + "=" + value);
    			redisClient.set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value));
    		}
    		@Override
    		public Object getObject(Object key) {
    			Object value = SerializeUtil.unserialize(redisClient.get(SerializeUtil.serialize(key.toString())));
    			logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>getObject:" + key + "=" + value);
    			return value;
    		}
    		@Override
    		public Object removeObject(Object key) {
    			return redisClient.expire(SerializeUtil.serialize(key.toString()), 0);
    		}
    		@Override
    		public void clear() {
    			redisClient.flushDB();
    		}
    		@Override
    		public ReadWriteLock getReadWriteLock() {
    			return readWriteLock;
    		}
    		protected static Jedis createReids() {
    			JedisPool pool = new JedisPool("127.0.0.1", 6379);
    			return pool.getResource();
    		}
    	}

以上代码很简单就是基本的Cache实现，在定义一个序列化的工具类

package com.demo.spring.mybatis.util;
    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    public class SerializeUtil {
    	public static byte[] serialize(Object object) {
    		ObjectOutputStream oos = null;
    		ByteArrayOutputStream baos = null;
    		try {
    			// 序列化
    			baos = new ByteArrayOutputStream();
    			oos = new ObjectOutputStream(baos);
    			oos.writeObject(object);
    			byte[] bytes = baos.toByteArray();
    			return bytes;
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return null;
    	}
    	public static Object unserialize(byte[] bytes) {
    		ByteArrayInputStream bais = null;
    		try {
    			// 反序列化
    			bais = new ByteArrayInputStream(bytes);
    			ObjectInputStream ois = new ObjectInputStream(bais);
    			return ois.readObject();
    		} catch (Exception e) {
    		}
    		return null;
    	}
    }

然后在mapper.xml配置

当然**在主配置文件里面还需要配置如下代码，代表开启二级缓存，默认是不开启的**

所以得配置和代码都已经完成了运行结果如下：

![Java程序员笔记——mybatis结合redis实战二级缓存][Java_mybatis_redis]

**为什么第二次走的是一级缓存呢？**

这个在讲二级缓存源码的时候分析过，只有当执行commit的时候才把之前查询的结果放入缓存。

打开吗redis查看如下，因为存入的是序列化的结果，不过我们隐约还是能看到一些信息到下图

![Java程序员笔记——mybatis结合redis实战二级缓存][Java_mybatis_redis 1]

# 二：官方的实例 #

地址: http://www.mybatis.org/redis-cache/

其实和我们自定义的差不多的，不过使用的时候需要注意redis客户端版本要和它的版本兼容，否则或报错。

mybatis-redis 1.0.0-beta2 对应负redis.clients » jedis 2.8.0 目前的最高版本2.9.0不支持

# **最后：** #

对Java架构技术提升很感兴趣，可以加入我的Java进阶之路来交流学习：878249276，里面都是同行，有资源共享。欢迎一到五年的工程师加入，合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEyNzcxMjM_size_16_color_FFFFFF_t_70]: /images/20220310/51f019729cac42729af677d1b3859f29.png
[Java_mybatis_redis]: http://p1.pstatp.com/large/pgc-image/cbe9cb525a7b4cbebc32495d4c865ec4
[Java_mybatis_redis 1]: http://p1.pstatp.com/large/pgc-image/b983ea655ed14097a6730deeee0767d5