Redis集群整合到springboot框架

整合步骤

　　1 配置application.properties

spring.redis.cluster.nodes=192.168.60.131:8000,192.168.60.131:8001,192.168.60.131:8002
spring.redis.maxTotal=200
spring.redis.maxIdle=8
spring.redis.minIdle=1

　　2 编写配置类(完成初始化对象的过程)

    @Bean
        public JedisCluster getInstance(){
            //收集信息
            Set<HostAndPort> infoSet=new HashSet<HostAndPort>();
            String[] node=nodes.split(",");//192.168.60.131:8000数组
            for (String hostAndPort : node) {
                //每次获取192.168.60.131:8000
                String host=hostAndPort.split(":")[0];
                Integer port=Integer.parseInt(hostAndPort.split(":")[1]);
                infoSet.add(new HostAndPort(host, port));}
            //配置对象
            GenericObjectPoolConfig config=new GenericObjectPoolConfig();
            config.setMaxIdle(maxIdle);
            config.setMaxTotal(maxTotal);
            config.setMinIdle(minIdle);
            JedisCluster cluster=new JedisCluster(infoSet,config);
            return cluster;}

3 封装底层api的类(RedisClusterService)

4 测试

    需求:
    • 存数据,从浏览器传递一些参数id,name
    • 在代码中生成key值,将value存储在cluster集群
    • 通过key值获取集群的value,返回浏览器;

    测试代码端的高可用
　　将前面存储的key值所在的节点宕机,再来访问查询的功能观察结果(不能查到,能查到,过一段时间能查到)

　　jedisCluster代码客户端高可用

　　初始化过程

　　

　　以set方法出现连接异常为例