13 客户端

Redis服务器是典型的一对多服务器程序:一个服务器可以与多个客户端建立网络连接,每个客户端可以向服务器发送命令请求,而服务器则接受并处理客户端发送的命令请求,并向客户端返回命令回复。
通过使用由I/O多路复用技术实现的文件事件处理器,Redis服务器使用单线程单进程的方式来处理命令请求,并与多个客户端进行网络通信。
对于每个与服务器进行连接的客户端,服务器都为这些客户端建立了相应的redis.h/redisClient结构(客户端状态),这个结构保存了客户端当前的状态信息,以及执行相关功能时需要用到的数据结构,其中包括

  • 客户端的套接字描述符
  • 客户端的名字
  • 客户端的标志值
  • 指向客户端正在使用的数据库的指针,以及该数据库的号码
  • 客户端当前要执行的命令、命令的参数、命令参数的个数,以及指向命令实现函数的指针。
  • 客户端的输入缓冲区和输出缓冲区。
  • 客户端的复制状态信息,以及进行复制所需要的数据结构。
  • 客户端执行BRPOPBLPOP等列表命令时使用的数据结构。
  • 客户端的事务状态,以及执行WATCH命令时用到的数据结构。
  • 客户端执行发布与订阅功能时用到数据结构。
  • 客户端的身份验证标志。
  • 客户端的创建时间,客户端和服务器最后一次通信时间,以及客户端的输出缓冲区大小超出软性限制(soft limit)的时间

Redis服务器状态结构clients属性是一个链表,这个链表保存了所有域服务器连接的客户端的状态结构,对客户端执行批量操作,或者查找某个指定的客户端,都可以通过遍历clients链表来完成。

13.1 客户端属性

客户端状态包含的属性可以分为两类

  • 一类是比较通用的属性,这些属性很少与特定功能相关,无论客户端执行的是什么工作,他们都要用到这些属性。
  • 另外一类是和特定功能相关的属性,比如操作数据库时需要用到的db属性和dictid属性,执行事务时需要用到的mstate属性,以及执行WATCH命令时需要用到的watched_keys属性等等。

13.1.1 套接字描述符

客户端状态的fd属性记录了客户端正在使用套接字描述符:

typedef struct redisClient{

    // ...

    int fd;

    // ...
}redisClient;

根据客户端类型的不同,fd属性的值可以是-1或者是大于-1的整数

  • 伪客户端(fake client)的fd属性的值为-1:伪客户端处理的命令请求来源于AOF文件或者Lua脚本,而不是网络,所以这种客户端不需要套接字连接,自然也不需要记录套接字描述符。目前Redis服务器会在两个地方用到为客户端,一个用于载入AOF文件并还原数据库状态,而另一个则用于执行Lua脚本中包含的Redis命令。
  • 普通客户端的fd属性的值为大于-1的整数:普通客户端使用套接字来与服务器进行通信,所以服务器会用fd属性来记录客户端套接字的描述符。因为合法的套接字描述符不能是-1,所以普通客户端的套接字描述符的值必然是大于-1的整数。

13.1.2 名字

在默认情况下,一个连接到服务器的客户端是没有名字的。
使用CLIENT setname命令可以为客户端设置一个名字,然给客户端的身份变得更为清晰。
客户端的名字记录在客户端状态的name属性里面:

typedef struct redisClient{

    // ...

    robj *name;

    // ...
}redisClient;

如果客户端没有为自己设置名字,那么响应客户端状态的name属性指向NULL指针;相反的,如果客户端为自己设置了名字,那么name属性将指向一个字符串对象,而该对象就保存着客户端的名字。

13.1.3 标志

客户端的标志属性flags记录了客户端的角色(role),以及客户端目前所处的状态:

typedef struct redisClient{

    // ...

    int flags;

    // ...
}redisClient;

flags属性的值可以是单个标志:

flags=<flag>

也可以是多个标志的二进制或

flags=<flag1>|<flag2>|...

13.1.4 输入缓存区

客户端状态的输入缓冲区用于保存客户端发送的命令请求:

typedef struct redisClient{

    // ...

    sds querybuf;

    // ...
}redisClient;

输入缓冲区的大小会根据输入内容动态地缩小或者扩大,但它的最大大小不能超过1GB,否者服务器将关闭这个客户端。

13.1.5 命令与命令参数

在服务器将客户端发送吃的命令请求保存到客户端状态querybuf属性之后,服务器将对命令请求的内容进行分析,并将得出的命令参数以及命令参数的个数分别保存到客户端状态argv属性和argc属性:

typedef struct redisClient{

    // ...

    robj **argv;

    int argc;

    // ...
}redisClient;

argv属性是一个数组,数组中的每个项都是一个字符串对象,其中argv[0]是要执行的名,而之后的其他项是传给命令的参数。
argc属性则负责记录argv数组的长度。

13.1.6 命令的实现函数

当服务器从协议内容中分析并得出argv属性和argc属性的值之后,服务器将根据项argv[0]的值,在命令表中查找命令所对应的命令实现函数。
当程序在命令中成功找到argv[0]所对应的redisCommand结构时,它会将客户端状态的cmd指向这个结构:

typedef struct redisClient{

    // ...

    struct redisCommand *cmd;

    // ...
}redisClient;

之后,服务器就可以使用cmd属性所指向的redisCommand结构,以及argvargc属性中所保存的命令参数信息,调用命令实现函数,执行客户端指定的命令。

13.1.7 输出缓冲区

