Redis是如何存取数据的

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介:

一:前言

这段时间事情比较多,难得抽出时间,便接着上篇文章《Redis是如何建立连接和处理命令的》,继续往下分析。Redis 本质就是数据库,要想深入了解Redis,那数据存取这一块肯定是大头。不过得益于 Redis 优良简洁的设计,数据存取倒没有那么复杂,源码读起来也比较轻松。

二:Redis 的数据库

Redis 对数据库进行了抽象,在 Redis 源码中,承担数据库角色的叫 redisDb。我们暂且无需去了解 redisDb 的内部结构,我们可以站在一个更加宏观的角度去初步了解它,这样能得到一个更全局的认识。

Redis服务可以同时配置多个 redisDb,每个redisDb的数据是相互隔离的。那么怎么配置多个 redisDb 呢?有过 redis 实战经验的同学肯定会说,这太简单了,我们只需要在 redis 的配置文件中配置 databases 即可。redis 默认配置的 redisDb 数量为 16。

Redis 用 redisServer 表示服务,redisServer 中有个数组 db,用来记录所有的 redisDb。当 Redis 进程启动后,便会在 initServer()中按照配置的 redisDb 数量,初始化好 Redis 服务的所有数据库。

server.db = zmalloc(sizeof(redisDb)*server.dbnum);

既然初始化了多个数据库,而每个数据库之间的数据又是隔离的,那么当客户端发存取命令的时候,Redis 服务又怎么知道使用那个数据库呢?诸位请往下看。

在上一篇文章中,我有提到过,每当一个新的客户端连接到 Redis 后,Redis 便会创建一个 client 对象来表示一个客户端连接,后续收到该客户端的所有命令,都会基于创建的 client 进行。

Redis 在为新连接创建 client 时,便会为其分配数据库,即 redisDb。代码如下所示:

client *createClient(int fd) {
    client *c = zmalloc(sizeof(client));
    ......
    selectDb(c,0);
    ......
}

selectDb(c,0)即为 client 分配 redisDb,第二个参数标志所分配的数据库在Redis服务中的索引,即第几个数据库。selectDb()逻辑很简单:

int selectDb(client *c, int id) {
    if (id < 0 || id >= server.dbnum)
        return C_ERR;
    c->db = &server.db[id];
    return C_OK;
}

现在我们知道了,事实上,所有客户端默认使用的都是Redis服务中的第一个redisDb。那么Redis 服务初始化这么多数据库干嘛呢?不是白费资源吗?

Redis 客户端有个 select 命令,使用 select 命令就可以选择使用那个 redisDb,这样不同客户端之间就实现了数据隔离。如调用 select 2,redis 服务在收到命令后,就会将该连接的数据库切换到索引为 2 的 redisDb。

三:数据库的内部结构

从宏观角度认识 redisDb 之后,我们便可以进入 redisDb 内部一探究竟。

typedef struct redisDb {
    dict *dict;                 /* The keyspace for this DB */
    dict *expires;              /* Timeout of keys with a timeout set */
    dict *blocking_keys;        /* Keys with clients waiting for data (BLPOP)*/
    dict *ready_keys;           /* Blocked keys that received a PUSH */
    dict *watched_keys;         /* WATCHED keys for MULTI/EXEC CAS */
    int id;                     /* Database ID */
    long long avg_ttl;          /* Average TTL, just for stats */
    list *defrag_later;         /* List of key names to attempt to defrag one by one, gradually. */
} redisDb;

乍一看,redisDb 内部包括了好几个 dict,即字典。从注释来看,这些字典各有各的用处,如 dict 用来存放键值对,expires 用来存放key的超时时间。由此可见,Redis 存放数据的核心便是这些字典了。

typedef struct dictEntry {
    void *key;
    union {
        void *val;
        uint64_t u64;
        int64_t s64;
        double d;
    } v;
    struct dictEntry *next;
} dictEntry;

typedef struct dictType {
    uint64_t (*hashFunction)(const void *key);
    void *(*keyDup)(void *privdata, const void *key);
    void *(*valDup)(void *privdata, const void *obj);
    int (*keyCompare)(void *privdata, const void *key1, const void *key2);
    void (*keyDestructor)(void *privdata, void *key);
    void (*valDestructor)(void *privdata, void *obj);
} dictType;

/* This is our hash table structure. Every dictionary has two of this as we
 * implement incremental rehashing, for the old to the new table. */
typedef struct dictht {
    dictEntry **table;
    unsigned long size;
    unsigned long sizemask;
    unsigned long used;
} dictht;

