spring JedisCluster操作rediscluster crud

jedisCluster 测试代码

 

// 连接redis集群

    @Test

    public void testJedisCluster() {

 

       JedisPoolConfig config = new JedisPoolConfig();

       // 最大连接数

       config.setMaxTotal(30);

       // 最大连接空闲数

       config.setMaxIdle(2);

       //集群结点

       Set jedisClusterNode = new HashSet();

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7001));

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7002));

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7003));

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7004));

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7005));

       jedisClusterNode.add(new HostAndPort("192.168.101.3", 7006));

       JedisCluster jc = new JedisCluster(jedisClusterNode, config);

      

       JedisCluster jcd = new JedisCluster(jedisClusterNode);

       jcd.set("name", "zhangsan");

       String value = jcd.get("name");

       System.out.println(value);

    }

使用spring

配置applicationContext.xml

 

   

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

      

       

   

   

      

          

             

                 

                 

             

             

                 

                 

             

             

                 

                 

             

             

                 

                 

             

             

                 

                 

             

             

                 

                 

             

          

      

      

   

测试代码

private ApplicationContext applicationContext;

    @Before

    public void init() {

       applicationContext = new ClassPathXmlApplicationContext(

              "classpath:applicationContext.xml");

    }

 

    //redis集群

    @Test

    public void testJedisCluster() {

    JedisCluster jedisCluster = (JedisCluster) applicationContext

                  .getBean("jedisCluster");

          

           jedisCluster.set("name", "zhangsan");

           String value = jedisCluster.get("name");

           System.out.println(value);

         }

redisCluster应用测试代码

 

jar包