需要的jar包:spring版本:4.3.6.release,jedis版本:2.9.0,spring-data-redis:1.8.0.release;如果使用jackson序列化的话还额外需要:jackson-annotations和jackson-databind包
spring集成redis单机版:
1.配置redistemplate
1
2
3
4
5
6
|
<bean id= "redistemplate" class = "org.springframework.data.redis.core.redistemplate" > <property name= "connectionfactory" ref= "connectionfactory" /> <property name= "defaultserializer" ref= "stringredisserializer" /> <property name= "keyserializer" ref= "stringredisserializer" /> <property name= "valueserializer" ref= "valueserializer" /> </bean> |
2.配置connectionfactory
1
2
3
4
5
6
7
8
9
10
|
<bean id= "connectionfactory" class = "org.springframework.data.redis.connection.jedis.jedisconnectionfactory" > <!-- 配置ip --> <property name= "hostname" value= "${redis.host}" /> <!-- 配置port --> <property name= "port" value= "${redis.port}" /> <!-- 是否使用连接池--> <property name= "usepool" value= "${redis.usepool}" /> <!-- 配置redis连接池--> <property name= "poolconfig" ref= "poolconfig" /> </bean> |
3.配置连接池
1
2
3
4
5
6
7
8
9
10
|
<bean id= "poolconfig" class = "redis.clients.jedis.jedispoolconfig" > <!--最大空闲实例数--> <property name= "maxidle" value= "${redis.maxidle}" /> <!--最大活跃实例数--> <property name= "maxtotal" value= "${redis.maxtotal}" /> <!--创建实例时最长等待时间--> <property name= "maxwaitmillis" value= "${redis.maxwaitmillis}" /> <!--创建实例时是否验证--> <property name= "testonborrow" value= "${redis.testonborrow}" /> </bean> |
spring集成redis集群
1.配置redistemplate步骤与单机版一致
2.配置connectionfactory
1
2
3
4
5
6
7
8
|
<bean id= "connectionfactory" class = "org.springframework.data.redis.connection.jedis.jedisconnectionfactory" > <!-- 配置redis连接池--> <constructor-arg ref= "poolconfig" ></constructor-arg> <!-- 配置redis集群--> <constructor-arg ref= "clusterconfig" ></constructor-arg> <!-- 是否使用连接池--> <property name= "usepool" value= "${redis.usepool}" /> </bean> |
3.配置连接池步骤与单机版一致
4.配置redis集群
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
<bean id= "clusterconfig" class = "org.springframework.data.redis.connection.redisclusterconfiguration" > <property name= "maxredirects" value= "3" ></property> <property name= "clusternodes" > <set> <bean class = "org.springframework.data.redis.connection.redisclusternode" > <constructor-arg value= "${redis.host1}" ></constructor-arg> <constructor-arg value= "${redis.port1}" ></constructor-arg> </bean> <bean class = "org.springframework.data.redis.connection.redisclusternode" > <constructor-arg value= "${redis.host2}" ></constructor-arg> <constructor-arg value= "${redis.port2}" ></constructor-arg> </bean> ...... </set> </property> </bean |
或者
1
2
3
4
5
6
|
<bean name= "propertysource" class = "org.springframework.core.io.support.resourcepropertysource" > <constructor-arg name= "location" value= "classpath:properties/spring-redis-cluster.properties" /> </bean> <bean id= "clusterconfig" class = "org.springframework.data.redis.connection.redisclusterconfiguration" > <constructor-arg name= "propertysource" ref= "propertysource" /> </bean> |
序列化配置简述:
1.stringredisserializer:由于redis的key是string类型所以一般使用stringredisserializer
2.valueserializer:对于redis的value序列化,spring-data-redis提供了许多序列化类,这里建议使用jackson2jsonredisserializer,默认为jdkserializationredisserializer
3.jdkserializationredisserializer: 使用jdk提供的序列化功能。 优点是反序列化时不需要提供类型信息(class),但缺点是序列化后的结果非常庞大,是json格式的5倍左右,这样就会消耗redis服务器的大量内存。
4.jackson2jsonredisserializer:使用jackson库将对象序列化为json字符串。优点是速度快,序列化后的字符串短小精悍。但缺点也非常致命,那就是此类的构造函数中有一个类型参数,必须提供要序列化对象的类型信息(.class对象)。
使用spring注解式来配置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
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
|
@configuration @enablecaching public class redisconfig extends cachingconfigurersupport { //spring3支持注解方式获取value 在application里配置配置文件路径即可获取 @value ( "${spring.redis.cluster.nodes}" ) private string clusternodes; @value ( "${spring.redis.cluster.timeout}" ) private long timeout; @value ( "${spring.redis.cluster.max-redirects}" ) private int redirects; @value ( "${redis.maxidle}" ) private int maxidle; @value ( "${redis.maxtotal}" ) private int maxtotal; @value ( "${redis.maxwaitmillis}" ) private long maxwaitmillis; @value ( "${redis.testonborrow}" ) private boolean testonborrow; /** * 选择redis作为默认缓存工具 * @param redistemplate * @return */ @bean public cachemanager cachemanager(redistemplate redistemplate) { rediscachemanager cachemanager = new rediscachemanager(redistemplate); //cachemanager.setdefaultexpiration(60); //map<string,long> expiresmap=new hashmap<>(); //expiresmap.put("rediscache",5l); //cachemanager.setexpires(expiresmap); return cachemanager; } @bean public redisclusterconfiguration redisclusterconfiguration(){ map<string, object> source = new hashmap<>(); source.put( "spring.redis.cluster.nodes" , clusternodes); source.put( "spring.redis.cluster.timeout" , timeout); source.put( "spring.redis.cluster.max-redirects" , redirects); return new redisclusterconfiguration( new mappropertysource( "redisclusterconfiguration" , source)); } @bean public jedisconnectionfactory redisconnectionfactory(redisclusterconfiguration configuration){ jedispoolconfig poolconfig = new jedispoolconfig(); poolconfig.setmaxidle(maxidle); poolconfig.setmaxtotal(maxtotal); poolconfig.setmaxwaitmillis(maxwaitmillis); poolconfig.settestonborrow(testonborrow); return new jedisconnectionfactory(configuration,poolconfig); } /** * retemplate相关配置 * @param factory * @return */ @bean public redistemplate<string, object> redistemplate(jedisconnectionfactory factory) { redistemplate<string, object> template = new redistemplate<>(); // 配置连接工厂 template.setconnectionfactory(factory); //使用jackson2jsonredisserializer来序列化和反序列化redis的value值(默认使用jdk的序列化方式) jackson2jsonredisserializer jacksonseial = new jackson2jsonredisserializer(object. class ); objectmapper om = new objectmapper(); // 指定要序列化的域,field,get和set,以及修饰符范围,any是都有包括private和public om.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any); // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如string,integer等会跑出异常 //om.enabledefaulttyping(objectmapper.defaulttyping.non_final); jacksonseial.setobjectmapper(om); // 值采用json序列化 template.setvalueserializer(jacksonseial); //使用stringredisserializer来序列化和反序列化redis的key值 template.setkeyserializer( new stringredisserializer()); // 设置hash key 和value序列化模式 template.sethashkeyserializer( new stringredisserializer()); template.sethashvalueserializer(jacksonseial); template.afterpropertiesset(); return template; } } |
注意事项:
1.采用注解式配置redis或者使用@configuration需要在配置文件中指定扫描什么哪些包下的配置文件,当然如果是springboot那当我没说过这句话...
1
|
<context:component-scan base- package = "com.*" /> |
2.spring3支持注解方式获取value,但是需要在加载的配置文件配置文件路径即可,具体值自己指定吧...
1
|
<value>classpath:properties/spring-redis-cluster.properties</value> |
3.由于我们公司原有的框架采用的是spring2.5.6, 而对于spring2 和spring2+主要区别(当然是我自己觉得啊)是把各模块分成了不同的jar,而对于使用spring-data-redis模板化处理redis的话,单机情况下spring2.5.6和spring4不会冲突,而如果使用集群模式需要配置redis集群的时候就会出现jar包冲突,这个时候就看要如何取决了,可以直接使用jediscluster来连接redis集群(不过很多方法都需要自己去写),也可以把spring2.5.6替换成高版本的spring4,只是框架替换需要注意的事情更多了啊(我们公司的直接全部替换没啥毛病好吧,o(∩_∩)o哈哈~),至于重写jedisconnectionfactory和redisclusterconfiguration我还未去尝试,这个可以作为后续补充吧...
4.顺便说句,spring4不在支持ibatis了,如果你需要用spring4,又需要连接ibatis的话,最粗暴的方式是把spring-orm包换成spring3版本,其他的jar还是4版本即可。(当然我这边直接替换是没啥问题,但同3一样可能存在潜在问题啊,所以说嘛,公司有时候还是需要更新换代下吧...)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://segmentfault.com/a/1190000018208317