typedef struct dict {
    dictType *type;
    void *privdata;
    dictht ht[2];
    long rehashidx; /* rehashing not in progress if rehashidx == -1 */
    unsigned long iterators; /* number of iterators currently running */
} dict;

dict 中利用 dictht 来存放数据,dictht 其实就是 HashTable,本质也是通过计算 key 的 hash 值,将数据分布到不同的桶之中。 这里比较有趣的是,一个 dict 中有两个 dictht,按道理只要一个 dictht 用来存放数据不就够了吗?其实平时用来存放数据的也就是 ht[0],只有当要进行 rehash 的时候,才会使用 ht[1],临时作为一个新的HashTable,存放新增数据。ht[0]中的存量数据会 rehash 到 ht[1] 中,等到 rehash 完成,ht[0] 就会再指向 ht[1] 的 dictht,完成职责交换。

dictht 中存放着一个二维指针:dictEntry **table ,第一维指针用来指向 dictEntry 链表,第二维指针指向dictEntry 链表中的某个dictEntry,dictEntry本身是也一个链表,记录着hash(key)相同的元素。

总结下,也就是说真正用来存放数据的就是 dictEntry,而 dictht 作为HashTable,将数据根据 key hash,存放到不同的 dictEntry 中,并通过 table 这个二维指针管理所有 dictEntry。

四:数据存取流程

聊完了数据库,再来聊聊Redis 是如何从数据库存取数据的。

Redis 一共支持 5 种基础数据结构:

  • string:字符串
  • list:列表
  • hash:字典
  • set:集合
  • zset:有序集合

今天我们从最简单的数据结构 string 入手,窥探下 Redis 内部设计。

在 Redis 客户端调用命令,Redis 服务收到命令后便会调用命令对应的处理函数,如调用 set a A ,Redis 对应的命令处理函数便为 t_string.c 中的 setCommand()。 setCommand()解析命令附带标志后,便调用了 setGenericCommand()处理数据。

void setGenericCommand(client *c, int flags, robj *key, robj *val, robj *expire, int unit, robj *ok_reply, robj *abort_reply) {
    ......
    setKey(c->db,key,val);
    ......
}

setGenericCommand()中用来存放数据就一行代码,即 setKey(c->db,key,val),将数据存放到 client 对应的 redisDb 中。接下来的要看的逻辑,便就是 redisDb 如何存入 了。

void setKey(redisDb *db, robj *key, robj *val) {
    if (lookupKeyWrite(db,key) == NULL) {
        dbAdd(db,key,val);
    } else {
        dbOverwrite(db,key,val);
    }
    incrRefCount(val);
    removeExpire(db,key);
    signalModifiedKey(db,key);
}

setKey()首先会查询数据库中是否已存在相同的key,如果不存在,就调用 dbAdd()插入数据,否则调用 dbOverwrite()覆盖掉旧数据。

废话不多说,我们直接看 dbAdd()插入数据的逻辑:

void dbAdd(redisDb *db, robj *key, robj *val) {
    sds copy = sdsdup(key->ptr);
    int retval = dictAdd(db->dict, copy, val);
    ......
}

上面逻辑主要分为两步:
(1)调用sdsdup(),将 key 的 C 字符串转化为 redis 自定义的 sds 字符串,之所以将字符串由普通的字符数组转化为 sds,主要就是为了效率考虑,sds 规避了普通字符数组的很多问题。
(2)调用dictAdd(),将 sds 类型的key ,和 val 一起存入redisDb 的字典 dict 中。dictAdd()逻辑也不复杂,代码如下:

int dictAdd(dict *d, void *key, void *val)
{
    dictEntry *entry = dictAddRaw(d,key,NULL);

    if (!entry) return DICT_ERR;
    dictSetVal(d, entry, val);
    return DICT_OK;
}

dictAdd()同样分两步走:
(1)从dict 中找到 key 对应的哈希桶。
(2)调用dictSetVal(),将 value 存放到哈希桶中。到此,就被成功的存储到数据库中了。至于从 Redis 中读取数据,那就更加简单了,也就是根据 key,从 redisDb 的 dict 中找到对应的 dictEntry,并返回 dictEntry 中存放的 value。

五:总结

