Redis的Monitor监视器

一  介绍
客户端可以通过执行MONITOR命令，将客户端转换成监视器，接收并打印服务器处理的每个命令请求的相关信息。
当一个客户端从普通客户端变为监视器时，该客户端的REDIS_MONITOR标识会被打开。
服务器将所有监视器都记录在monitors链表中。
每次处理命令请求时，服务器都会遍历monitors链表，将相关信息发送给监视器。

当前客户端变身监视器,将服务器当前处理的命令都打印出来。
除了命令与参数外，还有精确到微妙的时间戳，选择的数据库，客户端的ip,port。

192.168.1.3:6379> monitor
OK
1464487722.534521 [0 10.249.88.69:33846] "get" "fwy"
1464487728.486523 [0 10.249.88.69:33846] "set" "fwy" "b"
1464488225.302544 [0 10.249.88.69:45389] "select" "3;"
1464488230.006471 [0 10.249.88.69:45389] "select" "3"
1464488232.342483 [3 10.249.88.69:45389] "set" "fwy" "a"

二  数据结构

redisServer的slave链表,保存着各个监视器，新来的监视器，会加到链表尾。

struct redisServer {
    ...

    list *slaves, *monitors;    /* List of slaves and MONITORs */
    ...
}



三  算法

服务器处理客户端发来的命令请求，还会把命令信息发给各个监视器。





服务器主要是通过replicationFeedMonitors(),来将各个命令信息发给监视器们。
replication.c/replicationFeedMonitors()

void replicationFeedMonitors(redisClient *c, list *monitors, int dictid, robj **argv, int argc) {
    /*1.根据命令与参数构造发送给监视器的字符串对象；
      2.遍历各个监视器，把字符串对象发出。
      参数:客户端状态,监视器链表,客户端的dbnum,命令参数与个数
     */
    listNode *ln;
    listIter li;
    int j;
    sds cmdrepr = sdsnew("+");
    robj *cmdobj;
    struct timeval tv;

    gettimeofday(&tv,NULL);

    // 创建要发给各个监视器的信息
    cmdrepr = sdscatprintf(cmdrepr,"%ld.%06ld ",(long)tv.tv_sec,(long)tv.tv_usec);

    // 发送给监视器的信息要包含该客户端的ip,port，但如果是lua脚本客户端与unixsocket客户端，就没有port了,但也需要打印它们的信息,比如来自于哪个unixsocket
    if (c->flags & REDIS_LUA_CLIENT) {
        cmdrepr = sdscatprintf(cmdrepr,"[%d lua] ",dictid);
    } else if (c->flags & REDIS_UNIX_SOCKET) {
        cmdrepr = sdscatprintf(cmdrepr,"[%d unix:%s] ",dictid,server.unixsocket);
    } else {
        cmdrepr = sdscatprintf(cmdrepr,"[%d %s] ",dictid,getClientPeerId(c));
    }

    // 命令与参数输出,如果是int则用%ld输出,否则用字符串输出
    for (j = 0; j < argc; j++) {
        if (argv[j]->encoding == REDIS_ENCODING_INT) {
            cmdrepr = sdscatprintf(cmdrepr, "\"%ld\"", (long)argv[j]->ptr);
        } else {
            cmdrepr = sdscatrepr(cmdrepr,(char*)argv[j]->ptr,
                        sdslen(argv[j]->ptr));
        }
        // 如果是最后一个参数
        if (j != argc-1)
            cmdrepr = sdscatlen(cmdrepr," ",1);
    }
    cmdrepr = sdscatlen(cmdrepr,"\r\n",2);
    // 创建一个字符串对象cmdobj
    cmdobj = createObject(REDIS_STRING,cmdrepr);

    // 迭代各个监视器,把信息输出
    listRewind(monitors,&li);
    while((ln = listNext(&li))) {
        redisClient *monitor = ln->value;
        addReply(monitor,cmdobj);
    }
    // 减少其引用计数让服务器一会自动回收
    decrRefCount(cmdobj);
}

四 客户端

客户端发送 monitor 命令

redis.c/monitorCommand()    

// 客户端发送monitor命令的处理函数
void monitorCommand(redisClient *c) {
    /* ignore MONITOR if already slave or in monitor mode */
    // 如果已经是slave模式,或monitor模式(monitor模式的也会打开slave模式),则不理会.
    if (c->flags & REDIS_SLAVE) return;

    // 客户端置位为monitor标记，还会置位为slave.
    c->flags |= (REDIS_SLAVE|REDIS_MONITOR);

    // 把客户端增加到server.monitors链表的表尾
    listAddNodeTail(server.monitors,c);

    // 回复OK
    addReply(c,shared.ok);
}