本教程是在上篇文章“springboot2访问redis单服务器demo”的基础上进行的,读者可以对照着进行阅读。
在application配置中增加redis集群的配置:
redis:
# Redis数据库索引(默认为0)
database: 0
# Redis服务器集群地址
cluster:
clusterNodes: 127.0.0.1:6379,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
maxRedirects: 6
commandTimeout: 5000
移除redis配置文件中,生成redis链接的访问redis单服务器的redisConnectionFactory方法,增加对redis集群的访问方法:
@Bean("jedisConnectionFactory")
public JedisConnectionFactory jedisConnectionFactory() {
//redis cluster
JedisConnectionFactory factory = new JedisConnectionFactory(redisProperties(),jedisPoolConfig());
return factory;
}
/**
* redisCluster配置
*
* @return
*/
@Bean
public RedisClusterConfiguration redisProperties() {
Map source = new HashMap();
source.put("spring.redis.cluster.nodes", clusterNodes);
source.put("spring.redis.cluster.timeout", commandTimeout);
return new RedisClusterConfiguration(new MapPropertySource("RedisProperties", source));
}
运行工程,可以发现能在redis集群中进行正确的读写操作了。
有什么不清楚的可以参考github上的demo的redisCluster分支:
最后修改于 2019-03-04 17:07:21
如果觉得我的文章对你有用,请随意赞赏
扫一扫支付

