关于redis:Redis-入门实践

Redis，REmote DIctionary Server，是一个由 Salvatore Sanfilippo 写的 Key-Value 存储系统。

Redis 是一个开源的应用 ANSI C 语言编写、恪守 BSD 协定、反对网络、可基于内存亦可长久化的日志型、Key-Value 数据库，并提供多种语言的 API。

它通常被称为数据结构服务器，因为值 (Value) 能够是字符串 (String), 哈希(Map), 列表(list), 汇合(sets) 和有序汇合 (sorted sets) 等类型。

官网地址：https://redis.io

下载地址：https://github.com/antirez/redis/releases

装置实现后在装置目录下执行：

redis-server.exe redis.windows.conf

下载，解压缩并编译 Redis 最新稳固版本：

wget http://download.redis.io/releases/redis-5.0.3.tar.gz
tar xzf redis-5.0.3.tar.gz
cd redis-5.0.3
make

启动 Redis 服务：

cd src
./redis-server ../redis.conf

Redis 的配置文件，Windows 是装置目录的 redis.windows.conf 文件，Linux 是装置目录下的 redis.conf 文件。

在连贯上 Redis 服务后，能够通过 config 命令查看或者编辑配置项。

redis 127.0.0.1:6379> config get ${name}

例：

127.0.0.1:6379> config get port
1) "port"
2) "6379"

redis 127.0.0.1:6379> config set ${name} ${value}

例：

127.0.0.1:6379> config set loglevel "notice"
OK

注：局部配置不能通过 config 命令动静编辑，须要间接批改配置文件对应内容，例如端口 port。

是否以守护线程运行，默认为 no，应用 yes 启用守护线程；（后盾启动）

Redis 监听端口，默认为 6379；

注：作者曾解释过 6379 的来历。6379 在手机按键对应的英文是 MERZ，意大利歌女 Alessia Merz 的名字。参考链接：http://oldblog.antirez.com/po…

指定客户端连贯地址，默认为 127.0.0.1，也就是只能本地连接，屏蔽该参数启用近程连贯；

客户端闲暇多长时间（秒）敞开该连贯，指定为 0 敞开该性能；

save <seconds> <changes>

指定在多长时间内，至多有多少次更新操作，就将数据同步到数据文件，能够多个条件配合应用；

Redis 默认提供了三个条件：

save 900 1
save 300 10
save 60 10000

阐明 Redis 在下列三种状况将会同步数据到文件中：

在 900 秒后至多 1 个 key 产生扭转；
在 300 秒后至多 10 个 key 产生扭转；
在 60 秒后至多 10000 个 key 产生扭转；

本地数据库文件名，默认是 dump.rdb；

本地数据库文件寄存门路，默认是./（当前目录）；

replicaof <masterip> <masterport>

当在主从复制中，本人作为 slave，设置 master 的 ip 和端口，在该 slave 启动时，会主动从 master 进行数据同步；

当 master 设置了明码后，slave 连贯 master 的明码；

设置 Redis 连贯明码，默认敞开；

开启 Redis 数据长久化到日志中（AOF），默认为 no 未开启；

因为默认的数据长久化计划（RDB)，存储到 dump.rdb 文件中，在断电或服务忽然挂掉的状况下会失落数据，开启日志长久化能够补救该有余；

日志文件名，默认为 appendonly.aof；

日志更新频率，有 3 个可选值；

no，让操作系统本人决定，速度最快；
always，每次操作都会写更新日志，速度较慢但最平安；
everysec，每秒更新一次日志，折中计划；（默认）

# maxmemory <bytes>