总结下上面的源码分析:
(1)Redis 默认会创建 16 个数据库:redisDb,每个数据库之间数据隔离。
(2)Redis 默认为每个客户端分配第 0 号索引的 redisDb,客户端可以调用 select 命令切换需要使用的数据库。
(3)redisDb 内部采用了 HashTable 结构存放数据。
今天我们通过最基本的数据结构 string 学习了Redis 存取数据的核心逻辑,其实 Redis 在数据存放过程中还有很多细节,如渐进式 rehash、过期 key 惰性删除等。有兴趣的同学可以关注下我的专栏,后续文章中我将继续分析 Redis 源码,与大家一起学习。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
2月前
|
存储 缓存 NoSQL
数据的存储--Redis缓存存储(一)
数据的存储--Redis缓存存储(一)
95 1
|
28天前
|
NoSQL Redis
Redis的数据淘汰策略有哪些 ?
Redis 提供了 8 种数据淘汰策略,分为淘汰易失数据和淘汰全库数据两大类。易失数据淘汰策略包括:volatile-lru、volatile-lfu、volatile-ttl 和 volatile-random;全库数据淘汰策略包括:allkeys-lru、allkeys-lfu 和 allkeys-random。此外,还有 no-eviction 策略,禁止驱逐数据,当内存不足时新写入操作会报错。
55 16
|
2月前
|
监控 NoSQL Java
场景题:百万数据插入Redis有哪些实现方案?
场景题:百万数据插入Redis有哪些实现方案?
43 1
场景题:百万数据插入Redis有哪些实现方案?
|
2月前
|
存储 缓存 NoSQL
数据的存储--Redis缓存存储(二)
数据的存储--Redis缓存存储(二)
51 2
数据的存储--Redis缓存存储(二)
|
28天前
|
缓存 NoSQL 关系型数据库
Redis和Mysql如何保证数据⼀致?
在项目中,为了解决Redis与Mysql的数据一致性问题,我们采用了多种策略:对于低一致性要求的数据,不做特别处理;时效性数据通过设置缓存过期时间来减少不一致风险;高一致性但时效性要求不高的数据,利用MQ异步同步确保最终一致性;而对一致性和时效性都有高要求的数据,则采用分布式事务(如Seata TCC模式)来保障。
58 14
|
21天前
|
缓存 NoSQL PHP
Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出
本文深入探讨了Redis作为PHP缓存解决方案的优势、实现方式及注意事项。Redis凭借其高性能、丰富的数据结构、数据持久化和分布式支持等特点,在提升应用响应速度和处理能力方面表现突出。文章还介绍了Redis在页面缓存、数据缓存和会话缓存等应用场景中的使用,并强调了缓存数据一致性、过期时间设置、容量控制和安全问题的重要性。
36 5
|
28天前
|
存储 NoSQL 算法
Redis分片集群中数据是怎么存储和读取的 ?
Redis集群采用哈希槽分区算法,共有16384个哈希槽,每个槽分配到不同的Redis节点上。数据操作时,通过CRC16算法对key计算并取模,确定其所属的槽和对应的节点,从而实现高效的数据存取。
47 13
|
28天前
|
存储 NoSQL Redis
Redis的数据过期策略有哪些 ?
Redis 采用两种过期键删除策略:惰性删除和定期删除。惰性删除在读取键时检查是否过期并删除,对 CPU 友好但可能积压大量过期键。定期删除则定时抽样检查并删除过期键,对内存更友好。默认每秒扫描 10 次,每次检查 20 个键,若超过 25% 过期则继续检查,单次最大执行时间 25ms。两者结合使用以平衡性能和资源占用。
44 11
|
28天前
|
监控 NoSQL 测试技术
【赵渝强老师】Redis的AOF数据持久化
Redis 是内存数据库,提供数据持久化功能,支持 RDB 和 AOF 两种方式。AOF 以日志形式记录每个写操作,支持定期重写以压缩文件。默认情况下,AOF 功能关闭,需在 `redis.conf` 中启用。通过 `info` 命令可监控 AOF 状态。AOF 重写功能可有效控制文件大小,避免性能下降。
|
28天前
|
存储 监控 NoSQL
【赵渝强老师】Redis的RDB数据持久化
Redis 是内存数据库,提供数据持久化功能以防止服务器进程退出导致数据丢失。Redis 支持 RDB 和 AOF 两种持久化方式,其中 RDB 是默认的持久化方式。RDB 通过在指定时间间隔内将内存中的数据快照写入磁盘,确保数据的安全性和恢复能力。RDB 持久化机制包括创建子进程、将数据写入临时文件并替换旧文件等步骤。优点包括适合大规模数据恢复和低数据完整性要求的场景,但也有数据完整性和一致性较低及备份时占用内存的缺点。