(1)pom.xml引入jar包,如下:
1
2
3
4
|
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> |
(2)修改項目啟動類,增加注解@EnableCaching,開啟緩存功能,如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
|
package springboot; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cache.annotation.EnableCaching; import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication @EnableScheduling @EnableCaching public class SpringbootApplication{ public static void main(String[] args) { SpringApplication.run(SpringbootApplication. class , args); } } |
(3)application.properties中配置Redis連接信息,如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
# Redis數(shù)據(jù)庫索引(默認為 0 ) spring.redis.database= 0 # Redis服務器地址 spring.redis.host= 172.31 . 19.222 # Redis服務器連接端口 spring.redis.port= 6379 # Redis服務器連接密碼(默認為空) spring.redis.password= # 連接池最大連接數(shù)(使用負值表示沒有限制) 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 |
(4)新建Redis緩存配置類RedisConfig,如下:
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
|
package springboot.config; import org.springframework.beans.factory.annotation.Value; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; /** * Redis緩存配置類 * @author szekinwin * */ @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport{ @Value ( "${spring.redis.host}" ) private String host; @Value ( "${spring.redis.port}" ) private int port; @Value ( "${spring.redis.timeout}" ) private int timeout; //自定義緩存key生成策略 // @Bean // public KeyGenerator keyGenerator() { // return new KeyGenerator(){ // @Override // public Object generate(Object target, java.lang.reflect.Method method, Object... params) { // StringBuffer sb = new StringBuffer(); // sb.append(target.getClass().getName()); // sb.append(method.getName()); // for(Object obj:params){ // sb.append(obj.toString()); // } // return sb.toString(); // } // }; // } //緩存管理器 @Bean public CacheManager cacheManager( @SuppressWarnings ( "rawtypes" ) RedisTemplate redisTemplate) { RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate); //設置緩存過期時間 cacheManager.setDefaultExpiration( 10000 ); return cacheManager; } @Bean public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory){ StringRedisTemplate template = new StringRedisTemplate(factory); setSerializer(template); //設置序列化工具 template.afterPropertiesSet(); return template; } private void setSerializer(StringRedisTemplate template){ @SuppressWarnings ({ "rawtypes" , "unchecked" }) Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object. class ); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); template.setValueSerializer(jackson2JsonRedisSerializer); } } |
(5)新建UserMapper,如下:
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
|
package springboot.dao; import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Insert; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update; import org.springframework.cache.annotation.CacheConfig; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.Cacheable; import springboot.domain.User; @Mapper @CacheConfig (cacheNames = "users" ) public interface UserMapper { @Insert ( "insert into user(name,age) values(#{name},#{age})" ) int addUser( @Param ( "name" )String name, @Param ( "age" )String age); @Select ( "select * from user where id =#{id}" ) @Cacheable (key = "#p0" ) User findById( @Param ( "id" ) String id); @CachePut (key = "#p0" ) @Update ( "update user set name=#{name} where id=#{id}" ) void updataById( @Param ( "id" )String id, @Param ( "name" )String name); //如果指定為 true,則方法調(diào)用后將立即清空所有緩存 @CacheEvict (key = "#p0" ,allEntries= true ) @Delete ( "delete from user where id=#{id}" ) void deleteById( @Param ( "id" )String id); } |
@Cacheable將查詢結(jié)果緩存到redis中,(key="#p0")指定傳入的第一個參數(shù)作為redis的key。
@CachePut,指定key,將更新的結(jié)果同步到redis中
@CacheEvict,指定key,刪除緩存數(shù)據(jù),allEntries=true,方法調(diào)用后將立即清除緩存
(6)service層與controller層跟上一篇整合一樣,啟動redis服務器,redis服務器的安裝與啟動可以參考之前的博客,地址如下:
http://www.cnblogs.com/gdpuzxs/p/6623171.html
(7)配置log4j日志信息,如下:
1
2
3
4
5
6
|
## LOG4J配置 log4j.rootCategory=DEBUG,stdout ## 控制臺輸出 log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} %5p %c{ 1 }:%L - %m%n |
(8)驗證redis緩存
首先我們向user表總插入一條數(shù)據(jù),數(shù)據(jù)庫顯示如下:
現(xiàn)在,我們查詢一下user表中id=24的數(shù)據(jù),觀擦控制臺輸出的信息,如下:
通過控制臺輸出信息我們可以知道,這次執(zhí)行了數(shù)據(jù)庫查詢,并開啟了Redis緩存查詢結(jié)果。接下來我們再次查詢user表中id=24的數(shù)據(jù),觀察控制臺,如下:
通過控制臺輸出信息我們可以知道,這次并沒有執(zhí)行數(shù)據(jù)庫查詢,而是從Redis緩存中查詢,并返回查詢結(jié)果。我們查看redis中的信息,如下:
方法finduser方法使用了注解@Cacheable(key="#p0"),即將id作為redis中的key值。當我們更新數(shù)據(jù)的時候,應該使用@CachePut(key="#p0")進行緩存數(shù)據(jù)的更新,否則將查詢到臟數(shù)據(jù)。
總結(jié)
以上所述是小編給大家介紹的SpringBoot使用Redis緩存的實現(xiàn)方法,希望對大家有所幫助,如果大家有任何疑問歡迎給我留言,小編會及時回復大家的!
原文鏈接:https://www.cnblogs.com/gdpuzxs/p/7222309.html