Java代碼操作Redis的sentinel和Redis的集群Cluster操作

Jedis操作Redis的sentinel示例代碼:

總共四台機器,crxy99,crxy98分別是主節點和從節點.   crxy97和crxy96是兩個監控此主從架構的sentinel節點.

 上代碼:

import org.junit.Test;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;

public class TestSentinel {
    @Test
    public void test1() {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        String masterName = "mymaster";
        Set<String> sentinels = new HashSet<String>();
        sentinels.add("192.168.1.97:26379");
        sentinels.add("192.168.1.96:26379");
        JedisSentinelPool jedisSentinelPool = new JedisSentinelPool(masterName, sentinels, poolConfig);
        HostAndPort currentHostMaster = jedisSentinelPool.getCurrentHostMaster();
        System.out.println(currentHostMaster.getHost()+"--"+currentHostMaster.getPort());//獲取主節點的信息
        Jedis resource = jedisSentinelPool.getResource();
        String value = resource.get("a");
        System.out.println(value);//獲得鍵a對應的value值
        resource.close();
    }

}

運行結果入下:

192.168.1.99--6379
1

 

Jedis操作集群示例代碼:

模擬的集群環境.在一台機器上啟動多個redis..每個redis對應的是不同端口.

在crxy99 192.168.1.99上啟動的....總共3主3從 端口號對應的的是7000~7005.....

看代碼:

import java.util.HashSet;
import java.util.Set;
import org.junit.Test;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

public class TestCluster {
    @Test
    public void test1() throws Exception {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
        HostAndPort hostAndPort = new HostAndPort("192.168.1.99", 7000);
        HostAndPort hostAndPort1 = new HostAndPort("192.168.1.99", 7001);
        HostAndPort hostAndPort2 = new HostAndPort("192.168.1.99", 7002);
        HostAndPort hostAndPort3 = new HostAndPort("192.168.1.99", 7003);
        HostAndPort hostAndPort4 = new HostAndPort("192.168.1.99", 7004);
        HostAndPort hostAndPort5 = new HostAndPort("192.168.1.99", 7005);
        nodes.add(hostAndPort);
        nodes.add(hostAndPort1);
        nodes.add(hostAndPort2);
        nodes.add(hostAndPort3);
        nodes.add(hostAndPort4);
        nodes.add(hostAndPort5);
        JedisCluster jedisCluster = new JedisCluster(nodes, poolConfig);//JedisCluster中默認分裝好了連接池.
        //redis內部會創建連接池，從連接池中獲取連接使用，然后再把連接返回給連接池
        String string = jedisCluster.get("a");
        System.out.println(string);            
    }
}