Redis源码笔记-初步

落日映苍穹つ 2022-05-11 01:52 161阅读 0赞

# **目录** #

目录 1

1. 前言 2

2. 名词 2

3. dict.c 2

3.1. siphash算法 2

3.2. 核心函数 3

3.3. 核心宏 3

3.4. 核心结构体 3

3.4.1. dictEntry 3

4. Redis命令 4

4.1. SELECT命令 4

4.1.1. redisCommand结构体 4

4.1.2. redisCommandTable变量 5

4.1.3. selectCommand函数 5

4.2. SET命令 6

4.2.1. setCommand函数 6

4.2.2. dictAdd函数 9

4.2.3. dictFind函数 9

4.3. HSETNX命令 10

4.3.1. hsetnxCommand函数 10

4.3.2. hashTypeSet函数 11

5. Redis多路复用机制 11

5.1. AE是什么？ 11

5.2. 多路复用选择aeApiPoll 11

5.3. 多路复用调用aeCreateFileEvent 12

6. 网络收发过程 14

6.1. 过程简要 14

6.2. 接受连接请求acceptTcpHandler 14

6.3. 创建client对象createClient 16

6.4. 读取命令readQueryFromClient 17

6.5. 命令处理processCommand 17

7. 持久化和复制 22

7.1. propagate函数（aof&replication） 22

7.2. 写AOF文件feedAppendOnlyFile 23

7.3. 数据复制replicationFeedSlaves 25

8. 进程启动时做了些什么？ 26

9. 核心对象 29

9.1. redisServer 29

9.2. client 30

9.3. redisCommand 31

9.4. redisDb 31

9.5. clusterNode 32

9.6. clusterState 32

10. 主备同步 33

11. 主备切换 33

# **1. 前言** #

Redis代码优美，注释也很到位，阅读起来会赏心悦目，大大降低了理解门槛。由于redis单线程几乎完成所有工作，整体逻辑是相当复杂的，涉及了太多状态，作者的技术深厚可见一斑。

Redis的单线程设计给出了一种优雅实现高性能服务思路，在实践中值得借鉴。需要注意Redis并不是严格的单线程，实际上它是多进程+多线程。为解决IO和慢速操作带的性能毛刺和卡顿，Redis实现引入的多进程和多线程。但是它的主体仍然是单线程的，单个线程完成网络IO操作和其它操作。

疑问：Redis选择slot数为16384，是一个偶数，没有采用质数，这个可能并不是一个最好的主意。

# **2. 名词** #

<table style="width:426.15pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:64.95pt;"> RESP </td> 
 <td style="vertical-align:top;width:208.35pt;"> REdis&nbsp;Serialization&nbsp;Protocol </td> 
 <td style="vertical-align:top;width:152.85pt;"> Redis序列化协议 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:64.95pt;"> AE </td> 
 <td style="vertical-align:top;width:208.35pt;"> A&nbsp;simple&nbsp;Event&nbsp;drived&nbsp;programming&nbsp;library </td> 
 <td style="vertical-align:top;width:152.85pt;"> 一个简单的事务驱动编程库 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:64.95pt;"> ASAP </td> 
 <td style="vertical-align:top;width:208.35pt;"> &nbsp; </td> 
 <td style="vertical-align:top;width:152.85pt;"> &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:64.95pt;"> AOF </td> 
 <td style="vertical-align:top;width:208.35pt;"> Append&nbsp;Only&nbsp;File </td> 
 <td style="vertical-align:top;width:152.85pt;"> 仅仅追加写文件 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:64.95pt;"> BIO </td> 
 <td style="vertical-align:top;width:208.35pt;"> Backgroup&nbsp;IO </td> 
 <td style="vertical-align:top;width:152.85pt;"> 后台IO操作，三种涉及BIO：FSYNC、关闭文件和内存free，均为阻塞或慢操作 </td> 
 </tr> 
 </tbody> 
</table>

# **3. dict.c** #

哈希表的实现，哈希函数使用了siphash哈希算法。

## **3.1. siphash算法** ##

一种非加密的64位哈希算法。

## **3.2. 核心函数** ##

Redis中非常核心的算法——哈希表的实现在这个文件中，很多命令都有用到，比如set/hset等，它是除内存分配管理外的最基础实现。核心函数包含但不限于：dictFind、dictNext、dictAdd、dictDelete、dictFetchValue、dictGetHash、dictReplace、dictAddRaw、dictCreate、dictDelete、dictRelease、dictUnlink、dictRehash、dictEmpty、dictResize等。

## **3.3. 核心宏** ##

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> CLUSTER_SLOTS </td> 
 <td style="vertical-align:top;width:284.1pt;"> 定义Redis集群Slots个数，值为16384 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> DICT_HT_INITIAL_SIZE </td> 
 <td style="vertical-align:top;width:284.1pt;"> 定义哈希表默认大小宏，值为4 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictSetVal </td> 
 <td style="vertical-align:top;width:284.1pt;"> 设置Value </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictSetKey </td> 
 <td style="vertical-align:top;width:284.1pt;"> 设置Key </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictCompareKeys </td> 
 <td style="vertical-align:top;width:284.1pt;"> 比较两个Key </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictHashKey </td> 
 <td style="vertical-align:top;width:284.1pt;"> 对Key求哈希 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictGetKey </td> 
 <td style="vertical-align:top;width:284.1pt;"> 取Key </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictGetVal </td> 
 <td style="vertical-align:top;width:284.1pt;"> 取Value </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictSlots </td> 
 <td style="vertical-align:top;width:284.1pt;"> 得到槽（slot）个数 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictSize </td> 
 <td style="vertical-align:top;width:284.1pt;"> 得到已用槽（slot）个数 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictGetSignedIntegerVal </td> 
 <td style="vertical-align:top;width:284.1pt;"> 取8字节有符号整数值 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictGetUnsignedIntegerVal </td> 
 <td style="vertical-align:top;width:284.1pt;"> 取8字节无符号整数值 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:142pt;"> dictGetDoubleVal </td> 
 <td style="vertical-align:top;width:284.1pt;"> 取double类型值 </td> 
 </tr> 
 </tbody> 
</table>

## **3.4. 核心结构体** ##

### **3.4.1. dictEntry** ###

定义了哈希节点的数据结构：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> typedef&nbsp;struct&nbsp;dictEntry&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;*key;&nbsp;//&nbsp;Key &nbsp;&nbsp;&nbsp;&nbsp;union&nbsp;{&nbsp;//&nbsp;支持4种类型的值 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;*val;&nbsp;//&nbsp;字符串值，或二进制值 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;u64;&nbsp;//&nbsp;8字节无符号整数值 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int64_t&nbsp;s64;&nbsp;//&nbsp;8字节有符号整数值 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;double&nbsp;d;&nbsp;//&nbsp;双精度浮点值 &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;v; &nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;dictEntry&nbsp;*next;&nbsp;//&nbsp;下一节点，链地址冲突解决法 }&nbsp;dictEntry; </td> 
 </tr> 
 </tbody> 
</table>

# **4. Redis命令** #

各具体的命令并不做持久化（写AOF等）和传播给Slaves，这两项是公共操作，在上层统一执行，具体函数为server.c中的“void **call**(client \*c, int flags)”，具体执行函数为server.c中的“void **propagate**(struct redisCommand \*cmd, int dbid, robj \*\*argv, int argc, int flags)”。

## **4.1. SELECT命令** ##

群里有人问select跟普通命令的效率，猜想select没有效率问题，阅读源代码也证实了这一点。因为它只是改变指针指向，所以不存在效率问题，自然比普通命令效率要高。

Redis支持的所有命令，都存储在类型为redisCommand函数表中，函数表名为**redisCommandTable**的数组中。

### **4.1.1. redisCommand结构体** ###

如果以C++来理解redisCommand，可以将redisCommand看抽象基类，它定义了两个虚函数proc和getkeys\_proc，各种command是它的具体实现。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.h struct&nbsp;redisCommand&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*name;&nbsp;//&nbsp;命令名，比如：GET &nbsp;&nbsp;&nbsp;&nbsp;redisCommandProc&nbsp;*proc;&nbsp;//&nbsp;命令处理过程（函数指针） &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;命令参数的个数，用于检查命令请求的格式是否正确 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果这个值为负数-N，那么表示参数的数量大于等于N &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;注意：命令的名字本身也是一个参数。 &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;arity; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;字符串形式的标识值，&nbsp;这个值记录了命令的属性 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;比如是读命令还是写命令，是否允许在载入数据时使用，是否允许在&nbsp;Lua&nbsp;脚本中使用等 &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*sflags;&nbsp;/*&nbsp;Flags&nbsp;as&nbsp;string&nbsp;representation,&nbsp;one&nbsp;char&nbsp;per&nbsp;flag.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;sflags对应的二进制值，方便程序“与”、“或”等操作操作 &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;flags;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;The&nbsp;actual&nbsp;flags,&nbsp;obtained&nbsp;from&nbsp;the&nbsp;'sflags'&nbsp;field.&nbsp;*/ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Use&nbsp;a&nbsp;function&nbsp;to&nbsp;determine&nbsp;keys&nbsp;arguments&nbsp;in&nbsp;a&nbsp;command&nbsp;line. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;Used&nbsp;for&nbsp;Redis&nbsp;Cluster&nbsp;redirect.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;redisGetKeysProc&nbsp;*getkeys_proc;&nbsp;//&nbsp;函数指针 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;What&nbsp;keys&nbsp;should&nbsp;be&nbsp;loaded&nbsp;in&nbsp;background&nbsp;when&nbsp;calling&nbsp;this&nbsp;command?&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;firstkey;&nbsp;/*&nbsp;The&nbsp;first&nbsp;argument&nbsp;that's&nbsp;a&nbsp;key&nbsp;(0&nbsp;=&nbsp;no&nbsp;keys)&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;lastkey;&nbsp;&nbsp;/*&nbsp;The&nbsp;last&nbsp;argument&nbsp;that's&nbsp;a&nbsp;key&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;keystep;&nbsp;&nbsp;/*&nbsp;The&nbsp;step&nbsp;between&nbsp;first&nbsp;and&nbsp;last&nbsp;key&nbsp;*/ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;服务器执行这个命令所耗费的总时长 &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;microseconds;; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;服务器总共执行了多少次这个命令 &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;calls; }; </td> 
 </tr> 
 </tbody> 
</table>

### **4.1.2. redisCommandTable变量** ###

