个人中心
gpt4 book ai didi

SpringBoot+Mybatis项目使用Redis做Mybatis的二级缓存的方法

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 27 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章SpringBoot+Mybatis项目使用Redis做Mybatis的二级缓存的方法由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

介绍 。

使用mybatis时可以使用二级缓存提高查询速度，进而改善用户体验.

使用redis做mybatis的二级缓存可是内存可控<如将单独的服务器部署出来用于二级缓存>，管理方便.

1.在pom.xml文件中引入redis依赖 。

?
1
2
3
4
< dependency >
   < groupId >org.springframework.boot</ groupId >
   < artifactId >spring-boot-starter-data-redis</ artifactId >
</ dependency >

2.在application.properties配置文件中进行redis的配置 。

?
1
2
3
4
5
6
7
8
9
10
## Redis
spring.redis.database=0
spring.redis.host=172.16.3.123
spring.redis.port=6379
spring.redis.password=
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.timeout=0

3.创建cache包，然后创建两个类，一个ApplicationContextHolder实现ApplicationContextAware接口，具体内容如下 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
package com.ruijie.SpringBootandRedis.cache;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
 
@Component
public class ApplicationContextHolder implements ApplicationContextAware {
   private static ApplicationContext applicationContext;
 
   @Override
   public void setApplicationContext(ApplicationContext ctx) throws BeansException {
     applicationContext = ctx;
   }
 
   /**
    * Get application context from everywhere
    *
    * @return
    */
   public static ApplicationContext getApplicationContext() {
     return applicationContext;
   }
 
   /**
    * Get bean by class
    *
    * @param clazz
    * @param <T>
    * @return
    */
   public static <T> T getBean(Class<T> clazz) {
     return applicationContext.getBean(clazz);
   }
 
   /**
    * Get bean by class name
    *
    * @param name
    * @param <T>
    * @return
    */
   public static <T> T getBean(String name) {
     return (T) applicationContext.getBean(name);
   }
}

4.创建RedisCache类实现Cache接口，具体内容如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package com.ruijie.SpringBootandRedis.cache;
import org.apache.ibatis.cache.Cache;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
 
public class RedisCache implements Cache {
   private static final Logger logger = LoggerFactory.getLogger(RedisCache. class );
   private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
   private final String id; // cache instance id
   private RedisTemplate redisTemplate;
   private static final long EXPIRE_TIME_IN_MINUTES = 30 ; // redis过期时间
   public RedisCache(String id) {
     if (id == null ) {
       throw new IllegalArgumentException( "Cache instances require an ID" );
     }
     this .id = id;
   }
 
   @Override
   public String getId() {
     return id;
   }
 
   /**
    * Put query result to redis
    *
    * @param key
    * @param value
    */
   @Override
   public void putObject(Object key, Object value) {
     try {
       RedisTemplate redisTemplate = getRedisTemplate();
       ValueOperations opsForValue = redisTemplate.opsForValue();
       opsForValue.set(key, value, EXPIRE_TIME_IN_MINUTES, TimeUnit.MINUTES);
       logger.debug( "Put query result to redis" );
     }
     catch (Throwable t) {
       logger.error( "Redis put failed" , t);
     }
   }
 
   /**
    * Get cached query result from redis
    *
    * @param key
    * @return
    */
   @Override
   public Object getObject(Object key) {
     try {
 
       RedisTemplate redisTemplate = getRedisTemplate();
       ValueOperations opsForValue = redisTemplate.opsForValue();
       logger.debug( "Get cached query result from redis" );
       System.out.println( "****" +opsForValue.get(key).toString());
       return opsForValue.get(key);
     }
     catch (Throwable t) {
       logger.error( "Redis get failed, fail over to db" , t);
       return null ;
     }
   }
 
   /**
    * Remove cached query result from redis
    *
    * @param key
    * @return
    */
   @Override
   @SuppressWarnings ( "unchecked" )
   public Object removeObject(Object key) {
     try {
       RedisTemplate redisTemplate = getRedisTemplate();
       redisTemplate.delete(key);
       logger.debug( "Remove cached query result from redis" );
     }
     catch (Throwable t) {
       logger.error( "Redis remove failed" , t);
     }
     return null ;
   }
 
   /**
    * Clears this cache instance
    */
   @Override
   public void clear() {
     RedisTemplate redisTemplate = getRedisTemplate();
     redisTemplate.execute((RedisCallback) connection -> {
       connection.flushDb();
       return null ;
     });
     logger.debug( "Clear all the cached query result from redis" );
   }
 
   /**
    * This method is not used
    *
    * @return
    */
   @Override
   public int getSize() {
     return 0 ;
   }
 
   @Override
   public ReadWriteLock getReadWriteLock() {
     return readWriteLock;
   }
 
   private RedisTemplate getRedisTemplate() {
     if (redisTemplate == null ) {
       redisTemplate = ApplicationContextHolder.getBean( "redisTemplate" );
     }
     return redisTemplate;
   }
}

5.实体类中要实现Serializable接口，并且要声明序列号 。

?
1
private static final long serialVersionUID = -2566441764189220519L;

6.开启Mybatis的二级缓存 。

在pom.xml配置文件中配置 。

?
1
mybatis.configuration.cache-enabled=true

在mapper接口中加入 。

?
1
@CacheNamespace (implementation=(com.demo.testdemo.cache.RedisCache. class ))

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：http://blog.csdn.net/qq_38158631/article/details/78721794 。

最后此篇关于SpringBoot+Mybatis项目使用Redis做Mybatis的二级缓存的方法的文章就讲到这里了,如果你想了解更多关于SpringBoot+Mybatis项目使用Redis做Mybatis的二级缓存的方法的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

27 4 0
文章推荐： Android图片处理实例介绍(图)
文章推荐： 详解用Eclipse如何创建Web项目
文章推荐： Android TableLayout数据列表的回显清空实现思路及代码
文章推荐： SpringBoot+LayIM+t-io 实现好友申请通知流程
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com