Redis系列七：数据结构List双向链表中LPUSH、LPOP、RPUSH、RPOP、LLEN命令

1.示意图

2.各命令详解

LPUSH/RPUSH

LPUSH:

从队列的左边入队一个或多个元素

将所有指定的值插入到存于 key 的列表的头部。如果 key 不存在，那么在进行 push 操作前会创建一个空列表。如果 key 对应的值不是一个 list 的话，那么会返回一个错误。

可以使用一个命令把多个元素 push 进入列表，只需在命令末尾加上多个指定的参数。元素是从最左端的到最右端的、一个接一个被插入到 list 的头部。

所以对于这个命令例子 LPUSH mylist a b c，返回的列表是 c 为第一个元素， b 为第二个元素， a 为第三个元素。

RPUSH:

从队列的右边入队一个元素

向存于 key 的列表的尾部插入所有指定的值。如果 key 不存在，那么会创建一个空的列表然后再进行 push 操作。当 key 保存的不是一个列表，那么会返回一个错误。

可以使用一个命令把多个元素打入队列，只需要在命令后面指定多个参数。元素是从左到右一个接一个从列表尾部插入。比如命令 RPUSH mylist a b c 会返回一个列表，其第一个元素是 a ，第二个元素是 b ，第三个元素是 c。

两个命令都返回list的长度

时间复杂度O(1) 相对于i++的操作

127.0.0.1:6379> lpush mylist c b a
(integer) 3
 rpush mylist d e f
(integer) 6
6379> lrange mylist 0 5
1) "a"
2) b3) c4) d5) e6) f6379>

源码解析

    {rpush",rpushCommand,-3,write use-memory fast @list"0,NULL,1,1)">0},{lpush0},

LPUSH和RPUSH都是调的同一个函数通过传入LIST_HEAD和LIST_TAIL来判断怎么入队列

void lpushCommand(client *c) {
    pushGenericCommand(c,LIST_HEAD);
}

void rpushCommand(client *
void pushGenericCommand(client *c,int where) {
    int j,pushed = ;
    robj *lobj = lookupKeyWrite(c->db,c->argv[1]);

    if (lobj && lobj->type != OBJ_LIST) {
        addReply(c,shared.wrongtypeerr);
        return;
    }

    for (j = 2; j < c->argc; j++) {
        if (!lobj) {
            lobj = createQuicklistObject();
            quicklistSetoptions(lobj->ptr,server.list_max_ziplist_size,server.list_compress_depth);
            dbAdd(c->db,1)">],lobj);
        }
        listTypePush(lobj,c->argv[j],1)">);
        pushed++;
    }
    addReplyLongLong(c,(lobj ? listTypeLength(lobj) : ));
    if (pushed) {
        char *event = (where == LIST_HEAD) ? " : ;

        signalModifiedKey(c,c->db,1)">]);
        notifyKeyspaceEvent(NOTIFY_LIST,event,1)">1],c->db->id);
    }
    server.dirty += pushed;
}

LPOP/RPOP

LPOP:

移除并且返回 key 对应的 list 的第一个元素。

RPOP:

移除并返回存于 key 的 list 的最后一个元素。

两个命令都返回被移除的元素

时间复杂度O(1) 相对于i--的操作

 lpop mylist
 rpop mylist
rpop2write fast @listlpop
void lpopCommand(client *c) {
    popGenericCommand(c,1)">void rpopCommand(client *可见和push一样通过判断LIST_HEAD，来确定删除db中元素

void popGenericCommand(client *c,1)">) {
    robj *o = lookupKeyWriteOrReply(c,shared.null[c->resp]);
    if (o == NULL || checkType(c,o,OBJ_LIST)) ;

    robj *value = listTypePop(o,1)">);
    if (value == NULL) {
        addReplyNull(c);
    } else {
        ;

        addReplyBulk(c,value);
        decrRefCount(value);
        notifyKeyspaceEvent(NOTIFY_LIST,1)">id);
        if (listTypeLength(o) == ) {
            notifyKeyspaceEvent(NOTIFY_GENERIC,1)">delid);
            dbDelete(c->db,1)">]);
        }
        signalModifiedKey(c,1)">]);
        server.dirty++;
    }
}

LLEN
返回存储在 key 里的list的长度。 如果 key 不存在，那么就被看作是空list，并且返回长度为 0。 当存储在 key 里的值不是一个list的话，会返回error。
时间复杂度：O(1) 相当于常量操作

 llen mylist
(integer) 4
llenread-only fast @listvoid llenCommand(client *c) {
    robj *o = lookupKeyReadOrReply(c,shared.czero);
    ;
    addReplyLongLong(c,listTypeLength(o));
}

 

unsigned long listTypeLength(const robj *subject) {
    if (subject->encoding == OBJ_ENCODING_QUICKLIST) {
        return quicklistCount(subject->ptr);
    }  {
        serverPanic(UnkNown list encoding);
    }
}

 

unsigned long quicklistCount(const quicklist *ql) { return ql->count; }

 

                
                                 版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。