# MAXMEMORY POLICY: how Redis will select what to remove when maxmemory
# is reached. You can select among five behaviors:
#
# volatile-lru -> Evict using approximated LRU among the keys with an expire set.
# allkeys-lru -> Evict any key using approximated LRU.
# volatile-lfu -> Evict using approximated LFU among the keys with an expire set.
# allkeys-lfu -> Evict any key using approximated LFU.
# volatile-random -> Remove a random key among the ones with an expire set.
# allkeys-random -> Remove a random key, any key.
# volatile-ttl -> Remove the key with the nearest expire time (minor TTL)
# noeviction -> Don't evict anything, just return an error on write operations.
#
# LRU means Least Recently Used
# LFU means Least Frequently Used
#
# Both LRU, LFU and volatile-ttl are implemented using approximated
# randomized algorithms.
#
# Note: with any of the above policies, Redis will return an error on write
#       operations, when there are no suitable keys for eviction.
#
#       At the date of writing these commands are: set setnx setex append
#       incr decr rpush lpush rpushx lpushx linsert lset rpoplpush sadd
#       sinter sinterstore sunion sunionstore sdiff sdiffstore zadd zincrby
#       zunionstore zinterstore hset hsetnx hmset hincrby incrby decrby
#       getset mset msetnx exec sort
#
# The default is:
#
# maxmemory-policy noeviction

LRU least recently used 最近应用；
LFU least frequently used 起码应用；
noeviction 默认淘汰策略，return an error；

Redis 反对五种数据类型：string（字符串），hash（哈希），list（列表），set（汇合）及 zset（sorted set：有序汇合）。

最根本类型，二进制平安，也能够蕴含 jpg 或序列化后的对象，最大反对 512M；

例：

127.0.0.1:6379> SET name "caojiantao"
OK
127.0.0.1:6379> GET name
"caojiantao"

Key-Value 键值对汇合，适宜用来存储简略对象；

例：

127.0.0.1:6379> hmset user name caojiantao age 18
OK
127.0.0.1:6379> hget user age
"18"

简略的字符串列表，双向链表 的数据结构；

例：

127.0.0.1:6379> lpush months 1
(integer) 1
127.0.0.1:6379> lpush months 2
(integer) 2
127.0.0.1:6379> rpush months 3
(integer) 3
127.0.0.1:6379> lrange months 0 10
1) "2"
2) "1"
3) "3"
127.0.0.1:6379> lpop months
"2"
127.0.0.1:6379> rpop months
"3"

string 类型的无序汇合（唯一性），hash 构造，操作复杂度为 O(1)；

例：

127.0.0.1:6379> sadd team zhangsan lisi
(integer) 2
127.0.0.1:6379> smembers team
1) "zhangsan"
2) "lisi"
127.0.0.1:6379> sadd team lisi
(integer) 0

同 set，不过每个子元素会关联一个 double 类型的分数 score，zset 依据 score 排序；

例：

127.0.0.1:6379> zadd days 1 one
(integer) 1
127.0.0.1:6379> zadd days 0 zero
(integer) 1
127.0.0.1:6379> zadd days 2 two
(integer) 1
127.0.0.1:6379> zrangebyscore days 0 10
1) "zero"
2) "one"
3) "two"

geo 为地理位置类型，3.2+ 版本才开始反对，其底层实现仍是 zset，所以删除成员命令同 zrem；

重要命令一览：

geoadd 减少某个地理位置坐标
geopos 获取某个地理位置坐标
geodist 获取两个地理位置的间隔
georadius 依据给定的地理位置坐标获取指定范畴内的地理位置汇合
geohash 获取某个地理位置的 geohash 值

例：

127.0.0.1:6379> geoadd positions 116.407258 39.991496 olympics 116.403909 39.915547 tiananmen 116.333374 40.009645 qinghua
(integer) 3
127.0.0.1:6379> geodist positions tiananmen qinghua
"12070.5091"
127.0.0.1:6379> georadiusbymember positions tiananmen 20 km
1) "qinghua"
2) "tiananmen"
3) "olympics"
127.0.0.1:6379> georadiusbymember positions tiananmen 10 km
1) "tiananmen"
2) "olympics"

类型	简介	个性	场景
String(字符串)	二进制平安	能够蕴含任何数据, 比方 jpg 图片或者序列化的对象, 一个键最大能存储 512M	—
Hash(字典)	键值对汇合, 即编程语言中的 Map 类型	适宜存储对象, 并且能够像数据库中 update 一个属性一样只批改某一项属性值(Memcached 中须要取出整个字符串反序列化成对象批改完再序列化存回去)	存储、读取、批改用户属性
List(列表)	链表(双向链表)	增删快, 提供了操作某一段元素的 API	1, 最新消息排行等性能(比方朋友圈的工夫线) 2, 音讯队列
Set(汇合)	哈希表实现, 元素不反复	1、增加、删除, 查找的复杂度都是 O(1) 2、为汇合提供了求交加、并集、差集等操作	1、独特好友 2、利用唯一性, 统计拜访网站的所有独立 ip 3、好友举荐时, 依据 tag 求交加, 大于某个阈值就能够举荐
Sorted Set(有序汇合)	将 Set 中的元素减少一个权重参数 score, 元素按 score 有序排列	数据插入汇合时, 曾经进行人造排序	1、排行榜
geo	经纬度坐标类型		左近的人

