美文网首页
redis t_hash

redis t_hash

作者: lmem | 来源:发表于2017-06-03 11:27 被阅读20次

    1.作用

    t_hash.c,z_list,z_set.c,t_string.c,t_zset.c,这些文件的功能其实都差不多,就是用来实现Client和Server之间的命令处理的操作类,通过robj的形式,把dict,ziplist等存入robj中,进行各个转换,实现命令操作。避开了结构体原先的复杂结构,相当于是封装了结构体的操作类

    t_hash 如果长度小于64则用结构体ziplist 否则使用dict类

    /* 下面是方法的归类 */  
    void hashTypeTryConversion(robj *o, robj **argv, int start, int end) /* 当hashType为ziplist时,判断对象长度是否超出了服务端可接受的ziplist最大长度,超过则转成哈希字典类型*/  
    void hashTypeTryObjectEncoding(robj *subject, robj **o1, robj **o2) /* 当robj用的是字典的编码方式的时候,则经过编码转换 */  
    int hashTypeGetFromZiplist(robj *o, robj *field,unsigned char **vstr,unsigned int *vlen,long long *vll) /* 获取ziplist压缩列表中的某个索引位置上的值 */  
    int hashTypeGetFromHashTable(robj *o, robj *field, robj **value) /* 获取哈希字典中的某个值 */  
    robj *hashTypeGetObject(robj *o, robj *field) /* 获取某个key对应的对象类型 */  
    int hashTypeExists(robj *o, robj *field)   /* hastType类型判断某个键是否存在 */  
    int hashTypeSet(robj *o, robj *field, robj *value) /* hashType设置操作,分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迭代器获取下一个元素 */  
    void hashTypeCurrentFromZiplist(hashTypeIterator *hi, int what,unsigned char **vstr,unsigned int *vlen,long long *vll) /* 根据当前迭代器的位置,获取当前ziplist的所在位置的key位置,或value该位置上的值 */  
    void hashTypeCurrentFromHashTable(hashTypeIterator *hi, int what, robj **dst) /* 根据当前迭代器的位置,获取当前dict的所在位置的key位置,或value该位置上的值 */  
    robj *hashTypeCurrentObject(hashTypeIterator *hi, int what) /* 根据当前迭代器的位置,获取当前key对象 */  
    robj *hashTypeLookupWriteOrCreate(redisClient *c, robj *key) /* 根据c客户端对象,找到key是否存在,创建或实现添加操作  */  
    void hashTypeConvertZiplist(robj *o, int enc) /* 从ziplist压缩表到hashtable的转换 */  
    void hashTypeConvert(robj *o, int enc) /* 对象转换操作,例如从ziplist到dict的转换 */
    

    hashType的相关操作命令类,其实就是对上面方法的结合调用

    /* 哈希命令类型 */  
    void hsetCommand(redisClient *c)  /* 客户端设置指令 */  
    void hsetnxCommand(redisClient *c) /* 客户端设置下一个位置指令 */  
    void hmsetCommand(redisClient *c) /* 客户单设置命令,如果没有key,还有后续操作 */  
    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操作,如果为空,会返回一些了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参数 */  
    void hkeysCommand(redisClient *c) /* 客户端获取key值命令 */  
    void hvalsCommand(redisClient *c) /* 客户端获取val值命令 */  
    void hgetallCommand(redisClient *c) /* 客户端获取key;value 2个值都获取 */  
    void hexistsCommand(redisClient *c) /* 客户端判断记录是否存在操作 */  
    void hscanCommand(redisClient *c) /* 客户端扫描操作 */  
    

    2.查找

    //根据key 获取某个对象
    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. */
    // 增加一个值,丢弃原先的值,如果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;
            //进行解码
            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) {//直接把数据加入到尾部
                /* 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的相关操作命令类,其实就是对上面方法的结合调用:
    void hsetCommand(client *c) {
        int update;
        robj *o;
    
        if ((o = hashTypeLookupWriteOrCreate(c,c->argv[1])) == NULL) return;
        hashTypeTryConversion(o,c->argv,2,3);
        // 对字符串进行编码
        hashTypeTryObjectEncoding(o,&c->argv[2], &c->argv[3]);
        //跟新
        update = hashTypeSet(o,c->argv[2],c->argv[3]);
        //操作完添加回复
        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++;
    }
    

    相关文章

      网友评论

          本文标题:redis t_hash

          本文链接:https://www.haomeiwen.com/subject/otwpfxtx.html