【Redis学习笔记】2018-07-05 Redis指令学习1

news/2024/12/14 19:08:39

顺风车运营研发团队 施洪宝

getbit, getrange, blpop, brpop, rpop

一. getbit
1.命令说明
使用方式: getbit key offset

功能: 对key对应value的值, 取对应偏移量上的值。

返回值: key不存在, offset比字符串长度大时, 返回0, 否则返回对应位上的值。

时间复杂度: O(1)

2.源码实现
源码实现的步骤可以分为两步: 1. 获取偏移量所在字节数。 2. 获取偏移量所在字节的bit。

void getbitCommand(client *c) {
    robj *o;
    char llbuf[32];
    size_t bitoffset;
    size_t byte, bit;
    size_t bitval = 0;
    //读取参数
    if (getBitOffsetFromArgument(c,c->argv[2],&bitoffset,0,0) != C_OK)
        return;
 
    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.czero)) == NULL ||
        checkType(c,o,OBJ_STRING)) return;
    //获取offset对应的字节位置以及对应的bit
    byte = bitoffset >> 3;
    bit = 7 - (bitoffset & 0x7);
 
    //读取结果并返回
    if (sdsEncodedObject(o)) {
        if (byte < sdslen(o->ptr))
            bitval = ((uint8_t*)o->ptr)[byte] & (1 << bit);
    } else {
        if (byte < (size_t)ll2string(llbuf,sizeof(llbuf),(long)o->ptr))
            bitval = llbuf[byte] & (1 << bit);
    }
 
    addReply(c, bitval ? shared.cone : shared.czero);
}

3. 参考
http://doc.redisfans.com/stri...

二. getrange
1.命名说明
使用方式:getrange key start end

功能: 返回key中字符串值得子字符串,字符串截取位置由start, end决定

返回值: 截取的子字符串,超过范围自动截取

时间复杂度: O(n)

2.源码实现

void getrangeCommand(client *c) {
    robj *o;
    long long start, end;
    char *str, llbuf[32];
    size_t strlen;
 
    //获取参数
    if (getLongLongFromObjectOrReply(c,c->argv[2],&start,NULL) != C_OK)
        return;
    if (getLongLongFromObjectOrReply(c,c->argv[3],&end,NULL) != C_OK)
        return;
    if ((o = lookupKeyReadOrReply(c,c->argv[1],shared.emptybulk)) == NULL ||
        checkType(c,o,OBJ_STRING)) return;
 
    //获取值对应的字符串
    if (o->encoding == OBJ_ENCODING_INT) {
        str = llbuf;
        strlen = ll2string(llbuf,sizeof(llbuf),(long)o->ptr);
    } else {
        str = o->ptr;
        strlen = sdslen(str);
    }
 
    //start, end处理
    /* Convert negative indexes */
    if (start < 0 && end < 0 && start > end) {
        addReply(c,shared.emptybulk);
        return;
    }
    if (start < 0) start = strlen+start;
    if (end < 0) end = strlen+end;
    if (start < 0) start = 0;
    if (end < 0) end = 0;
    if ((unsigned long long)end >= strlen) end = strlen-1;
 
    /* Precondition: end >= 0 && end < strlen, so the only condition where
     * nothing can be returned is: start > end. */
    if (start > end || strlen == 0) {
        addReply(c,shared.emptybulk);
    } else {
        addReplyBulkCBuffer(c,(char*)str+start,end-start+1);
    }
}

3.参考
http://doc.redisfans.com/stri...
三. blpop
1.命令说明
使用方法: blpop key [key...] timeout

功能: 从给定的key中,找到一个非空列表,返回头元素。查找顺序按照给定的key顺序。如果所有key对应的列表都是空的,则操作被阻塞,阻塞时间可由timeout设置

时间复杂度: O(n), n为key的个数(没有被阻塞的情况下)

返回值: 返回key以及列表的元素

2.源码实现

void blockingPopGenericCommand(client *c, int where) {
    robj *o;
    mstime_t timeout;
    int j;
 
    //获取超时时间
    if (getTimeoutFromObjectOrReply(c,c->argv[c->argc-1],&timeout,UNIT_SECONDS)
        != C_OK) return;
 
    //依次遍历所有给定的key
    for (j = 1; j < c->argc-1; j++) {
        //获取key对应的value
        o = lookupKeyWrite(c->db,c->argv[j]);
        if (o != NULL) {
            if (o->type != OBJ_LIST) {
                addReply(c,shared.wrongtypeerr);
                return;
            } else {
                if (listTypeLength(o) != 0) {
                    /* Non empty list, this is like a non normal [LR]POP. */
                    char *event = (where == LIST_HEAD) ? "lpop" : "rpop";
                    robj *value = listTypePop(o,where); //从列表中弹出一个元素,位置由where决定, 头部或者尾部。
                    serverAssert(value != NULL);
                 
                    //返回结果
                    addReplyMultiBulkLen(c,2);
                    addReplyBulk(c,c->argv[j]);
                    addReplyBulk(c,value);
                    decrRefCount(value);
                    //发送键空间事件通知(pub, sub)
                    notifyKeyspaceEvent(NOTIFY_LIST,event,
                                        c->argv[j],c->db->id);
                    if (listTypeLength(o) == 0) {
                        dbDelete(c->db,c->argv[j]);
                        notifyKeyspaceEvent(NOTIFY_GENERIC,"del",
                                            c->argv[j],c->db->id);
                    }
                    //通知正在watch这个key的client, 具体实现为将client的flags开启CLIENT_DIRTY_CAS
                    signalModifiedKey(c->db,c->argv[j]);
                    server.dirty++;
 
                    /* Replicate it as an [LR]POP instead of B[LR]POP. */
                    //因为已经在一个key上找到元素,故而可以将blpop, brpop改写为lpop, rpop
                    rewriteClientCommandVector(c,2,
                        (where == LIST_HEAD) ? shared.lpop : shared.rpop,
                        c->argv[j]);
                    return;
                }
            }
        }
    }
 
    /* If we are inside a MULTI/EXEC and the list is empty the only thing
     * we can do is treating it as a timeout (even with timeout 0). */
    //Redis正在执行事务
    if (c->flags & CLIENT_MULTI) {
        addReply(c,shared.nullmultibulk);
        return;
    }
 
    /* If the list is empty or the key does not exists we must block */
    //列表为空或者key不存在
    blockForKeys(c, c->argv + 1, c->argc - 2, timeout, NULL);
}