redisCommandTable的部分定义：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.c struct&nbsp;redisCommand&nbsp;redisCommandTable[]&nbsp;=&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;{"module",moduleCommand,-2,"as",0,NULL,0,0,0,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;{"get",getCommand,2,"rF",0,NULL,1,1,1,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;{"set",setCommand,-3,"wm",0,NULL,1,1,1,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;{"select",selectCommand,2,"lF",0,NULL,0,0,0,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;{"post",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;{"host:",securityWarningCommand,-1,"lt",0,NULL,0,0,0,0,0}, &nbsp;&nbsp;&nbsp;&nbsp;{"latency",latencyCommand,-2,"aslt",0,NULL,0,0,0,0,0} }; </td> 
 </tr> 
 </tbody> 
</table>

### **4.1.3. selectCommand函数** ###

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.c void&nbsp;selectCommand(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;id; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;第一个参数值为DB的ID &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(getLongFromObjectOrReply(c,&nbsp;c-&gt;argv[1],&nbsp;&amp;id, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"invalid&nbsp;DB&nbsp;index")&nbsp;!=&nbsp;C_OK) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;集群不支持SELECT命令 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.cluster_enabled&nbsp;&amp;&amp;&nbsp;id&nbsp;!=&nbsp;0)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyError(c,"SELECT&nbsp;is&nbsp;not&nbsp;allowed&nbsp;in&nbsp;cluster&nbsp;mode"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(selectDb(c,id)&nbsp;==&nbsp;C_ERR)&nbsp;{&nbsp;//&nbsp;切换DB &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyError(c,"DB&nbsp;index&nbsp;is&nbsp;out&nbsp;of&nbsp;range"); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,shared.ok); &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; //&nbsp;db.c int&nbsp;selectDb(client&nbsp;*c,&nbsp;int&nbsp;id)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(id&nbsp;&lt;&nbsp;0&nbsp;||&nbsp;id&nbsp;&gt;=&nbsp;server.dbnum)&nbsp;//&nbsp;dbnum值由redis.conf中的databases决定，默认为16 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_ERR; &nbsp;&nbsp;&nbsp;&nbsp;c-&gt;db&nbsp;=&nbsp;&amp;server.db[id]; &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; } </td> 
 </tr> 
 </tbody> 
</table>

## **4.2. SET命令** ##

SET命令主要是字典操作（**dict**）。

### **4.2.1. setCommand函数** ###

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;t_string.c /*&nbsp;SET&nbsp;key&nbsp;value&nbsp;[NX]&nbsp;[XX]&nbsp;[EX&nbsp;&lt;seconds&gt;]&nbsp;[PX&nbsp;&lt;milliseconds&gt;]&nbsp;*/ void&nbsp;setCommand(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;j; &nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;*expire&nbsp;=&nbsp;NULL; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;unit&nbsp;=&nbsp;UNIT_SECONDS; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;flags&nbsp;=&nbsp;OBJ_SET_NO_FLAGS; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;以下一长段均为参数选项解析， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;第一3个开始，因为第一个为命令SET自身，第二个为KEY，第三个为VALUE &nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(j&nbsp;=&nbsp;3;&nbsp;j&nbsp;&lt;&nbsp;c-&gt;argc;&nbsp;j++)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*a&nbsp;=&nbsp;c-&gt;argv[j]-&gt;ptr; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;*next&nbsp;=&nbsp;(j&nbsp;==&nbsp;c-&gt;argc-1)&nbsp;?&nbsp;NULL&nbsp;:&nbsp;c-&gt;argv[j+1]; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((a[0]&nbsp;==&nbsp;'n'&nbsp;||&nbsp;a[0]&nbsp;==&nbsp;'N')&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(a[1]&nbsp;==&nbsp;'x'&nbsp;||&nbsp;a[1]&nbsp;==&nbsp;'X')&nbsp;&amp;&amp;&nbsp;a[2]&nbsp;==&nbsp;'\0'&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(flags&nbsp;&amp;&nbsp;OBJ_SET_XX)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flags&nbsp;|=&nbsp;OBJ_SET_NX; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;if&nbsp;((a[0]&nbsp;==&nbsp;'x'&nbsp;||&nbsp;a[0]&nbsp;==&nbsp;'X')&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(a[1]&nbsp;==&nbsp;'x'&nbsp;||&nbsp;a[1]&nbsp;==&nbsp;'X')&nbsp;&amp;&amp;&nbsp;a[2]&nbsp;==&nbsp;'\0'&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(flags&nbsp;&amp;&nbsp;OBJ_SET_NX)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flags&nbsp;|=&nbsp;OBJ_SET_XX; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;if&nbsp;((a[0]&nbsp;==&nbsp;'e'&nbsp;||&nbsp;a[0]&nbsp;==&nbsp;'E')&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(a[1]&nbsp;==&nbsp;'x'&nbsp;||&nbsp;a[1]&nbsp;==&nbsp;'X')&nbsp;&amp;&amp;&nbsp;a[2]&nbsp;==&nbsp;'\0'&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(flags&nbsp;&amp;&nbsp;OBJ_SET_PX)&nbsp;&amp;&amp;&nbsp;next) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flags&nbsp;|=&nbsp;OBJ_SET_EX; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;unit&nbsp;=&nbsp;UNIT_SECONDS; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;expire&nbsp;=&nbsp;next; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;j++; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;if&nbsp;((a[0]&nbsp;==&nbsp;'p'&nbsp;||&nbsp;a[0]&nbsp;==&nbsp;'P')&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(a[1]&nbsp;==&nbsp;'x'&nbsp;||&nbsp;a[1]&nbsp;==&nbsp;'X')&nbsp;&amp;&amp;&nbsp;a[2]&nbsp;==&nbsp;'\0'&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(flags&nbsp;&amp;&nbsp;OBJ_SET_EX)&nbsp;&amp;&amp;&nbsp;next) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flags&nbsp;|=&nbsp;OBJ_SET_PX; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;unit&nbsp;=&nbsp;UNIT_MILLISECONDS; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;expire&nbsp;=&nbsp;next; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;j++; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,shared.syntaxerr);&nbsp;//&nbsp;语法错误 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;c-&gt;argv[2]&nbsp;=&nbsp;tryObjectEncoding(c-&gt;argv[2]); &nbsp;&nbsp;&nbsp;&nbsp;setGenericCommand(c,flags,c-&gt;argv[1],c-&gt;argv[2],expire,unit,NULL,NULL); } &nbsp; //&nbsp;t_string.c void&nbsp;setGenericCommand(client&nbsp;*c,&nbsp;int&nbsp;flags,&nbsp;robj&nbsp;*key,&nbsp;robj&nbsp;*val,&nbsp;robj&nbsp;*expire,&nbsp;int&nbsp;unit,&nbsp;robj&nbsp;*ok_reply,&nbsp;robj&nbsp;*abort_reply)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;setKey(c-&gt;db,key,val); &nbsp;&nbsp;&nbsp;&nbsp;server.dirty++; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(expire)&nbsp;setExpire(c,c-&gt;db,key,mstime()+milliseconds); &nbsp;&nbsp;&nbsp;&nbsp;notifyKeyspaceEvent(NOTIFY_STRING,"set",key,c-&gt;db-&gt;id); &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(expire)&nbsp;notifyKeyspaceEvent(NOTIFY_GENERIC,"expire",key,c-&gt;db-&gt;id); &nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;ok_reply&nbsp;?&nbsp;ok_reply&nbsp;:&nbsp;shared.ok); } &nbsp; //&nbsp;db.c void&nbsp;setKey(redisDb&nbsp;*db,&nbsp;robj&nbsp;*key,&nbsp;robj&nbsp;*val)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(lookupKeyWrite(db,key)&nbsp;==&nbsp;NULL)&nbsp;{&nbsp;//&nbsp;性能开销主要在这，参见dictFind函数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dbAdd(db,key,val); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dbOverwrite(db,key,val); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;incrRefCount(val); &nbsp;&nbsp;&nbsp;&nbsp;removeExpire(db,key); &nbsp;&nbsp;&nbsp;&nbsp;signalModifiedKey(db,key); } &nbsp; //&nbsp;db.c /*&nbsp;Add&nbsp;the&nbsp;key&nbsp;to&nbsp;the&nbsp;DB.&nbsp;It's&nbsp;up&nbsp;to&nbsp;the&nbsp;caller&nbsp;to&nbsp;increment&nbsp;the&nbsp;reference &nbsp;*&nbsp;counter&nbsp;of&nbsp;the&nbsp;value&nbsp;if&nbsp;needed. &nbsp;* &nbsp;*&nbsp;The&nbsp;program&nbsp;is&nbsp;aborted&nbsp;if&nbsp;the&nbsp;key&nbsp;already&nbsp;exists.&nbsp;*/ void&nbsp;dbAdd(redisDb&nbsp;*db,&nbsp;robj&nbsp;*key,&nbsp;robj&nbsp;*val)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;sds&nbsp;copy&nbsp;=&nbsp;sdsdup(key-&gt;ptr); &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;retval&nbsp;=&nbsp;dictAdd(db-&gt;dict,&nbsp;copy,&nbsp;val); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;serverAssertWithInfo(NULL,key,retval&nbsp;==&nbsp;DICT_OK); &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(val-&gt;type&nbsp;==&nbsp;OBJ_LIST&nbsp;|| &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;val-&gt;type&nbsp;==&nbsp;OBJ_ZSET) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;signalKeyAsReady(db,&nbsp;key); &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.cluster_enabled)&nbsp;slotToKeyAdd(key); } &nbsp; //&nbsp;dict.h #define&nbsp;dictSetVal(d,&nbsp;entry,&nbsp;_val_)&nbsp;do&nbsp;{&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((d)-&gt;type-&gt;valDup)&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(entry)-&gt;v.val&nbsp;=&nbsp;(d)-&gt;type-&gt;valDup((d)-&gt;privdata,&nbsp;_val_);&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;\ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(entry)-&gt;v.val&nbsp;=&nbsp;(_val_);&nbsp;\ }&nbsp;while(0) &nbsp; //&nbsp;db.c //&nbsp;KEY存在时覆盖写 /*&nbsp;Overwrite&nbsp;an&nbsp;existing&nbsp;key&nbsp;with&nbsp;a&nbsp;new&nbsp;value.&nbsp;Incrementing&nbsp;the&nbsp;reference &nbsp;*&nbsp;count&nbsp;of&nbsp;the&nbsp;new&nbsp;value&nbsp;is&nbsp;up&nbsp;to&nbsp;the&nbsp;caller. &nbsp;*&nbsp;This&nbsp;function&nbsp;does&nbsp;not&nbsp;modify&nbsp;the&nbsp;expire&nbsp;time&nbsp;of&nbsp;the&nbsp;existing&nbsp;key. &nbsp;* &nbsp;*&nbsp;The&nbsp;program&nbsp;is&nbsp;aborted&nbsp;if&nbsp;the&nbsp;key&nbsp;was&nbsp;not&nbsp;already&nbsp;present.&nbsp;*/ void&nbsp;dbOverwrite(redisDb&nbsp;*db,&nbsp;robj&nbsp;*key,&nbsp;robj&nbsp;*val)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;dictEntry&nbsp;*de&nbsp;=&nbsp;dictFind(db-&gt;dict,key-&gt;ptr); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;serverAssertWithInfo(NULL,key,de&nbsp;!=&nbsp;NULL); &nbsp;&nbsp;&nbsp;&nbsp;dictEntry&nbsp;auxentry&nbsp;=&nbsp;*de; &nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;*old&nbsp;=&nbsp;dictGetVal(de); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;内存策略由redis.conf中的maxmemory-policy决定 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;LFU策略是4.0开始引入的（Least&nbsp;Frequently&nbsp;Used，最不经常使用） &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_FLAG_LRU&nbsp;(1&lt;&lt;0) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_FLAG_LFU&nbsp;(1&lt;&lt;1) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_FLAG_ALLKEYS&nbsp;(1&lt;&lt;2) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_FLAG_NO_SHARED_INTEGERS&nbsp;(MAXMEMORY_FLAG_LRU|MAXMEMORY_FLAG_LFU) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_VOLATILE_LRU&nbsp;((0&lt;&lt;8)|MAXMEMORY_FLAG_LRU) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_VOLATILE_LFU&nbsp;((1&lt;&lt;8)|MAXMEMORY_FLAG_LFU) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_VOLATILE_TTL&nbsp;(2&lt;&lt;8) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_VOLATILE_RANDOM&nbsp;(3&lt;&lt;8) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_ALLKEYS_LRU&nbsp;((4&lt;&lt;8)|MAXMEMORY_FLAG_LRU|MAXMEMORY_FLAG_ALLKEYS) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_ALLKEYS_LFU&nbsp;((5&lt;&lt;8)|MAXMEMORY_FLAG_LFU|MAXMEMORY_FLAG_ALLKEYS) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_ALLKEYS_RANDOM&nbsp;((6&lt;&lt;8)|MAXMEMORY_FLAG_ALLKEYS) &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;MAXMEMORY_NO_EVICTION&nbsp;(7&lt;&lt;8) &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.maxmemory_policy&nbsp;&amp;&nbsp;MAXMEMORY_FLAG_LFU)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;val-&gt;lru&nbsp;=&nbsp;old-&gt;lru; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;dictSetVal(db-&gt;dict,&nbsp;de,&nbsp;val); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.lazyfree_lazy_server_del)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;freeObjAsync(old); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dictSetVal(db-&gt;dict,&nbsp;&amp;auxentry,&nbsp;NULL); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;dictFreeVal(db-&gt;dict,&nbsp;&amp;auxentry); } </td> 
 </tr> 
 </tbody> 
</table>

### **4.2.2. dictAdd函数** ###

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;dict.c //&nbsp;KEY不存在时新增 /*&nbsp;Add&nbsp;an&nbsp;element&nbsp;to&nbsp;the&nbsp;target&nbsp;hash&nbsp;table&nbsp;*/ int&nbsp;dictAdd(dict&nbsp;*d,&nbsp;void&nbsp;*key,&nbsp;void&nbsp;*val) { &nbsp;&nbsp;&nbsp;&nbsp;dictEntry&nbsp;*entry&nbsp;=&nbsp;dictAddRaw(d,key,NULL); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!entry)&nbsp;return&nbsp;DICT_ERR; &nbsp;&nbsp;&nbsp;&nbsp;dictSetVal(d,&nbsp;entry,&nbsp;val); &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;DICT_OK; } </td> 
 </tr> 
 </tbody> 
</table>

### **4.2.3. dictFind函数** ###

字典查找实现：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> dictEntry&nbsp;*dictFind(dict&nbsp;*d,&nbsp;const&nbsp;void&nbsp;*key) { &nbsp;&nbsp;&nbsp;&nbsp;dictEntry&nbsp;*he; &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;h,&nbsp;idx,&nbsp;table; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(d-&gt;ht[0].used&nbsp;+&nbsp;d-&gt;ht[1].used&nbsp;==&nbsp;0)&nbsp;return&nbsp;NULL;&nbsp;/*&nbsp;dict&nbsp;is&nbsp;empty&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(dictIsRehashing(d))&nbsp;_dictRehashStep(d); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;#define&nbsp;dictHashKey(d,&nbsp;key)&nbsp;(d)-&gt;type-&gt;hashFunction(key) &nbsp;&nbsp;&nbsp;&nbsp;h&nbsp;=&nbsp;dictHashKey(d,&nbsp;key);&nbsp;//&nbsp;对key求哈希值 &nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(table&nbsp;=&nbsp;0;&nbsp;table&nbsp;&lt;=&nbsp;1;&nbsp;table++)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;idx&nbsp;=&nbsp;h&nbsp;&amp;&nbsp;d-&gt;ht[table].sizemask; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;he&nbsp;=&nbsp;d-&gt;ht[table].table[idx]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;while(he)&nbsp;{&nbsp;//&nbsp;链式冲突解决法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(key==he-&gt;key&nbsp;||&nbsp;dictCompareKeys(d,&nbsp;key,&nbsp;he-&gt;key)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;he; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;he&nbsp;=&nbsp;he-&gt;next; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!dictIsRehashing(d))&nbsp;return&nbsp;NULL;&nbsp;//&nbsp;重哈希 &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;NULL; } &nbsp; typedef&nbsp;struct&nbsp;dictType&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;(*hashFunction)(const&nbsp;void&nbsp;*key); &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;*(*keyDup)(void&nbsp;*privdata,&nbsp;const&nbsp;void&nbsp;*key); &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;*(*valDup)(void&nbsp;*privdata,&nbsp;const&nbsp;void&nbsp;*obj); &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;(*keyCompare)(void&nbsp;*privdata,&nbsp;const&nbsp;void&nbsp;*key1,&nbsp;const&nbsp;void&nbsp;*key2); &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;(*keyDestructor)(void&nbsp;*privdata,&nbsp;void&nbsp;*key); &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;(*valDestructor)(void&nbsp;*privdata,&nbsp;void&nbsp;*obj); }&nbsp;dictType; </td> 
 </tr> 
 </tbody> 
</table>

## **4.3. HSETNX命令** ##

### **4.3.1. hsetnxCommand函数** ###

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;t_hash.c void&nbsp;hsetnxCommand(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;*o; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((o&nbsp;=&nbsp;hashTypeLookupWriteOrCreate(c,c-&gt;argv[1]))&nbsp;==&nbsp;NULL)&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;hashTypeTryConversion(o,c-&gt;argv,2,3); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(hashTypeExists(o,&nbsp;c-&gt;argv[2]-&gt;ptr))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.czero); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;hashTypeSet(o,c-&gt;argv[2]-&gt;ptr,c-&gt;argv[3]-&gt;ptr,HASH_SET_COPY); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.cone); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;signalModifiedKey(c-&gt;db,c-&gt;argv[1]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;notifyKeyspaceEvent(NOTIFY_HASH,"hset",c-&gt;argv[1],c-&gt;db-&gt;id); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.dirty++; &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

### **4.3.2. hashTypeSet函数** ###

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;t_hash.c int&nbsp;hashTypeSet(robj&nbsp;*o,&nbsp;sds&nbsp;field,&nbsp;sds&nbsp;value,&nbsp;int&nbsp;flags)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(o-&gt;encoding&nbsp;==&nbsp;OBJ_ENCODING_ZIPLIST)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;ziplistInsert &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;ziplistPush &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;if&nbsp;(o-&gt;encoding&nbsp;==&nbsp;OBJ_ENCODING_HT)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dictAdd(o-&gt;ptr,f,v); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverPanic("Unknown&nbsp;hash&nbsp;encoding"); &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

# **5. Redis多路复用机制** #

## **5.1. AE是什么？** ##

“AE”为“**A** simple **e**vent-driven programming library”的缩写，翻译成中文，即**一个简单的事件驱动编程库**。就Linux而言，可简单理解为对epoll的封装。

## **5.2. 多路复用选择aeApiPoll** ##

Redis支持select、epoll、kqueue和evport四种模式，编译Redis时决定采用哪一种，因此运行时只会有一种有效。优先顺序是：evport -> epoll -> kqueue -> select，其中select为兜底用，因为所有系统都会支持select。

对应的源码文件，分别为：

<table style="width:426.2pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:59.5pt;"> evport </td> 
 <td style="vertical-align:top;width:172.1pt;"> ae_evport.c </td> 
 <td style="vertical-align:top;width:194.6pt;"> Solaris </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:59.5pt;"> epoll </td> 
 <td style="vertical-align:top;width:172.1pt;"> ae_epoll.c </td> 
 <td style="vertical-align:top;width:194.6pt;"> Linux系统 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:59.5pt;"> kqueue </td> 
 <td style="vertical-align:top;width:172.1pt;"> ae_kqueue.c </td> 
 <td style="vertical-align:top;width:194.6pt;"> BSD类系统 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:59.5pt;"> select </td> 
 <td style="vertical-align:top;width:172.1pt;"> ae_select.c </td> 
 <td style="vertical-align:top;width:194.6pt;"> 其它不支持epoll、evport和kqueue系统 </td> 
 </tr> 
 </tbody> 
</table>

桥接它们的文件则是**ae.c**，桥接代码：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;Include&nbsp;the&nbsp;best&nbsp;multiplexing&nbsp;layer&nbsp;supported&nbsp;by&nbsp;this&nbsp;system. &nbsp;*&nbsp;The&nbsp;following&nbsp;should&nbsp;be&nbsp;ordered&nbsp;by&nbsp;performances,&nbsp;descending.&nbsp;*/ #ifdef&nbsp;HAVE_EVPORT #include&nbsp;"ae_evport.c" #else &nbsp;&nbsp;&nbsp;&nbsp;#ifdef&nbsp;HAVE_EPOLL &nbsp;&nbsp;&nbsp;&nbsp;#include&nbsp;"ae_epoll.c" &nbsp;&nbsp;&nbsp;&nbsp;#else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;#ifdef&nbsp;HAVE_KQUEUE &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;#include&nbsp;"ae_kqueue.c" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;#else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;#include&nbsp;"ae_select.c" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;#endif &nbsp;&nbsp;&nbsp;&nbsp;#endif #endif </td> 
 </tr> 
 </tbody> 
</table>

宏HAVE\_EVPORT、HAVE\_EPOLL、HAVE\_KQUEUE则在config.h中决议出：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> #ifdef&nbsp;__sun #include&nbsp;&lt;sys/feature_tests.h&gt; #ifdef&nbsp;_DTRACE_VERSION #define&nbsp;HAVE_EVPORT&nbsp;1 #endif #endif &nbsp; #ifdef&nbsp;__linux__ #define&nbsp;HAVE_EPOLL&nbsp;1 #endif &nbsp; #if&nbsp;(defined(__APPLE__)&nbsp;&amp;&amp;&nbsp;defined(MAC_OS_X_VERSION_10_6))&nbsp;||&nbsp;defined(__FreeBSD__)&nbsp;||&nbsp;defined(__OpenBSD__)&nbsp;||&nbsp;defined&nbsp;(__NetBSD__) #define&nbsp;HAVE_KQUEUE&nbsp;1 #endif </td> 
 </tr> 
 </tbody> 
</table>

## **5.3. 多路复用调用aeCreateFileEvent** ##

自main函数开始的调用过程（读事件和写事件的顺序，作者在这里用了个小技巧，支持优先响应是查询，即立即返回查询结果）：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> int&nbsp;main(int&nbsp;argc,&nbsp;char&nbsp;**argv)&nbsp;{&nbsp;//&nbsp;server.c &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;aeMain(server.el); &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;aeMain(aeEventLoop&nbsp;*eventLoop)&nbsp;//&nbsp;ae.c &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;(!eventLoop-&gt;stop)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(eventLoop-&gt;beforesleep&nbsp;!=&nbsp;NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventLoop-&gt;beforesleep(eventLoop);&nbsp;//&nbsp;这很重要，写AOF文件在这里进行 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;aeProcessEvents(eventLoop,&nbsp;AE_ALL_EVENTS|AE_CALL_AFTER_SLEEP); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;aeProcessEvents(aeEventLoop&nbsp;*eventLoop,&nbsp;int&nbsp;flags)&nbsp;{&nbsp;//&nbsp;ae.c &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;linux实际调用的是ae_epoll.c中的aeApiPoll函数 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;numevents&nbsp;=&nbsp;aeApiPoll(eventLoop,&nbsp;tvp); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(eventLoop-&gt;aftersleep&nbsp;!=&nbsp;NULL&nbsp;&amp;&amp;&nbsp;flags&nbsp;&amp;&nbsp;AE_CALL_AFTER_SLEEP) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventLoop-&gt;aftersleep(eventLoop); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(j&nbsp;=&nbsp;0;&nbsp;j&nbsp;&lt;&nbsp;numevents;&nbsp;j++)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;一般优先处理读事件，然后再写事件，但有时为立即响应是查询则写优先 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Normally&nbsp;we&nbsp;execute&nbsp;the&nbsp;readable&nbsp;event&nbsp;first,&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;and&nbsp;the&nbsp;writable&nbsp;event&nbsp;laster.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;invert&nbsp;=&nbsp;fe-&gt;mask&nbsp;&amp;&nbsp;AE_BARRIER; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Fire&nbsp;the&nbsp;readable&nbsp;event&nbsp;if&nbsp;the&nbsp;call&nbsp;sequence&nbsp;is&nbsp;not&nbsp;inverted.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fe-&gt;rfileProc(eventLoop,fd,fe-&gt;clientData,mask); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Fire&nbsp;the&nbsp;writable&nbsp;event.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fe-&gt;wfileProc(eventLoop,fd,fe-&gt;clientData,mask); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;If&nbsp;we&nbsp;have&nbsp;to&nbsp;invert&nbsp;the&nbsp;call,&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fire&nbsp;the&nbsp;readable&nbsp;event&nbsp;now&nbsp;after&nbsp;the&nbsp;writable&nbsp;one.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fe-&gt;rfileProc(eventLoop,fd,fe-&gt;clientData,mask); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;函数aeCreateFileEvent中设置rfileProc和wfileProc &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;rfileProc和wfileProc的初始化均在aeCreateFileEvent中完成 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } &nbsp; //&nbsp;初始化rfileProc和wfileProc int&nbsp;aeCreateFileEvent(aeEventLoop&nbsp;*eventLoop,&nbsp;int&nbsp;fd,&nbsp;int&nbsp;mask, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;aeFileProc&nbsp;*proc,&nbsp;void&nbsp;*clientData) { &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(fd&nbsp;&gt;=&nbsp;eventLoop-&gt;setsize)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;errno&nbsp;=&nbsp;ERANGE; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;AE_ERR; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;aeFileEvent&nbsp;*fe&nbsp;=&nbsp;&amp;eventLoop-&gt;events[fd];&nbsp;//&nbsp;events是一个以fd为下标的数组，0查找 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(aeApiAddEvent(eventLoop,&nbsp;fd,&nbsp;mask)&nbsp;==&nbsp;-1)&nbsp;//&nbsp;fd放到epoll或select等中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;AE_ERR; &nbsp;&nbsp;&nbsp;&nbsp;fe-&gt;mask&nbsp;|=&nbsp;mask;&nbsp;//&nbsp;读写事件 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mask&nbsp;&amp;&nbsp;AE_READABLE)&nbsp;fe-&gt;rfileProc&nbsp;=&nbsp;proc; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(mask&nbsp;&amp;&nbsp;AE_WRITABLE)&nbsp;fe-&gt;wfileProc&nbsp;=&nbsp;proc; &nbsp;&nbsp;&nbsp;&nbsp;fe-&gt;clientData&nbsp;=&nbsp;clientData;&nbsp;//&nbsp;附加数据 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(fd&nbsp;&gt;&nbsp;eventLoop-&gt;maxfd) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventLoop-&gt;maxfd&nbsp;=&nbsp;fd;&nbsp;//&nbsp;这个主要给select时用，epoll等不需要 &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;AE_OK; } </td> 
 </tr> 
 </tbody> 
</table>

# **6. 网络收发过程** #

## **6.1. 过程简要** ##

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> main -&gt;&nbsp;initServer -&gt;&nbsp;aeCreateFileEvent(acceptTcpHandler) -&gt;&nbsp;createClient -&gt;&nbsp;aeCreateFileEvent(readQueryFromClient) -&gt;&nbsp;read -&gt;&nbsp;processCommand -&gt;&nbsp;lookupCommand -&gt;&nbsp;call(c,CMD_CALL_FULL)&nbsp;//&nbsp;call在调用proc后，会调用propagate函数将命令传播给AOF和Slaves -&gt;&nbsp;c-&gt;cmd-&gt;proc(c)&nbsp;//&nbsp;这个proc就是各种redis命令处理过程，比如：setCommand、hgetCommand等 </td> 
 </tr> 
 </tbody> 
</table>

## **6.2. 接受连接请求acceptTcpHandler** ##

在main函数中，会为accept注册一个事件**acceptTcpHandler**：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.c int&nbsp;main(int&nbsp;argc,&nbsp;char&nbsp;**argv)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;initServer(void)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;支持多个IP，即redis.conf中可以bind多个IP &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(j&nbsp;=&nbsp;0;&nbsp;j&nbsp;&lt;&nbsp;server.ipfd_count;&nbsp;j++)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(aeCreateFileEvent(server.el,&nbsp;server.ipfd[j],&nbsp;//&nbsp;以读事件方式加入到epoll中 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AE_READABLE,&nbsp;acceptTcpHandler,&nbsp;NULL)&nbsp;==&nbsp;AE_ERR) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverPanic("Unrecoverable&nbsp;error&nbsp;creating&nbsp;server.ipfd&nbsp;file&nbsp;event."); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; //&nbsp;networking.c void&nbsp;acceptTcpHandler(aeEventLoop&nbsp;*el,&nbsp;int&nbsp;fd,&nbsp;void&nbsp;*privdata,&nbsp;int&nbsp;mask)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;cport,&nbsp;cfd,&nbsp;max&nbsp;=&nbsp;MAX_ACCEPTS_PER_CALL; &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;cip[NET_IP_STR_LEN]; &nbsp;&nbsp;&nbsp;&nbsp;UNUSED(el); &nbsp;&nbsp;&nbsp;&nbsp;UNUSED(mask); &nbsp;&nbsp;&nbsp;&nbsp;UNUSED(privdata); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;一次性连接接受max个连接，以提升效率 &nbsp;&nbsp;&nbsp;&nbsp;while(max--)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;anetTcpAccept处理了中断ENTR，方式是重试到成功或出错 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cfd&nbsp;=&nbsp;anetTcpAccept(server.neterr,&nbsp;fd,&nbsp;cip,&nbsp;sizeof(cip),&nbsp;&amp;cport); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(cfd&nbsp;==&nbsp;ANET_ERR)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(errno&nbsp;!=&nbsp;EWOULDBLOCK)&nbsp;//&nbsp;EWOULDBLOCK是正常的 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_WARNING, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"Accepting&nbsp;client&nbsp;connection:&nbsp;%s",&nbsp;server.neterr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_VERBOSE,"Accepted&nbsp;%s:%d",&nbsp;cip,&nbsp;cport); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptCommonHandler(cfd,0,cip); &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; //&nbsp;networking.c static&nbsp;void&nbsp;acceptCommonHandler(int&nbsp;fd,&nbsp;int&nbsp;flags,&nbsp;char&nbsp;*ip)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;client&nbsp;*c; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;createClient为aceeptCommonHandler调用的核心函数 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;在createClient中会为fd关联读事件过程，并加入到epoll中 &nbsp;&nbsp;&nbsp;&nbsp;c&nbsp;=&nbsp;createClient(fd); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;控制连接数不超过redis.conf上配置的最大数 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(listLength(server.clients)&nbsp;&gt;&nbsp;server.maxclients)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*err&nbsp;=&nbsp;"-ERR&nbsp;max&nbsp;number&nbsp;of&nbsp;clients&nbsp;reached\r\n"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;That's&nbsp;a&nbsp;best&nbsp;effort&nbsp;error&nbsp;message,&nbsp;don't&nbsp;check&nbsp;write&nbsp;errors&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(write(c-&gt;fd,err,strlen(err))&nbsp;==&nbsp;-1)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Nothing&nbsp;to&nbsp;do,&nbsp;Just&nbsp;to&nbsp;avoid&nbsp;the&nbsp;warning...&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.stat_rejected_conn++;&nbsp;//&nbsp;被拒绝的连接数增一 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;freeClient(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;保护模式处理 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.protected_mode&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.bindaddr_count&nbsp;==&nbsp;0&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.requirepass&nbsp;==&nbsp;NULL&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(flags&nbsp;&amp;&nbsp;CLIENT_UNIX_SOCKET)&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ip&nbsp;!=&nbsp;NULL) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;保护模式下，只允许127.0.0.1连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(strcmp(ip,"127.0.0.1")&nbsp;&amp;&amp;&nbsp;strcmp(ip,"::1"))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*err&nbsp;=&nbsp;"-DENIED&nbsp;Redis&nbsp;is&nbsp;running&nbsp;in&nbsp;protected&nbsp;mode&nbsp;because&nbsp;protected。。。。。。"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(write(c-&gt;fd,err,strlen(err))&nbsp;==&nbsp;-1)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Nothing&nbsp;to&nbsp;do,&nbsp;Just&nbsp;to&nbsp;avoid&nbsp;the&nbsp;warning...&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.stat_rejected_conn++;&nbsp;//&nbsp;被拒绝的连接数增一 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;freeClient(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;server.stat_numconnections++;&nbsp;//&nbsp;当前连接数增一 &nbsp;&nbsp;&nbsp;&nbsp;c-&gt;flags&nbsp;|=&nbsp;flags; } </td> 
 </tr> 
 </tbody> 
</table>

## **6.3. 创建client对象createClient** ##

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;networking.c client&nbsp;*createClient(int&nbsp;fd)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;client&nbsp;*c&nbsp;=&nbsp;zmalloc(sizeof(client)); &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果redis.conf中开启了tcpkeepalive，配置项名tcp-keepalive，单位：秒 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.tcpkeepalive) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;anetKeepAlive(NULL,fd,server.tcpkeepalive); &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;注册c到epoll，并关联readQueryFromClient，事件为读事件AE_READABLE &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(aeCreateFileEvent(server.el,fd,AE_READABLE,&nbsp;readQueryFromClient,&nbsp;c)&nbsp;==&nbsp;AE_ERR) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(fd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;zfree(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;NULL; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;selectDb(c,0);&nbsp;//&nbsp;默认选择第1个DB，调用者需要执行select命令切换 &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } </td> 
 </tr> 
 </tbody> 
</table>

## **6.4. 读取命令readQueryFromClient** ##

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;networking.c void&nbsp;readQueryFromClient(aeEventLoop&nbsp;*el,&nbsp;int&nbsp;fd,&nbsp;void&nbsp;*privdata,&nbsp;int&nbsp;mask)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;client&nbsp;*c&nbsp;=&nbsp;(client*)privdata; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;nread&nbsp;=&nbsp;read(fd,&nbsp;c-&gt;querybuf+qblen,&nbsp;readlen); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;processInputBufferAndReplicate(c); } &nbsp; /*&nbsp;This&nbsp;is&nbsp;a&nbsp;wrapper&nbsp;for&nbsp;processInputBuffer&nbsp;that&nbsp;also&nbsp;cares&nbsp;about&nbsp;handling &nbsp;*&nbsp;the&nbsp;replication&nbsp;forwarding&nbsp;to&nbsp;the&nbsp;sub-slaves,&nbsp;in&nbsp;case&nbsp;the&nbsp;client&nbsp;'c' &nbsp;*&nbsp;is&nbsp;flagged&nbsp;as&nbsp;master.&nbsp;Usually&nbsp;you&nbsp;want&nbsp;to&nbsp;call&nbsp;this&nbsp;instead&nbsp;of&nbsp;the &nbsp;*&nbsp;raw&nbsp;processInputBuffer().&nbsp;*/ void&nbsp;processInputBufferAndReplicate(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_MASTER))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processInputBuffer(c);&nbsp;//&nbsp;处理命令 &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;prev_offset&nbsp;=&nbsp;c-&gt;reploff; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processInputBuffer(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;applied&nbsp;=&nbsp;c-&gt;reploff&nbsp;-&nbsp;prev_offset; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(applied)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;处理主从复制 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;replicationFeedSlavesFromMasterStream(server.slaves, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;pending_querybuf,&nbsp;applied); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sdsrange(c-&gt;pending_querybuf,applied,-1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

## **6.5. 命令处理processCommand** ##

processInputBuffer调用processCommand，大量逻辑在processCommand中：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;networking.c /*&nbsp;If&nbsp;this&nbsp;function&nbsp;gets&nbsp;called&nbsp;we&nbsp;already&nbsp;read&nbsp;a&nbsp;whole &nbsp;*&nbsp;command,&nbsp;arguments&nbsp;are&nbsp;in&nbsp;the&nbsp;client&nbsp;argv/argc&nbsp;fields. &nbsp;*&nbsp;processCommand()&nbsp;execute&nbsp;the&nbsp;command&nbsp;or&nbsp;prepare&nbsp;the &nbsp;*&nbsp;server&nbsp;for&nbsp;a&nbsp;bulk&nbsp;read&nbsp;from&nbsp;the&nbsp;client. &nbsp;* &nbsp;*&nbsp;If&nbsp;C_OK&nbsp;is&nbsp;returned&nbsp;the&nbsp;client&nbsp;is&nbsp;still&nbsp;alive&nbsp;and&nbsp;valid&nbsp;and &nbsp;*&nbsp;other&nbsp;operations&nbsp;can&nbsp;be&nbsp;performed&nbsp;by&nbsp;the&nbsp;caller.&nbsp;Otherwise &nbsp;*&nbsp;if&nbsp;C_ERR&nbsp;is&nbsp;returned&nbsp;the&nbsp;client&nbsp;was&nbsp;destroyed&nbsp;(i.e.&nbsp;after&nbsp;QUIT).&nbsp;*/ void&nbsp;processInputBuffer(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;server.current_client&nbsp;=&nbsp;c; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;processCommand(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;单独处理QUIT命令 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;The&nbsp;QUIT&nbsp;command&nbsp;is&nbsp;handled&nbsp;separately.&nbsp;Normal&nbsp;command&nbsp;procs&nbsp;will &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;go&nbsp;through&nbsp;checking&nbsp;for&nbsp;replication&nbsp;and&nbsp;QUIT&nbsp;will&nbsp;cause&nbsp;trouble &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;when&nbsp;FORCE_REPLICATION&nbsp;is&nbsp;enabled&nbsp;and&nbsp;would&nbsp;be&nbsp;implemented&nbsp;in &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;a&nbsp;regular&nbsp;command&nbsp;proc.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!strcasecmp(c-&gt;argv[0]-&gt;ptr,"quit"))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,shared.ok); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;flags&nbsp;|=&nbsp;CLIENT_CLOSE_AFTER_REPLY; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_ERR; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;查找命令的处理 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Now&nbsp;lookup&nbsp;the&nbsp;command&nbsp;and&nbsp;check&nbsp;ASAP&nbsp;about&nbsp;trivial&nbsp;error&nbsp;conditions &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;such&nbsp;as&nbsp;wrong&nbsp;arity,&nbsp;bad&nbsp;command&nbsp;name&nbsp;and&nbsp;so&nbsp;forth.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd&nbsp;=&nbsp;c-&gt;lastcmd&nbsp;=&nbsp;lookupCommand(c-&gt;argv[0]-&gt;ptr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!c-&gt;cmd)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyErrorFormat(c,"unknown&nbsp;command&nbsp;`%s`,&nbsp;with&nbsp;args&nbsp;beginning&nbsp;with:&nbsp;%s",。。。); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sdsfree(args); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;((c-&gt;cmd-&gt;arity&nbsp;&gt;&nbsp;0&nbsp;&amp;&amp;&nbsp;c-&gt;cmd-&gt;arity&nbsp;!=&nbsp;c-&gt;argc)&nbsp;|| &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(c-&gt;argc&nbsp;&lt;&nbsp;-c-&gt;cmd-&gt;arity))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;参数个数不对 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyErrorFormat(c,"wrong&nbsp;number&nbsp;of&nbsp;arguments&nbsp;for&nbsp;'%s'&nbsp;command",&nbsp;c-&gt;cmd-&gt;name); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Check&nbsp;if&nbsp;the&nbsp;user&nbsp;is&nbsp;authenticated&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.requirepass&nbsp;&amp;&amp;&nbsp;!c-&gt;authenticated&nbsp;&amp;&amp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;authCommand)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;检查是否有设置密码，和密码是否已经验证通过 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,shared.noautherr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;检查是否需要重定向 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;If&nbsp;cluster&nbsp;is&nbsp;enabled&nbsp;perform&nbsp;the&nbsp;cluster&nbsp;redirection&nbsp;here. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;However&nbsp;we&nbsp;don't&nbsp;perform&nbsp;the&nbsp;redirection&nbsp;if: &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;1)&nbsp;The&nbsp;sender&nbsp;of&nbsp;this&nbsp;command&nbsp;is&nbsp;our&nbsp;master. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;2)&nbsp;The&nbsp;command&nbsp;has&nbsp;no&nbsp;key&nbsp;arguments.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.cluster_enabled&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_MASTER)&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_LUA&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.lua_caller-&gt;flags&nbsp;&amp;&nbsp;CLIENT_MASTER)&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;cmd-&gt;getkeys_proc&nbsp;==&nbsp;NULL&nbsp;&amp;&amp;&nbsp;c-&gt;cmd-&gt;firstkey&nbsp;==&nbsp;0&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;execCommand))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(n&nbsp;==&nbsp;NULL&nbsp;||&nbsp;n&nbsp;!=&nbsp;server.cluster-&gt;myself)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(c-&gt;cmd-&gt;proc&nbsp;==&nbsp;execCommand)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;discardTransaction(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flagTransaction(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;clusterRedirectClient(c,n,hashslot,error_code); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;检查最大内存，如果超过配置的maxmemory， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;则返回错误“-OOM&nbsp;command&nbsp;not&nbsp;allowed&nbsp;when&nbsp;used&nbsp;memory&nbsp;&gt;&nbsp;'maxmemory'.” &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Handle&nbsp;the&nbsp;maxmemory&nbsp;directive. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;First&nbsp;we&nbsp;try&nbsp;to&nbsp;free&nbsp;some&nbsp;memory&nbsp;if&nbsp;possible&nbsp;(if&nbsp;there&nbsp;are&nbsp;volatile &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;keys&nbsp;in&nbsp;the&nbsp;dataset).&nbsp;If&nbsp;there&nbsp;are&nbsp;not&nbsp;the&nbsp;only&nbsp;thing&nbsp;we&nbsp;can&nbsp;do &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;is&nbsp;returning&nbsp;an&nbsp;error. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;Note&nbsp;that&nbsp;we&nbsp;do&nbsp;not&nbsp;want&nbsp;to&nbsp;reclaim&nbsp;memory&nbsp;if&nbsp;we&nbsp;are&nbsp;here&nbsp;re-entering &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;the&nbsp;event&nbsp;loop&nbsp;since&nbsp;there&nbsp;is&nbsp;a&nbsp;busy&nbsp;Lua&nbsp;script&nbsp;running&nbsp;in&nbsp;timeout &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;condition,&nbsp;to&nbsp;avoid&nbsp;mixing&nbsp;the&nbsp;propagation&nbsp;of&nbsp;scripts&nbsp;with&nbsp;the&nbsp;propagation &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;of&nbsp;DELs&nbsp;due&nbsp;to&nbsp;eviction.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.maxmemory&nbsp;&amp;&amp;&nbsp;!server.lua_timedout)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;It&nbsp;was&nbsp;impossible&nbsp;to&nbsp;free&nbsp;enough&nbsp;memory,&nbsp;and&nbsp;the&nbsp;command&nbsp;the&nbsp;client &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;is&nbsp;trying&nbsp;to&nbsp;execute&nbsp;is&nbsp;denied&nbsp;during&nbsp;OOM&nbsp;conditions?&nbsp;Error.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;((c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_DENYOOM)&nbsp;&amp;&amp;&nbsp;out_of_memory)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.oomerr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;磁盘有问题不接受写请求 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Don't&nbsp;accept&nbsp;write&nbsp;commands&nbsp;if&nbsp;there&nbsp;are&nbsp;problems&nbsp;persisting&nbsp;on&nbsp;disk &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;and&nbsp;if&nbsp;this&nbsp;is&nbsp;a&nbsp;master&nbsp;instance.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;deny_write_type&nbsp;=&nbsp;writeCommandsDeniedByDiskError(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(deny_write_type&nbsp;!=&nbsp;DISK_ERROR_TYPE_NONE&nbsp;&amp;&amp;&nbsp;server.masterhost&nbsp;==&nbsp;NULL&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_WRITE&nbsp;||&nbsp;c-&gt;cmd-&gt;proc&nbsp;==&nbsp;pingCommand))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(deny_write_type&nbsp;==&nbsp;DISK_ERROR_TYPE_RDB) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.bgsaveerr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;else &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplySds(c,&nbsp;sdscatprintf(sdsempty(), &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"-MISCONF&nbsp;Errors&nbsp;writing&nbsp;to&nbsp;the&nbsp;AOF&nbsp;file:&nbsp;%s\r\n", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;strerror(server.aof_last_write_errno))); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;不接受写请求，如果没有足够多好的slave &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Don't&nbsp;accept&nbsp;write&nbsp;commands&nbsp;if&nbsp;there&nbsp;are&nbsp;not&nbsp;enough&nbsp;good&nbsp;slaves&nbsp;and &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;user&nbsp;configured&nbsp;the&nbsp;min-slaves-to-write&nbsp;option.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.masterhost&nbsp;==&nbsp;NULL&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.repl_min_slaves_to_write&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.repl_min_slaves_max_lag&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_WRITE&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.repl_good_slaves_count&nbsp;&lt;&nbsp;server.repl_min_slaves_to_write)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.noreplicaserr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;只读的slave不接受写请求 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Don't&nbsp;accept&nbsp;write&nbsp;commands&nbsp;if&nbsp;this&nbsp;is&nbsp;a&nbsp;read&nbsp;only&nbsp;slave.&nbsp;But &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;accept&nbsp;write&nbsp;commands&nbsp;if&nbsp;this&nbsp;is&nbsp;our&nbsp;master.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.masterhost&nbsp;&amp;&amp;&nbsp;server.repl_slave_ro&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_MASTER)&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_WRITE) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.roslaveerr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;只接受SUB、UNSUB、PSUB、PUNSUB和PING命令 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Only&nbsp;allow&nbsp;SUBSCRIBE&nbsp;and&nbsp;UNSUBSCRIBE&nbsp;in&nbsp;the&nbsp;context&nbsp;of&nbsp;Pub/Sub&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_PUBSUB&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;pingCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;subscribeCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;unsubscribeCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;psubscribeCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;punsubscribeCommand)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyError(c,"only&nbsp;(P)SUBSCRIBE&nbsp;/&nbsp;(P)UNSUBSCRIBE&nbsp;/&nbsp;PING&nbsp;/&nbsp;QUIT&nbsp;allowed&nbsp;in&nbsp;this&nbsp;context"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Only&nbsp;allow&nbsp;commands&nbsp;with&nbsp;flag&nbsp;"t",&nbsp;such&nbsp;as&nbsp;INFO,&nbsp;SLAVEOF&nbsp;and&nbsp;so&nbsp;on, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;when&nbsp;slave-serve-stale-data&nbsp;is&nbsp;no&nbsp;and&nbsp;we&nbsp;are&nbsp;a&nbsp;slave&nbsp;with&nbsp;a&nbsp;broken &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;link&nbsp;with&nbsp;master.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.masterhost&nbsp;&amp;&amp;&nbsp;server.repl_state&nbsp;!=&nbsp;REPL_STATE_CONNECTED&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.repl_serve_stale_data&nbsp;==&nbsp;0&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_STALE)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flagTransaction(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.masterdownerr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;正在加载DB，直接返回错误 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Loading&nbsp;DB?&nbsp;Return&nbsp;an&nbsp;error&nbsp;if&nbsp;the&nbsp;command&nbsp;has&nbsp;not&nbsp;the &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;CMD_LOADING&nbsp;flag.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.loading&nbsp;&amp;&amp;&nbsp;!(c-&gt;cmd-&gt;flags&nbsp;&amp;&nbsp;CMD_LOADING))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.loadingerr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Lua&nbsp;script&nbsp;too&nbsp;slow?&nbsp;Only&nbsp;allow&nbsp;a&nbsp;limited&nbsp;number&nbsp;of&nbsp;commands.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.lua_timedout&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;authCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;replconfCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;cmd-&gt;proc&nbsp;==&nbsp;shutdownCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;argc&nbsp;==&nbsp;2&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tolower(((char*)c-&gt;argv[1]-&gt;ptr)[0])&nbsp;==&nbsp;'n')&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;!(c-&gt;cmd-&gt;proc&nbsp;==&nbsp;scriptCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;argc&nbsp;==&nbsp;2&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tolower(((char*)c-&gt;argv[1]-&gt;ptr)[0])&nbsp;==&nbsp;'k')) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;flagTransaction(c); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,&nbsp;shared.slowscripterr); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Exec&nbsp;the&nbsp;command&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(c-&gt;flags&nbsp;&amp;&nbsp;CLIENT_MULTI&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;execCommand&nbsp;&amp;&amp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;discardCommand&nbsp;&amp;&amp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;multiCommand&nbsp;&amp;&amp;&nbsp;c-&gt;cmd-&gt;proc&nbsp;!=&nbsp;watchCommand) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Add&nbsp;a&nbsp;new&nbsp;command&nbsp;into&nbsp;the&nbsp;MULTI&nbsp;commands&nbsp;queue&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;queueMultiCommand(c);&nbsp;//&nbsp;链上新的事务子命令（队列结构），等到EXEC时一块执行 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReply(c,shared.queued);&nbsp;//&nbsp;向client返回QUEUED &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;call(c,CMD_CALL_FULL);&nbsp;//&nbsp;调用命令处理过程 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c-&gt;woff&nbsp;=&nbsp;server.master_repl_offset;&nbsp;//&nbsp;更新复制偏移 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(listLength(server.ready_keys)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;handleClientsBlockedOnKeys(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;C_OK; &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

# **7. 持久化和复制** #

call在调用proc后，会调用propagate函数将命令传播给AOF和Slaves。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> int&nbsp;processCommand(client&nbsp;*c)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;void&nbsp;call(client&nbsp;*c,&nbsp;int&nbsp;flags)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;propagate(c-&gt;cmd,c-&gt;db-&gt;id,c-&gt;argv,c-&gt;argc,propagate_flags); &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

## **7.1. propagate函数（aof&replication）** ##

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;Propagate&nbsp;the&nbsp;specified&nbsp;command&nbsp;(in&nbsp;the&nbsp;context&nbsp;of&nbsp;the&nbsp;specified&nbsp;database&nbsp;id) &nbsp;*&nbsp;to&nbsp;AOF&nbsp;and&nbsp;Slaves. &nbsp;* &nbsp;*&nbsp;flags&nbsp;are&nbsp;an&nbsp;xor&nbsp;between: &nbsp;*&nbsp;+&nbsp;PROPAGATE_NONE&nbsp;(no&nbsp;propagation&nbsp;of&nbsp;command&nbsp;at&nbsp;all) &nbsp;*&nbsp;+&nbsp;PROPAGATE_AOF&nbsp;(propagate&nbsp;into&nbsp;the&nbsp;AOF&nbsp;file&nbsp;if&nbsp;is&nbsp;enabled) &nbsp;*&nbsp;+&nbsp;PROPAGATE_REPL&nbsp;(propagate&nbsp;into&nbsp;the&nbsp;replication&nbsp;link) &nbsp;* &nbsp;*&nbsp;This&nbsp;should&nbsp;not&nbsp;be&nbsp;used&nbsp;inside&nbsp;commands&nbsp;implementation.&nbsp;Use&nbsp;instead &nbsp;*&nbsp;alsoPropagate(),&nbsp;preventCommandPropagation(),&nbsp;forceCommandPropagation(). &nbsp;*/ void&nbsp;propagate(struct&nbsp;redisCommand&nbsp;*cmd,&nbsp;int&nbsp;dbid,&nbsp;robj&nbsp;**argv,&nbsp;int&nbsp;argc,&nbsp;int&nbsp;flags) { &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.aof_state&nbsp;!=&nbsp;AOF_OFF&nbsp;&amp;&amp;&nbsp;flags&nbsp;&amp;&nbsp;PROPAGATE_AOF) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;feedAppendOnlyFile(cmd,dbid,argv,argc);&nbsp;//&nbsp;写AOF &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(flags&nbsp;&amp;&nbsp;PROPAGATE_REPL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;replicationFeedSlaves(server.slaves,dbid,argv,argc);&nbsp;//&nbsp;推送给Slaves } </td> 
 </tr> 
 </tbody> 
</table>

## **7.2. 写AOF文件feedAppendOnlyFile** ##

feedAppendOnlyFile并不实际写文件，而只是将内容组织到AOF buffer中。写AOF文件是在每次epoll之前进行，redis-server启动时注册了函数beforeSleep，它在每次epoll之前被调用。beforeSleep调用flushAppendOnlyFile将AOF buffer写入到AOF文件。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> void&nbsp;feedAppendOnlyFile(struct&nbsp;redisCommand&nbsp;*cmd,&nbsp;int&nbsp;dictid,&nbsp;robj&nbsp;**argv,&nbsp;int&nbsp;argc)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Append&nbsp;to&nbsp;the&nbsp;AOF&nbsp;buffer.&nbsp;This&nbsp;will&nbsp;be&nbsp;flushed&nbsp;on&nbsp;disk&nbsp;just&nbsp;before &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;of&nbsp;re-entering&nbsp;the&nbsp;event&nbsp;loop,&nbsp;so&nbsp;before&nbsp;the&nbsp;client&nbsp;will&nbsp;get&nbsp;a &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;positive&nbsp;reply&nbsp;about&nbsp;the&nbsp;operation&nbsp;performed.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.aof_state&nbsp;==&nbsp;AOF_ON)&nbsp;//&nbsp;aof_state值由redis.conf中的appendonly控制 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.aof_buf&nbsp;=&nbsp;sdscatlen(server.aof_buf,buf,sdslen(buf)); } </td> 
 </tr> 
 </tbody> 
</table>

redis-server启动：

调用beforeSleep：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> void&nbsp;aeMain(aeEventLoop&nbsp;*eventLoop)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;eventLoop-&gt;stop&nbsp;=&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;while&nbsp;(!eventLoop-&gt;stop)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(eventLoop-&gt;beforesleep&nbsp;!=&nbsp;NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;eventLoop-&gt;beforesleep(eventLoop);&nbsp;//&nbsp;将AOF&nbsp;buffer写入到AOF文件 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;aeProcessEvents(eventLoop,&nbsp;AE_ALL_EVENTS|AE_CALL_AFTER_SLEEP);&nbsp;//&nbsp;epoll &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

调用**flushAppendOnlyFile**函数将AOF buffer写入到AOF文件：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;This&nbsp;function&nbsp;gets&nbsp;called&nbsp;every&nbsp;time&nbsp;Redis&nbsp;is&nbsp;entering&nbsp;the &nbsp;*&nbsp;main&nbsp;loop&nbsp;of&nbsp;the&nbsp;event&nbsp;driven&nbsp;library,&nbsp;that&nbsp;is,&nbsp;before&nbsp;to&nbsp;sleep &nbsp;*&nbsp;for&nbsp;ready&nbsp;file&nbsp;descriptors.&nbsp;*/ void&nbsp;beforeSleep(struct&nbsp;aeEventLoop&nbsp;*eventLoop)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Unblock&nbsp;all&nbsp;the&nbsp;clients&nbsp;blocked&nbsp;for&nbsp;synchronous&nbsp;replication &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;in&nbsp;WAIT.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(listLength(server.clients_waiting_acks)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processClientsWaitingReplicas(); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Try&nbsp;to&nbsp;process&nbsp;pending&nbsp;commands&nbsp;for&nbsp;clients&nbsp;that&nbsp;were&nbsp;just&nbsp;unblocked.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(listLength(server.unblocked_clients)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processUnblockedClients(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Write&nbsp;the&nbsp;AOF&nbsp;buffer&nbsp;on&nbsp;disk&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;flushAppendOnlyFile(0); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Handle&nbsp;writes&nbsp;with&nbsp;pending&nbsp;output&nbsp;buffers.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;handleClientsWithPendingWrites(); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 } </td> 
 </tr> 
 </tbody> 
</table>

写AOF文件：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;Write&nbsp;the&nbsp;append&nbsp;only&nbsp;file&nbsp;buffer&nbsp;on&nbsp;disk. &nbsp;* &nbsp;*&nbsp;Since&nbsp;we&nbsp;are&nbsp;required&nbsp;to&nbsp;write&nbsp;the&nbsp;AOF&nbsp;before&nbsp;replying&nbsp;to&nbsp;the&nbsp;client, &nbsp;*&nbsp;and&nbsp;the&nbsp;only&nbsp;way&nbsp;the&nbsp;client&nbsp;socket&nbsp;can&nbsp;get&nbsp;a&nbsp;write&nbsp;is&nbsp;entering&nbsp;when&nbsp;the &nbsp;*&nbsp;the&nbsp;event&nbsp;loop,&nbsp;we&nbsp;accumulate&nbsp;all&nbsp;the&nbsp;AOF&nbsp;writes&nbsp;in&nbsp;a&nbsp;memory &nbsp;*&nbsp;buffer&nbsp;and&nbsp;write&nbsp;it&nbsp;on&nbsp;disk&nbsp;using&nbsp;this&nbsp;function&nbsp;just&nbsp;before&nbsp;entering &nbsp;*&nbsp;the&nbsp;event&nbsp;loop&nbsp;again. &nbsp;* &nbsp;*&nbsp;About&nbsp;the&nbsp;'force'&nbsp;argument: &nbsp;* &nbsp;*&nbsp;When&nbsp;the&nbsp;fsync&nbsp;policy&nbsp;is&nbsp;set&nbsp;to&nbsp;'everysec'&nbsp;we&nbsp;may&nbsp;delay&nbsp;the&nbsp;flush&nbsp;if&nbsp;there &nbsp;*&nbsp;is&nbsp;still&nbsp;an&nbsp;fsync()&nbsp;going&nbsp;on&nbsp;in&nbsp;the&nbsp;background&nbsp;thread,&nbsp;since&nbsp;for&nbsp;instance &nbsp;*&nbsp;on&nbsp;Linux&nbsp;write(2)&nbsp;will&nbsp;be&nbsp;blocked&nbsp;by&nbsp;the&nbsp;background&nbsp;fsync&nbsp;anyway. &nbsp;*&nbsp;When&nbsp;this&nbsp;happens&nbsp;we&nbsp;remember&nbsp;that&nbsp;there&nbsp;is&nbsp;some&nbsp;aof&nbsp;buffer&nbsp;to&nbsp;be &nbsp;*&nbsp;flushed&nbsp;ASAP,&nbsp;and&nbsp;will&nbsp;try&nbsp;to&nbsp;do&nbsp;that&nbsp;in&nbsp;the&nbsp;serverCron()&nbsp;function. &nbsp;* &nbsp;*&nbsp;However&nbsp;if&nbsp;force&nbsp;is&nbsp;set&nbsp;to&nbsp;1&nbsp;we'll&nbsp;write&nbsp;regardless&nbsp;of&nbsp;the&nbsp;background &nbsp;*&nbsp;fsync.&nbsp;*/ #define&nbsp;AOF_WRITE_LOG_ERROR_RATE&nbsp;30&nbsp;/*&nbsp;Seconds&nbsp;between&nbsp;errors&nbsp;logging.&nbsp;*/ void&nbsp;flushAppendOnlyFile(int&nbsp;force)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;aofWrite调用write将AOF&nbsp;buffer写入到AOF文件，处理了ENTR，其它没什么 &nbsp;&nbsp;&nbsp;&nbsp;ssize_t&nbsp;nwritten&nbsp;=&nbsp;aofWrite(server.aof_fd,server.aof_buf,sdslen(server.aof_buf)); &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Handle&nbsp;the&nbsp;AOF&nbsp;write&nbsp;error.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.aof_fsync&nbsp;==&nbsp;AOF_FSYNC_ALWAYS)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;We&nbsp;can't&nbsp;recover&nbsp;when&nbsp;the&nbsp;fsync&nbsp;policy&nbsp;is&nbsp;ALWAYS&nbsp;since&nbsp;the &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;reply&nbsp;for&nbsp;the&nbsp;client&nbsp;is&nbsp;already&nbsp;in&nbsp;the&nbsp;output&nbsp;buffers,&nbsp;and&nbsp;we &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;have&nbsp;the&nbsp;contract&nbsp;with&nbsp;the&nbsp;user&nbsp;that&nbsp;on&nbsp;acknowledged&nbsp;write&nbsp;data &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;is&nbsp;synced&nbsp;on&nbsp;disk.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_WARNING,"Can't&nbsp;recover&nbsp;from&nbsp;AOF&nbsp;write&nbsp;error&nbsp;when&nbsp;the&nbsp;AOF&nbsp;fsync&nbsp;policy&nbsp;is&nbsp;'always'.&nbsp;Exiting..."); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;exit(1); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return;&nbsp;/*&nbsp;We'll&nbsp;try&nbsp;again&nbsp;on&nbsp;the&nbsp;next&nbsp;call...&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Successful&nbsp;write(2).&nbsp;If&nbsp;AOF&nbsp;was&nbsp;in&nbsp;error&nbsp;state,&nbsp;restore&nbsp;the &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;OK&nbsp;state&nbsp;and&nbsp;log&nbsp;the&nbsp;event.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Perform&nbsp;the&nbsp;fsync&nbsp;if&nbsp;needed.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.aof_fsync&nbsp;==&nbsp;AOF_FSYNC_ALWAYS)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;redis_fsync是一个宏，Linux实际为fdatasync，其它为fsync &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;所以最好不要将redis.conf中的appendfsync设置为always，这极影响性能 &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;//&nbsp;注意，Redis的实现并没有处理fsync和close的返回值，所以还不是最严格的 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;redis_fsync(server.aof_fd);&nbsp;/*&nbsp;Let's&nbsp;try&nbsp;to&nbsp;get&nbsp;this&nbsp;data&nbsp;on&nbsp;the&nbsp;disk&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;((server.aof_fsync&nbsp;==&nbsp;AOF_FSYNC_EVERYSEC&nbsp;&amp;&amp;&nbsp;server.unixtime&nbsp;&gt;&nbsp;server.aof_last_fsync))&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果已在sync状态，则不再重复 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;BIO线程会间隔设置sync_in_progress &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;if&nbsp;(server.aof_fsync&nbsp;==&nbsp;AOF_FSYNC_EVERYSEC) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sync_in_progress&nbsp;=&nbsp;bioPendingJobsOfType(BIO_AOF_FSYNC)&nbsp;!=&nbsp;0; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!sync_in_progress) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;eversec性能并不那么糟糕，因为它： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;后台方式执行fsync &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Redis并不是严格意义上的单线程，实际上它创建一组BIO线程，专门处理阻塞和慢操作 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;这些操作就包括FSYNC，另外还有关闭文件和内存的free两个操作。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;不像always，EVERYSEC模式并不立即调用fsync， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;而是将这个操作丢给了BIO线程异步执行， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;BIO线程在进程启动时被创建，两者间通过bio_jobs和bio_pending两个 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;全局对象交互，其中主线程负责写，BIO线程负责消费。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;aof_background_fsync(server.aof_fd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.aof_last_fsync&nbsp;=&nbsp;server.unixtime; &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

## **7.3. 数据复制replicationFeedSlaves** ##

这里也不会真正将数据发给Slaves，而只是将数据放入到replication buffer中。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;Propagate&nbsp;write&nbsp;commands&nbsp;to&nbsp;slaves,&nbsp;and&nbsp;populate&nbsp;the&nbsp;replication&nbsp;backlog &nbsp;*&nbsp;as&nbsp;well.&nbsp;This&nbsp;function&nbsp;is&nbsp;used&nbsp;if&nbsp;the&nbsp;instance&nbsp;is&nbsp;a&nbsp;master:&nbsp;we&nbsp;use &nbsp;*&nbsp;the&nbsp;commands&nbsp;received&nbsp;by&nbsp;our&nbsp;clients&nbsp;in&nbsp;order&nbsp;to&nbsp;create&nbsp;the&nbsp;replication &nbsp;*&nbsp;stream.&nbsp;Instead&nbsp;if&nbsp;the&nbsp;instance&nbsp;is&nbsp;a&nbsp;slave&nbsp;and&nbsp;has&nbsp;sub-slaves&nbsp;attached, &nbsp;*&nbsp;we&nbsp;use&nbsp;replicationFeedSlavesFromMaster()&nbsp;*/ void&nbsp;replicationFeedSlaves(list&nbsp;*slaves,&nbsp;int&nbsp;dictid,&nbsp;robj&nbsp;**argv,&nbsp;int&nbsp;argc)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;。。。。。。 &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Write&nbsp;the&nbsp;command&nbsp;to&nbsp;every&nbsp;slave.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;listRewind(slaves,&amp;li); &nbsp;&nbsp;&nbsp;&nbsp;while((ln&nbsp;=&nbsp;listNext(&amp;li)))&nbsp;{ &nbsp;//&nbsp;遍历所有的slaves &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;client&nbsp;*slave&nbsp;=&nbsp;ln-&gt;value;&nbsp;//&nbsp;Slave也被当作client &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Don't&nbsp;feed&nbsp;slaves&nbsp;that&nbsp;are&nbsp;still&nbsp;waiting&nbsp;for&nbsp;BGSAVE&nbsp;to&nbsp;start&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(slave-&gt;replstate&nbsp;==&nbsp;SLAVE_STATE_WAIT_BGSAVE_START)&nbsp;continue; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Feed&nbsp;slaves&nbsp;that&nbsp;are&nbsp;waiting&nbsp;for&nbsp;the&nbsp;initial&nbsp;SYNC&nbsp;(so&nbsp;these&nbsp;commands &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;are&nbsp;queued&nbsp;in&nbsp;the&nbsp;output&nbsp;buffer&nbsp;until&nbsp;the&nbsp;initial&nbsp;SYNC&nbsp;completes), &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;or&nbsp;are&nbsp;already&nbsp;in&nbsp;sync&nbsp;with&nbsp;the&nbsp;master.&nbsp;*/ &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Add&nbsp;the&nbsp;multi&nbsp;bulk&nbsp;length.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyMultiBulkLen(slave,argc); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Finally&nbsp;any&nbsp;additional&nbsp;argument&nbsp;that&nbsp;was&nbsp;not&nbsp;stored&nbsp;inside&nbsp;the &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;static&nbsp;buffer&nbsp;if&nbsp;any&nbsp;(from&nbsp;j&nbsp;to&nbsp;argc).&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for&nbsp;(j&nbsp;=&nbsp;0;&nbsp;j&nbsp;&lt;&nbsp;argc;&nbsp;j++) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;addReplyBulk(slave,argv[j]); &nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>

# **8. 进程启动时做了些什么？** #

进程启动时事项：

1) 为所有配置设置默认值

2) 加载配置文件redis.conf，覆盖默认值

3) 安装信号处理器

4) 初始化全局状态

5) 创建epoll，启动TCP监控

6) 创建BIO线程

