所有redis服务启动后，在任一服务器中创建redis集群环境。

（注意此处是为了模拟所以IP都在同一台服务器上）

redis-cli --cluster create --cluster-replicas 1 10.21.176.206:6377 10.21.176.206:6378 10.21.176.206:6379 10.21.176.206:6387 10.21.176.206:6388 10.21.176.206:6389

启动成功信息：

...
[OK] All nodes agree about slots configuration.
>>> Check for open slots...
>>> Check slots coverage...
[OK] All 16384 slots covered.

11.2.2 连接

一旦创建了集群环境，再使用默认的连接方式，虽然可以成功连接，但操作会失败。

需以集群的方式连接：

redis-cli -c -h 10.21.176.206 -p 6379

连接后即可查看集群信息：

10.21.176.206:6378> cluster nodes

集群信息，展示了主从关系及插槽分配

a4f8c0d2fc5945c5d40313cb2a5d1b319326348d 10.21.176.206:6377@16377 master - 0 1656124082792 1 connected 0-5460
a81763fb76280d1e4531ab386f2a17c5153edab3 10.21.176.206:6379@16379 master - 0 1656124081000 3 connected 10923-16383
cb073f3dba5f3d275c8932241e4d0321af2b188f 10.21.176.206:6389@16389 slave 86acdf59984c3e947bb7e741d885bcae8c1f6bb6 0 1656124082000 2 connected
86acdf59984c3e947bb7e741d885bcae8c1f6bb6 10.21.176.206:6378@16378 myself,master - 0 1656124080000 2 connected 5461-10922
13c71f711488c4dc0577d7c62f3f6c62ee88acc8 10.21.176.206:6387@16387 slave a81763fb76280d1e4531ab386f2a17c5153edab3 0 1656124081779 3 connected
a832ebaee968cea9f2c9c1a05f2a962881589469 10.21.176.206:6388@16388 slave a4f8c0d2fc5945c5d40313cb2a5d1b319326348d 0 1656124082000 1 connected 

11.2.3 关闭集群

关闭集群仅需关闭每一个节点服务即可。

注意要保证每个节点都关闭，否则会影响再次创建集群环境。

11.2.4 往集群中添加节点

往已有集群中再添加节点，大致分为如下几步：

1、添加master

加入集群

redis-cli --cluster add-node [节点ip:port] [集群中任意节点ip:port]

手动分配slot

新加的节点没有分配任何slot，需要手动将已有节点的插槽slot分配给新加的节点。

redis-cli --cluster reshard ...

2、若添加从机，则需要指明主机

redis-cli --cluster add-node [节点ip:port] [master节点ip:port] --cluster-slave --cluster-master-id [masterid]

11.3 集群数据分配

redis cluster 如何分配节点

redis-cli --cluster create --cluster-replicas 1 10.21.176.206:6377 10.21.176.206:6378 10.21.176.206:6379 10.21.176.206:6387 10.21.176.206:6388 10.21.176.206:6389

• 一个集群至少要有三个主节点
• 选项 –cluster-replicas 1 ：表示我们希望为集群中的每个主节点创建一个从节点。
• 分配原则尽量保证每个主数据库运行在不同的 IP 地址，每个从库和主库不在一个 IP 地址上。

什么是 slots

一个 Redis 集群包含 16384 （2的14次方）个插槽（hash slot），数据库中的每个键都属于这 16384 个插槽的其中一个。

集群使用公式 CRC16 (key) % 16384 来计算键 key 属于哪个槽， 其中 CRC16 (key) 语句用于计算键 key 的 CRC16 校验和 。

集群中的每个节点负责处理一部分插槽。 举个例子， 如果一个集群可以有主节点， 其中：

• 节点 A 负责处理 0 号至 5460 号插槽。
• 节点 B 负责处理 5461 号至 10922 号插槽。
• 节点 C 负责处理 10923 号至 16383 号插槽。

在集群中录入值

在 redis-cli 每次录入、查询键值，redis 都会计算出该 key 应该送往的插槽，如果不是该客户端对应服务器的插槽，redis 会报错，并告知应前往的 redis 实例地址和端口。

redis-cli 客户端提供了 –c 参数实现自动重定向。如 redis-cli -c –p 6379 登入后，再录入、查询键值对可以自动重定向。不在一个 slot 下的键值，是不能使用 mget,mset 等多键操作。

集群中常用命令