multi
...（命令）exec

一次执行多条命令，有以下特点：

发送 exec 指令前，所有的操作都会放入队列缓存；
执行事务时，任何命令执行失败，其余命令失常被执行，已操作的命令不会回滚（非原子性）；
执行过程中，其余客户端的命令不会插入到该事务中；

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a 1
QUEUED
127.0.0.1:6379> set b 2
QUEUED
127.0.0.1:6379> get a
QUEUED
127.0.0.1:6379> del a
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) "1"
4) (integer) 1

Redis 反对一个公布订阅的音讯通信模式，发送者 pub 发送音讯，订阅者 sub 承受音讯，可订阅任意数量的频道 channel；

三个客户端都订阅了 channel 这个频道；

一旦有音讯公布 pub 到 channel 中，之前订阅该 channel 的三个客户端都会收到这个 message；

例：

客户端订阅 talk 频道；

127.0.0.1:6379> subscribe talk
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "talk"
3) (integer) 1

另开客户端公布音讯值 talk 频道；

127.0.0.1:6379> publish talk "hello world"
(integer) 1

此时客户端收到音讯；

1) "message"
2) "talk"
3) "hello world"

Redis 应用 Lua 解释器执行，执行命令为 eval；

eval script numkeys key [key ...] arg [arg ...]

script，lua 脚本内容
numkeys，key 的个数
key，Redis 中 key 属性
arg，自定义参数

注：key 和 arg 在 lua 脚本占位符别离为 KEYS[] 和 ARGV[]，必须大写，数组下标从 1 开始。

例：获取脚本参数

127.0.0.1:6379> eval "return {KEYS[1],KEYS[2],ARGV[1]}" 2 "key1" "key2" "argv1"
1) "key1"
2) "key2"
3) "argv1"

通常会将脚本存储到一个 lua 文件中，如果 test.lua 内容如下：

return {KEYS[1],KEYS[2],ARGV[1]}

执行这个 lua 脚本命令；

redis-cli.exe --eval test.lua "key1" "key2" , "argv1"
1) "key1"
2) "key2"
3) "argv1"

留神参数格局与之前有点出入，执行 lua 脚本文件不须要 numkeys，key 和 arg 参数用逗号相隔；

两种编码实现：ziplist 和 skiplist，当满足下列条件采纳 ziplist 编码方式：

有序汇合保留的元素数量小于 128 个；
有序汇合保留的所有元素成员的长度小于 64 字节；

同时 zset 还保护了一个字典，保留元素 member 到分值 score 的映射，便于等值查找。

压缩列表，2 个紧挨在一起的节点组成一个元素，代表元素的理论值和分值大小。

跳跃表，有利于范畴查找，相比红黑树实现难度较为简单得多。

参考：https://segmentfault.com/a/11…

齐全基于内存；
数据结构简略；
单线程防止上下文切换；
多路 I/0 复用模型，非阻塞；

github: https://github.com/xetorthio/jedis

阻塞 I/O 模型，调用办法都是同步的，不反对异步调用，并且 Jedis 客户端非线程平安，须要联合连接池应用；

maven 依赖：

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

demo 示例：

String host = "127.0.0.1";
int port = 6379;
// 连贯本地的 Redis 服务
Jedis jedis = new Jedis(host, port);
// 查看服务是否运行
System.out.println("服务正在运行:" + jedis.ping());

// 基本操作
String key = "welcome";
jedis.set(key, "hello world");
System.out.println(jedis.get(key));

// 连接池配置
GenericObjectPoolConfig config = new GenericObjectPoolConfig();
config.setMaxTotal(1);
// 连接池操作
JedisPool pool = new JedisPool(config, host, port);
Jedis a = pool.getResource();
// a.close();
System.out.println(a);
Jedis b = pool.getResource();
System.out.println(b);

