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

友情链接
ioDraw流程图
API参考文档
OK工具箱
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:ixiaoyang8@qq.com
QQ群:637538335
关注微信