1 . pom.xml添加相关依赖
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
|
< parent > < groupId >org.springframework.boot</ groupId > < artifactId >spring-boot-starter-parent</ artifactId > < version >1.5.1.RELEASE</ version > </ parent > <!-- 依赖 --> < dependencies > <!-- mybatis --> < dependency > < groupId >org.mybatis.spring.boot</ groupId > < artifactId >mybatis-spring-boot-starter</ artifactId > < version >1.2.0</ version > </ dependency > <!-- redis相关 --> < dependency > < groupId >redis.clients</ groupId > < artifactId >jedis</ artifactId > </ dependency > < dependency > < groupId >org.springframework.data</ groupId > < artifactId >spring-data-redis</ artifactId > </ dependency > < dependencies > |
2 . 配置Redis集群,参考spring-data-redis官方文档
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
|
@Component @ConfigurationProperties (prefix = "spring.redis.cluster" ) public class ClusterConfigurationProperties { /* * spring.redis.cluster.nodes[0] = 127.0.0.1:7379 * spring.redis.cluster.nodes[1] = 127.0.0.1:7380 * ... */ List<String> nodes; /** * Get initial collection of known cluster nodes in format {@code host:port}. * * @return */ public List<String> getNodes() { return nodes; } public void setNodes(List<String> nodes) { this.nodes = nodes; } } @Configuration public class AppConfig { /** * Type safe representation of application.properties */ @Autowired ClusterConfigurationProperties clusterProperties; public @Bean RedisConnectionFactory connectionFactory() { return new JedisConnectionFactory( new RedisClusterConfiguration(clusterProperties.getNodes())); } } |
3 . 自定义二级缓存类
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
|
public class RedisCache implements Cache { private static final String PREFIX = "SYS_CONFIG:" ; private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock( true ); private String id; private JdkSerializationRedisSerializer jdkSerializer = new JdkSerializationRedisSerializer(); private static RedisConnectionFactory redisConnectionFactory; public RedisCache( final String id) { if (id == null ) { throw new IllegalArgumentException( "Cache instances require an ID" ); } this .id = id; } @Override public String getId() { return this .id; } @Override public void putObject(Object key, Object value) { RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); if (key == null ) return ; String strKey = PREFIX + key.toString(); conn.set(strKey.getBytes(), jdkSerializer.serialize(value)); conn.close(); } @Override public Object getObject(Object key) { if (key != null ) { String strKey = PREFIX + key.toString(); RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); byte [] bs = conn.get(strKey.getBytes()); conn.close(); return jdkSerializer.deserialize(bs); } return null ; } @Override public Object removeObject(Object key) { if (key != null ) { RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); conn.del(key.toString().getBytes()); conn.close(); } return null ; } @Override public void clear() { // 关键代码,data更新时清理缓存 RedisClusterConnection conn = redisConnectionFactory .getClusterConnection(); Set< byte []> keys = conn.keys((PREFIX+ "*" ).getBytes()); for ( byte [] bs : keys) { conn.del(bs); } conn.close(); } @Override public int getSize() { // TODO Auto-generated method stub return 0 ; } @Override public ReadWriteLock getReadWriteLock() { return this .readWriteLock; } public static void setRedisConnectionFactory(RedisConnectionFactory redisConnectionFactory) { RedisCache.redisConnectionFactory = redisConnectionFactory; } } |
使用一个Transfer类间接注入RedisConnectionFactory
1
2
3
4
5
6
7
8
9
|
@Component public class RedisCacheTransfer { @Autowired public void setJedisConnectionFactory( RedisConnectionFactory jedisConnectionFactory) { RedisCache.setRedisConnectionFactory(jedisConnectionFactory); } } |
4 . 在application.propreties中开启二级缓存
开启mybatis的二级缓存
1
|
spring.datasource.cachePrepStmts=true |
5 . 基于注解的使用
1
2
3
4
|
@CacheNamespace (implementation = RedisCache. class ) public interface ConfigDaoMapper { ..... } |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://blog.csdn.net/soul_code/article/details/62422036?utm_source=tuicool&utm_medium=referral