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

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

一：自定义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配置
<cache eviction="LRU" type="com.demo.spring.mybatis.cache.MybatisRedisCache"/>
当然在主配置文件里面还需要配置如下代码，代表开启二级缓存，默认是不开启的
<setting name="cacheEnabled" value="true" />
所以得配置和代码都已经完成了运行结果如下：

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

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

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

二：官方的实例

地址: 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，里面都是同行，有资源共享。欢迎一到五年的工程师加入，合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！

热门工具换一换