jedis连接redis集群_redis集群问题

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

启动redis集群

搭建redis集群，搭建具体过程如下
http://blog.csdn.net/lucky_ly/article/details/78703102
启动redis集群。

测试集群搭建在虚拟机的Linux系统下，客户机访问采用的windows环境下。
默认情况下redis只允许本机进行访问的。但我们为了方便测试，将redis.conf的bind 改为对应的Linux系统ip，这里为192.168.48.138

使用jedisCluster

package com.redis;

import java.util.HashSet;
import java.util.Set;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

public class RedisClusterTest { 
   
    public static void main(String[] args){
        //创建ip地址集合
        Set<HostAndPort> ips = new HashSet<HostAndPort>();
        ips.add(new HostAndPort("192.168.48.138", 7000));
        ips.add(new HostAndPort("192.168.48.138", 7001));
        ips.add(new HostAndPort("192.168.48.138", 7002));
        ips.add(new HostAndPort("192.168.48.138", 7003));
        ips.add(new HostAndPort("192.168.48.138", 7004));
        ips.add(new HostAndPort("192.168.48.138", 7005));

        JedisCluster cluster = new JedisCluster(ips);
        cluster.set("redisCluster", "pretty good");
        System.out.println(cluster.get("redisCluster"));
    }
}

使用spring装配JedisCluster

<bean class="redis.clients.jedis.JedisCluster" id="jedisCluster">
        <constructor-arg>
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7000"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7001"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7002"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7003"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7004"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.48.138"/>
                    <constructor-arg name="port" value="7005"/>
                </bean>
            </set>
        </constructor-arg>
    </bean> 

package ly;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;


import redis.clients.jedis.JedisCluster;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:spring.xml")
public class JedisTest {

    @Autowired
    private  JedisCluster jedisCluster;


    @Test
    public void clusterTest(){
        jedisCluster.set("goodMan", "ly");
        System.out.println(jedisCluster.get("one"));
    }

}