github: https://github.com/lettuce-io/lettuce-core

基于 Netty 框架，异步调用，线程平安；

maven 依赖：

<dependency>
    <groupId>io.lettuce</groupId>
    <artifactId>lettuce-core</artifactId>
    <version>5.0.3.RELEASE</version>
</dependency>

demo 示例：

// 1. 结构 uri
RedisURI uri = RedisURI.builder()
    .withHost("127.0.0.1")
    .withPort(6379)
    .build();
// 2. 创立 client
RedisClient client = RedisClient.create(uri);
// 3. 连贯 redis
StatefulRedisConnection<String, String> connect = client.connect();
// 4. 获取操作命令（同步）RedisCommands<String, String> commands = connect.sync();
String key = "welcome";
System.out.println(commands.get(key));

connect.close();

github: https://github.com/redisson/redisson

实现了分布式和可扩大的 Java 数据结构；

maven 依赖：

<dependency>
   <groupId>org.redisson</groupId>
   <artifactId>redisson</artifactId>
   <version>3.11.5</version>
</dependency>

demo 示例：

public static void main(String[] args) {
    // 1. 创立连贯配置
    Config config = new Config();
    config.useSingleServer().setAddress("redis://10.242.24.246:6379");
    // 2. 创立 redisson 实例
    RedissonClient client = Redisson.create(config);
    // 操作数据
    RBucket<Object> bucket = client.getBucket("name");
    bucket.set("caojiantao");
    System.out.println(bucket.get());
    // 3. 敞开连贯实例
    client.shutdown();}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

注：springboot 2.x 之后应用了 Lettuce 替换掉了底层 Jedis 的依赖。

在 application.yml 增加上面属性

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    # 连接池配置（依据须要）lettuce:
      pool:
        max-idle: 8

springboot 默认注入了 RedisTemplate 和 StringRedisTemplate 两个实例用来操作 Redis，前者 key 和 value 都是采纳 JDK 序列化，后者只能操作 String 数据类型；

可间接注入应用；

@Autowired
@Qualifier("redisTemplate")
private RedisTemplate redisTemplate;

@Autowired
@Qualifier("stringRedisTemplate")
private StringRedisTemplate stringRedisTemplate;

public void test() {
    String key = "welcome";
    Object o = redisTemplate.opsForValue().get(key);
    // 此处为 null，因为 key 序列化形式为 JDK
    System.out.println(o);

    String s = stringRedisTemplate.opsForValue().get(key);
    System.out.println(s);
}

注：Redis 默认注入原理可参考 RedisAutoConfiguration 类。

默认注入的两种 RedisTemplate 显然不实用所有的业务场景，自定义 Template 个别只需下列两个步骤；

自定义 RedisSerializer；
注入自定义 Template；

参考第三方序列化框架 protostuff，序列化后体积较小，速度快；

import io.protostuff.*;
import io.protostuff.runtime.RuntimeSchema;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;

/**
 * @author caojiantao
 */
public class ProtoStuffSerializer<T> implements RedisSerializer<T> {

    private Class<T> clazz;

    public ProtoStuffSerializer(Class<T> clazz) {this.clazz = clazz;}

    @Override
    public byte[] serialize(T t) throws SerializationException {if (t == null) {return new byte[0];
        }
        Schema<T> schema = RuntimeSchema.getSchema(clazz);
        return ProtostuffIOUtil.toByteArray(t, schema, LinkedBuffer.allocate());
    }

    @Override
    public T deserialize(byte[] bytes) throws SerializationException {if (bytes == null) {return null;}
        Schema<T> schema = RuntimeSchema.getSchema(clazz);
        T t = schema.newMessage();
        ProtostuffIOUtil.mergeFrom(bytes, t, schema);
        return t;
    }
}

而后手动注入到 spring 容器中；

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;

@Configuration
public class RedisConfig {@Bean("customTemplate")
    public RedisTemplate<String, Student> customTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Student> template = new RedisTemplate<>();
        // 注入 redis 连贯工厂实例
        template.setConnectionFactory(factory);
        ProtoStuffSerializer<Student> serializer = new ProtoStuffSerializer<>(Student.class);
        // 设置 key、value 序列化形式
        template.setKeySerializer(RedisSerializer.string());
        template.setValueSerializer(serializer);
        template.afterPropertiesSet();
        return template;
    }
}

