Redis源码简要分析
在文章的開(kāi)頭我們把所有服務(wù)端文件列出來(lái)，并且標(biāo)示出其作用：
adlist.c //雙向鏈表
ae.c //事件驅(qū)動(dòng)
ae_epoll.c //epoll接口, linux用
ae_kqueue.c //kqueue接口, freebsd用
ae_select.c //select接口, windows用
anet.c //網(wǎng)絡(luò)處理
aof.c //處理AOF文件
config.c //配置文件解析
db.c //DB處理
dict.c //hash表
intset.c //轉(zhuǎn)換為數(shù)字類(lèi)型數(shù)據(jù)
multi.c //事務(wù)，多條命令一起打包處理
networking.c //讀取、解析和處理客戶(hù)端命令
object.c //各種對(duì)像的創(chuàng)建與銷(xiāo)毀,string、list、set、zset、hash
rdb.c //redis數(shù)據(jù)文件處理
redis.c //程序主要文件
replication.c //數(shù)據(jù)同步master-slave
sds.c //字符串處理
sort.c //用于list、set、zset排序
t_hash.c //hash類(lèi)型處理
t_list.c //list類(lèi)型處理
t_set.c //set類(lèi)型處理
t_string.c //string類(lèi)型處理
t_zset.c //zset類(lèi)型處理
ziplist.c //節(jié)省內(nèi)存方式的list處理
zipmap.c //節(jié)省內(nèi)存方式的hash處理
zmalloc.c //內(nèi)存管理
上面基本是redis最主要的處理文件，部分沒(méi)有列出來(lái)，如VM之類(lèi)的，就不在這里講了。
首先我們來(lái)回顧一下redis的一些基本知識(shí):
1、redis有N個(gè)DB(默認(rèn)為16個(gè)DB),并且每個(gè)db有一個(gè)hash表負(fù)責(zé)存放key,同一個(gè)DB不能有相同的KEY，但是不同的DB可以相同的KEY;
2、支持的幾種數(shù)據(jù)類(lèi)型：string、hash、list、set、zset;
3、redis可以使用aof來(lái)保存寫(xiě)操作日志(也可以使用快照方式保存數(shù)據(jù)文件)
對(duì)于數(shù)據(jù)類(lèi)型在這里簡(jiǎn)單的介紹一下(網(wǎng)上有圖，下面我貼上圖片可能更容易理解)
1、對(duì)于一個(gè)string對(duì)像，直接存儲(chǔ)內(nèi)容;
2、對(duì)于一個(gè)hash對(duì)像，當(dāng)成員數(shù)量少于512的時(shí)候使用zipmap(一種很省內(nèi)存的方式實(shí)現(xiàn)hash table),反之使用hash表(key存儲(chǔ)成員名,value存儲(chǔ)成員數(shù)據(jù));
3、對(duì)于一個(gè)list對(duì)像，當(dāng)成員數(shù)量少于512的時(shí)候使用ziplist(一種很省內(nèi)存的方式實(shí)現(xiàn)list),反之使用雙向鏈表(list);
4、對(duì)于一個(gè)set對(duì)像，使用hash表(key存儲(chǔ)數(shù)據(jù),內(nèi)容為空)
5、對(duì)于一個(gè)zset對(duì)像,使用跳表(skip list),關(guān)于跳表的相關(guān)內(nèi)容可以查看本blog的跳表學(xué)習(xí)筆記;
下面正式進(jìn)入源代碼的分析
1、首先是初始化配置,initServerConfig(redis.c:759)
void initServerConfig() {
server.port = REDIS_SERVERPORT;
server.bindaddr = NULL;
server.unixsocket = NULL;
server.ipfd = -1;
server.sofd = -1;
2.在初始化配置中調(diào)用了populateCommandTable(redis.c:925)函數(shù),該函數(shù)的目地是將命令集分布到一個(gè)hash table中,大家可以看到每一個(gè)命令都對(duì)應(yīng)一個(gè)處理函數(shù)，因?yàn)?span style="word-wrap:break-word">redis支持的命令集還是蠻多，所以如果要靠if分支來(lái)做命令處理的話即繁瑣效率還底， 因此放到hash table中，在理想的情況下只需一次就能定位命令的處理函數(shù)。
void populateCommandTable(void) {
int j;
int numcommands = sizeof(readonlyCommandTable)/sizeof(struct redisCommand);
for (j = 0; j < numcommands; j++) {
struct redisCommand *c = readonlyCommandTable+j;
int retval;
retval = dictAdd(server.commands, sdsnew(c->name), c);
assert(retval == DICT_OK);
}
}
3、對(duì)參數(shù)的解析,redis-server有一個(gè)參數(shù)(可以不需要),這個(gè)參數(shù)是指定配置文件路徑,然后由函數(shù)loadServerConfig(config.c:28)加載所有配置
if (argc == 2) {
if (strcmp(argv[1], “-v”) == 0 ||
strcmp(argv[1], “–version”) == 0) version();
if (strcmp(argv[1], “–help”) == 0) usage();
resetServerSaveParams();
loadServerConfig(argv[1]);
4、初始化服務(wù)器initServer(redis.c:836),?該函數(shù)初始化一些服務(wù)器信息，包括創(chuàng)建事件處理對(duì)像、db、socket、客戶(hù)端鏈表、公共字符串等。
void initServer() {
int j;
signal(SIGHUP, SIG_IGN);
signal(SIGPIPE, SIG_IGN);
setupSignalHandlers();//設(shè)置信號(hào)處理
if (server.syslog_enabled) {
openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
server.syslog_facility);
}
5、在上面初始化服務(wù)器中有一段代碼是創(chuàng)建事件驅(qū)動(dòng)，aeCreateTimeEvent是創(chuàng)建一個(gè)定時(shí)器，下面創(chuàng)建的定時(shí)器將會(huì)每毫秒調(diào)用?serverCron函數(shù)，而aeCreateFileEvent是創(chuàng)建網(wǎng)絡(luò)事件驅(qū)動(dòng)，當(dāng)server.ipfd和server.sofd有數(shù)據(jù)可讀的情 況將會(huì)分別調(diào)用函數(shù)acceptTcpHandler和acceptUnixHandler。
aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL);
if (server.ipfd > 0 && aeCreateFileEvent(server.el,server.ipfd,AE_READABLE,
acceptTcpHandler,NULL) == AE_ERR) oom(“creating file event”);
if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,
acceptUnixHandler,NULL) == AE_ERR) oom(“creating file event”);
6、接下來(lái)就是初始化數(shù)據(jù)，如果開(kāi)啟了AOF，那么會(huì)調(diào)用loadAppendOnlyFile(aof.c:216)去加載AOF文件，在AOF?文件中存放了客戶(hù)端的命令，函數(shù)將數(shù)據(jù)讀取出來(lái)然后依次去調(diào)用命令集去處理，當(dāng)AOF文件很大的時(shí)候勢(shì)必為影響客戶(hù)端的請(qǐng)求，所以每處理1000條命令就 會(huì)去嘗試接受和處理客戶(hù)端的請(qǐng)求，其代碼在aof.c第250行;?但是如果沒(méi)有開(kāi)啟AOF并且有rdb的情況，會(huì)調(diào)用rdbLoad(redis.c:873)嘗試去加載rdb文件，理所當(dāng)然的在加載rdb文件的內(nèi)部也 會(huì)考慮文件太大而影響客戶(hù)端請(qǐng)求，所以跟AOF一樣，每處理1000條也會(huì)嘗試去接受和處理客戶(hù)端請(qǐng)求。
7、當(dāng)所有初始化工作做完之后，服務(wù)端就開(kāi)始正式工作了
aeSetBeforeSleepProc(server.el,beforeSleep);
aeMain(server.el);
8、大家都知道redis是單線程模式，所有的請(qǐng)求、處理都是在同一個(gè)線程里面進(jìn)行，也就是一個(gè)無(wú)限循環(huán)，在這個(gè)無(wú)限循環(huán)的內(nèi)部有兩件事要做，第一 件就是調(diào)用通過(guò)aeSetBeforeSleepProc函數(shù)設(shè)置的回調(diào)函數(shù)，第二件就是開(kāi)始接受客戶(hù)端的請(qǐng)求和處理，所以我們可以在第7節(jié)看到設(shè)置了回 調(diào)函數(shù)為beforeSleep，但是這個(gè)beforeSleep到底有什么作用呢？我們?cè)诘?span style="word-wrap:break-word">9節(jié)再詳細(xì)講述。對(duì)于aeMain(ae.c:375)就是 整個(gè)程序的主要循環(huán)。
void aeMain(aeEventLoop *eventLoop) {
eventLoop->stop = 0;
while (!eventLoop->stop) {
if (eventLoop->beforesleep != NULL)
eventLoop->beforesleep(eventLoop);
aeProcessEvents(eventLoop, AE_ALL_EVENTS);
}
}
9、在beforeSleep內(nèi)部一共有三部分，第一部分對(duì)vm進(jìn)行處理(即第一個(gè)if塊)，這里我們略過(guò)；第二部分是釋放客戶(hù)端的阻塞操作，在?redis里有兩個(gè)命令BLPOP和BRPOP需要使用這些操作（彈出列表頭或者尾，實(shí)現(xiàn)方式見(jiàn)t_list.c:862行的?blockingPopGenericCommand函數(shù)），當(dāng)指定的key不存在或者列表為空的情況下，那么客戶(hù)端會(huì)一直阻塞，直到列表有數(shù)據(jù)時(shí)，服務(wù) 端就會(huì)去執(zhí)行lpop或者rpop并返回給客戶(hù)端，那么什么時(shí)候需要用到BLPOP和BRPOP呢？大家平時(shí)肯定用redis做過(guò)隊(duì)列，最常見(jiàn)的處理方式 就是使用llen去判斷隊(duì)列有沒(méi)有數(shù)據(jù)，如果有數(shù)據(jù)就去取N條，然后處理，如果沒(méi)有就sleep(3)，然后繼續(xù)循環(huán)，其實(shí)這里就可以使用BLPOP或者?BRPOP來(lái)輕松實(shí)現(xiàn)，而且可以減少請(qǐng)求，具體怎么實(shí)現(xiàn)留給大家思考；第三部分就是flushAppendOnlyFile(aof.c:60)，這個(gè)函 數(shù)主要目的是將aofbuf的數(shù)據(jù)寫(xiě)到文件，那aofbuf是什么呢？他是AOF的一個(gè)緩沖區(qū)，所以客戶(hù)端的命令都會(huì)在處理完后把這些命令追加到這個(gè)緩沖 區(qū)中，然后待一輪數(shù)據(jù)處理完之后統(tǒng)一寫(xiě)到文件(所以aof也是不能100%保證數(shù)據(jù)不丟失的，因?yàn)槿绻?dāng)redis正在處理這些命令的情況下服務(wù)就掛掉， 那么這部分的數(shù)據(jù)是沒(méi)有保存到硬盤(pán)的)，大家都知道寫(xiě)數(shù)據(jù)到文件并不是立即寫(xiě)到硬盤(pán)，只是保存到一個(gè)文件緩沖區(qū)中，什么情況下會(huì)把緩沖區(qū)的數(shù)據(jù)轉(zhuǎn)到硬盤(pán) 呢？只要滿足如下三種條件的一種就能將數(shù)據(jù)真正存到硬盤(pán)：1、手動(dòng)調(diào)用刷新緩沖區(qū)；2、緩沖區(qū)已滿；3、程序正常退出。因此redis將數(shù)據(jù)寫(xiě)到文件緩沖 區(qū)之后會(huì)判斷是否需要刷到硬盤(pán)，server.appendfsync有兩種方式，第一種(APPENDFSYNC_ALWAYS)：無(wú)條件刷新，即每次 寫(xiě)文件都會(huì)保存到硬盤(pán)，第二種(APPENDFSYNC_EVERYSEC)：每隔一秒保存到硬盤(pán)。
10、接下來(lái)我們開(kāi)始講解aeProcessEvents(ae.c:275)的處理流程，首先我們來(lái)回顧一下第5節(jié)設(shè)置的定時(shí)器和監(jiān)聽(tīng)?socket事件處理，其中socket事件處理會(huì)回調(diào)acceptTcpHandler(networking.c:410)和定時(shí)器回調(diào)函數(shù)?serverCron(redis.c:519)，在aeProcessEvents的內(nèi)部有兩部分需要處理，第一部分是調(diào)用aeApiPoll判斷?socket是否有數(shù)據(jù)可讀，整個(gè)服務(wù)端的socket里面要分監(jiān)聽(tīng)socket和客戶(hù)端socket，當(dāng)有客戶(hù)端鏈接服務(wù)器時(shí)，會(huì)觸發(fā)監(jiān)聽(tīng)socket?的事件處理函數(shù)，也就是acceptTcpHandler，而acceptTcpHandler會(huì)去調(diào)用?createClient(networking.c:13)創(chuàng)建客戶(hù)端對(duì)像，然后為這個(gè)客戶(hù)端設(shè)置事件處理函數(shù)?readQueryFromClient(networking.c:827)，所以當(dāng)客戶(hù)端有消息時(shí)就會(huì)觸發(fā)客戶(hù)端socket事件處理函數(shù)，處理數(shù)據(jù)部分講在后面詳細(xì)講解，接下來(lái)的第二部分就是定時(shí)器，每次在socket部分處理完后就用調(diào)用processTimeEvents(ae.c:212)來(lái)處理定時(shí)器，那么內(nèi)部實(shí)現(xiàn)也很簡(jiǎn)單，當(dāng)設(shè)置定時(shí)器的時(shí)候就會(huì)計(jì)算好應(yīng)該觸發(fā)的時(shí)間，所以這里就 只需要判斷當(dāng)前時(shí)間是否大于或者等于應(yīng)該觸發(fā)的時(shí)間即可。那么這個(gè)定時(shí)器到底做了什么呢？請(qǐng)繼續(xù)第11節(jié)。
11、我們繼續(xù)跟蹤源代碼serverCron(redis.c:519)，整個(gè)函數(shù)分為七個(gè)部分，第一部分：在服務(wù)端打印一些關(guān)于DB的信息(包 括key數(shù)量，內(nèi)存使用量等)；第二部分：判斷DB的hash table是否需要擴(kuò)展大小tryResizeHashTables(redis.c:432)；第三部分：關(guān)閉太長(zhǎng)時(shí)間沒(méi)有通信的鏈接closeTimedoutClients(networking.c:629)；第四部分：保存rdb文件?rdbSaveBackground(rdb.c:507)，當(dāng)然也是在需要保存的情況才會(huì)保存，即設(shè)置save參數(shù)；第五部分：清除過(guò)期的key，當(dāng)然 這里不是清除全部，他只是隨機(jī)取出一些activeExpireCycle(redic.c:477)；第六部分：虛擬內(nèi)存交換部分，將一部分key轉(zhuǎn)到 虛擬內(nèi)存中，這里的key也是隨機(jī)抽取的, vmSwapOneObjectBlocking(vm.c:521)；第七部分：主從同 步，replicationCron(replication.c:500)。
12、在第10節(jié)中我們講到客戶(hù)端socket處理函數(shù)readQueryFromClient,這里我們一層層分析，首先是從客戶(hù)端讀取數(shù)據(jù)，然 后調(diào)用processInputBuffer，在內(nèi)部先是判斷類(lèi)型，然后調(diào)用processInlineBuffer或者?processMultibulkBuffer解析參數(shù)，解析后的參數(shù)由argv存儲(chǔ)參數(shù)，其類(lèi)型是一個(gè)指向指針的指針，其中argv[0]是命令名稱(chēng)， 后面就是命令參數(shù)，argc存儲(chǔ)參數(shù)數(shù)量；然后調(diào)用processCommand(redis.c:979)處理命令，在內(nèi)部調(diào)用?lookupCommand(redis.c:940)獲取命令對(duì)應(yīng)的函數(shù)，然后調(diào)用freeMemoryIfNeeded(redis.c:1385)?判斷是否需要釋放一些內(nèi)存，接下來(lái)就是調(diào)用call(redis.c:954)去執(zhí)行命令，執(zhí)行命令后會(huì)調(diào)用feedAppendOnlyFile(aof.c:137)把命令行保存到aofbuf中，然后判斷是否需要同步數(shù)據(jù)到slave，如果需要?jiǎng)t調(diào)用replicationFeedSlaves(replication.c:10)，接下來(lái)就是判斷是否需要將數(shù)據(jù)發(fā)送到監(jiān)控端，如果需要?jiǎng)t調(diào)用replicationFeedMonitors(replication.c:82)，到這里整個(gè)服務(wù)流程就結(jié)束了。至于每條命令如何執(zhí)行，大家可以去 查看以t_開(kāi)頭的幾個(gè)文件。下面是一張整個(gè)服務(wù)的流程圖。
注：redis源代碼為2.2.8,希望大家看文章的時(shí)候配合源代碼一起看，更容易理解
Redis通過(guò)定義一個(gè) struct redisServer 類(lèi)型的全局變量server 來(lái)保存服務(wù)器的相關(guān)信息（比如：配置信息，統(tǒng)計(jì)信息，服務(wù)器狀態(tài)等等）。啟動(dòng)時(shí)通過(guò)讀取配置文件里邊的信息對(duì)server進(jìn)行初始化（如果沒(méi)有指定配置文件，將使用默認(rèn)值對(duì)sever進(jìn)行初始化），初始化的內(nèi)容有：起監(jiān)聽(tīng)端口，綁定有新連接時(shí)的回調(diào)函數(shù)，綁定服務(wù)器的定時(shí)函數(shù)，虛擬內(nèi)存初始化，log初始化等等。
啟動(dòng)
初始化服務(wù)器配置
先來(lái)看看redis 的main函數(shù)的入口
Redis.c：1694
| int?main(int?argc,?char?**argv)?{? ????time_t?start;? ????initServerConfig();? ????if?(argc?==?2)?{? ????????if?(strcmp(argv[1],?"-v")?==?0?||? ????????????strcmp(argv[1],?"--version")?==?0)?version();? ????????if?(strcmp(argv[1],?"--help")?==?0)?usage();? ????????resetServerSaveParams();? ????????loadServerConfig(argv[1]);? ????}?else?if?((argc?>?2))?{? ????????usage();? ????}?else?{? ????????...? ????}? ????if?(server.daemonize)?daemonize();? ????initServer();? ????... |
- initServerConfig初始化全局變量 server 的屬性為默認(rèn)值。
- 如果命令行指定了配置文件， resetServerSaveParams重置對(duì)落地備份的配置（即重置為默認(rèn)值）并讀取配置文件的內(nèi)容對(duì)全局變量 server 再進(jìn)行初始化 ，沒(méi)有在配置文件中配置的將使用默認(rèn)值。
- 如果服務(wù)器配置成后臺(tái)執(zhí)行，則對(duì)服務(wù)器進(jìn)行 daemonize。
- initServer初始化服務(wù)器，主要是設(shè)置信號(hào)處理函數(shù)，初始化事件輪詢(xún)，起監(jiān)聽(tīng)端口，綁定有新連接時(shí)的回調(diào)函數(shù)，綁定服務(wù)器的定時(shí)函數(shù)，初始化虛擬內(nèi)存和log等等。
- 創(chuàng)建服務(wù)器監(jiān)聽(tīng)端口。
Redis.c：923
| ????if?(server.port?!=?0)?{? ????????server.ipfd=?anetTcpServer(server.neterr,server.port,server.bindaddr);? ????????if?(server.ipfd?==?ANET_ERR)?{? ????????????redisLog(REDIS_WARNING,?"Opening?port?%d:?%s",? ????????????????server.port,?server.neterr);? ????????????exit(1);? ????????}? ????} |
- anetTcpServer創(chuàng)建一個(gè)socket并進(jìn)行監(jiān)聽(tīng)，然后把返回的socket fd賦值給server.ipfd。
事件輪詢(xún)結(jié)構(gòu)體定義
先看看事件輪詢(xún)的結(jié)構(gòu)體定義
Ae.h：88
| /*?State?of?an?event?based?program?*/? typedef?struct?aeEventLoop?{? ????int?maxfd;? ????long?long?timeEventNextId;? ????aeFileEvent?events[AE_SETSIZE];?/*?Registered?events?*/? ????aeFiredEvent?fired[AE_SETSIZE];?/*?Fired?events?*/? ????aeTimeEvent?*timeEventHead;? ????int?stop;? ????void?*apidata;?/*?This?is?used?for?polling?API?specific?data?*/? ????aeBeforeSleepProc?*beforesleep;? }?aeEventLoop; |
- maxfd是最大的文件描述符，主要用來(lái)判斷是否有文件事件需要處理（ae.c：293）和當(dāng)使用select 來(lái)處理網(wǎng)絡(luò)IO時(shí)作為select的參數(shù)（ae_select.c：50）。
- timeEventNextId 是下一個(gè)定時(shí)事件的ID。
- events[AE_SETSIZE]用于保存通過(guò)aeCreateFileEvent函數(shù)創(chuàng)建的文件事件，在sendReplyToClient函數(shù)和freeClient函數(shù)中通過(guò)調(diào)用aeDeleteFileEvent函數(shù)刪除已經(jīng)處理完的事件。
- fired[AE_SETSIZE]用于保存已經(jīng)觸發(fā)的文件事件，在對(duì)應(yīng)的網(wǎng)絡(luò)I/O函數(shù)中進(jìn)行賦值（epoll,select,kqueue），不會(huì)對(duì)fired進(jìn)行刪除操作，只會(huì)一直覆蓋原來(lái)的值。然后在aeProcessEvents函數(shù)中對(duì)已經(jīng)觸發(fā)的事件進(jìn)行處理。
- timeEventHead 是定時(shí)事件鏈表的頭，定時(shí)事件的存儲(chǔ)用鏈表實(shí)現(xiàn)。
- Stop 用于停止事件輪詢(xún)處理。
- apidata 用于保存輪詢(xún)api需要的數(shù)據(jù)，即aeApiState結(jié)構(gòu)體，對(duì)于epoll來(lái)說(shuō)，aeApiState結(jié)構(gòu)體的定義如下：
| typedef?struct?aeApiState?{? ????int?epfd;? ????struct?epoll_event?events[AE_SETSIZE];? }?aeApiState; |
- beforesleep 是每次進(jìn)入處理事件時(shí)執(zhí)行的函數(shù)。
創(chuàng)建事件輪詢(xún)
Redis.c：920
| ??server.el?=?aeCreateEventLoop();? Ae.c：55? aeEventLoop?*aeCreateEventLoop(void)?{? ????aeEventLoop?*eventLoop;? ????int?i;? ????eventLoop?=?zmalloc(sizeof(*eventLoop));? ????if?(!eventLoop)?return?NULL;? ????eventLoop->timeEventHead?=?NULL;? ????eventLoop->timeEventNextId?=?0;? ????eventLoop->stop?=?0;? ????eventLoop->maxfd?=?-1;? ????eventLoop->beforesleep?=?NULL;? ????if?(aeApiCreate(eventLoop)?==?-1)?{? ????????zfree(eventLoop);? ????????return?NULL;? ????}? /*?Events?with?mask?==?AE_NONE?are?not?set.?So?let's?initialize? ?*?the?vector?with?it.?*/? ????for?(i?=?0;?i?<?AE_SETSIZE;?i++)? ????????eventLoop->events[i].mask?=?AE_NONE;? ????return?eventLoop;? } |
綁定定時(shí)函數(shù)和有新連接時(shí)的回調(diào)函數(shù)
redis.c：973
| aeCreateTimeEvent(server.el,?1,?serverCron,?NULL,?NULL);? if?(server.ipfd?>?0?&&? ????aeCreateFileEvent(server.el,server.ipfd,AE_READABLE,? acceptTcpHandler,NULL)?==?AE_ERR)?oom("creating?file?event"); |
- aeCreateTimeEvent創(chuàng)建定時(shí)事件并綁定回調(diào)函數(shù)serverCron，這個(gè)定時(shí)事件第一次是超過(guò)1毫秒就有權(quán)限執(zhí)行，如果其他事件的處理時(shí)間比較長(zhǎng)，可能會(huì)出現(xiàn)超過(guò)一定時(shí)間都沒(méi)執(zhí)行情況。這里的1毫秒只是超過(guò)后有可執(zhí)行的權(quán)限，并不是一定會(huì)執(zhí)行。第一次執(zhí)行后，如果還要執(zhí)行，是由定時(shí)函數(shù)的返回值確定的，在processTimeEvents（ae.c：219）中，當(dāng)調(diào)用定時(shí)回調(diào)函數(shù)后，獲取定時(shí)回調(diào)函數(shù)的返回值，如果返回值不等于-1，則設(shè)置定時(shí)回調(diào)函數(shù)的下一次觸發(fā)時(shí)間為當(dāng)前時(shí)間加上定時(shí)回調(diào)函數(shù)的返回值，即調(diào)用間隔時(shí)間。serverCron的返回值是100ms，表明從二次開(kāi)始，每超過(guò)100ms就有權(quán)限執(zhí)行。（定時(shí)回調(diào)函數(shù)serverCron用于更新lru時(shí)鐘，更新服務(wù)器的狀態(tài)，打印一些服務(wù)器信息，符合條件的情況下對(duì)hash表進(jìn)行重哈希，啟動(dòng)后端寫(xiě)AOF或者檢查后端寫(xiě)AOF或者備份是否完成，檢查過(guò)期的KEY等等）
- aeCreateFileEvent創(chuàng)建監(jiān)聽(tīng)端口的socket fd的文件讀事件（即注冊(cè)網(wǎng)絡(luò)io事件）并綁定回調(diào)函數(shù)acceptTcpHandler。
進(jìn)入事件輪詢(xún)
初始化后將進(jìn)入事件輪詢(xún)
Redis.c：1733
| ????aeSetBeforeSleepProc(server.el,beforeSleep);? ????aeMain(server.el);? ????aeDeleteEventLoop(server.el); |
- 設(shè)置每次進(jìn)入事件處理前會(huì)執(zhí)行的函數(shù)beforeSleep。
- 進(jìn)入事件輪詢(xún)aeMain。
- 退出事件輪詢(xún)后刪除事件輪詢(xún)，釋放事件輪詢(xún)占用內(nèi)存aeDeleteEventLoop（不過(guò)沒(méi)在代碼中發(fā)現(xiàn)有執(zhí)行到這一步的可能，服務(wù)器接到shutdown命令時(shí)通過(guò)一些處理后直接就通過(guò)exit退出了，可能是我看錯(cuò)了，待驗(yàn)證）。
事件輪詢(xún)函數(shù)aeMain
看看aeMain的內(nèi)容
Ae.c：382
| void?aeMain(aeEventLoop?*eventLoop)?{? ????eventLoop->stop?=?0;? ????while?(!eventLoop->stop)?{? ????????if?(eventLoop->beforesleep?!=?NULL)? ????????????eventLoop->beforesleep(eventLoop);? ????????aeProcessEvents(eventLoop,?AE_ALL_EVENTS);? ????}? } |
- 每次進(jìn)入事件處理前，都會(huì)調(diào)用設(shè)置的beforesleep，beforeSleep函數(shù)主要是處理被阻塞的命令和根據(jù)配置寫(xiě)AOF。
- aeProcessEvents處理定時(shí)事件和網(wǎng)絡(luò)io事件。
啟動(dòng)完畢，等待客戶(hù)端請(qǐng)求
到進(jìn)入事件輪詢(xún)函數(shù)后，redis的啟動(dòng)工作就做完了，接下來(lái)就是等待客戶(hù)端的請(qǐng)求了。
接收請(qǐng)求
新連接到來(lái)時(shí)的回調(diào)函數(shù)
在綁定定時(shí)函數(shù)和有新連接時(shí)的回調(diào)函數(shù)中說(shuō)到了綁定有新連接來(lái)時(shí)的回調(diào)函數(shù)acceptTcpHandler，現(xiàn)在來(lái)看看這個(gè)函數(shù)的具體內(nèi)容
Networking.c：427
| void?acceptTcpHandler(aeEventLoop?*el,?int?fd,?void?*privdata,?int?mask)?{? ????int?cport,?cfd;? ????char?cip[128];? ????REDIS_NOTUSED(el);? ????REDIS_NOTUSED(mask);? ????REDIS_NOTUSED(privdata);? ????cfd?=?anetTcpAccept(server.neterr,?fd,?cip,?&cport);? ????if?(cfd?==?AE_ERR)?{? ????????redisLog(REDIS_WARNING,"Accepting?client?connection:?%s",?server.neterr);? ????????return;? ????}? ????redisLog(REDIS_VERBOSE,"Accepted?%s:%d",?cip,?cport);? ????acceptCommonHandler(cfd);? } |
- anetTcpAccept 函數(shù) accept新連接，返回的cfd是新連接的socket fd。
- acceptCommonHandler 函數(shù)是對(duì)新建立的連接進(jìn)行處理，這個(gè)函數(shù)在使用 unix socket 時(shí)也會(huì)被用到。
接收客戶(hù)端的新連接
接下來(lái)看看anetTcpAccept函數(shù)的具體內(nèi)容
| Anet.c：330? int?anetTcpAccept(char?*err,?int?s,?char?*ip,?int?*port)?{? ????int?fd;? ????struct?sockaddr_in?sa;? ????socklen_t?salen?=?sizeof(sa);? ????if?((fd?=?anetGenericAccept(err,s,(struct?sockaddr*)&sa,&salen))?==?ANET_ERR)? ????????return?ANET_ERR;? ????if?(ip)?strcpy(ip,inet_ntoa(sa.sin_addr));? ????if?(port)?*port?=?ntohs(sa.sin_port);? ????return?fd;? } |
再進(jìn)去anetGenericAccept 看看
Anet.c：313
| static?int?anetGenericAccept(char?*err,?int?s,?struct?sockaddr?*sa,?socklen_t?*len)?{? ????int?fd;? ????while(1)?{? ????????fd?=?accept(s,sa,len);? ????????if?(fd?==?-1)?{? ????????????if?(errno?==?EINTR)? ????????????????continue;? ????????????else?{? ????????????????anetSetError(err,?"accept:?%s",?strerror(errno));? ????????????????return?ANET_ERR;? ????????????}? ????????}? ????????break;? ????}? ????return?fd;? } |
- anetTcpAccept 函數(shù)中調(diào)用anetGenericAccept 函數(shù)進(jìn)行接收新連接，anetGenericAccept函數(shù)在 unix socket 的新連接處理中也會(huì)用到。
- anetTcpAccept 函數(shù)接收新連接后，獲取客戶(hù)端得ip，port 并返回。
創(chuàng)建redisClient進(jìn)行接收處理
anetTcpAccept 運(yùn)行完后，返回新連接的socket fd, 然后返回到調(diào)用函數(shù)acceptTcpHandler中，繼續(xù)執(zhí)行acceptCommonHandler 函數(shù)
Networking.c：403
| static?void?acceptCommonHandler(int?fd)?{? ????redisClient?*c;? ????if?((c?=?createClient(fd))?==?NULL)?{? ????????redisLog(REDIS_WARNING,"Error?allocating?resoures?for?the?client");? ????????close(fd);?/*?May?be?already?closed,?just?ingore?errors?*/? ????????return;? ????}? ????/*?If?maxclient?directive?is?set?and?this?is?one?client?more...?close?the? ?????*?connection.?Note?that?we?create?the?client?instead?to?check?before? ?????*?for?this?condition,?since?now?the?socket?is?already?set?in?nonblocking? ?????*?mode?and?we?can?send?an?error?for?free?using?the?Kernel?I/O?*/? ????if?(server.maxclients?&&?listLength(server.clients)?>?server.maxclients)?{? ????????char?*err?=?"-ERR?max?number?of?clients?reached\r\n";? ????????/*?That's?a?best?effort?error?message,?don't?check?write?errors?*/? ????????if?(write(c->fd,err,strlen(err))?==?-1)?{? ????????????/*?Nothing?to?do,?Just?to?avoid?the?warning...?*/? ????????}? ????????freeClient(c);? ????????return;? ????}? ????server.stat_numconnections++;? } |
- 創(chuàng)建一個(gè) redisClient 來(lái)處理新連接，每個(gè)連接都會(huì)創(chuàng)建一個(gè) redisClient 來(lái)處理。
- 如果配置了最大并發(fā)客戶(hù)端，則對(duì)現(xiàn)有的連接數(shù)進(jìn)行檢查和處理。
- 最后統(tǒng)計(jì)連接數(shù)。
綁定有數(shù)據(jù)可讀時(shí)的回調(diào)函數(shù)
Networking.c：15
| redisClient?*createClient(int?fd)?{? ????redisClient?*c?=?zmalloc(sizeof(redisClient));? ????c->bufpos?=?0;? ????anetNonBlock(NULL,fd);? ????anetTcpNoDelay(NULL,fd);? ????if?(aeCreateFileEvent(server.el,fd,AE_READABLE,? ????????readQueryFromClient,?c)?==?AE_ERR)? ????{? ????????close(fd);? ????????zfree(c);? ????????return?NULL;? ????}? ????selectDb(c,0);? ????c->fd?=?fd;? ????c->querybuf?=?sdsempty();? c->reqtype?=?0;? ...? } |
- 創(chuàng)建新連接的socket fd對(duì)應(yīng)的文件讀事件，綁定回調(diào)函數(shù)readQueryFromClient。
- 如果創(chuàng)建成功，則對(duì) redisClient 進(jìn)行一系列的初始化，因?yàn)?redisClient 是通用的，即不管是什么命令的請(qǐng)求，都是通過(guò)創(chuàng)建一個(gè) redisClient 來(lái)處理的，所以會(huì)有比較多的字段需要初始化。
createClient 函數(shù)執(zhí)行完后返回到調(diào)用處acceptCommonHandler函數(shù)，然后從acceptCommonHandler函數(shù)再返回到acceptTcpHandler函數(shù)。
接收請(qǐng)求完畢，準(zhǔn)備接收客戶(hù)端得數(shù)據(jù)
到此為止，新連接到來(lái)時(shí)的回調(diào)函數(shù)acceptTcpHandler執(zhí)行完畢，在這個(gè)回調(diào)函數(shù)中創(chuàng)建了一個(gè)redisClient來(lái)處理這個(gè)客戶(hù)端接下來(lái)的請(qǐng)求，并綁定了接收的新連接的讀文件事件。當(dāng)有數(shù)據(jù)可讀時(shí)，網(wǎng)絡(luò)i/o輪詢(xún)（比如epoll）會(huì)有事件觸發(fā)，此時(shí)綁定的回調(diào)函數(shù)readQueryFromClient將會(huì)調(diào)用來(lái)處理客戶(hù)端發(fā)送過(guò)來(lái)的數(shù)據(jù)。
讀取客戶(hù)端請(qǐng)求的數(shù)據(jù)
在綁定有數(shù)據(jù)可讀時(shí)的回調(diào)函數(shù)中的createClient函數(shù)中綁定了一個(gè)有數(shù)據(jù)可讀時(shí)的回調(diào)函數(shù)readQueryFromClient函數(shù)，現(xiàn)在看看這個(gè)函數(shù)的具體內(nèi)容
Networking.c：874
| void?readQueryFromClient(aeEventLoop?*el,?int?fd,?void?*privdata,?int?mask)?{? ????redisClient?*c?=?(redisClient*)?privdata;? ????char?buf[REDIS_IOBUF_LEN];? ????int?nread;? ????REDIS_NOTUSED(el);? ????REDIS_NOTUSED(mask);? ????server.current_client?=?c;? ????nread?=?read(fd,?buf,?REDIS_IOBUF_LEN);? ????if?(nread?==?-1)?{? ????????if?(errno?==?EAGAIN)?{? ????????????nread?=?0;? ????????}?else?{? ????????????redisLog(REDIS_VERBOSE,?"Reading?from?client:?%s",strerror(errno));? ????????????freeClient(c);? ????????????return;? ????????}? ????}?else?if?(nread?==?0)?{? ????????redisLog(REDIS_VERBOSE,?"Client?closed?connection");? ????????freeClient(c);? ????????return;? ????}? ????if?(nread)?{? ????????c->querybuf?=?sdscatlen(c->querybuf,buf,nread);? ????????c->lastinteraction?=?time(NULL);? ????}?else?{? ????????server.current_client?=?NULL;? ????????return;? ????}? ????if?(sdslen(c->querybuf)?>?server.client_max_querybuf_len)?{? ????????sds?ci?=?getClientInfoString(c),?bytes?=?sdsempty();? ????????bytes?=?sdscatrepr(bytes,c->querybuf,64);? ????????redisLog(REDIS_WARNING,"Closing?client?that?reached?max?query?buffer?length:?%s?(qbuf?initial?bytes:?%s)",?ci,?bytes);? ????????sdsfree(ci);? ????????sdsfree(bytes);? ????????freeClient(c);? ????????return;? ????}? ????processInputBuffer(c);? ????server.current_client?=?NULL;? } |
- 調(diào)用系統(tǒng)函數(shù)read來(lái)讀取客戶(hù)端傳送過(guò)來(lái)的數(shù)據(jù)，調(diào)用read后對(duì)讀取過(guò)程中被系統(tǒng)中斷的情況（nread == -1 && errno == EAGAIN），客戶(hù)端關(guān)閉的情況（nread == 0）進(jìn)行了判斷處理。
- 如果讀取的數(shù)據(jù)超過(guò)限制（1GB）則報(bào)錯(cuò)。
- 讀取完后進(jìn)入processInputBuffer進(jìn)行協(xié)議解析。
請(qǐng)求協(xié)議
從readQueryFromClient函數(shù)讀取客戶(hù)端傳過(guò)來(lái)的數(shù)據(jù)，進(jìn)入processInputBuffer函數(shù)進(jìn)行協(xié)議解析，可以把processInputBuffer函數(shù)看作是輸入數(shù)據(jù)的協(xié)議解析器
Networking.c：835
| void?processInputBuffer(redisClient?*c)?{? ????/*?Keep?processing?while?there?is?something?in?the?input?buffer?*/? ????while(sdslen(c->querybuf))?{? ????????/*?Immediately?abort?if?the?client?is?in?the?middle?of?something.?*/? ????????if?(c->flags?&?REDIS_BLOCKED?||?c->flags?&?REDIS_IO_WAIT)?return;? ????????/*?REDIS_CLOSE_AFTER_REPLY?closes?the?connection?once?the?reply?is? ?????????*?written?to?the?client.?Make?sure?to?not?let?the?reply?grow?after? ?????????*?this?flag?has?been?set?(i.e.?don't?process?more?commands).?*/? ????????if?(c->flags?&?REDIS_CLOSE_AFTER_REPLY)?return;? ????????/*?Determine?request?type?when?unknown.?*/? ????????if?(!c->reqtype)?{? ????????????if?(c->querybuf[0]?==?'*')?{? ????????????????c->reqtype?=?REDIS_REQ_MULTIBULK;? ????????????}?else?{? ????????????????c->reqtype?=?REDIS_REQ_INLINE;? ????????????}? ????????}? ????????if?(c->reqtype?==?REDIS_REQ_INLINE)?{? ????????????if?(processInlineBuffer(c)?!=?REDIS_OK)?break;? ????????}?else?if?(c->reqtype?==?REDIS_REQ_MULTIBULK)?{? ????????????if?(processMultibulkBuffer(c)?!=?REDIS_OK)?break;? ????????}?else?{? ????????????redisPanic("Unknown?request?type");? ????????}? ????????/*?Multibulk?processing?could?see?a?<=?0?length.?*/? ????????if?(c->argc?==?0)?{? ????????????resetClient(c);? ????????}?else?{? ????????????/*?Only?reset?the?client?when?the?command?was?executed.?*/? ????????????if?(processCommand(c)?==?REDIS_OK)? ????????????????resetClient(c);? ????????}? ????}? } |
- Redis支持兩種協(xié)議，一種是inline，一種是multibulk。inline協(xié)議是老協(xié)議，現(xiàn)在一般只在命令行下的redis客戶(hù)端使用，其他情況一般是使用multibulk協(xié)議。
- 如果客戶(hù)端傳送的數(shù)據(jù)的第一個(gè)字符時(shí)‘*’，那么傳送數(shù)據(jù)將被當(dāng)做multibulk協(xié)議處理，否則將被當(dāng)做inline協(xié)議處理。Inline協(xié)議的具體解析函數(shù)是processInlineBuffer，multibulk協(xié)議的具體解析函數(shù)是processMultibulkBuffer。
- 當(dāng)協(xié)議解析完畢，即客戶(hù)端傳送的數(shù)據(jù)已經(jīng)解析出命令字段和參數(shù)字段，接下來(lái)進(jìn)行命令處理，命令處理函數(shù)是processCommand。
Inline請(qǐng)求協(xié)議
Networking.c：679
| int?processInlineBuffer(redisClient?*c)?{? ????...? } |
- 根據(jù)空格分割客戶(hù)端傳送過(guò)來(lái)的數(shù)據(jù)，把傳送過(guò)來(lái)的命令和參數(shù)保存在argv數(shù)組中，把參數(shù)個(gè)數(shù)保存在argc中，argc的值包括了命令參數(shù)本身。即set key value命令，argc的值為3。詳細(xì)解析見(jiàn)協(xié)議詳解
Multibulk請(qǐng)求協(xié)議
Multibulk協(xié)議比inline協(xié)議復(fù)雜，它是二進(jìn)制安全的，即傳送數(shù)據(jù)可以包含不安全字符。Inline協(xié)議不是二進(jìn)制安全的，比如，如果set key value命令中的key或value包含空白字符，那么inline協(xié)議解析時(shí)將會(huì)失敗，因?yàn)榻馕龀鰜?lái)的參數(shù)個(gè)數(shù)與命令需要的的參數(shù)個(gè)數(shù)會(huì)不一致。
協(xié)議格式
| *<number?of?arguments>?CR?LF? $<number?of?bytes?of?argument?1>?CR?LF? <argument?data>?CR?LF? ...? $<number?of?bytes?of?argument?N>?CR?LF? <argument?data>?CR?LF |
協(xié)議舉例
| *3? $3? SET? $5? mykey? $7? myvalue |
具體解析代碼位于
Networking.c：731
| int?processMultibulkBuffer(redisClient?*c)?{? ...? } |
詳細(xì)解析見(jiàn)協(xié)議詳解
處理命令
當(dāng)協(xié)議解析完畢，則表示客戶(hù)端的命令輸入已經(jīng)全部讀取并已經(jīng)解析成功，接下來(lái)就是執(zhí)行客戶(hù)端命令前的準(zhǔn)備和執(zhí)行客戶(hù)端傳送過(guò)來(lái)的命令
Redis.c：1062
| /*?If?this?function?gets?called?we?already?read?a?whole? ?*?command,?argments?are?in?the?client?argv/argc?fields.? ?*?processCommand()?execute?the?command?or?prepare?the? ?*?server?for?a?bulk?read?from?the?client.? ?*? ?*?If?1?is?returned?the?client?is?still?alive?and?valid?and? ?*?and?other?operations?can?be?performed?by?the?caller.?Otherwise? ?*?if?0?is?returned?the?client?was?destroied?(i.e.?after?QUIT).?*/? int?processCommand(redisClient?*c)?{? ...? ?/*?Now?lookup?the?command?and?check?ASAP?about?trivial?error?conditions? ??*?such?as?wrong?arity,?bad?command?name?and?so?forth.?*/? c->cmd?=?c->lastcmd?=?lookupCommand(c->argv[0]->ptr);? ...? call(c);? ...? } |
- lookupCommand先根據(jù)客戶(hù)端傳送過(guò)來(lái)的數(shù)據(jù)查找該命令并找到命令的對(duì)應(yīng)處理函數(shù)。
- Call函數(shù)調(diào)用該命令函數(shù)來(lái)處理命令，命令與對(duì)應(yīng)處理函數(shù)的綁定位于。
Redi.c：72
| struct?redisCommand?*commandTable;? struct?redisCommand?readonlyCommandTable[]?=?{? {"get",getCommand,2,0,NULL,1,1,1},? ...? } |
回復(fù)請(qǐng)求
回復(fù)請(qǐng)求位于對(duì)應(yīng)的命令中，以get命令為例
T_string.c：67
| void?getCommand(redisClient?*c)?{? ????getGenericCommand(c);? } |
T_string.c：52
| int?getGenericCommand(redisClient?*c)?{? ????robj?*o;? ????if?((o?=?lookupKeyReadOrReply(c,c->argv[1],shared.nullbulk))?==?NULL)? ????????return?REDIS_OK;? ????if?(o->type?!=?REDIS_STRING)?{? ????????addReply(c,shared.wrongtypeerr);? ????????return?REDIS_ERR;? ????}?else?{? ????????addReplyBulk(c,o);? ????????return?REDIS_OK;? ????}? } |
- getGenericCommand在getset 命令中也會(huì)用到。
- lookupKeyReadOrReply是以讀數(shù)據(jù)為目的查詢(xún)key函數(shù)，并且如果該key不存在，則在該函數(shù)中做不存在的回包處理。
- 如果該key存在，則返回該key對(duì)應(yīng)的數(shù)據(jù)，addReply函數(shù)以及以addReply函數(shù)開(kāi)頭的都是回包函數(shù)。
綁定寫(xiě)數(shù)據(jù)的回調(diào)函數(shù)
接下來(lái)看看addReply函數(shù)里的內(nèi)容
Networking.c：190
| void?addReply(redisClient?*c,?robj?*obj)?{? ????if?(_installWriteEvent(c)?!=?REDIS_OK)?return;? ????...? } |
Networking.c：64
| int?_installWriteEvent(redisClient?*c)?{? ????if?(c->fd?<=?0)?return?REDIS_ERR;? ????if?(c->bufpos?==?0?&&?listLength(c->reply)?==?0?&&? ????????(c->replstate?==?REDIS_REPL_NONE?||? ?????????c->replstate?==?REDIS_REPL_ONLINE)?&&? ????????aeCreateFileEvent(server.el,?c->fd,?AE_WRITABLE,? ????????sendReplyToClient,?c)?==?AE_ERR)?return?REDIS_ERR;? ????return?REDIS_OK;? } |
- addReply函數(shù)一進(jìn)來(lái)就先調(diào)用綁定寫(xiě)數(shù)據(jù)的回調(diào)函數(shù)installWriteEvent。
- installWriteEvent函數(shù)中創(chuàng)建了一個(gè)文件寫(xiě)事件和綁定寫(xiě)事件的回調(diào)函數(shù)為sendReplyToClient。
準(zhǔn)備寫(xiě)的數(shù)據(jù)內(nèi)容
??? addReply函數(shù)一進(jìn)來(lái)后就綁定寫(xiě)數(shù)據(jù)的回調(diào)函數(shù)，接下來(lái)就是準(zhǔn)備寫(xiě)的數(shù)據(jù)內(nèi)容
Networking.c：190
| void?addReply(redisClient?*c,?robj?*obj)?{? ????if?(_installWriteEvent(c)?!=?REDIS_OK)?return;? ????redisAssert(!server.vm_enabled?||?obj->storage?==?REDIS_VM_MEMORY);? ????/*?This?is?an?important?place?where?we?can?avoid?copy-on-write? ?????*?when?there?is?a?saving?child?running,?avoiding?touching?the? ?????*?refcount?field?of?the?object?if?it's?not?needed.? ?????*? ?????*?If?the?encoding?is?RAW?and?there?is?room?in?the?static?buffer? ?????*?we'll?be?able?to?send?the?object?to?the?client?without? ?????*?messing?with?its?page.?*/? ????if?(obj->encoding?==?REDIS_ENCODING_RAW)?{? ????????if?(_addReplyToBuffer(c,obj->ptr,sdslen(obj->ptr))?!=?REDIS_OK)? ????????????_addReplyObjectToList(c,obj);? ????}?else?{? ????????/*?FIXME:?convert?the?long?into?string?and?use?_addReplyToBuffer()? ?????????*?instead?of?calling?getDecodedObject.?As?this?place?in?the? ?????????*?code?is?too?performance?critical.?*/? ????????obj?=?getDecodedObject(obj);? ????????if?(_addReplyToBuffer(c,obj->ptr,sdslen(obj->ptr))?!=?REDIS_OK)? ????????????_addReplyObjectToList(c,obj);? ????????decrRefCount(obj);? ????}? } |
- 先嘗試把要返回的內(nèi)容添加到發(fā)送數(shù)據(jù)緩沖區(qū)中（redisClient->buf），如果該緩沖區(qū)的大小已經(jīng)放不下這次想放進(jìn)去的數(shù)據(jù)，或者已經(jīng)有數(shù)據(jù)在排隊(duì)（redisClient->reply 鏈表不為空），則把數(shù)據(jù)添加到發(fā)送鏈表的尾部。
給客戶(hù)端答復(fù)數(shù)據(jù)
在綁定寫(xiě)數(shù)據(jù)的回調(diào)函數(shù)中看到綁定了回調(diào)函數(shù)sendReplyToClient，現(xiàn)在來(lái)看看這個(gè)函數(shù)的主要內(nèi)容
Networking.c：566
| void?sendReplyToClient(aeEventLoop?*el,?int?fd,?...)?{? ????...? while(c->bufpos?>?0?||?listLength(c->reply))?{? ????...? ????if(c->bufpos?>?0){? ????????...? ????????????nwritten=write(fd,...,c->bufpos-c->sentlen);? ????????????...? ????????}?else?{? ????????????o?=?listNodeValue(listFirst(c->reply));? ????????????...? ????????????nwritten=write(fd,...,objlen-c->sentlen);? ????????????...? ????????}? ????}? } |
- 通過(guò)調(diào)用系統(tǒng)函數(shù)write給客戶(hù)端發(fā)送數(shù)據(jù)，如果緩沖區(qū)有數(shù)據(jù)就把緩沖區(qū)的數(shù)據(jù)發(fā)送給客戶(hù)端，緩沖區(qū)的數(shù)據(jù)發(fā)送完了，如果有排隊(duì)數(shù)據(jù)，則繼續(xù)發(fā)送。
退出
Redis 服務(wù)器的退出是通過(guò)shutdown命令來(lái)退出的，退出前會(huì)做一系列的清理工作
Db.c：347
| void?shutdownCommand(redisClient?*c)?{? ????if?(prepareForShutdown()?==?REDIS_OK)? ????????exit(0);? ????addReplyError(c,"Errors?trying?to?SHUTDOWN.?Check?logs.");? } |
總結(jié)
框架從啟動(dòng)，接收請(qǐng)求，讀取客戶(hù)端數(shù)據(jù)，請(qǐng)求協(xié)議解析，處理命令，回復(fù)請(qǐng)求，退出對(duì)redis運(yùn)行的整個(gè)流程做了一個(gè)梳理。對(duì)整個(gè)redis的運(yùn)作和框架有了一個(gè)初步的了解。
總結(jié)
以上是生活随笔為你收集整理的Redis源码简要分析的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： cJSON库源码分析
- 下一篇： 移动开发框架剖析