我要评论慢查询
添加新日志
在每次执行命令的之前和之后，程序都会记录微妙格式的当前unix时间戳，这两个时间戳之间的差就是服务器执行命令所耗费的时长，服务器会将这个时长作为参数之一传给slowlogpushentryifneeded函数，而slowlogpushentryifneeded函数则负责检查是否需要为这次执行的命令创建慢查询日志。
伪代码过程
# 记录执行命令前的时间 before = unixtime_now_in_us() # 执行命令 execute_command(argv, argc, client) # 记录执行命令后的时间 after = unixtime_now_in_us() # 检查是否需要创建新的慢查询日志 slowlogpushentryifneeded(argv, argc, after - before)
slowlogpushentryifneeded函数的作用
- 1.检查命令的时长是否超过slowlog-log-slower-than选项设置的时间， 如果是的话，就为命令创建一个新的日志，并将新日志添加到slowlog链表的表头
- 2.检查慢查询日志的长度是否超过slowlog-max-len选项所设置的长度，如果是的话，那么将多出来的日志从slowlog链表中删除掉
slowlogpushentryifneeded函数的实现代码:
void slowlogpushentryifneeded(robj **argv, int argc, long long duration) {
// 慢查询功能未开启，直接返回
if (server.slowlog_log_slower_than < 0) return ;
// 如果执行时间超过服务器设置的上限，那么将命令添加到慢查询日志
if (duration >= server.slowlog_log_slower_than)
// 新日志添加到链表表头
listaddnodehead(server.slowlog, slowlogcreateentry(argv, argc, duration));
// 如果日志数量过多，那么进行删除
while (listlength(server.slowlog) > server.slowlog_max_len)
listdelnode(server.slowlog, listlast(server.slowlog))
}
该函数根据传入的参数，创建一个新的慢查询日志，并将redisserver.slowlog_entry_id的值增1
例子
举个例子。假设服务器当前保存的慢查询日志如图所示，如果执行以下命令:
127.0.0.1:6379> expire msg 10086 (integer) 1
服务器在执行完这个expire命令之后，就会调用slowlogpushentryifneeded函数，函数将未expire命令创建一条id为7的慢查询日志，并将这条新日志添加到slowlog链表的表头如图所示.注意，除了slowlog链表发生了变化之外，slowlog_entry_id的值也从7变为8了，之后，slowlogpushentryifneeded函数发现，服务器设定的最大慢查询日志数目为5条，而服务器目前保存的慢查询日志数目为6条，于是服务器将id为2的慢查询日志删除，让服务器的慢查询日志数量回到设定好的5条
监视器
概述
通过执行monitor命令，客户端可以将自己变为一个监视器，实时地接收并打印出服务器当前处理的命令请求的相关信息:
127.0.0.1:6379> monitor ok 1713790637.787549 [0 127.0.0.1:60753] "ping" 1713790641.908992 [0 127.0.0.1:60753] "set" "k1" "v1" 1713790645.044945 [0 127.0.0.1:60753] "set" "k2" "v2"
每当一个客户端服务器发送一条命令请求时，服务器除了会处理这条命令请求之外，还会将关于这条命令请求的信息发送给所有监视器，如图所示
成为监视器
发送monitor命令可以让一个普通客户端变为一个监视器，该命令的实现原理可以用以下伪代码来实现:
def monitor():
# 打开客户端的监视器状态
client.flags |= redis_monitor
# 将客户端添加到服务器状态的monitors链表的末尾
server.monitor.append(client)
# 向客户端返回ok
send_reply("ok")
例子
举个例子，如果客户端c10086向服务器发送monitor命令，那么这个客户端的redis_monitor标志会被打开，并且这个客户端本身会被添加到monitors链表的表尾。假设客户端c10086发送monitor之前，monitors链表的状态如图所示，那么在服务器执行客户端c10086发送的monitor命令之后，monitors链表将被更新为如图所示的状态
向监视器发送命令信息
服务器在每次处理命令请求之前，都会调用replicationfeedmonitors函数，由这个函数将被处理的命令请求的相关信息发送给各个监视器。以下是replicationfeedmonitors函数的伪代码定义，函数首先根据传入的参数创建信息，然后将信息发送给所有监视器:
def replicationfeedmonitors(client, monitors, dbid,argv, argc): # 根据执行命令的客户端、当前数据库的号码、命令参数、命令参数个数等参数 # 创建要发送给各个监视器的信息 msg = create_message(client, dbid, argv, argc) # 遍历所有监视器 for monitor in monitors: # 将信息发送给监视器 send_message(monitor, msg)
例子
举个例子，假设服务器在时间1713791641.329412,根据ip为127.0.0.1、端口号为56604的客户端发送的命令请求，对0号数据库执行命令keys*,那么服务器将创建以下信息:
1713791641.329412 [0 127.0.0.1:56604] "keys" "*"
如果服务器monitors链表的当前状态如图上如c10086执行命令之后所示，那么服务器会分别将信息发送给c128、c256、c512和c10086四个监视器，如图所示
以上就是一文搞懂redis中的慢查询日志和监视器的详细内容，更多关于redis慢查询日志和监视器的资料请关注代码网其它相关文章！
发表评论