数据库操作
1) REDIS是全部由KEY和VALUE值构成,对数据库的增删改查操作都是基于在通过key 映射到哈希槽 然后通过哈希槽进行单向链式遍历 查找到value和具体的key。
同样 在查看大师写的源码时可以说是一种很好借鉴:
这里所有的操作已经主体源码引用都是zai redis/src/db.c下进行的:
查
robj *lookupKey(redisDb *db, robj *key) {
dictEntry *de = dictFind(db->dict,key->ptr);
if (de) {
robj *val = dictGetVal(de);
/* Update the access time for the ageing algorithm.
* Don‘t do it if we have a saving child, as this will trigger
* a copy on write madness. */
if (server.rdb_child_pid == -1 && server.aof_child_pid == -1)
val->lru = server.lruclock;
return val;
} else {
return NULL;
}
}
lookforKey: 根据key 来寻找value
robj 是redis提出的一个抽象对象类【当然是用C写的 但是这是一层抽象层】含有一系列redis所需要的参数数据,在这里 通过dictFind查找之后就可以得到dicEntry 【就是dic最基本的元素/含有key value指针】 就会构造出一个robj需要的值。
中间的rdb_child_pid和aof_child_pid是服务器做持久化缓存的2种进制,redis通过cow策略来做,如果有正在做持久化的一个动作,就会去设置lru变量 这个等到后面持久化等部分会详细介绍。
在这里: 有一个细节点: void *val 是dicEntry一个变量,怎么robj *val 就可以得到dicGetVal(de)呢 而且还能顺利的得到val的lru值呢?
因为所有写操作 都是通过robj对象写进去的 只不过在dicEntry定义void*类型。
这个操作是最基本的 不管做增删改查 都需要调用lookforKey
robj *lookupKeyRead(redisDb *db, robj *key) {
robj *val;
expireIfNeeded(db,key);
val = lookupKey(db,key);
if (val == NULL)
server.stat_keyspace_misses++;
else
server.stat_keyspace_hits++;
return val;
}
redis是一个支持键值存在长度的数据库,所以呢 在写和读的上层操作时 都需要做一个expireIfNeed的操作。这个操作就是看看Key到期了没 这个Key的时间热度 在后面的部分也详细做分析
stat_keyspace_misss 就是统计整个服务器的Key不存在的总数量,这些数据给server做出相应的决策 在后面同样要进行分析server一系列的数据
robj *lookupKeyReadOrReply(redisClient *c, robj *key, robj *reply) {
robj *o = lookupKeyRead(c->db, key);
if (!o) addReply(c,reply);
return o;
}
这里是REDISClient做抽象的 如果robj 不是NULL,那么都会给客户端返回一个结果 这个结果都是统一用addReply函数来实现
写
void dbAdd(redisDb *db, robj *key, robj *val) {
sds copy = sdsdup(key->ptr);
int retval = dictAdd(db->dict, copy, val);
redisAssertWithInfo(NULL,key,retval == REDIS_OK);
}
这个函数就是添加操作。调用dic里的添加函数,可以看出redis所有的redis都是一个字符串构成, sds 是char*。所以这里存的copy就是一个指向字符串的指针。
注意点: 这里的Key是复制一份到copy中的,为什么这么做,如果主调程序删除了Key空间,但是我按照功能来讲:redis是一个存储Key和value的结构,不管主调程序是否释放空间,我都应该存在 只有当用户发出删除命令或者达到时间限制命令才会释放key空间。这里的sdsdup是一个复制一个字符串的过程。
处理修改KEY
- /*-----------------------------------------------------------------------------
- * Hooks for key space changes.
- *
- * Every time a key in the database is modified the function
- * signalModifiedKey() is called.
- *
- * Every time a DB is flushed the function signalFlushDb() is called.
- *----------------------------------------------------------------------------*/
- void signalModifiedKey(redisDb *db, robj *key) {
- touchWatchedKey(db,key);
- }
- void signalFlushedDb(int dbid) {
- touchWatchedKeysOnFlush(dbid);
- }
这里先来看key 每当key被改变时,都会调用touchWatchedKey(db,key). 在redis每次做改 为什么会调用这个function呢?
以及touchWatchedKey的具体含义在哪里?
在事务部分可以看到 每当上层修改操作进行改这个key时 都会调用touchWatchedKey() 如果Key没有touched 进行正常的增删改
如果有的话,主调函数进行正常的增删改,只不过会做相应的redisClient的DIR改写