前提:搭建好redis集群环境,搭建方式请看:http://www.zzvips.com/article/29914.html
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
1
2
3
|
spring.redis.cluster.nodes= 127.0 . 0.1 : 6380 , 127.0 . 0.1 : 6381 , 127.0 . 0.1 : 6382 , 127.0 . 0.1 : 6383 , 127.0 . 0.1 : 6384 , 127.0 . 0.1 : 6385 spring.redis.cluster.timeout= 1000 spring.redis.cluster.max-redirects= 3 |
3. 新建下面的两个类
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@configuration public class redisconfiguration { @resource private lettuceconnectionfactory mylettuceconnectionfactory; @bean public redistemplate<string, serializable> redistemplate() { redistemplate<string, serializable> template = new redistemplate<>(); template.setkeyserializer( new stringredisserializer()); template.setvalueserializer( new genericjackson2jsonredisserializer()); template.setconnectionfactory(mylettuceconnectionfactory); return template; } } |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
@configuration public class redisfactoryconfig { @autowired private environment environment; @bean public redisconnectionfactory mylettuceconnectionfactory() { map<string, object> source = new hashmap<string, object>(); source.put( "spring.redis.cluster.nodes" , environment.getproperty( "spring.redis.cluster.nodes" )); source.put( "spring.redis.cluster.timeout" , environment.getproperty( "spring.redis.cluster.timeout" )); source.put( "spring.redis.cluster.max-redirects" , environment.getproperty( "spring.redis.cluster.max-redirects" )); redisclusterconfiguration redisclusterconfiguration; redisclusterconfiguration = new redisclusterconfiguration( new mappropertysource( "redisclusterconfiguration" , source)); return new lettuceconnectionfactory(redisclusterconfiguration); } } |
4. 执行测试
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@springboottest @runwith (springrunner. class ) public class redisconfigurationtest { @autowired private redistemplate redistemplate; @test public void redistemplate() throws exception { redistemplate.opsforvalue().set( "author" , "damein_xym" ); } } |
5. 验证,使用redis desktop manager 连接redis节点,查看里面的数据是否存在author,有如下显示,证明成功。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://www.cnblogs.com/xymBlog/p/9303032.html