从源码看redis的AOF持久化机制

Code.SLICE.source("buf[0] = '*';" +
"    len = 1+ll2string(buf+1,sizeof(buf)-1,argc);" +
"    buf[len++] = '\r';" +
"    buf[len++] = '\n';" +
"    dst = sdscatlen(dst,buf,len);" +
"    for (j = 0; j < argc; j++) {" +
"        o = getDecodedObject(argv[j]);" +
"        buf[0] = '$';" +
"        len = 1+ll2string(buf+1,sizeof(buf)-1,sdslen(o->ptr));" +
"        buf[len++] = '\r';" +
"        buf[len++] = '\n';" +
"        dst = sdscatlen(dst,buf,len);" +
"        dst = sdscatlen(dst,o->ptr,sdslen(o->ptr));" +
"        dst = sdscatlen(dst,\"\r\n\",2);" +
"        decrRefCount(o);" +
"    }")
.interpretation("按照一定的格式转化命令，放到要存放的目的地")
.interpretation("1: 先计算命令一共有几个字符 ，比如命令 set msg hello ，那么首先写入的就是 3，然后追加 \r\n")
.interpretation("2: 遍历每个字符，先写下$符号，然后记下这个字符的长度，追加 \r\n再记下长度和字符本身，然后追加 \r\n")
.interpretation("3: set msg hello 最终需要追加的内容为  3\r\n$3\r\nmsg\r\n$5\r\nhello\r\n");
复制代码

 //..
Code.SLICE.source("while(1) ")
    .interpretation("读取AOF文件的内容，按照 REPL 的格式 ，1条条命令处理");
//..
Code.SLICE.source("if (fgets(buf,sizeof(buf),fp) == NULL)")
    .interpretation("从文件中读取一定字节到buf中");
//..
Code.SLICE.source("argc = atoi(buf+1);")
    .interpretation("拿到命令的长度");
//..
Code.SLICE.source("for (j = 0; j < argc; j++) ")
    .interpretation("一个个的解析这条命令的所有数据,中间会对写入的数据做校验");
//..
Code.SLICE.source("argv[j] = createObject(OBJ_STRING,argsds);")
    .interpretation("将数据存储到argv数组");
//..
Code.SLICE.source("cmd = lookupCommand(argv[0]->ptr);")
    .interpretation("确保要执行的命令是合法的redis命令");
//..
Code.SLICE.source("cmd->proc(fakeClient);")
    .interpretation("模拟执行");