将所有数据存储到单个 Redis 次要存在两个问题；

数据备份；
数据量过大升高性能；

主从模式 很好的解决了以上问题。一个 Redis 实例作为主机 master，其余的作为从机 slave，主机次要用于数据的写入，从机则次要提供数据的读取。从机在启动时会同步全量主机数据，主机也会在写入数据的时候同步到所有的从机。

有两种形式能够设置主从关系；

在启动配置文件指定 replicaof 参数；
启动 Redis 实例后执行 replicaof ip port 命令；

简略测试，复制 redis.conf 文件，次要配置如下：

master：

port 6379
logfile "6379.log"
dbfilename "dump-6379.rdb"

slave_1：

port 6380
logfile "6380.log"
dbfilename "dump-6380.rdb"
replicaof 127.0.0.1 6379

slave_2：

port 6381
logfile "6381.log"
dbfilename "dump-6381.rdb"
replicaof 127.0.0.1 6379

slave_3：

port 6382
logfile "6382.log"
dbfilename "dump-6382.rdb"
replicaof 127.0.0.1 6379

顺次启动上述四个 Redis 实例；

./redis-server 6379.conf
./redis-server 6380.conf
./redis-server 6381.conf
./redis-server 6382.conf

连贯 6379 主机 master，查看 replication 信息；

127.0.0.1:6379> info replication
# Replication
role:master
connected_slaves:3
slave0:ip=127.0.0.1,port=6380,state=online,offset=322,lag=0
slave1:ip=127.0.0.1,port=6381,state=online,offset=322,lag=1
slave2:ip=127.0.0.1,port=6382,state=online,offset=322,lag=0
master_replid:417b1e3811a2d9b3465876d65c67a36949de8f9f
master_replid2:0000000000000000000000000000000000000000
master_repl_offset:322
second_repl_offset:-1
repl_backlog_active:1
repl_backlog_size:1048576
repl_backlog_first_byte_offset:1
repl_backlog_histlen:322

阐明了以后 Redis 实例为主机，有三个从机；

在以后主机写入数据；

127.0.0.1:6379> set msg "hello world"
OK

在其余任意从机执行获取操作；

127.0.0.1:6382> get msg
"hello world"

曾经胜利设置主从同步。

主从模式存在肯定的弊病，master 一旦产生宕机，主从同步过程将会中断。

Sentinel（哨兵）作为一个独自的服务，用来监控 master 主机，间接监控所有 slave 从机，如下图所示；

sentinel 次要有以下三个特点；

监控 Redis 实例是否失常运行；
节点产生故障，可能告诉另外；

当 master 产生故障，sentinel 会采纳在以后 sentinel 集群中投票形式，从以后所有 slave 中，推举一个作为新的 master，从而保障了 Redis 的高可用性。

在哨兵模式下，每个 Redis 实例都是存储的全量数据。为了最大化利用内存空间，采纳集群模式，即分布式存储，每台 Redis 存储不同的内容。Redis 集群没有应用一致性 hash，而是引入了哈希槽的概念。

数据存储在 16384 个 slot（插槽）中，所有的数据都是依据肯定算法映射到某个 slot 中；

为什么是 16384：https://github.com/antirez/re…

集群模式至多三个 Redis 节点，否则会提醒：

./redis-cli --cluster create 127.0.0.1:7000 127.0.0.1:7001
*** ERROR: Invalid configuration for cluster creation.
*** Redis Cluster requires at least 3 master nodes.
*** This is not possible with 2 nodes and 0 replicas per node.
*** At least 3 nodes are required.

在 src 目录创立 confs 文件夹，复制 redis.conf 文件 6 分，三主三从；

次要配置如下；

port 7000
cluster-enabled yes
cluster-node-timeout 15000
cluster-config-file "nodes-7000.conf"
pidfile /var/run/redis-7000.pid
logfile "cluster-7000.log"
dbfilename dump-cluster-7000.rdb
appendfilename "appendonly-cluster-7000.aof"

程序启动相干 Redis 示例，最初创立集群；

