百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

向Redis发出一条命令,会发生什么?

yuyutoo 2025-03-13 21:50 7 浏览 0 评论

天下皆知美之为美,斯恶已;皆知善之为善,斯不善已。
故有无相生,难易相成,长短相形,高下相倾,音声相和,前后相随,恒也。
是以圣人处无为之事,行不言之教。万物作焉而不辞,生而不有,为而不恃,功成而弗居。夫唯弗居,是以不去。

文章导航

日常工作中,我们经常在Redis中设置值和取值,那么一条命令发出去之后,都经历了什么呢?

127.0.0.1:6379> SET key value
OK

一条命令,从发送到得到回复的过程,客户端和服务端需要完成一系列的操作。以上面代码为例,客户端和服务端共需要经历下面的步骤:

  1. 客户端向服务端发送SET key value命令。
  2. 服务端接收客户端请求,并处理。在数据库中进行设置操作,并产生命令回复OK。
  3. 服务端将命令回复OK发送给客户端
  4. 客户端接收服务端返回命令并回复OK,并将该回复显示给用户

本文关于Redis 源码部分,源于Redis 7.0

客户端发送命令请求

将用户在客户端输入一个命令后,客户端会将命令请求转成协议格式,并发送给服务端。

客户端向服务端发送命令

比如在客户端输入下面命令:

127.0.0.1:6379> SET key value
OK

客户端会将该命令转成协议格式,并发送给服务端。

*3\r\n$3\r\nSET\r\n$3\r\nkey\r\n$5\r\nvalue\r\n

为了使文章结构清晰,关于协议格式不再赘述,文末详细介绍!

服务端读取命令请求

当客户端向服务端发送完命令请求后,服务端会调用命令请求处理器进行下面操作:

  1. 读取协议格式的命令请求,并保存到客户端缓冲区(Client )。
  2. 对命令请求解析,提取出命令参数及参数个数。
  3. 调用命令执行器,执行命令。

redis-server client.drawio.png

上图是Redis将命令请求保存到客户端缓冲区后的结构。

client是客户端缓冲区结构体,其中将协议格式的命令请求保存在client的querybuf中。argc保存命令请求的个数。参数保存到argv中。后文我们用client来替代客户端缓冲区

接下来Redis Server会调用命令执行器完成执行命令的后续部分。

命令执行器之查找命令

首先命令执行器要根据客户端缓冲区的argv[0]在redisCommandTable中查找参数指定的命令,并保存到client的cmd字段中。

redisCommandTable是一个全局变量,定义了所有 Redis 命令,值为redisCommand结构,包括命令的名称、实现函数、所需参数数量以及其他属性。它用于存储和管理 Redis 的命令信息。

以下是redisCommand结构体的主要字段整理出来,完整描述详见源码server.h/redisCommand

字段名

类型

描述

declared_name

char*

命令的声明名称

summary

char*

命令的摘要

complexity

char*

复杂度描述

since

char*

命令引入的版本号

proc

redisCommandProc*

命令实现函数指针

arity

int

参数数量

flags

uint64_t

命令标志

acl_categories

uint64_t

ACL分类

getkeys_proc

redisGetKeysProc*

获取键参数的函数指针

microseconds

long long

命令执行时间(微秒)

calls

long long

命令调用次数

rejected_calls

long long

被拒绝的命令调用次数

failed_calls

long long

失败的命令调用次数

redisCommandTable采用与大小写无关的查找策略,因此命令名字的大小写不影响查找。

命令执行器之预执行