//计算插槽
127.0.0.1:6379> cluster keyslot k1
(integer) 12706

//查看插槽中的键数（仅当此插槽段分配给当前主机时有效）
127.0.0.1:6379> cluster countkeysinslot 12706
(integer) 1

11.4 故障恢复

主从恢复

主节点下线，从节点会自动升为主节点。（注意：timeout秒后）

主机下线后再恢复，再上线后会变成从机。

集群故障

如果所有某一段插槽的主从节点都宕掉，redis 服务是否还能继续？

• 如果某一段插槽的主从都挂掉，而 cluster-require-full-coverage 为 yes ，那么整个集群都挂掉。
• 如果某一段插槽的主从都挂掉，而 cluster-require-full-coverage 为 no ，那么该插槽数据全都不能使用也无法存储。

11.5 Jedis连接

public void clusterDemo(){
    //连接任意节点即可
    HostAndPort hostAndPort = new HostAndPort("10.21.176.206", 6379);
    JedisCluster jedisCluster = new JedisCluster(hostAndPort);

    jedisCluster.set("name", "test1");
    String name = jedisCluster.get("name");
    System.out.println(name);
}

11.6 总结

Redis 集群优点

• 实现扩容
• 分摊压力
• 无中心配置相对简单

Redis 集群不足

• 多键操作是不被支持的。
• 多键的 Redis 事务是不被支持的，lua 脚本不被支持。
• 由于集群方案出现较晚，很多公司已经采用了其他的集群方案，而代理或者客户端分片的方案想要迁移至 redis cluster，需要整体迁移而不是逐步过渡，复杂度较大。

十二、应用问题解决

12.1 缓存穿透

问题描述

key 对应的数据在数据源并不存在，每次针对此 key 的请求从缓存获取不到，请求都会压到数据源（数据库），从而可能压垮数据源。

比如用一个不存在的用户 id 获取用户信息，不论缓存还是数据库都没有，若黑客利用此漏洞进行攻击可能压垮数据库。

缓存穿透发生的条件：

• 应用服务器压力变大
• redis 命中率降低
• 一直查询数据库，使得数据库压力太大而压垮

其实 redis 在这个过程中一直平稳运行，崩溃的是我们的数据库（如 MySQL）。

缓存穿透发生的原因：黑客或者其他非正常用户频繁进行很多非正常的 url 访问，使得 redis 查询不到，压力给到数据库。

解决方案

• 对空值缓存：如果一个查询返回的数据为空（不管是数据是否不存在），我们仍然把这个空结果（null）进行缓存，设置空结果的过期时间会很短，最长不超过五分钟。
• 设置可访问的名单（白名单）：使用 bitmaps 类型定义一个可以访问的名单，名单 id 作为 bitmaps 的偏移量，每次访问和 bitmap 里面的 id 进行比较，如果访问 id 不在 bitmaps 里面，进行拦截，不允许访问。
• 采用布隆过滤器：布隆过滤器（Bloom Filter）是 1970 年由布隆提出的。它实际上是一个很长的二进制向量 (位图) 和一系列随机映射函数（哈希函数）。布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都远远超过一般的算法，缺点是有一定的误识别率和删除困难。
• 进行实时监控：当发现 Redis 的命中率开始急速降低，需要排查访问对象和访问的数据，和运维人员配合，可以设置黑名单限制服务。

12.2 缓存击穿

问题描述

key 对应的数据存在，但在 redis 中过期，此时若有大量并发请求过来，这些请求发现缓存过期一般都会从后端数据库加载数据并回设到缓存，这个时候大并发的请求可能会瞬间把后端数据库压垮。

缓存击穿的现象：

• 数据库访问压力瞬时增加，数据库崩溃
• redis 里面没有出现大量 key 过期
• redis 正常运行

缓存击穿发生的原因：redis 某个 key 过期了，大量访问使用这个 key（热门 key）。

解决方案

key 可能会在某些时间点被超高并发地访问，是一种非常 “热点” 的数据。

• 预先设置热门数据：在 redis 高峰访问之前，把一些热门数据提前存入到 redis 里面，加大这些热门数据 key 的时长。
• 实时调整：现场监控哪些数据热门，实时调整 key 的过期时长。
• 使用锁：
  • 就是在缓存失效的时候（判断拿出来的值为空），不是立即去 load db。
  • 先使用缓存工具的某些带成功操作返回值的操作（比如 Redis 的 SETNX）去 set 一个 mutex key。
  • 当操作返回成功时，再进行 load db 的操作，并回设缓存，最后删除 mutex key；
  • 当操作返回失败，证明有线程在 load db，当前线程睡眠一段时间再重试整个 get 缓存的方法。

