使用Jedis建立客户端管理的集群，这种集群主要由客户端管理实现分片，数据库端各节点彼此独立

用到的类主要有redis.clients.jedis.ShardedJedis,实现增删改查

懒得切linux系统了，直接在Windows下面搞的，复制三份redis.windows.conf，分别改一下端口，然后启动

secound.java

import org.junit.Test;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedis;
import java.util.ArrayList;
import java.util.List;
public class secound {
    private List<JedisShardInfo> list;

    private ShardedJedis getConnection() {
        return new ShardedJedis(list);
    }
    public void insert(String key, String value) throws Exception {
        ShardedJedis connection = getConnection();
        String value1 = connection.get(key);
        if(connection.get(key) != null) {
            connection.close();
            throw new Exception("插入失败，已经有名为"+key+"的键"+ "，value：" + value1);
        }
        else {
            connection.set(key, value);
            System.out.println("成功插入一组键值对" + "key：" + key + "，value：" + value);
        }
        connection.close();
    }

    public void delete(String key) throws Exception {
        ShardedJedis connection = getConnection();
        String value = connection.get(key);
        if(connection.get(key) == null) {
            connection.close();
            throw new Exception("删除失败，不存在名为"+key+"的键"+ "，value：" + value);
        }
        else {
            System.out.println("成功删除一组键值对" + "key:" + key + "，value:" + value);
            connection.del(key);
        }
        connection.close();
    }

    public void update(String key, String value) throws Exception {
        ShardedJedis connection = getConnection();
        if(connection.get(key) == null) {
            String value1 = connection.get(key);
            connection.close();
            throw new Exception("更新失败，不存在名为"+key+"的键"+ "，value：" + value1);
        }
        else {
            connection.set(key, value);
            System.out.println("成功更新一组键值对" + "key:" + key + "，value:" + value);
        }
        connection.close();
    }

    public String query(String key) {
        ShardedJedis connection = getConnection();
        String value = connection.get(key);
        String result = null;
        if(value == null) {
            System.out.println("查询结果，不存在名为"+key+"的键");
        }
        else {
            result = value;
            System.out.println("成功查找一组键值对"+"key:"+key+"，value:"+value);
        }
        connection.close();
        return result;
    }


    @SuppressWarnings("resource")
    @Test
    public void secound() {

        List<JedisShardInfo> port = new ArrayList<>();
        port.add(new JedisShardInfo("localhost", 6379));
        port.add(new JedisShardInfo("localhost", 6380));
        port.add(new JedisShardInfo("localhost", 6381));
        this.list = port;
        try {
            insert("name", "test1");
        }
        catch(Exception e) {
            System.out.println(e.getMessage());
        }
        try {
            update("name", "test3");
        }
        catch(Exception e) {
            System.out.println(e.getMessage());
        }
        try {
            query("name");
        }
        catch(Exception e) {
            System.out.println(e.getMessage());
        }
        try {
            delete("name");
        }
        catch(Exception e) {
            System.out.println(e.getMessage());
        }
    }
}

运行结果