Redis的Monitor监视器 redis 监听

一 介绍

客户端可以通过执行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链表,保存着各个监视器，新来的监视器，会加到链表尾。

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);

}