12.3 缓存雪崩

问题描述

key 对应的数据存在，但在 redis 中过期，此时若有大量并发请求过来，这些请求发现缓存过期一般都会从后端数据库加载数据并回设到缓存，这个时候大并发的请求可能会瞬间把后端数据库压垮。

缓存雪崩与缓存击穿的区别在于这里针对很多 key 缓存，前者则是某一个 key 正常访问。

缓存失效瞬间：

解决方案

• 构建多级缓存架构：nginx 缓存 + redis 缓存 + 其他缓存（ehcache 等）。
• 使用锁或队列：用加锁或者队列的方式来保证不会有大量的线程对数据库一次性进行读写，从而避免失效时大量的并发请求落到底层存储系统上，该方法不适用高并发情况。
• 设置过期标志更新缓存：记录缓存数据是否过期（设置提前量），如果过期会触发通知另外的线程在后台去更新实际 key 的缓存。
• 将缓存失效时间分散开：比如可以在原有的失效时间基础上增加一个随机值，比如 1-5 分钟随机，这样每一个缓存的过期时间的重复率就会降低，就很难引发集体失效的事件。

12.4 分布式锁

12.4.1 问题描述

随着业务发展的需要，原单体单机部署的系统被演化成分布式集群系统后，由于分布式系统多线程的特点以及分布在不同机器上，这将使原单机部署情况下的并发控制锁策略失效，单纯的 Java API 并不能提供分布式锁的能力。为了解决这个问题就需要一种跨 JVM 的互斥机制来控制共享资源的访问，这就是分布式锁要解决的问题。

分布式锁主流的实现方案：

• 基于数据库实现分布式锁
• 基于缓存（Redis 等）
• 基于 Zookeeper

根据实现方式，分布式锁还可以分为类 CAS 自旋式分布式锁以及 event 事件类型分布式锁：

• 类 CAS 自旋式分布式锁：询问的方式，类似 java 并发编程中的线程获询问的方式尝试加锁，如 mysql、redis。
• 另外一类是 event 事件通知进程后续锁的变化，轮询向外的过程，如 zookeeper、etcd。

每一种分布式锁解决方案都有各自的优缺点：

• 性能：redis 最高
• 可靠性：zookeeper 最高

12.4.2 使用 redis 实现分布式锁

• setnx：通过该命令尝试获得锁，没有获得锁的线程会不断等待尝试。
• set key ex 3000nx：设置过期时间，自动释放锁，解决当某一个业务异常而导致锁无法释放的问题。但是当业务运行超过过期时间时，开辟监控线程增加该业务的运行时间，直到运行结束，释放锁。
• uuid：设置 uuid，释放前获取这个值，判断是否自己的锁，防止误删锁，造成没锁的情况。

Java示例：

public static void testLock() throws InterruptedException {
    Jedis jedis = new Jedis("127.0.0.1", 6379);

    //1、声明唯一uuid
    String lockValue = UUID.randomUUID().toString();

    //2、尝试获取锁
    SetParams nx = new SetParams().ex(2).nx();
    String lock = jedis.set(lockKey, lockValue, nx);
    System.out.println(lock);

    if ("OK".equals(lock)) {
        //3、获取得到就处理业务，处理完成后释放锁
        value++;

        //4、释放锁  （避免业务处理时长 > 过期时间，导致删掉其他线程的锁）
        if (lockValue.equals(jedis.get(lockKey))) {
            //★★
            jedis.del(lockKey);
        }
    } else {
        //5、获取不到则睡眠一会再次尝试
        Thread.sleep(1000);
        testLock();
    }
}

注意一下两点：

1. 创建锁时要同时设置过期时间。否则若创建完锁后，连接断掉未设置过期时间，会导致其他线程始终无法获取到锁。
2. 释放锁时要判断是否是当前线程加的锁值。避免因业务超时锁自动释放后，误删除掉其他线程的锁。

即使保证了如上两点，★★处仍有可能误删其他线程的锁：锁值是当前线程添加的，符合删除条件。但准备删除的一瞬间，若锁到达超时时间自动释放，且被其他线程获取到并加锁，则删除时会误删掉其他线程的锁。