现在我们已经准备好执行命令了,但是在执行前还需要一些预备检查,以便命令可以正确、顺利的执行。

  1. 客户端身份验证:如果Redis服务器启用了身份验证机制,首先会验证客户端是否已成功通过身份验证。只有通过身份验证的客户端才能继续执行后续的命令。
  2. 命令权限检查:根据ACL(访问控制列表)配置,检查当前连接的客户端是否具有执行该命令的权限。ACL可以限制每个用户或用户组能够执行的特定命令。
  3. 命令存在性检查:检查客户端请求的命令是否存在于Redis服务器的命令字典中。如果命令不存在,则向客户端返回错误响应。
  4. 参数数量检查:根据命令定义的参数数量要求(arity字段),检查客户端请求的参数数量是否满足要求。如果参数数量不正确,则向客户端返回错误响应。
  5. 参数格式检查:对于某些命令,进一步检查参数的格式是否符合预期。例如,对于SET命令,会检查键和值参数的类型是否正确。
  6. 服务器状态检查:在执行某些命令之前,可能会检查服务器的状态是否允许执行该命令。例如,在主从复制模式下,只有主节点允许执行写操作。

命令执行器之执行

到这一步,所有的前置准备工作已经就绪,接下来要真正执行了!

前面我们知道客户端缓冲区保存了命令的参数和参数个数,分别保存在client的argv、argc属性中,当执行命令的时候,运行下面语句即,代码位于service.c/call

c->cmd->proc(c); //setCommand(client)

client结构

被调用的命令实现函数执行响应的操作,并产生对应的命令回复,保存在客户端缓冲区(client的reply和buf属性中)。

命令回复结构

命令执行器之善后

命令执行结束后,命令执行器还需要执行一些善后工作:

  1. 释放资源:在命令执行完毕后,命令执行器需要释放相关的资源,包括临时数据结构、数据库锁等。这样可以避免资源泄露和浪费,保持系统的稳定性和高效性。
  2. 日志记录:根据配置和需求,命令执行器可能需要记录命令执行的日志。这包括成功执行的命令、出现错误的命令、重要事件等。日志记录有助于故障排查、性能优化和监控。
  3. 统计和计数:命令执行器可能需要对命令执行过程中的统计数据进行更新和计数。例如,命令调用次数、执行时间、失败次数等。这些统计信息可以用于性能分析和监控系统健康状态。
  4. 处理事务回滚:如果命令执行过程中发生了错误,导致事务无法完成,命令执行器可能需要执行相应的回滚操作,撤销之前已执行的命令。这保证了事务的一致性和可靠性。

将命令回复发送给客户端,并打印

Redis Server 执行命令回复处理器,将客户端缓冲区中的命令回复发送给客户端。

客户端在收到命令回复后,将协议格式转换为人类可读模式,并打印出来。

到这里,客户端和服务端的整个请求过程已经结束了。有同学开始问了,集群下是如何运行的?客户端怎么知道key所在节点的呢?

在集群模式下,服务端在接收到命令请求后,会先根据key判断命令请求中的key所在槽是否在当前节点,如果不是,会向客户端返回一个MOVED错误,客户端根据MOVED错误信息转向正确的节点重新发送命令请求并执行上述操作。

redis cluster check

Redis协议格式

Redis 协议是一种用于与 Redis 数据库进行通信的简单而高效的文本协议。它使用 TCP/IP 进行传输,并以行为单位进行交互。

在 Redis 协议中,每个请求和响应都由多个字符组成。我们可以将协议的格式分为请求格式和响应格式:

请求格式:

  • *<参数数量> CR LF:表示参数数量的前缀,用于指定请求中的参数个数。
  • $<参数长度> CR LF:表示参数长度的前缀,用于指定接下来的参数的长度。如果参数为空,则长度为 -1。
  • <参数值> CR LF:参数的实际内容。

举个例子,如果我们要设置一个键值对,请求可以如下所示:

*3 // 参数数量为 3

$3 // 第一个参数长度为 3

SET // 第一个参数值为 SET

$5 // 第二个参数长度为 5

mykey // 第二个参数值为 mykey

$7 // 第三个参数长度为 7

myvalue // 第三个参数值为 myvalue

响应格式:

Redis 的响应也由多个字符组成,有以下几种可能的类型:

  • 状态回复(Status Reply):以 "+" 开头,后面跟着状态信息。
  • 错误回复(Error Reply):以 "-" 开头,后面跟着错误信息。
  • 整数回复(Integer Reply):以 ":" 开头,后面跟着一个整数。
  • 批量回复(Bulk Reply):以 "$" 开头,后面跟着回复的长度和内容。如果长度为 -1,则表示空值。
  • 多条批量回复(Multi Bulk Reply):以 "*" 开头,后面跟着回复的数量和内容。