执行命令所得到命令回复会被保存在客户端状态的输出缓冲区里面,每个客户端都有两个输出缓冲区可用,一个缓冲区的大小是规定的,另一个缓冲区的大小是可变的:

  • 固定大小的缓冲区用于保存那些长度比较小的回复,比如OK、简短的字符串值、整数值、错误回复等等。
  • 可变大小的缓冲区用于保存那些长度比较大的回复。

客户端的固定大小缓冲区bufbufpos两个属性组成:

typedef struct redisClient{

    // ...

    char buf[REDIS_REPLY_CHUNK_BYTES];

    int bufpos;

    // ...
}redisClient;

buf是一个大小为REDIS_REPLY_CHUNK_BYTES字节的字节数组,而bufpos属性则记录了buf数组目前已使用的字节数量。
REDIS_REPLY_CHUNK_BYTES常量目前的默认值为16*1024,为16KB
buf数组的空间已经用完,或者回复太大没有办法放进buf数组里面时,服务器就会开始使用可变大小缓冲区。
可变大小缓冲区由reply链表和一个或多个字符串对象组成:

typedef struct redisClient{

    // ...

    list *reply;

    // ...
}redisClient;

通过使用链表来连接多个字符串对象,服务器可以为客户端保存一个非常长的命令回复。

13.1.8 身份验证

客户端状态的authenticated属性用于记录客户端是否通过了身份验证:

typedef struct redisClient{

    // ...

    int authenticated;

    // ...
}redisClient;

如果authentication的值为0,那么表示客户端未通过身份验证;如果authentication的值为1,那么小时客户端已经通过了身份验证。
当客户端authentication属性的值为0时,除了AUTH命令之外,客户端发送的所有其他命令都会被服务器拒绝执行。
当客户端通过AUTH命令成功进行身份验证之后,客户端状态authentication属性的值就会从0变成1,可以正常发送命令请求
authentication属性仅在服务器启用了身份验证功能时使用。如果服务器没有启用身份验证功能的话,那么authentication属性的值为0,服务器也不会拒绝执行客户端发送的命令请求。

13.1.9 时间

typedef struct redisClient{

    // ...

    time_t ctime;

    time_t lastinteraction;

    time_t obuf_soft_limit_reached_time;

    // ...
}redisClient;

ctime属性记录了创建客户端的时间,这个时间可以用来计算客户端与服务器已经连接了多少秒
lastinteraction属性记录了客户端与服务器最后一次进行互动的时间。
obuf_soft_limit_reached_time属性记录输出缓存区第一次到达软限制的时间。

13.2 客户端的创建与关闭

服务器使用不同的方式来创建和关闭不同类型的客户端。

13.2.1 创建普通客户端

如果客户端通过网络连接与服务器进行连接的普通用户客户端,那么在客户端使用connect函数连接到服务器时,服务器就会调用连接事件处理器,为客户端创建相应的客户端状态,并将这个新的客户端状态添加到服务器状态结构clients链表的末尾。

13.2.2 关闭普通客户端

一个普通客户端可以因为多种原因而被关闭:

  • 客户端进程退出或者被杀死
  • 客户端发送不符合协议格式的命令请求
  • 客户端成为了CLIENT KILL命令的目标
  • 设置了timeout配置选项,同时客户端的空转时间超过这个值。
  • 客户端输入缓冲区超过限制大小
  • 客户端输出缓冲区超过限制大小

服务器使用两种模式来限制客户端输出缓冲区大小:

  • 硬性限制:超过硬性限制,立即关闭
  • 软性限制:超过软性限制,没有超过硬性限制。使用obuf_soft_limit_reached_time记录时间,如果一直超过限制,并且持续时间超过服务器设定的市场,那么服务器关闭客户端;相反,在规定的时间内,没有超过软性限制,那么客户端不会被关闭,同时obuf_soft_limit_reached_time会被清零。

使用client-output-buffer-limit选项可以为普通客户端、从服务器客户端。执行发布与订阅功能的客户端分别设置不同的软性限制和硬性限制

client-output-buffer-limit <class> <hard limit> <soft limit> <soft seconds>

13.2.3 Lua脚本的伪客户端

服务器会在初始化时创建负责执行Lua脚本中包含的Redis命令的伪客户端,并将这个伪客户端关联在服务器状态结构lua_client属性中:

struct redisServer{

    // ...

    redisClient *lua_client;

    // ...
};

lua_client伪客户端在服务器运行的整个生命期中会一直存在,只有服务器被关闭时,这个客户端才会被关闭。

13.2.4 AOF文件的伪客户端

服务器在载入AOF文件时,会创建用于执行AOF文件包含的Redis命令的伪客户端,并在载入完成之后,关闭这个伪客户端。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,585评论 18 139
  • 1.Redis特性 1)速度快:数据存放在内存上、基于C语言实现、单线程架构预防多线程竞争问题;2)基于键值对的数...
    Sponge1128阅读 614评论 0 1
  • 半壁东南五楚雄,刘郎死去霸图空。 几时痛饮黄龙酒,横揽江流一奠公。 黄易先生也走了,曌,一路好走。 浙东雁荡山...
    蠡舟阅读 226评论 0 3
  • 文/国境之南 -1- 记得清楚,那年你的生日。 提前了好久,我开始做准备,想过许多有创意的,将我们的合照找出来,找...
    国境之南_阅读 736评论 4 12
  • 有事要回老家,列车出行必须先到北京。而18点北京出发的列车,从保定来比较之后就只有1点40分出发15点多到的一趟符...
    乐播报阅读 264评论 0 3