鉴于上述可能，可采用LUA脚本方式：

public static void testLock() throws InterruptedException {
    Jedis jedis = new Jedis("127.0.0.1", 6379);

    //1、声明唯一uuid
    String lockValue = UUID.randomUUID().toString();

    //2、尝试获取锁
    SetParams nx = new SetParams().ex(2).nx();
    String lock = jedis.set(lockKey, lockValue, nx);
    System.out.println(lock);


    if ("OK".equals(lock)) {
        //3、获取得到就处理业务，处理完成后释放锁
        value++;

        //4、释放锁
        String script = "if redis.call('get', KEYS[1]) == KEYS[2] then return redis.call('del', KEYS[1]) else return 0 end";
        String sha1 = jedis.scriptLoad(script);
        Object result = jedis.evalsha(sha1, 2, lockKey, lockValue);
        System.out.println(result);
    } else {
        //5、获取不到则睡眠一会再次尝试
        Thread.sleep(1000);
        testLock();
    }
}

12.4.3 RedLock

Redlock 是一种算法，Redlock 也就是 Redis Distributed Lock，可用实现多节点 redis 的分布式锁。

RedLock 官方推荐，Redisson 完成了对 Redlock 算法封装。

此种方式具有以下特性：

• 互斥访问：即永远只有一个 client 能拿到锁。
• 避免死锁：最终 client 都可能拿到锁，不会出现死锁的情况，即使锁定资源的服务崩溃或者分区，仍然能释放锁。
• 容错性：只要大部分 Redis 节点存活（一半以上），就可以正常提供服务

RedLock 原理（了解）

• 获取当前 Unix 时间，以毫秒为单位。
• 依次尝试从 N 个实例，使用相同的 key 和随机值获取锁。在步骤 2，当向 Redis 设置锁时，客户端应该设置一个网络连接和响应超时时间，这个超时时间应该小于锁的失效时间。例如你的锁自动失效时间为 10 秒，则超时时间应该在 5-50 毫秒之间。这样可以避免服务器端 Redis 已经挂掉的情况下，客户端还在死死地等待响应结果。如果服务器端没有在规定时间内响应，客户端应该尽快尝试另外一个 Redis 实例。
• 客户端使用当前时间减去开始获取锁时间（步骤 1 记录的时间）就得到获取锁使用的时间。当且仅当从大多数（这里是 3 个节点）的 Redis 节点都取到锁，并且使用的时间小于锁失效时间时，锁才算获取成功。
• 如果取到了锁，key 的真正有效时间等于有效时间减去获取锁所使用的时间（步骤 3 计算的结果）。
• 如果因为某些原因，获取锁失败（没有在至少 N/2+1 个 Redis 实例取到锁或者取锁时间已经超过了有效时间），客户端应该在所有的 Redis 实例上进行解锁（即便某些 Redis 实例根本就没有加锁成功）。

13 新版功能

6.0之后版本添加的功能。

13.1 ACL 访问控制列表

Access Control List功能允许设置用户可以执行的命令和键。

比如：

//查看当前acl权限列表
127.0.0.1:6379> acl list
1) "user default on nopass ~* &* +@all"
//查看当前用户
127.0.0.1:6379> acl whoami
"default"

添加acl：

127.0.0.1:6379> acl setuser xiang on >xiang ~cache:* +get
OK

切换用户后，该用户访问受限

127.0.0.1:6379> auth xiang xiang
127.0.0.1:6379> get cache
(error) NOPERM this user has no permissions to access one of the keys used as arguments
127.0.0.1:6379> get cache:
(nil)

13.2 IO多线程

简介

IO 多线程其实指客户端交互部分的网络 IO 交互处理模块 多线程，而非执行命令多线程。

Redis6 执行命令依然是单线程。

原理架构

Redis 6 加入多线程，但跟 Memcached 这种从 IO 处理到数据访问多线程的实现模式有些差异。Redis 的多线程部分只是用来处理网络数据的读写和协议解析，执行命令仍然是单线程。之所以这么设计是不想因为多线程而变得复杂，需要去控制 key、lua、事务，LPUSH/LPOP 等等的并发问题。整体的设计大体如下:

另外，多线程 IO 默认也是不开启的，需要再配置文件中配置：

• io-threads-do-reads yes
• io-threads 4

14 总结

加油加油！