./redis-server confs/7000.conf
./redis-server confs/7001.conf
./redis-server confs/7002.conf
./redis-server confs/7003.conf
./redis-server confs/7004.conf
./redis-server confs/7005.conf
./redis-cli --cluster create 127.0.0.1:7000 127.0.0.1:7001 127.0.0.1:7002 127.0.0.1:7003 127.0.0.1:7004 127.0.0.1:7005 --cluster-replicas 1

控制台输入创立集群信息：

>>> Performing hash slots allocation on 6 nodes...
Master[0] -> Slots 0 - 5460
Master[1] -> Slots 5461 - 10922
Master[2] -> Slots 10923 - 16383
Adding replica 10.242.24.246:7003 to 10.242.24.246:7000
Adding replica 10.242.24.246:7004 to 10.242.24.246:7001
Adding replica 10.242.24.246:7005 to 10.242.24.246:7002
>>> Trying to optimize slaves allocation for anti-affinity
[WARNING] Some slaves are in the same host as their master
M: bbb45e488e5679b79dd077f97803304534793420 10.242.24.246:7000
   slots:[0-5460] (5461 slots) master
M: b490121213e22451a9b788755b0be0d3bf158cda 10.242.24.246:7001
   slots:[5461-10922] (5462 slots) master
M: 000f55716f8e9f2c635744999a49425bcc65595d 10.242.24.246:7002
   slots:[10923-16383] (5461 slots) master
S: 17611ff6f3dffbfab60ce4ae7b7991a9ae280bcd 10.242.24.246:7003
   replicates b490121213e22451a9b788755b0be0d3bf158cda
S: 950a5a467ccb6af3280b67a3f2ce2e3fa7510bd8 10.242.24.246:7004
   replicates 000f55716f8e9f2c635744999a49425bcc65595d
S: c15ce5e96e69a1d93c5a71953ee044af6b2bd560 10.242.24.246:7005
   replicates bbb45e488e5679b79dd077f97803304534793420
Can I set the above configuration? (type 'yes' to accept): yes
>>> Nodes configuration updated
>>> Assign a different config epoch to each node
>>> Sending CLUSTER MEET messages to join the cluster
Waiting for the cluster to join
...........
>>> Performing Cluster Check (using node 10.242.24.246:7000)
M: bbb45e488e5679b79dd077f97803304534793420 10.242.24.246:7000
   slots:[0-5460] (5461 slots) master
   1 additional replica(s)
S: c15ce5e96e69a1d93c5a71953ee044af6b2bd560 10.242.24.246:7005
   slots: (0 slots) slave
   replicates bbb45e488e5679b79dd077f97803304534793420
M: b490121213e22451a9b788755b0be0d3bf158cda 10.242.24.246:7001
   slots:[5461-10922] (5462 slots) master
   1 additional replica(s)
S: 950a5a467ccb6af3280b67a3f2ce2e3fa7510bd8 10.242.24.246:7004
   slots: (0 slots) slave
   replicates 000f55716f8e9f2c635744999a49425bcc65595d
M: 000f55716f8e9f2c635744999a49425bcc65595d 10.242.24.246:7002
   slots:[10923-16383] (5461 slots) master
   1 additional replica(s)
S: 17611ff6f3dffbfab60ce4ae7b7991a9ae280bcd 10.242.24.246:7003
   slots: (0 slots) slave
   replicates b490121213e22451a9b788755b0be0d3bf158cda
[OK] All nodes agree about slots configuration.
>>> Check for open slots...
>>> Check slots coverage...
[OK] All 16384 slots covered.

集群部署胜利后，连贯 7000 这个节点，留神连贯命令：

./redis-cli -c -p 7000
127.0.0.1:7000> get name
-> Redirected to slot [5798] located at 127.0.0.1:7001
(nil)

如果以后集群为 7000, 7001, 7002 三个节点，正确配置启动新节点 7003 后执行命令：

[root@localhost redis-conf]# redis-cli --cluster add-node 127.0.0.1:7003 127.0.0.1:7000
>>> Adding node 127.0.0.1:7003 to cluster 127.0.0.1:7000
>>> Performing Cluster Check (using node 127.0.0.1:7000)
M: 9de886a23be8bc92bbe51a4e73ad27d2fb96df8d 127.0.0.1:7000
   slots:[0-5460] (5461 slots) master
