1.作用
t_hash.c,z_list,z_set.c,t_string.c,t_zset.c,這些文件的功能其實(shí)都差不多碟案，就是用來實(shí)現(xiàn)Client和Server之間的命令處理的操作類稍刀，通過robj的形式咱枉，把dict,ziplist等存入robj中贷笛，進(jìn)行各個(gè)轉(zhuǎn)換，實(shí)現(xiàn)命令操作翅楼。避開了結(jié)構(gòu)體原先的復(fù)雜結(jié)構(gòu)映砖，相當(dāng)于是封裝了結(jié)構(gòu)體的操作類
t_hash 如果長度小于64則用結(jié)構(gòu)體ziplist 否則使用dict類
/* 下面是方法的歸類 */
void hashTypeTryConversion(robj *o, robj **argv, int start, int end) /* 當(dāng)hashType為ziplist時(shí)，判斷對象長度是否超出了服務(wù)端可接受的ziplist最大長度面粮，超過則轉(zhuǎn)成哈希字典類型*/
void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2) /* 當(dāng)robj用的是字典的編碼方式的時(shí)候少孝，則經(jīng)過編碼轉(zhuǎn)換 */
int hashTypeGetFromZiplist(robj *o, robj *field,unsigned char **vstr,unsigned int *vlen,long long *vll) /* 獲取ziplist壓縮列表中的某個(gè)索引位置上的值 */
int hashTypeGetFromHashTable(robj *o, robj *field, robj **value) /* 獲取哈希字典中的某個(gè)值 */
robj *hashTypeGetObject(robj *o, robj *field) /* 獲取某個(gè)key對應(yīng)的對象類型 */
int hashTypeExists(robj *o, robj *field) /* hastType類型判斷某個(gè)鍵是否存在 */
int hashTypeSet(robj *o, robj *field, robj *value) /* hashType設(shè)置操作，分2種情況熬苍，ziplist,和字典hashtable */
int hashTypeDelete(robj *o, robj *field) /* hashType刪除操作稍走，分為ziplist的刪除操作，和hashtable的刪除操作 */
unsigned long hashTypeLength(robj *o) /* hashType求長度操作 */
hashTypeIterator *hashTypeInitIterator(robj *subject) /* 獲取hashType迭代器 */
void hashTypeReleaseIterator(hashTypeIterator *hi) /* 釋放hashType迭代器 */
int hashTypeNext(hashTypeIterator *hi) /* 通過hashType迭代器獲取下一個(gè)元素 */
void hashTypeCurrentFromZiplist(hashTypeIterator *hi, int what,unsigned char **vstr,unsigned int *vlen,long long *vll) /* 根據(jù)當(dāng)前迭代器的位置柴底，獲取當(dāng)前ziplist的所在位置的key位置婿脸，或value該位置上的值 */
void hashTypeCurrentFromHashTable(hashTypeIterator *hi, int what, robj **dst) /* 根據(jù)當(dāng)前迭代器的位置，獲取當(dāng)前dict的所在位置的key位置柄驻，或value該位置上的值 */
robj *hashTypeCurrentObject(hashTypeIterator *hi, int what) /* 根據(jù)當(dāng)前迭代器的位置盖淡，獲取當(dāng)前key對象 */
robj *hashTypeLookupWriteOrCreate(redisClient *c, robj *key) /* 根據(jù)c客戶端對象，找到key是否存在凿歼，創(chuàng)建或?qū)崿F(xiàn)添加操作 */
void hashTypeConvertZiplist(robj *o, int enc) /* 從ziplist壓縮表到hashtable的轉(zhuǎn)換 */
void hashTypeConvert(robj *o, int enc) /* 對象轉(zhuǎn)換操作褪迟，例如從ziplist到dict的轉(zhuǎn)換 */
hashType的相關(guān)操作命令類，其實(shí)就是對上面方法的結(jié)合調(diào)用
/* 哈希命令類型 */
void hsetCommand(redisClient *c) /* 客戶端設(shè)置指令 */
void hsetnxCommand(redisClient *c) /* 客戶端設(shè)置下一個(gè)位置指令 */
void hmsetCommand(redisClient *c) /* 客戶單設(shè)置命令答憔，如果沒有key,還有后續(xù)操作 */
void hincrbyCommand(redisClient *c) /* 客戶端添加value值操作 */
void hincrbyfloatCommand(redisClient *c) /* 客戶端添加float類型value值操作 */
static void addHashFieldToReply(redisClient *c, robj *o, robj *field) /* */
void hgetCommand(redisClient *c) /* 客戶端獲取操作味赃，如果沒找到，直接不做任何操作 */
void hmgetCommand(redisClient *c) /* 客戶端獲取key操作虐拓，如果為空心俗，會(huì)返回一些了NULL值 */
void hdelCommand(redisClient *c) /* 客戶端刪除操作 */
void hlenCommand(redisClient *c) /* 客戶端求長度命令 */
static void addHashIteratorCursorToReply(redisClient *c, hashTypeIterator *hi, int what) /* 客戶端添加hashType迭代器操作 */
void genericHgetallCommand(redisClient *c, int flags) /* 客戶端獲取操作原始方法，可以添加flag參數(shù) */
void hkeysCommand(redisClient *c) /* 客戶端獲取key值命令 */
void hvalsCommand(redisClient *c) /* 客戶端獲取val值命令 */
void hgetallCommand(redisClient *c) /* 客戶端獲取key;value 2個(gè)值都獲取 */
void hexistsCommand(redisClient *c) /* 客戶端判斷記錄是否存在操作 */
void hscanCommand(redisClient *c) /* 客戶端掃描操作 */
2.查找
//根據(jù)key 獲取某個(gè)對象
robj *hashTypeGetObject(robj *o, robj *field) {
robj *value = NULL;
if (o->encoding == OBJ_ENCODING_ZIPLIST) {
unsigned char *vstr = NULL;
unsigned int vlen = UINT_MAX;
long long vll = LLONG_MAX;
if (hashTypeGetFromZiplist(o, field, &vstr, &vlen, &vll) == 0) {
if (vstr) {
value = createStringObject((char*)vstr, vlen);
} else {
value = createStringObjectFromLongLong(vll);
}
}
} else if (o->encoding == OBJ_ENCODING_HT) {
robj *aux;
if (hashTypeGetFromHashTable(o, field, &aux) == 0) {
incrRefCount(aux);
value = aux;
}
} else {
serverPanic("Unknown hash encoding");
}
return value;
}
3.更新
/* Add an element, discard the old if the key already exists.
* Return 0 on insert and 1 on update.
* This function will take care of incrementing the reference count of the
* retained fields and value objects. */
// 增加一個(gè)值蓉驹，丟棄原先的值城榛，如果key存在的話，返回1updata态兴，0insert
//分兩種請看狠持，hash 或者dict
int hashTypeSet(robj *o, robj *field, robj *value) {
int update = 0;
if (o->encoding == OBJ_ENCODING_ZIPLIST) {
unsigned char *zl, *fptr, *vptr;
//進(jìn)行解碼
field = getDecodedObject(field);
value = getDecodedObject(value);
zl = o->ptr;
fptr = ziplistIndex(zl, ZIPLIST_HEAD);
if (fptr != NULL) {
fptr = ziplistFind(fptr, field->ptr, sdslen(field->ptr), 1);//查找到
if (fptr != NULL) {
/* Grab pointer to the value (fptr points to the field) */
vptr = ziplistNext(zl, fptr);
serverAssert(vptr != NULL);
update = 1;
/* Delete value 刪除*/
zl = ziplistDelete(zl, &vptr);
/* Insert new value 增加*/
zl = ziplistInsert(zl, vptr, value->ptr, sdslen(value->ptr));
}
}
if (!update) {//直接把數(shù)據(jù)加入到尾部
/* Push new field/value pair onto the tail of the ziplist */
zl = ziplistPush(zl, field->ptr, sdslen(field->ptr), ZIPLIST_TAIL);
zl = ziplistPush(zl, value->ptr, sdslen(value->ptr), ZIPLIST_TAIL);
}
o->ptr = zl;
decrRefCount(field);
decrRefCount(value);
/* Check if the ziplist needs to be converted to a hash table */
if (hashTypeLength(o) > server.hash_max_ziplist_entries)
hashTypeConvert(o, OBJ_ENCODING_HT);
} else if (o->encoding == OBJ_ENCODING_HT) {
if (dictReplace(o->ptr, field, value)) { /* Insert */
incrRefCount(field);
} else { /* Update */
update = 1;
}
incrRefCount(value);
} else {
serverPanic("Unknown hash encoding");
}
return update;
}
4.操作
//hashType的相關(guān)操作命令類，其實(shí)就是對上面方法的結(jié)合調(diào)用：
void hsetCommand(client *c) {
int update;
robj *o;
if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
hashTypeTryConversion(o,c->argv,2,3);
// 對字符串進(jìn)行編碼
hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
//跟新
update = hashTypeSet(o,c->argv[2],c->argv[3]);
//操作完添加回復(fù)
addReply(c, update ? shared.czero : shared.cone);
signalModifiedKey(c->db,c->argv[1]);
notifyKeyspaceEvent(NOTIFY_HASH,"hset",c->argv[1],c->db->id);
server.dirty++;
}