7) 加载module

8) 加载AOF或RDB

9) 设置**beforeSleep**和**afterSleep**两个回调

10) 进入epoll循环

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> int&nbsp;main(int&nbsp;argc,&nbsp;char&nbsp;**argv)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;初始化所有配置，为它们设置默认值 &nbsp;&nbsp;&nbsp;&nbsp;initServerConfig(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果是sentinel模式，额外做相关初始化 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;sentinel_mode的值由命令行参数中是否包含参数“--sentinel”决定 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.sentinel_mode)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;initSentinelConfig(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;initSentinel(); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;redis-server和redis-check-rdb、redis-check-aof共享了同一个main函数 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;进入redis_check_rdb_main或redis_check_aof_main后不会再返回， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;也就是这两个函数后的代码均不会被执行。 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(strstr(argv[0],"redis-check-rdb")&nbsp;!=&nbsp;NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;redis_check_rdb_main(argc,argv,NULL); &nbsp;&nbsp;&nbsp;&nbsp;else&nbsp;if&nbsp;(strstr(argv[0],"redis-check-aof")&nbsp;!=&nbsp;NULL) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;redis_check_aof_main(argc,argv); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;加载redis.conf， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;包括初始化module列表loadmodule_queue， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;注意会将redis-server的命令行参数一并传递给module &nbsp;&nbsp;&nbsp;&nbsp;loadServerConfig(configfile,options); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;置为deamon方式， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;可通过redis.conf中的daemonize控制是否以deamon方式运行 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(background)&nbsp;daemonize(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;对redis-server核心的初始化，包括但不限于： &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;1)&nbsp;忽略HUP和PIPE信号 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;2)&nbsp;安装TERM和INT两个信号的处理器 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;3)&nbsp;初始化全局的redisServer对象server &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;4)&nbsp;注册定时器回调serverCron &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;5)&nbsp;注册accept的回调acceptTcpHandler &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;6)&nbsp;注册UNIX套接字回调acceptUnixHandler &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;7)&nbsp;注册模块回调moduleBlockedClientPipeReadable &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;8)&nbsp;创建或追加模式打开AOF文件 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;9)&nbsp;集群server.cluster初始化 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;10)&nbsp;复制脚本初始化 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;11)&nbsp;初始化lua运行环境 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;12)&nbsp;慢日志初始化 &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;13)&nbsp;初始化延迟监控（latency&nbsp;monitor） &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;14)&nbsp;创建BIO线程，由bio.h中的BIO_NUM_OPS决定个数，当前为3个 &nbsp;&nbsp;&nbsp;&nbsp;initServer(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果是daemon方式，则创建pid文件 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(background&nbsp;||&nbsp;server.pidfile)&nbsp;createPidFile(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;修改进程的title，加入状态和端口号，这样对ps等更为友好 &nbsp;&nbsp;&nbsp;&nbsp;redisSetProcTitle(argv[0]); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;进程启动时显示LOGO， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;可通过redis.conf中的always-show-logo控制是否显示 &nbsp;&nbsp;&nbsp;&nbsp;redisAsciiArt(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;检查TCP的“/proc/sys/net/core/somaxconn” &nbsp;&nbsp;&nbsp;&nbsp;checkTcpBacklogSettings &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.sentinel_mode)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sentinelIsRunning(); &nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果是Linux， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;检查“/proc/sys/vm/overcommit_memory” &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;和“/sys/kernel/mm/transparent_hugepage/enabled”的值。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;“/proc/sys/vm/overcommit_memory”值需要为1， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;“/sys/kernel/mm/transparent_hugepage/enabled”需要为“never” &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;linuxMemoryWarnings(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;加载所有的模块，如果有一个加载失败则启动失败 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;具体有哪些模块，由redis.conf中的loadmodule决定，如： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;loadmodule&nbsp;/path/to/my_module.so &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;loadmodule&nbsp;/path/to/other_module.so &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;每个module一行 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;moduleLoadFromQueue(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;从磁盘加载RDB或AOF到内存 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;如果开启了AOF， &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;则调用loadAppendOnlyFile加载AOF文件，这个时候不会加载RDB文件 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;没开启AOF时，调用rdbLoad加载RDB文件 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;不管是AOF还是RDB，加载不成功时，进程均不能启动。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;loadDataFromDisk(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.cluster_enabled)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(verifyClusterConfigWithData()&nbsp;==&nbsp;C_ERR)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_WARNING, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"You&nbsp;can't&nbsp;have&nbsp;keys&nbsp;in&nbsp;a&nbsp;DB&nbsp;different&nbsp;than&nbsp;DB&nbsp;0&nbsp;when&nbsp;in&nbsp;" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"Cluster&nbsp;mode.&nbsp;Exiting."); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;exit(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.ipfd_count&nbsp;&gt;&nbsp;0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_NOTICE,"Ready&nbsp;to&nbsp;accept&nbsp;connections"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.sofd&nbsp;&gt;&nbsp;0) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_NOTICE, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"The&nbsp;server&nbsp;is&nbsp;now&nbsp;ready&nbsp;to&nbsp;accept&nbsp;connections&nbsp;at&nbsp;%s", &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;server.unixsocket); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;redis.conf中的maxmemory值过小，进行警告提示 &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(server.maxmemory&nbsp;&gt;&nbsp;0&nbsp;&amp;&amp;&nbsp;server.maxmemory&nbsp;&lt;&nbsp;1024*1024)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;serverLog(LL_WARNING,"WARNING:&nbsp;You&nbsp;specified&nbsp;a&nbsp;maxmemory&nbsp;value&nbsp;that&nbsp;is&nbsp;less&nbsp;than&nbsp;1MB&nbsp;(current&nbsp;value&nbsp;is&nbsp;%llu&nbsp;bytes).&nbsp;Are&nbsp;you&nbsp;sure&nbsp;this&nbsp;is&nbsp;what&nbsp;you&nbsp;really&nbsp;want?",&nbsp;server.maxmemory); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;注册回调beforeSleep， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;对于eversec模式的appendfsync将在这个回调中进行 &nbsp;&nbsp;&nbsp;&nbsp;aeSetBeforeSleepProc(server.el,beforeSleep); &nbsp;&nbsp;&nbsp;&nbsp;aeSetAfterSleepProc(server.el,afterSleep); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;进入epoll主循环： &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;BSD为kqueue死循环， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Solaris为evport死循环， &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;其它为select死循环 &nbsp;&nbsp;&nbsp;&nbsp;// &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;网络数据的收和发，以及所有COMMAND的操作均在这个循环中完成 &nbsp;&nbsp;&nbsp;&nbsp;aeMain(server.el); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;关闭epoll，释放相关资源 &nbsp;&nbsp;&nbsp;&nbsp;aeDeleteEventLoop(server.el); &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;0; } </td> 
 </tr> 
 </tbody> 
</table>

# **9. 核心对象** #

Redis虽然采用C语言实现，但内含明显的对象，核心的对象包括：

## **9.1. redisServer** ##

这是一个**超大**的对象，实为redis-server的Context对象，承载了redis-server的各种全局状态。下面只列出它的一小部分：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.h struct&nbsp;redisServer&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;General&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;pid_t&nbsp;pid;&nbsp;/*&nbsp;Main&nbsp;process&nbsp;pid.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*configfile;&nbsp;/*&nbsp;Absolute&nbsp;config&nbsp;file&nbsp;path,&nbsp;or&nbsp;NULL&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Networking&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;port;&nbsp;/*&nbsp;TCP&nbsp;listening&nbsp;port&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;AOF&nbsp;persistence&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;aof_state;&nbsp;/*&nbsp;AOF_(ON|OFF|WAIT_REWRITE)&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;aof_fsync;&nbsp;/*&nbsp;Kind&nbsp;of&nbsp;fsync()&nbsp;policy&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;RDB&nbsp;persistence&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;dirty;&nbsp;/*&nbsp;Changes&nbsp;to&nbsp;DB&nbsp;from&nbsp;the&nbsp;last&nbsp;save&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Logging&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*logfile;&nbsp;/*&nbsp;Path&nbsp;of&nbsp;log&nbsp;file&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Replication&nbsp;(master)&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;replid[CONFIG_RUN_ID_SIZE+1];&nbsp;/*&nbsp;My&nbsp;current&nbsp;replication&nbsp;ID.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Replication&nbsp;(slave)&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*masterhost;&nbsp;/*&nbsp;Hostname&nbsp;of&nbsp;master&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Cluster&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;cluster_enabled;&nbsp;/*&nbsp;Is&nbsp;cluster&nbsp;enabled?&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Scripting&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;lua_State&nbsp;*lua;&nbsp;/*&nbsp;The&nbsp;Lua&nbsp;interpreter.&nbsp;We&nbsp;use&nbsp;just&nbsp;one&nbsp;for&nbsp;all&nbsp;clients&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Latency&nbsp;monitor&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*latency_events; }; </td> 
 </tr> 
 </tbody> 
</table>

## **9.2. client** ##

一个client对象，可以是一个Client，也可以是一个slave，也可以是一个master。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;server.h /*&nbsp;With&nbsp;multiplexing&nbsp;we&nbsp;need&nbsp;to&nbsp;take&nbsp;per-client&nbsp;state. &nbsp;*&nbsp;Clients&nbsp;are&nbsp;taken&nbsp;in&nbsp;a&nbsp;linked&nbsp;list.&nbsp;*/ typedef&nbsp;struct&nbsp;client&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;id;&nbsp;/*&nbsp;Client&nbsp;incremental&nbsp;unique&nbsp;ID.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;fd;&nbsp;/*&nbsp;Client&nbsp;socket.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;redisDb&nbsp;*db;&nbsp;/*&nbsp;Pointer&nbsp;to&nbsp;currently&nbsp;SELECTed&nbsp;DB.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;*name;&nbsp;/*&nbsp;As&nbsp;set&nbsp;by&nbsp;CLIENT&nbsp;SETNAME.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;sds&nbsp;querybuf;&nbsp;/*&nbsp;Buffer&nbsp;we&nbsp;use&nbsp;to&nbsp;accumulate&nbsp;client&nbsp;queries.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp;qb_pos;&nbsp;/*&nbsp;The&nbsp;position&nbsp;we&nbsp;have&nbsp;read&nbsp;in&nbsp;querybuf.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;argc;&nbsp;/*&nbsp;Num&nbsp;of&nbsp;arguments&nbsp;of&nbsp;current&nbsp;command.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;robj&nbsp;**argv;&nbsp;/*&nbsp;Arguments&nbsp;of&nbsp;current&nbsp;command.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;redisCommand&nbsp;*cmd,&nbsp;*lastcmd;&nbsp;/*&nbsp;Last&nbsp;command&nbsp;executed.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;list&nbsp;*reply;&nbsp;/*&nbsp;List&nbsp;of&nbsp;reply&nbsp;objects&nbsp;to&nbsp;send&nbsp;to&nbsp;the&nbsp;client.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;authenticated;&nbsp;/*&nbsp;When&nbsp;requirepass&nbsp;is&nbsp;non-NULL.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;replstate;&nbsp;/*&nbsp;Replication&nbsp;state&nbsp;if&nbsp;this&nbsp;is&nbsp;a&nbsp;slave.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;replid[CONFIG_RUN_ID_SIZE+1];&nbsp;/*&nbsp;Master&nbsp;replication&nbsp;ID&nbsp;(if&nbsp;master).&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Response&nbsp;buffer&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;bufpos; &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;buf[PROTO_REPLY_CHUNK_BYTES]; }; </td> 
 </tr> 
 </tbody> 
</table>

## **9.3. redisCommand** ##

Redis命令结构：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> struct&nbsp;redisCommand&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*name;&nbsp;//&nbsp;Redis命令名，如：GET等 &nbsp;&nbsp;&nbsp;&nbsp;redisCommandProc&nbsp;*proc;&nbsp;//&nbsp;处理该命令的过程 &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;arity; &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;*sflags;&nbsp;/*&nbsp;Flags&nbsp;as&nbsp;string&nbsp;representation,&nbsp;one&nbsp;char&nbsp;per&nbsp;flag.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;flags;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;The&nbsp;actual&nbsp;flags,&nbsp;obtained&nbsp;from&nbsp;the&nbsp;'sflags'&nbsp;field.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Use&nbsp;a&nbsp;function&nbsp;to&nbsp;determine&nbsp;keys&nbsp;arguments&nbsp;in&nbsp;a&nbsp;command&nbsp;line. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;Used&nbsp;for&nbsp;Redis&nbsp;Cluster&nbsp;redirect.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;redisGetKeysProc&nbsp;*getkeys_proc; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;What&nbsp;keys&nbsp;should&nbsp;be&nbsp;loaded&nbsp;in&nbsp;background&nbsp;when&nbsp;calling&nbsp;this&nbsp;command?&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;firstkey;&nbsp;/*&nbsp;The&nbsp;first&nbsp;argument&nbsp;that's&nbsp;a&nbsp;key&nbsp;(0&nbsp;=&nbsp;no&nbsp;keys)&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;lastkey;&nbsp;&nbsp;/*&nbsp;The&nbsp;last&nbsp;argument&nbsp;that's&nbsp;a&nbsp;key&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;keystep;&nbsp;&nbsp;/*&nbsp;The&nbsp;step&nbsp;between&nbsp;first&nbsp;and&nbsp;last&nbsp;key&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;microseconds,&nbsp;calls; }; </td> 
 </tr> 
 </tbody> 
</table>

## **9.4. redisDb** ##

Redis的DB结构：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> /*&nbsp;Redis&nbsp;database&nbsp;representation.&nbsp;There&nbsp;are&nbsp;multiple&nbsp;databases&nbsp;identified &nbsp;*&nbsp;by&nbsp;integers&nbsp;from&nbsp;0&nbsp;(the&nbsp;default&nbsp;database)&nbsp;up&nbsp;to&nbsp;the&nbsp;max&nbsp;configured &nbsp;*&nbsp;database.&nbsp;The&nbsp;database&nbsp;number&nbsp;is&nbsp;the&nbsp;'id'&nbsp;field&nbsp;in&nbsp;the&nbsp;structure.&nbsp;*/ typedef&nbsp;struct&nbsp;redisDb&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*dict;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;The&nbsp;keyspace&nbsp;for&nbsp;this&nbsp;DB&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*expires;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Timeout&nbsp;of&nbsp;keys&nbsp;with&nbsp;a&nbsp;timeout&nbsp;set&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*blocking_keys;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Keys&nbsp;with&nbsp;clients&nbsp;waiting&nbsp;for&nbsp;data&nbsp;(BLPOP)*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*ready_keys;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Blocked&nbsp;keys&nbsp;that&nbsp;received&nbsp;a&nbsp;PUSH&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*watched_keys;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;WATCHED&nbsp;keys&nbsp;for&nbsp;MULTI/EXEC&nbsp;CAS&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;id;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Database&nbsp;ID&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;avg_ttl;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Average&nbsp;TTL,&nbsp;just&nbsp;for&nbsp;stats&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;list&nbsp;*defrag_later;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;List&nbsp;of&nbsp;key&nbsp;names&nbsp;to&nbsp;attempt&nbsp;to&nbsp;defrag&nbsp;one&nbsp;by&nbsp;one,&nbsp;gradually.&nbsp;*/ }&nbsp;redisDb; </td> 
 </tr> 
 </tbody> 
</table>

## **9.5. clusterNode** ##

Redis集群节点结构：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> typedef&nbsp;long&nbsp;long&nbsp;mstime_t;&nbsp;/*&nbsp;millisecond&nbsp;time&nbsp;type.&nbsp;*/ typedef&nbsp;struct&nbsp;clusterNode&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;ctime;&nbsp;/*&nbsp;Node&nbsp;object&nbsp;creation&nbsp;time.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;name[CLUSTER_NAMELEN];&nbsp;/*&nbsp;Node&nbsp;name,&nbsp;hex&nbsp;string,&nbsp;sha1-size&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;flags;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;CLUSTER_NODE_...&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;configEpoch;&nbsp;/*&nbsp;Last&nbsp;configEpoch&nbsp;observed&nbsp;for&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp;char&nbsp;slots[CLUSTER_SLOTS/8];&nbsp;/*&nbsp;slots&nbsp;handled&nbsp;by&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;numslots;&nbsp;&nbsp;&nbsp;/*&nbsp;Number&nbsp;of&nbsp;slots&nbsp;handled&nbsp;by&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;numslaves;&nbsp;&nbsp;/*&nbsp;Number&nbsp;of&nbsp;slave&nbsp;nodes,&nbsp;if&nbsp;this&nbsp;is&nbsp;a&nbsp;master&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;所有的slave节点 &nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;clusterNode&nbsp;**slaves;&nbsp;/*&nbsp;pointers&nbsp;to&nbsp;slave&nbsp;nodes&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;master节点 &nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;clusterNode&nbsp;*slaveof;&nbsp;/*&nbsp;pointer&nbsp;to&nbsp;the&nbsp;master&nbsp;node.&nbsp;Note&nbsp;that&nbsp;it &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;may&nbsp;be&nbsp;NULL&nbsp;even&nbsp;if&nbsp;the&nbsp;node&nbsp;is&nbsp;a&nbsp;slave &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;we&nbsp;don't&nbsp;have&nbsp;the&nbsp;master&nbsp;node&nbsp;in&nbsp;our &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tables.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;最近一次发送ping的时间 &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;ping_sent;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Unix&nbsp;time&nbsp;we&nbsp;sent&nbsp;latest&nbsp;ping&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;最近一次接收pong的时间 &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;pong_received;&nbsp;&nbsp;/*&nbsp;Unix&nbsp;time&nbsp;we&nbsp;received&nbsp;the&nbsp;pong&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;fail_time;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Unix&nbsp;time&nbsp;when&nbsp;FAIL&nbsp;flag&nbsp;was&nbsp;set&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;voted_time;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Last&nbsp;time&nbsp;we&nbsp;voted&nbsp;for&nbsp;a&nbsp;slave&nbsp;of&nbsp;this&nbsp;master&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;repl_offset_time;&nbsp;&nbsp;/*&nbsp;Unix&nbsp;time&nbsp;we&nbsp;received&nbsp;offset&nbsp;for&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;orphaned_time;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Starting&nbsp;time&nbsp;of&nbsp;orphaned&nbsp;master&nbsp;condition&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;long&nbsp;long&nbsp;repl_offset;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Last&nbsp;known&nbsp;repl&nbsp;offset&nbsp;for&nbsp;this&nbsp;node.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;char&nbsp;ip[NET_IP_STR_LEN];&nbsp;&nbsp;/*&nbsp;Latest&nbsp;known&nbsp;IP&nbsp;address&nbsp;of&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;port;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Latest&nbsp;known&nbsp;clients&nbsp;port&nbsp;of&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;cport;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Latest&nbsp;known&nbsp;cluster&nbsp;port&nbsp;of&nbsp;this&nbsp;node.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;clusterLink&nbsp;*link;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;TCP/IP&nbsp;link&nbsp;with&nbsp;this&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;list&nbsp;*fail_reports;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;List&nbsp;of&nbsp;nodes&nbsp;signaling&nbsp;this&nbsp;as&nbsp;failing&nbsp;*/ }&nbsp;clusterNode; </td> 
 </tr> 
 </tbody> 