M: cba883e361f23f1415e4d94148c7c26900c28111 127.0.0.1:7001
   slots:[5461-10922] (5462 slots) master
M: 3855e27b1ec68d6481d6d308101fb28dd6ed21df 127.0.0.1:7002
   slots:[10923-16383] (5461 slots) master
[OK] All nodes agree about slots configuration.
>>> Check for open slots...
>>> Check slots coverage...
[OK] All 16384 slots covered.
>>> Send CLUSTER MEET to node 127.0.0.1:7003 to make it join the cluster.
[OK] New node added correctly.

增加的新节点没有调配 slots，须要手动调配：

[root@localhost redis-conf]# redis-cli --cluster reshard 127.0.0.1:7000
>>> Performing Cluster Check (using node 127.0.0.1:7000)
M: 9de886a23be8bc92bbe51a4e73ad27d2fb96df8d 127.0.0.1:7000
   slots:[0-5460] (5461 slots) master
M: cba883e361f23f1415e4d94148c7c26900c28111 127.0.0.1:7001
   slots:[5461-10922] (5462 slots) master
M: 28eedd55e0fd8e35d36766055b720418c14fa04a 127.0.0.1:7003
   slots: (0 slots) master
M: 3855e27b1ec68d6481d6d308101fb28dd6ed21df 127.0.0.1:7002
   slots:[10923-16383] (5461 slots) master
[OK] All nodes agree about slots configuration.
>>> Check for open slots...
>>> Check slots coverage...
[OK] All 16384 slots covered.
How many slots do you want to move (from 1 to 16384)? 100
What is the receiving node ID? 28eedd55e0fd8e35d36766055b720418c14fa04a 
Please enter all the source node IDs.
  Type 'all' to use all the nodes as source nodes for the hash slots.
  Type 'done' once you entered all the source nodes IDs.
Source node #1: 9de886a23be8bc92bbe51a4e73ad27d2fb96df8d 
Source node #2: done

Ready to move 100 slots.
  Source nodes:
    M: 9de886a23be8bc92bbe51a4e73ad27d2fb96df8d 127.0.0.1:7000
       slots:[0-5460] (5461 slots) master
  Destination node:
    M: 28eedd55e0fd8e35d36766055b720418c14fa04a 127.0.0.1:7003
       slots: (0 slots) master
  Resharding plan:
    ...
    ...
Do you want to proceed with the proposed reshard plan (yes/no)? yes
  ...
  ...

节点查看：

[root@localhost redis-conf]# redis-cli --cluster info 127.0.0.1:7000
127.0.0.1:7000 (9de886a2...) -> 0 keys | 5361 slots | 0 slaves.
127.0.0.1:7001 (cba883e3...) -> 0 keys | 5462 slots | 0 slaves.
127.0.0.1:7003 (28eedd55...) -> 0 keys | 100 slots | 0 slaves.
127.0.0.1:7002 (3855e27b...) -> 0 keys | 5461 slots | 0 slaves.

首先将该节点的 slots 转移（同新增），而后执行删除节点操作：

[root@localhost redis-conf]# redis-cli --cluster del-node 127.0.0.1:7003 28eedd55e0fd8e35d36766055b720418c14fa04a
>>> Removing node 28eedd55e0fd8e35d36766055b720418c14fa04a from cluster 127.0.0.1:7003
>>> Sending CLUSTER FORGET messages to the cluster...
>>> SHUTDOWN the node.

场景：定时工作集群部署，Job 须要加锁单次执行；

计划：基于 Redis 实现分布式锁，以 Job 惟一标识为 key，设置 expiration，在 Job 执行前获取锁断定；

长处：实现较为简单，过期策略避免死锁，效率较高；

基于 springboot 2.x 我的项目，参考代码如下；

加锁：

/**
  * 尝试加锁
  *
  * @param lockKey    加锁的 KEY
  * @param requestId  加锁客户端惟一 ID 标识
  * @param expireTime 过期工夫
  * @param timeUnit   工夫单位
  * @return 是否加锁胜利
  */
