redis命令执行过程
- redis服务器如何解析客户端请求数据
-
从连接中获取客户端
-
开启I/O线程，读取并解析请求数据(RESP协议)
-
若当前读取的是超大参数(大于32KB)，则需要保证查询缓冲区只有当前参数数据
-
更新单词读取数据量峰值，扩容查询缓冲区，使其可用内存不小于读取字节数，再从socket读取数据
-
如果客户端是主节点客户端，还需要更新主从机制方面的属性
-
处理读取数据
- 请求数据类型未确认，代表当前解析的是一个新的命令请求，需要判断请求类型
- 从请求数据解析命令参数，若读取完全则执行命令，否则TCP拆包，继续读取该请求剩余数据
- 读取当前命令所有参数
- 若参数为一个超大参数，需清除缓冲区内其他参数，确保缓冲区只有当前参数，并对缓冲区扩容，确保其能容纳当前命令参数
- 若当前缓冲区字符串长度小于当前命令参数长度，则说明命令参数并没有读取完成，退出，等待下次继续读取剩余数据
- 若读取数据是一个超大参数，则直接使用查询缓冲区创建一个redisObject作为参数，并申请新的内存作为查询缓冲区
- 若读取数据不是超大参数，则复制查询缓冲区数据并创建一个redisObject作为参数
- 读取完执行命令
因为redis使用的epoll条件触发模式，所以未读取完数据时，系统会发信号给redis继续读取，直到读取完redis才会执行命令。
-
- 服务器如何返回响应数据
- 响应数据通常小于16KB，若大于16KB需要申请新的内存块。
- 按照RESP协议处理数据
- 先尝试写入缓冲区，写不下，申请新的内存
- 将回复缓冲区数据写入TCP发送缓冲区
- 遍历需要回复的客户端
- 将client回复缓冲区内容写入到TCP缓冲区
- 如果client回复缓冲区还有数据，则说明数据太多，无法一次性发送给TCP缓冲区，这时需要注册WRITEABLE文件事件回调函数，等待TCP缓冲区可写后，继续写入数据。
- 服务器执行命令过程
redis启动的时候，会加载命令和命令记录到内存中(命令字典)- 触发Module Filter，Module优先级很高
- 针对quit命令处理，给client添加退出标志，然后退出 （退出优先级也很高）
- 使用命令，从命令字典中查找对应的redisCommand，并检查参数是否满足命令要求
- 拒绝执行命令场景
- 客户端身份验证未通过
- 客户端没有权限执行该命令
- 如果该服务运行再cluster模式下，当前节点并不是该命令的健的存储节点，返回数据通知客户端真正的请求节点
- 若服务器设置了最大内存，在淘汰数据失败的情况下，会拒绝执行命令
- 服务器是主节点持久化出现错误会拒绝执行命令
- 主从节点断开连接，拒绝查询命令
- 服务器正在加载数据
- 服务器处于lua脚本超时状态
- 如果当前client处于事务上下文中，那么除EXEC\DISCARD\MULTI\WATCH以外的命令都会加入到事务队列中，否则执行命令。
- 发送命令信息给监控模式下的客户端
- 命令执行前，重置传播控制标志，这些标志只在命令执行过程中开启，因为执行命令是递归调用，所以执行前要先清除
- 执行命令处理的逻辑
- 命令处理完后，要求尽快关闭客户端
- 如果当前正在加载数据并且当前命令执行是lua脚本，则清除慢日志，命令统计这两个客户端标志，该命令既不输出到慢日志也不添加到命令统计之中
- 如果当前客户端时lua脚本伪装的客户端，需要将该客户端的标志转移到真实客户端中
- 记录慢日志并统计命令信息
- 将命令记录到AOF文件或复制到从服务器中
- 命令执行器会清除client的传播控制标志，如果cilent本就有这些标志，又会重新赋值
- 需额外传播的命令，这里将它记录到AOF或复制到从服务器中
- 若执行的是一个查询命令，redis会记住该命令，若后续查询的健发生变化会通知客户端(这是redis新增的tracking机制)
- 命令执行完之后操作
- 若客户端是主节点客户端，并且客户端不处于事务上下文中，则更新client.reploff,该属性记录当前服务器已同步命令偏移量，用于主从同步
- 重置客户端，这个过程不会清除client回复缓冲区
- 若客户端时主节点客户端，则将命令复制到当前服务器的从节点