Redis 可以支持多种部署方式，今天来看下不同的部署方式下，要如何使用jedis来进行连接。为什么使用Jedis 呢，因为它足够老(但易用性不一定是最高的)！

当然也有其他几种客户端：

1. RedisTemplate 是基于SpringBoot的封装，SpringBoot 1.x 底层也是依赖于Jedis，而 SpringBoot 2.x 以上是基于 lettuce
2. Jedis 是比较早的Redis 客户端，采用同步阻塞式IO，采用线程池时是线程安全的，对于高级的功能需要自己封装
3. Lettuce 是基于Netty 采用异步非阻塞IO，是线程安全的，提供了比较多的Redis高级功能。
4. Redission 是 Redis的分布式客户端，也是基于Netty 采用异步非阻塞式IO,线程安全

连接组件统一使用jedis

        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.1.0</version>
        </dependency>

单机

最简单的部署方式，但也是高可用性最差的一种，生产环境不建议这样部署

通过 JedisPool 获取对应连接

    public static void main(String[] args) {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(2);
        JedisPool jedisPool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 3000, "123456");
        try (Jedis jedis = jedisPool.getResource()) {
            jedis.set("test:001", "002");
        }
    }

主从

原生的Jedis没有对于读写的处理方式，可以对于主从的部署方式和单机的类似，可以使用主从两个JedisPool对象来分别管理

    public static void main(String[] args) {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(2);
        // 主redis
        JedisPool jedisPool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 3000, "123456");
        try (Jedis jedis = jedisPool.getResource()) {
            jedis.set("test:001", "002");
        }

        // 从redis
        JedisPool slavePool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 3000, "123456");
        try (Jedis slave = slavePool.getResource()) {
            slave.get("test:001");
        }
    }

哨兵

哨兵模式提供了一种高可用的方案，它主要负责监控Master与Slave的状态，如果检测出异常通知客户端，自动失效转移(如果master节点有异常，可以自动选择一个其他节点为master)

    public static void main(String[] args) {
        Set<String> sentinels = new HashSet<>();
        sentinels.add("127.0.0.1:9001");
        sentinels.add("127.0.0.1:9002");
        sentinels.add("127.0.0.1:9003");
        JedisSentinelPool sentinelPool = new JedisSentinelPool("master-sentinel", sentinels, "password");
        try (Jedis jedis = sentinelPool.getResource()) {
            jedis.set("test:001", "002");
        }
    }

集群

Redis Cluster 比较有意思，这里来讲解下大概的集群的原理。

Redis集群模式，提供了数据分片功能，不同节点存储的整个数据库的部分数据，为了保证每个主节点的高可用，每一个主节点需要有一个备节点。

Redis Cluster 将全部的内存空间分成 16384块，每一块空间称为Slot，同时将这些Slot与所对应的K-V划分给群中的每个主节点负责，而每个Key都会通过 Hash(key) mod slot的总数计算出一个Slot值，再通过 slot 找到对应的Redis实例，如果不是在当前节点，则会返回MOVE/ASK，使客户端Redirect后，与正确的服务器进行通信，所以需要客户端实现 MOVE/ASK的语义。

Redis Cluster 对于非分布式下的单一键值的命令都可以实现，但因为客户端是直连后端的服务器，对于多键值的操作，那则需要遍历所有的节点，这一点是不支持的。但是对于批量或是lua操作，可以通过 Redis Cluster的 hashTag 功能，如对于键 test:001, u:001，可以改成 test:{001} ,u:{001} ，那在计算hash值时，只会以{}号内的值作为有效值，那这些值对应的slot 可以是在同一个，达到在同一个节点上处理的能力(像Lua脚本中的涉及的Key是要在一个节点上，确实需要使用，可以使用hashtag的功能)。

客户端是可以将命令发送到Redis Cluster中任意节点，接收指令的节点会计算对应的key所在slot，如果不是当前节点，会将对应的slot对应的数据返回给客户端，那这些数据是从哪里来的呢？

Redis Cluster中的各节点使用 Gossip 协议维护节点的元数据信息，主要用于交换数据。主要包含以下四种消息：

• meet 消息： 通知节点，当前发送的节点要加入集群
• ping 消息： 集群中的节点会定期向集群中其他节点发送连接检测指令、同时也会进行信息交换, 这里的信息包含当前节点知道的其他节点信息
• pong 消息：节点接收到meeting、ping消息后会回复给来源节点，通知请求正常，并响应当前节点的状态
• fail 消息： 当一个节点判定集群中某个节点下线后，会广播通知集群其他所有节点

1. 当集群启动时，节点之间会进行通信握手，会向集群内的其他所有节点发送meet 消息，该消息会包含当前节点的信息(节点id，所负责的slot，节点标识等)，同时还会包含与该节点通信的其他节点信息，一并发出去，接收该消息的节点会获取到这些信息，并与本地节点列表进行比对，如果不存在，则接收节点会主动向新加入的节点发送一个meet消息。同时接收节点处理完成以后，会回复一个pong消息给来源节点(也会包含接收节点已经存储的节点信息)
2. 集群启动后，集群里的各个节点会向集群内其他各节点发送ping消息，检测目标节点是否正常，同时同步更新自己最新的节点slot信息给目标节点，目标节点也会响应pong消息，由来源节点更新本地节点的信息。此过程中，如果与某一个节点通信失败，则会通知集群内的其他节点进行广播fail消息
3. 当集群内的节点数比较大时，则对于集群内的节点的通信也是一个负担，主要是交换的信息量会越来越大，因此Redis Cluster 内部会以一个定时任务，每10s执行一次，按一定的规则(对于最近一次接收到pong消息时间大于cluster_node_time/2的节点)进行发送ping，这个消息会包含当前节点的信息，同时会带上1/10的其他节点信息来避免节点之前的通信成本过大。

代码配置如下：

    public static void main(String[] args) {
        Set<HostAndPort> hostAndPortSet = new HashSet<>();
        // Redis 集群的配置
        hostAndPortSet.add(new HostAndPort("127.0.0.1", 6379));
        hostAndPortSet.add(new HostAndPort("127.0.0.1", 6378));

        JedisCluster jedisCluster = new JedisCluster(hostAndPortSet);
        jedisCluster.set("test:001", "122");
    }

问题

单机版本的模式，可以如何处理做到集群的效果呢？