public Boolean tryLock(String lockKey, String requestId, long expireTime, TimeUnit timeUnit) {RedisConnection connection = connectionFactory.getConnection();
    Boolean result = connection.set(lockKey.getBytes(StandardCharsets.UTF_8), requestId.getBytes(StandardCharsets.UTF_8), Expiration.from(expireTime, timeUnit), RedisStringCommands.SetOption.SET_IF_ABSENT);
    connection.close();
    return result;
}

requestId 通常用作标识加锁申请的唯一性，只有对应的加锁申请，能力胜利解锁。避免某个客户端操作阻塞很久，锁超时主动开释被另外客户端拿到，而后本人又执行开释锁开释掉其余客户端以后持有的锁。

解锁：

/**
  * 开释锁
  *
  * @param lockKey   加锁的 KEY
  * @param requestId 加锁客户端惟一 ID 标识
  * @return 是否开释胜利
  */
public boolean releaseLock(String lockKey, String requestId) {
    // Lua 代码，一次性执行保障原子性，防止并发问题
    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
    RedisConnection connection = connectionFactory.getConnection();
    byte[][] keysAndArgs = new byte[2][];
    keysAndArgs[0] = lockKey.getBytes(StandardCharsets.UTF_8);
    keysAndArgs[1] = requestId.getBytes(StandardCharsets.UTF_8);
    Long result = connection.scriptingCommands().eval(script.getBytes(StandardCharsets.UTF_8), ReturnType.INTEGER, 1, keysAndArgs);
    connection.close();
    return result != null && result > 0;
}

留神解锁姿态，保障操作原子性。

当锁的持有工夫无奈估算，存在锁超时导致被主动开释掉的可能。能够在获取锁胜利时，开启一个定时线程询问持有锁情况，若以后仍持有锁状态，则刷新过期工夫。

参考 Redisson 实现：https://github.com/redisson/redisson/blob/master/redisson/src/main/java/org/redisson/RedissonLock.java (renewExpiration)

主从复制时，获取锁胜利还未同步 slave 时，master 宕机会呈现数据不统一状况。

官网提供名为 RedLock 的算法思维：

获取以后工夫；
尝试按程序在 N 个节点获取锁；
在大多数节点获取锁胜利，则认为胜利；
如果锁获取胜利了，锁无效工夫就是最后的锁无效工夫减去之前获取锁所耗费的工夫；
如果锁获取失败了，将会尝试开释所有节点的锁；

Redlock 算法：https://redis.io/topics/distlock

形容：同一时间缓存大面积生效，数量级的申请间接打到数据库。

计划：给缓存生效工夫加上一个随机数。

形容：申请不合乎缓存条件，间接打到数据库。

计划：参数做好校验，null 值也可缓存。

形容：热点数据生效霎时，大量对该热点数据的申请间接打到数据库。

计划：设置缓存永不过期，或者查问引入互斥锁。

1 简介

2 装置

2.1 Windows

2.2 Linux

3 配置

3.1 查看

3.2 编辑

3.3 局部参数阐明

3.3.1 daemonize

3.3.2 port

3.3.3 bind

3.3.4 timeout

3.3.5 save

3.3.6 dbfilename

3.3.7 dir

3.3.8 replicaof

3.3.9 masterauth

3.3.10 requirepass

3.3.11 appendonly

3.3.12 appendfilename

3.3.13 appendfsync

3.4 淘汰策略

4 数据类型

4.1 string

4.2 hash

4.3 list

4.4 set

4.5 zset

4.6 geo

4.7 小结

5 个性

5.1 事务

5.2 公布订阅

5.3 脚本

6 数据结构

6.1 sorted set

6.1.1 ziplist

6.1.2 skiplist

7 为什么快

8 应用（Java）

8.1 客户端

8.1.1 Jedis

8.1.2 Lettuce

8.1.3 Redission

8.2 springboot 集成

8.2.1 maven 依赖

8.2.2 属性配置

8.2.3 根本应用

8.2.4 自定义 Template

9 分布式解决方案

9.1 主从同步

9.2 哨兵模式

9.3 集群模式

9.3.1 增加节点

9.3.2 删除节点

9.4 分布式锁

9.4.1 锁超时

9.4.2 RedLock

10 缓存雪崩、缓存穿透和缓存击穿

10.1 缓存雪崩

10.2 缓存穿透

10.3 缓存击穿