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不支持