</table>

## **9.6. clusterState** ##

Redis集群状态结构：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> typedef&nbsp;struct&nbsp;clusterState&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;clusterNode&nbsp;*myself;&nbsp;&nbsp;/*&nbsp;This&nbsp;node&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;currentEpoch; &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;state;&nbsp;/*&nbsp;CLUSTER_OK,&nbsp;CLUSTER_FAIL,&nbsp;...&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;size;&nbsp;/*&nbsp;Num&nbsp;of&nbsp;master&nbsp;nodes&nbsp;with&nbsp;at&nbsp;least&nbsp;one&nbsp;slot&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*nodes;&nbsp;/*&nbsp;Hash&nbsp;table&nbsp;of&nbsp;name&nbsp;-&gt;&nbsp;clusterNode&nbsp;structures&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;dict&nbsp;*nodes_black_list;&nbsp;/*&nbsp;Nodes&nbsp;we&nbsp;don't&nbsp;re-add&nbsp;for&nbsp;a&nbsp;few&nbsp;seconds.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;clusterNode&nbsp;*migrating_slots_to[CLUSTER_SLOTS]; &nbsp;&nbsp;&nbsp;&nbsp;clusterNode&nbsp;*importing_slots_from[CLUSTER_SLOTS]; &nbsp;&nbsp;&nbsp;&nbsp;clusterNode&nbsp;*slots[CLUSTER_SLOTS]; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;mstime_t&nbsp;failover_auth_time;&nbsp;/*&nbsp;Time&nbsp;of&nbsp;previous&nbsp;or&nbsp;next&nbsp;election.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;failover_auth_count;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Number&nbsp;of&nbsp;votes&nbsp;received&nbsp;so&nbsp;far.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;failover_auth_sent;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;True&nbsp;if&nbsp;we&nbsp;already&nbsp;asked&nbsp;for&nbsp;votes.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;int&nbsp;failover_auth_rank;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;This&nbsp;slave&nbsp;rank&nbsp;for&nbsp;current&nbsp;auth&nbsp;request.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;failover_auth_epoch;&nbsp;/*&nbsp;Epoch&nbsp;of&nbsp;the&nbsp;current&nbsp;election.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Manual&nbsp;failover&nbsp;state&nbsp;of&nbsp;master.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;clusterNode&nbsp;*mf_slave;&nbsp;/*&nbsp;Slave&nbsp;performing&nbsp;the&nbsp;manual&nbsp;failover.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;The&nbsp;followign&nbsp;fields&nbsp;are&nbsp;used&nbsp;by&nbsp;masters&nbsp;to&nbsp;take&nbsp;state&nbsp;on&nbsp;elections.&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;uint64_t&nbsp;lastVoteEpoch;&nbsp;/*&nbsp;Epoch&nbsp;of&nbsp;the&nbsp;last&nbsp;vote&nbsp;granted.&nbsp;*/ }&nbsp;clusterState; </td> 
 </tr> 
 </tbody> 
</table>

# **10. 主备同步** #

待续。

# **11. 主备切换** #

待续。