一 介绍
客户端可以通过执行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," ",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);
}
原文链接：https://blog.csdn.net/whiteoldbig/article/details/51530808