人工智能
Redis服务器负责与多个客户端建立网络连接,处理客户端发送三个的命令请求,在数据库中爆粗你客户单执行命令所产生的数据,并通过资源管理来维持服务器自身的运转。
命令请求的执行过程 当服务器与客户端的连接套接字因为客户端的写入而变得可读时,服务器将调用命令请求处理器来执行以下操作:
-1、读取套接字中协议格式的命令请求,并将其保存到客户端状态的输入缓冲区中;
-2、对输入缓冲区中的命令请求进行分析,提取出命令请求中包含的命令参数,以及命令参数的个数,然后分别将参数和参数个数保存到客户单状态的argv属性和argc属性里面;
-3、调用命令执行器,执行客户单指定的命令。
命令执行器做的第一件事就是根据客户单状态的argv[0]参数,在命令表中查找参数所指定的命令,并将命令保存到客户端状态的cmd属性中。
命令执行器的预备操作:
-1、检查客户端状态的cmd指针是否指向NULL,如果是的话,说明用户输入的命令名字找不到实现,返回错误;
-2、根据cmd属性指向的arity属性,检查命令参数是否正确,不正确返回错误;
-3、检查客户的江岸是否已经通过了身份验证,未通过身份验证的客户单只能执行auth命令,如果未通过客户端执行其他命令,返回错误;
-4,如果服务器打开了maxmemory功能,那么在执行命令之前,先检查副武器的内存占用情况,并在有需要的时候回收内存,从而使得接下来的命令可以顺利执行,如果回收失败,那么返回错误;
-5、如果服务器上一次执行bgsave出错,并且打开了stop-writes-on-bgsave-error功能,而且即将执行一个写命令,返回错误;
-6、如果客户端正在订阅频道,或者正在订阅模式,那么服务器智慧执行客户端发来的订阅相关命令;
-7、如果服务器正在进行数据载入,那么客户端发送的命令必须带有l标识才会执行,否则拒绝执行;
-8、如果服务器因为执行lua脚本而超时并进入阻塞状态,那么服务器智慧执行客户端发来的shutdown nosave命令和script kill命令,其他拒绝;
-9、如果客户端正在进行事务,那么服务器智慧执行客户端发来的事务相关命令,其他命令进队列;
-10、如果服务器打开了监视器功能,那么服务器会将要执行的命令和参数等信息发送给监视器。
调用命令实现函数
前面的操作已经将处理器注册到了cmd中,执行后将回复保存到客户端的输出缓冲区中。
执行后续工作
-1、如果服务器开启了慢查询日志功能,那么man插叙你日志模块会检查是否需要为刚刚执行完的命令请求添加一条新的慢查询日志。
-2、根据执行命令所耗费的时长,更新redisCommand的毫秒属性,并将命令的引用计数+1;
-3、如果服务器开启了AOF持久化功能,那么会将刚刚执行的命令请求写入到AOF缓冲区中;
-4、如果有其他从服务器正在复制当前这个服务器,那么服务器会将刚刚执行的命令传递给所有从服务器。
将命令回复发送给客户端
当客户单的套接字变为可写状态时,服务器就会执行命令回复处理器,将保存在客户端输出缓冲区中的命令回复发送给客户端,发送完毕后,回复处理器会清空客户单状态的输出缓冲区,为处理下一个命令请求做好准备。
serverCron函数
redis服务器中的serverCron函数默认每隔100ms执行一次,这个函数负责管理服务器资源,并保持服务器自身的良好运转。
功能:
-1、更新服务器时间缓存:会以100ms的频率更新unixtime和mstime;
-2、更新lru时钟:服务器状态中的lruclouk属性保存了副武器的lru时钟,默认每10秒更新一次的时钟缓存,用于计算键的空转时长,通过与对象的lru对比;
-3、更新服务器每秒执行命令次数:100ms的频率执行;
-4、更新服务器内存峰值记录:stat_peak_memory记录了服务器内存峰值的大小,每次执行serverCron都会查看当前的内存数量进行对比,判断是否覆盖。
-5、处理SIGTERM信号:在启动时,redis会为服务器进程的sigterm信号关联处理器,处理器会在服务器接到信号时,打开shutdown_asap标识,每次运行serverCron,程序都会检测这个标识,判断知否关闭服务器。
-6、管理客户端资源:每次调用会检查超时客户端并释放,如果客户单在上一次执行命令后,输入缓冲区的大小超过了一定的长度,那么程序会释放客户单当前的输入缓冲区,并重新创建一个默认大小的输入缓冲区,防止消耗过多内存。
-7、管理数据库资源:每次执行会调用databasesCron,它会检查一部分数据库,删除过期键,在必要时对字典进行收缩操作;
-8、执行被延迟的BGREWRITEAOF:在执行bgsave期间,客户端发来bgrewriteaof命令,那么这个命令会延迟到bgsave命令执行完毕之后;
-9、检查持久化操作的运行状态:只要rdb_child_pid和aof_child_pid其中一个不为-1,就会执行一次wait3,检查子进程是否有信号发来服务器进程。其他情况会判断是否有bgrewriteaof被延迟了,或者自动保存条件被触发,或者aof重写条件被触发;
-10、将aof缓冲区的内容写入aof文件;
-11、关闭异步客户端;
-12、增加cronloops计数器,每次执行都会+1;
初始化服务器
-1、初始化服务器状态结构:设置服务器运行id,设置默认配置文件路径,设置默认服务器频率,设置服务器运行架构,设置默认端口号,设置默认rdb条件和aof条件,初始化lru时钟,创建爱你命令表;
-2、载入配置选项:命令行的参数,配置文件的设置;
-3、初始化服务器数据结构:创建客户端状态的链表,创建数据库数组,创建订阅字典,创建订阅模式的链表,更改慢查询日志的slowlog属性,更改lua属性; 为服务器设置进程信号处理器,创建爱你共享对象,打开服务器监听端口,为serverCron创建时间事件,如果aof打开,那么打开现有aof文件,否则创建,初始化服务器的后台I/O模块bio。
还原数据库状态
如果开启了aof,使用aof文件还原数据库状态,否则使用rdb文件。
执行事件循环
server.c
全部0条评论
快来发表一下你的评论吧 !