举个例子,如果我们要获取一个键的值,响应可以如下所示:


$7 // 响应内容的长度为 7

myvalue // 响应内容为 myvalue

完整的协议格式参考:
https://redis.io/docs/reference/protocol-spec/

相关推荐

自卑的人容易患抑郁症吗?(自卑会导致抑郁吗)

Filephoto[Photo/IC]Lowself-esteemmakesusfeelbadaboutourselves.Butdidyouknowthatovert...

中考典型同(近)义词组(同义词考题)

中考典型同(近)义词组...

WPF 消息传递简明教程(wpf messagebox.show)

...

BroadcastReceiver的原理和使用(broadcast-suppression)

一、使用中注意的几点1.动态注册、静态注册的优先级在AndroidManifest.xml中静态注册的receiver比在代码中用registerReceiver动态注册的优先级要低。发送方在send...

Arduino通过串口透传ESP 13板与java程序交互

ESP13---是一个无线板子,配置通过热点通信Arduino通过串口透传ESP13板与java程序交互...

zookeeper的Leader选举源码解析(zookeeper角色选举角色包括)

作者:京东物流梁吉超zookeeper是一个分布式服务框架,主要解决分布式应用中常见的多种数据问题,例如集群管理,状态同步等。为解决这些问题zookeeper需要Leader选举进行保障数据的强一致...

接待外国人英文口语(接待外国友人的英语口语对话)

接待外国人英文口语询问访客身份:  MayIhaveyourname,please?  请问您贵姓?  Whatcompanyareyoufrom?  您是哪个公司的?  Could...

一文深入理解AP架构Nacos注册原理

Nacos简介Nacos是一款阿里巴巴开源用于管理分布式微服务的中间件,能够帮助开发人员快速实现动态服务发现、服务配置、服务元数据及流量管理等。这篇文章主要剖析一下Nacos作为注册中心时其服务注册与...

Android面试宝典之终极大招(android面试及答案)

以下内容来自兆隆IT云学院就业部,根据多年成功就业服务经验,以及职业素养课程部分内容,归纳总结:18.请描述一下Intent和IntentFilter。Android中通过Intent...

除了Crontab,Swoole Timer也可以实现定时任务的

一般的定时器是怎么实现的呢?我总结如下:1.使用Crontab工具,写一个shell脚本,在脚本中调用PHP文件,然后定期执行该脚本;2.ignore_user_abort()和set_time_li...

Spark源码阅读:DataFrame.collect 作业提交流程思维导图

本文分为两个部分:作业提交流程思维导图关键函数列表作业提交流程思维导图...

使用Xamarin和Visual Studio开发Android可穿戴设备应用

搭建开发环境我们需要做的第一件事情是安装必要的工具。因此,你需要首先安装VisualStudio。如果您使用的是VisualStudio2010,2012或2013,那么请确保它是一个专业版本或...

Android开发者必知的5个开源库(android 开发相关源码精编解析)

过去的时间里,Android开发逐步走向成熟,一个个与Android相关的开发工具也层出不穷。不过,在面对各种新鲜事物时,不要忘了那些我们每天使用的大量开源库。在这里,向大家介绍的就是,在这个任劳任怨...

Android事件总线还能怎么玩?(android实现事件处理的步骤)

顾名思义,AndroidEventBus是一个Android平台的事件总线框架,它简化了Activity、Fragment、Service等组件之间的交互,很大程度上降低了它们之间的耦合,使我们的代码...

Android 开发中文引导-应用小部件

应用小部件是可以嵌入其它应用(例如主屏幕)并收到定期更新的微型应用视图。这些视图在用户界面中被叫做小部件,并可以用应用小部件提供者发布。可以容纳其他应用部件的应用组件叫做应用部件的宿主(1)。下面的截...

取消回复欢迎 发表评论: