1
2
3
4
5
6

网络分区前:
Sentinel1,2,3 ←→ Master ←→ Slave1,2

网络分区后:
PartitionA: Sentinel1 ←→ Master (原主节点)
PartitionB: Sentinel2,3 ←→ Slave1 ←→ Slave2 (选举新主节点)

1
2
3
4
5

# Sentinel 配置文件
sentinel monitor mymaster 127.0.0.1 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000

1
2
3
4
5
6
7

# 计算 Key 哈希 Slot
HASH_SLOT = CRC16(key) % 16384

# Slot 分配示例（3 个 Master 节点）
Master1: 0-5461 (5462 Slot)
Master2: 5462-10923 (5462 Slot)
Master3: 10924-16383 (5460 Slot)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

# 创建集群
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

# 查看集群信息
CLUSTER INFO
CLUSTER NODES

# 重新分片
redis-cli --cluster reshard 127.0.0.1:7000

# 添加节点
redis-cli --cluster add-node 127.0.0.1:7006 127.0.0.1:7000

1
2
3
4

# 基本流程
# 1. 初始化: 创建 m 位位数组，k 个哈希函数
# 2. 添加元素: 对元素计算 k 个哈希值，设置对应位为 1
# 3. 查询元素: 计算 k 个哈希值，检查对应位是否都为 1

1
2
3
4
5
6
7

# 最优位数组大小
m = -n * ln(p) / (ln(2))^2

# 最优哈希函数数量
k = (m/n) * ln(2)

# 其中：n=元素数量，p=误报率，m=位数组大小，k=哈希函数数量

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

# 加载 RedisBloom 模块
MODULE LOAD /path/to/redisbloom.so

# 创建布隆过滤器
BF.RESERVE myfilter 0.01 10000

# 添加元素
BF.ADD myfilter "user123"
BF.MADD myfilter "user1" "user2" "user3"

# 检查元素
BF.EXISTS myfilter "user123"
BF.MEXISTS myfilter "user1" "user2"

# 获取信息
BF.INFO myfilter

1
2

<毫秒时间戳>-<序列号>
例如: 1609459200000-0

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

# 添加消息
XADD mystream * field1 value1 field2 value2
XADD mystream 1609459200000-0 user "john" action "login"

# 读取消息
XREAD COUNT 2 STREAMS mystream 0
XREAD BLOCK 1000 STREAMS mystream $  # 阻塞读取新消息

# 查看 Stream 信息
XINFO STREAM mystream
XLEN mystream

# 范围查询
XRANGE mystream - +
XRANGE mystream 1609459200000 1609459300000

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

# 创建消费者组
XGROUP CREATE mystream mygroup $ MKSTREAM

# 消费者读取
XREADGROUP GROUP mygroup consumer1 COUNT 1 STREAMS mystream >

# 确认消息
XACK mystream mygroup 1609459200000-0

# 查看消费者组信息
XINFO GROUPS mystream
XINFO CONSUMERS mystream mygroup

# 处理 pending 消息
XPENDING mystream mygroup
XCLAIM mystream mygroup consumer2 1800000 1609459200000-0

1
2
3
4
5
6
7
8

# 配置文件设置
save 900 1      # 900 秒内至少 1 个 key 变化
save 300 10     # 300 秒内至少 10 个 key 变化
save 60 10000   # 60 秒内至少 10000 个 key 变化

# 手动触发
SAVE    # 同步保存（阻塞）
BGSAVE  # 异步保存（后台）

1
2
3
4
5

# 配置选项
appendonly yes
appendfsync always    # 每次写入立即同步
appendfsync everysec  # 每秒同步一次（推荐）
appendfsync no        # 由 OS 决定同步时机

1

aof-use-rdb-preamble yes

1
2
3
4
5

# 配置最大内存
maxmemory 2gb

# 淘汰策略
maxmemory-policy allkeys-lru

1
2
3
4
5
6
7
8
9

# 加锁
SET lock_key unique_value PX 30000 NX

# 释放锁（Lua 脚本保证原子性）
if redis.call("get", KEYS[1]) == ARGV[1] then
    return redis.call("del", KEYS[1])
else
    return 0
end

1
2
3
4
5
6
7
8
9

# 使用 pipeline 减少网络往返
PIPELINE
SET key1 value1
SET key2 value2
EXEC

# 使用 MGET/MSET 批量操作
MSET key1 value1 key2 value2
MGET key1 key2

1
2
3
4
5

# 配置优化
hash-max-ziplist-entries 512
hash-max-ziplist-value 64
list-max-ziplist-size -2
set-max-intset-entries 512