本教程是在上篇文章“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分支:

https://github.com/whol/springbootdemo

最后修改于 2019-03-04 17:07:21
如果觉得我的文章对你有用,请随意赞赏
扫一扫支付
上一篇