3. 参考
http://doc.redisfans.com/list...

四. brpop
1.命令说明
使用方法: rlpop key [key...] timeout

功能: 从给定的key中,找到一个非空列表,返回尾部元素。查找顺序按照给定的key顺序。如果所有key对应的列表都是空的,则操作被阻塞,阻塞时间可由timeout设置

时间复杂度: O(n), n为key的个数(没有被阻塞的情况下)

返回值: 返回key以及列表的元素

2.源码实现
与blpop相同,二者都是通过调用blockingPopGenericCommand来实现的,唯一的区别再与,blpop弹出首部(blockingPopGenericCommand的where参数为LIST_HEAD),brpop弹出尾部元素(blockingPopGenericCommand的where参数为LIST_TAIL)

3. 参考
http://doc.redisfans.com/list...

五. rpop
1.命令说明
使用方法: rpop key

功能: 移除并返回列表的尾部元素。

返回值: 返回列表的尾部元素,不存在时返回nil

时间复杂度: O(1)

2. 源码实现

void popGenericCommand(client *c, int where) {
    robj *o = lookupKeyWriteOrReply(c,c->argv[1],shared.nullbulk); //查找key
    if (o == NULL || checkType(c,o,OBJ_LIST)) return;
 
    robj *value = listTypePop(o,where);
    if (value == NULL) {
        addReply(c,shared.nullbulk);  //value中没有元素
    } else {
        char *event = (where == LIST_HEAD) ? "lpop" : "rpop";
 
        addReplyBulk(c,value);  //返回结果
        decrRefCount(value);
        notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); //键空间通知
        if (listTypeLength(o) == 0) {
            notifyKeyspaceEvent(NOTIFY_GENERIC,"del",
                                c->argv[1],c->db->id);
            dbDelete(c->db,c->argv[1]);
        }
        signalModifiedKey(c->db,c->argv[1]);  //通知正在监听这个key的client, 具体实现为将client的flags开启CLIENT_DIRTY_CAS
        server.dirty++;   //脏标志加1
    }
}

3.参考
http://doc.redisfans.com/list...


http://www.niftyadmin.cn/n/3332519.html

相关文章

【Vue3系列】 父组件调用子组件的方法-子组件向父组件传值

一&#xff1a;父组件调用子组件的方法 父组件 <template><div>父页面<son-com ref"sonRef"/><button click"handleClick">test</button></div> </template> <script> import {defineComponent,ref} fr…

本地Docker镜像发布到阿里云的Docker Hub

2019独角兽企业重金招聘Python工程师标准>>> 1、配置镜像加速器 参考https://my.oschina.net/u/182501/blog/1549194 2、命名空间管理 进入https://cr.console.aliyun.com/#/namespace/index 3、创建镜像仓库 https://cr.console.aliyun.com/#/imageList 4、发布本地…

Java、创建一个文本文件

package io;import java.io.*; import java.security.SecureRandom; import java.util.Scanner;public class Exercise17_01 {public static void main(String[] args) throws IOException, Exception {File file new File("D:\\IDEA程序\\JavaFXProject\\src\\files\\Ex…

Eclipse安装zylin[转]

本文转载自&#xff1a;https://blog.csdn.net/dns888222/article/details/9263485 Eclipse安装zylin 在网上搜的是安装页为http://www.zylin.com/zylincdt但是用ie打开这个网址却发现page have moved.上google一搜&#xff0c;发现这个网址变成了&#xff1a;http://opensourc…

【JavaScript 】多层数组嵌套取其中某个值组成新的数组-动态渲染table头部内容

一&#xff1a;多层数组嵌套取其中某个值组成新的数组 List:[{id: 1,name: "haha",tag_list: {0:{id: 89is_checked_arr: [259, 260]is_checked_str: ""},1:{id: 90is_checked_arr: [259, 260]is_checked_str: ""},2:{id: 12is_checked_arr: [2…

【NuxtJs】支付宝PC支付跳转支付页面处理方案

一&#xff1a;支付宝支付基础结构页面构建 1.选择支付宝选项 2.点击下面立即支付按钮 <button click"handlePay">立即支付</button>二&#xff1a;支付宝官方页面唤起操作 支付宝支付一般是请求接口后收到一组form表单代码&#xff0c;在PC中&#…

Java、创建二进制数据文件

package io;import java.io.*; import java.security.SecureRandom;public class Exercise17_02 {public static void main(String[] args) throws IOException {File file new File("D:\\IDEA程序\\JavaFXProject\\src\\files\\Exercise17_02.dat"); //文件对象//…

【Vue3系列】vue3过滤器功能

1. computed computed: {computedStatus() {// 计算属性要return一个函数接收参数return function (state) {switch (state) {case 1:return 待支付;break;case 2:return 待签署合同;break;case 3:return 待发货;break;case 4:return 运输中;break;case 5:return 已完成;break;…