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配置

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

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

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

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

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

关于"mybatis如何结合redis实现二级缓存"这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。