Java-13 深入浅出 MyBatis - 二级缓存整合Redis 代码测试 与 原理探究 源码 ...

点一下关注吧！！！非常感谢！！连续更新！！！

大数据篇正在更新！https://blog.csdn.net/w776341482/category_12713819.html

目前已经更新到了：

• MyBatis（正在更新）
  

二级缓存整合 Redis

目前我们实现的二级缓存是每个服务的，此时缓存是在单个服务器上，如果我们想要实现分布式缓存的话，此时我们就必要考虑 Redis 来做我们的缓存服务。
以是接下来，我们将对 MyBatis 和 Redis 进行一个整合。
在 MyBatis 中，提供了一个针对 Cache 的接口，MyBatis 还提供了一个针对 Cache 接口的 Redis 实现类，该类存在在 myBatis-redis 包中。
pom.xml

1. <dependency>
2.     <groupId>org.mybatis.caches</groupId>
3.     <artifactId>mybatis-redis</artifactId>
4.     <version>1.0.0-beta2</version>
5. </dependency>

复制代码

编写代码

UserCacheMapper.xml

1. <?xml version="1.0" encoding="UTF-8" ?>
2. <!DOCTYPE mapper
3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
5. <mapper namespace="icu.wzk.mapper.UserCacheMapper">
7.     <!--开启二级缓存-->
8.     <cache type="org.mybatis.caches.redis.RedisCache"></cache>
10.     <resultMap id="userMap" type="icu.wzk.model.WzkUser">
11.         <result column="id" property="id"></result>
12.         <result column="username" property="username"></result>
13.         <result column="password" property="password"></result>
14.         <result column="birthday" property="birthday"></result>
15.         <collection property="orderList" ofType="icu.wzk.model.WzkOrder">
16.             <result column="oid" property="id"></result>
17.             <result column="ordertime" property="ordertime"></result>
18.             <result column="total" property="total"></result>
19.         </collection>
20.     </resultMap>
22.     <select id="findAll" resultMap="userMap" useCache="true">
23.         select *,o.id oid from wzk_user u left join wzk_orders o on u.id=o.uid;
24.     </select>
25. </mapper>

复制代码

UserCacheMapper.java

1. public interface UserCacheMapper {
2.     List<WzkUser> findAll();
3. }

复制代码

redis.properties

1. redis.host=10.10.52.11
2. redis.port=31679
3. redis.connectionTimeout=5000
4. redis.password=
5. redis.database=0

复制代码

测试代码

1. public class WzkicuCache05 {
3.     public static void main(String[] args) throws IOException {
4.         InputStream inputStream = Resources.getResourceAsStream("sqlMapConfig.xml");
5.         SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
6.                 .build(inputStream);
7.         SqlSession sqlSession1 = sqlSessionFactory.openSession();
8.         SqlSession sqlSession2 = sqlSessionFactory.openSession();
10.         UserCacheMapper userCacheMapper1 = sqlSession1.getMapper(UserCacheMapper.class);
11.         UserCacheMapper userCacheMapper2 = sqlSession2.getMapper(UserCacheMapper.class);
12.         List<WzkUser> wzkUserList = userCacheMapper1.findAll();
13.         for (WzkUser wu : wzkUserList) {
14.             System.out.println(wu);
15.         }
16.         sqlSession1.close();
18.         List<WzkUser> wzkUserList2 = userCacheMapper2.findAll();
19.         for (WzkUser wu : wzkUserList2) {
20.             System.out.println(wu);
21.         }
22.         sqlSession2.close();
23.     }
25. }

复制代码

运行效果

1. WzkUser(id=1, username=wzk-update, password=123-update, birthday=Mon Nov 11 00:00:00 CST 2024, orderList=[WzkOrder(id=1, ord

复制代码

对应的效果如下图所示：

这里代码我运行了多次，可以看到请求都不会发出了，因为在 Redis 上缓存了。
源码分析

RedisCache 和其他的缓存方案基本是相似的，无非是实现了 Cache 接口，并使用 Jedis 操作缓存。

1. public final class RedisCache implements Cache {
3.     private final String id;
4.     private final JedisPool pool;
6.     public RedisCache(final String id) {
7.         if (id == null) {
8.             throw new IllegalArgumentException("Cache instances require an ID");
9.         }
10.         this.id = id;
12.         RedisConfig redisConfig = RedisConfigurationBuilder.getInstance().parseConfiguration();
14.         pool = new JedisPool(
15.                 redisConfig,
16.                 redisConfig.getHost(),
17.                 redisConfig.getPort(),
18.                 redisConfig.getConnectionTimeout(),
19.                 redisConfig.getSoTimeout(),
20.                 redisConfig.getPassword(),
21.                 redisConfig.getDatabase(),
22.                 redisConfig.getClientName()
23.         );
24.     }
25. }

复制代码

RedisCache 在启动的时候，由 MyBatis 的 CacheBuilder 创建，创建的方式很简单，就是调用 RedisCache 的带有 String 参数的构造方法，即 RedisCache（String id），而 RedisCache 的构造方法中，调用了 RedisConfigurationBuilder 来创建对象 RedisConfig 对象，并使用 RedisConfig 来创建 JedisPool。
RedisConfig 继续了 JedisPoolConfig，提供了多个参数，这里的属性如下：

1. private String host = Protocol.DEFAULT_HOST;
2. private int port = Protocol.DEFAULT_PORT;
3. private int connectionTimeout = Protocol.DEFAULT_TIMEOUT;
4. private int soTimeout = Protocol.DEFAULT_TIMEOUT;
5. private String password;
6. private int database = Protocol.DEFAULT_DATABASE;
7. private String clientName;

复制代码

对应的截图如下所示：

RedisConfig 对象是由 RedisConfigurationBuilder 创建的，简单看下这个类，最告急的方法就是 parse 的部门：

1. public RedisConfig parseConfiguration(ClassLoader classLoader) {
2.         Properties config = new Properties();
3.         InputStream input = classLoader.getResourceAsStream(this.redisPropertiesFilename);
4.         if (input != null) {
5.             try {
6.                 config.load(input);
7.             } catch (IOException var12) {
8.                 throw new RuntimeException("An error occurred while reading classpath property '" + this.redisPropertiesFilename + "', see nested exceptions", var12);
9.             } finally {
10.                 try {
11.                     input.close();
12.                 } catch (IOException var11) {
13.                 }
15.             }
16.         }
18.         RedisConfig jedisConfig = new RedisConfig();
19.         this.setConfigProperties(config, jedisConfig);
20.         return jedisConfig;
21.     }

复制代码

对应的截图如下所示：

我们从这里看出，从 classpath 下读取了一个 redis.properties：

1. private final String redisPropertiesFilename = System.getProperty("redis.properties.filename", "redis.properties");

复制代码

并将该设置文件中内容设置到了 RedisConfig 对象中，并返回，接下来，就是 RedisCache 使用 RedisConfig 类创建完成 JedisPool。
在 RedisCache 中，有一个模板方法：

1.   private Object execute(RedisCallback callback) {
2.     Jedis jedis = pool.getResource();
3.     try {
4.       return callback.doWithRedis(jedis);
5.     } finally {
6.       jedis.close();
7.     }
8.   }

复制代码

对应的截图如下所示：

模板接口为 RedisCallback，接口中只实现了一个 doWithRedis 方法而已：

1. package org.mybatis.caches.redis;
3. import redis.clients.jedis.Jedis;
5. public interface RedisCallback {
7.         Object doWithRedis(Jedis jedis);
8. }

复制代码

对应的截图如下所示：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。