Redis 的数据清理策略详解

2023-11-18 13:37:45 浏览数 (1)

背景

摸清 Redis 的数据清理策略,给内存使用高的被动缓存场景,在遇到内存不足时

  • 怎么做是最优解提供决策依据。 

本文整理 Redis 的数据清理策略所有代码来自 Redis version : 5.x, 不同版本的 Redis 策略可能有调整

清理策略

Redis 的清理策略,总结概括为三点,被动清理、定时清理、驱逐清理

被动清理

访问 Key 时,每次都会检查该 Key 是否已过期,如果过期则删除该 Key ,get 、scan 等指令都会触发 Key 的过期检查。

关键代码如下, expireIfNeeded (redisDb *db, robj *key) 函数会触发检查并删除

代码语言:javascript复制
robj *lookupKeyReadWithFlags(redisDb *db, robj *key, int flags) {
    robj *val; if (expireIfNeeded(db,key) == 1) { /* Key expired. If we are in the context of a master, expireIfNeeded()
         * returns 0 only when the key does not exist at all, so it's safe
         * to return NULL ASAP. */ if (server.masterhost == NULL) {
            server.stat_keyspace_misses  ; return NULL;
        } if (server.current_client &&
            server.current_client != server.master &&
            server.current_client->cmd &&
            server.current_client->cmd->flags & CMD_READONLY)
        {
            server.stat_keyspace_misses  ; return NULL;
        }
    } val = lookupKey(db,key,flags); if (val == NULL)
        server.stat_keyspace_misses  ; else server.stat_keyspace_hits  ; return val;
}

定时清理

通过 serverCron 定期触发清理,可以通过 hz 参数,配置每秒执行多少次清理任务,流程如下

  • 1、Redis 配置项 hz 定义了 serverCron 任务的执行周期,默认为 10,即 CPU 空闲时每秒执行 10 次
  • 2、每次过期 Key 清理的 timelimit 不超过 CPU 时间的 25% ,即若 hz = 1,则一次清理时间最大为 250ms,若 hz = 10,则一次清理时间最大为 25ms,计算逻辑(timelimit = 1000000*ACTIVE_EXPIRE_CYCLE_SLOW_TIME_PERC/server.hz/100;)
  • 3、清理时依次遍历所有的 db;
  • 4、从 db 中随机取 20 个 key,判断是否过期,若过期,则逐出;
  • 5、若有 5 个以上 key 过期,则重复步骤 4,否则遍历下一个 db;
  • 6、在清理过程中,若达到了 timelimit 时间,退出清理过程;

关键代码如下,activeExpireCycle (int type) 会执行上述逻辑

代码语言:javascript复制
int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
    ...
    databasesCron();
    ...
} void databasesCron(void) { /* Expire keys by random sampling. Not required for slaves
     * as master will synthesize DELs for us. */ if (server.active_expire_enabled) { if (server.masterhost == NULL) {
            activeExpireCycle(ACTIVE_EXPIRE_CYCLE_SLOW);
        } else {
            expireSlaveKeys();
        }
    }
    ...
}

驱逐清理

Redis 在命令处理函数 processCommand 会进行内存的检查和驱逐,任何命令都会出触发,包括 ping 命令。

  • 如果配置了 maxmemory ,且当前内存超过 maxmemory 时,则会执行 maxmemory_policy 筛选出需要清理的 Key,继而判断 lazyfree-lazy-eviction 是否开启来进行 Key 的同步还是异步删除。无论是同步删除还是异步删除,最后都会继续校验内存是否超限,直到内存低于 maxmemory。驱逐只会在 Master 节点进行。

maxmemory_policy 可选如下:

  • volatile-lru:从已设置过期时间的数据集中挑选【最近最少使用】的 Key 进行删除
  • volatile-ttl:从己设置过期时间的数据集中挑选【将要过期】的 Key 进行删除
  • volatile-lfu:从己设置过期时间的数据集中选择【最不常用】的 Key 进行删除
  • volatile-random:从己设置过期时间的数据集中【任意选择】Key 进行删除
  • allkeys-lru:从数据集中挑选【最近最少使用】的 Key 进行删除
  • allkeys-lfu:从数据集中【优先删除掉最不常用】的 Key
  • allkeys-random:从数据集中【任意选择】 Key 进行删除
  • no-enviction:禁止驱逐数据

如上图,6.2 后的版本支持通过逐出因子 maxmemory-eviction-tenacity 来控制逐出阻塞的时间。具体的阻塞耗时间可以通过 latency-monitor 里的 eviction-cycle、eviction-del 来观测。

关键代码如下,freeMemoryIfNeeded () 函数会执行上述逻辑

代码语言:javascript复制
int processCommand(client *c) {
 ... if (server.maxmemory && !server.lua_timedout) { int out_of_memory =  freeMemoryIfNeededAndSafe() == C_ERR;
        ...
  }
 ...
} int freeMemoryIfNeededAndSafe(void) { if (server.lua_timedout || server.loading) return C_OK; return freeMemoryIfNeeded();
}

总结

回到开篇的背景问题,当遇到内存使用高的被动缓存场景,可用内存不足时:

  • 离线分析内存,是否存在大量【已过期】的内存来不及定时清理,此时可调大 hz 参数来加速过期内存的主动清理。hz 参数最大 500 ,不过要观察 CPU 的影响,不要因为 hz 影响读写流量
  • 如果调整 hz 还是没法及时清理已过期的内存,则可以使用 scan 指令来被动访问 key 的方式手动删除,注意执行 scan 时的 count ,同时观测 CPU 使用情况,scan 的 count 越大,CPU 消耗会越高,完成一次 sacn 删除的时间最快。为了减少对线上的影响,可以在业务低峰期,周期性的执行。
  • 通过 latency-monitor 观测 eviction-cycle、eviction-del 指标,是否因内存驱逐阻塞严重,可开启 lazyfree-lazy-eviction 来缓解阻塞,如果还是很慢,可升级内存规格
  • 可升级到 7.x 版本的 Redis ,通过 maxmemory-eviction-tenacity 参数主动控制每次驱逐的阻塞时间

参考:

  • 快手 Redis 架构演进实践_脱敏.pdf

0 人点赞