Redis服務(wù)器負(fù)責(zé)與多個(gè)客戶端建立網(wǎng)絡(luò)連接，處理客戶端發(fā)送三個(gè)的命令請(qǐng)求，在數(shù)據(jù)庫中爆粗你客戶單執(zhí)行命令所產(chǎn)生的數(shù)據(jù)，并通過資源管理來維持服務(wù)器自身的運(yùn)轉(zhuǎn)。

命令請(qǐng)求的執(zhí)行過程 當(dāng)服務(wù)器與客戶端的連接套接字因?yàn)榭蛻舳说膶懭攵兊每勺x時(shí)，服務(wù)器將調(diào)用命令請(qǐng)求處理器來執(zhí)行以下操作：

-1、讀取套接字中協(xié)議格式的命令請(qǐng)求，并將其保存到客戶端狀態(tài)的輸入緩沖區(qū)中；

-2、對(duì)輸入緩沖區(qū)中的命令請(qǐng)求進(jìn)行分析，提取出命令請(qǐng)求中包含的命令參數(shù)，以及命令參數(shù)的個(gè)數(shù)，然后分別將參數(shù)和參數(shù)個(gè)數(shù)保存到客戶單狀態(tài)的argv屬性和argc屬性里面；

-3、調(diào)用命令執(zhí)行器，執(zhí)行客戶單指定的命令。

命令執(zhí)行器做的第一件事就是根據(jù)客戶單狀態(tài)的argv［0］參數(shù)，在命令表中查找參數(shù)所指定的命令，并將命令保存到客戶端狀態(tài)的cmd屬性中。

命令執(zhí)行器的預(yù)備操作：

-1、檢查客戶端狀態(tài)的cmd指針是否指向NULL，如果是的話，說明用戶輸入的命令名字找不到實(shí)現(xiàn)，返回錯(cuò)誤；

-2、根據(jù)cmd屬性指向的arity屬性，檢查命令參數(shù)是否正確，不正確返回錯(cuò)誤；

-3、檢查客戶的江岸是否已經(jīng)通過了身份驗(yàn)證，未通過身份驗(yàn)證的客戶單只能執(zhí)行auth命令，如果未通過客戶端執(zhí)行其他命令，返回錯(cuò)誤；

-4，如果服務(wù)器打開了maxmemory功能，那么在執(zhí)行命令之前，先檢查副武器的內(nèi)存占用情況，并在有需要的時(shí)候回收內(nèi)存，從而使得接下來的命令可以順利執(zhí)行，如果回收失敗，那么返回錯(cuò)誤；

-5、如果服務(wù)器上一次執(zhí)行bgsave出錯(cuò)，并且打開了stop-writes-on-bgsave-error功能，而且即將執(zhí)行一個(gè)寫命令，返回錯(cuò)誤；

-6、如果客戶端正在訂閱頻道，或者正在訂閱模式，那么服務(wù)器智慧執(zhí)行客戶端發(fā)來的訂閱相關(guān)命令；

-7、如果服務(wù)器正在進(jìn)行數(shù)據(jù)載入，那么客戶端發(fā)送的命令必須帶有l(wèi)標(biāo)識(shí)才會(huì)執(zhí)行，否則拒絕執(zhí)行；

-8、如果服務(wù)器因?yàn)閳?zhí)行l(wèi)ua腳本而超時(shí)并進(jìn)入阻塞狀態(tài)，那么服務(wù)器智慧執(zhí)行客戶端發(fā)來的shutdown nosave命令和script kill命令，其他拒絕；

-9、如果客戶端正在進(jìn)行事務(wù)，那么服務(wù)器智慧執(zhí)行客戶端發(fā)來的事務(wù)相關(guān)命令，其他命令進(jìn)隊(duì)列；

-10、如果服務(wù)器打開了監(jiān)視器功能，那么服務(wù)器會(huì)將要執(zhí)行的命令和參數(shù)等信息發(fā)送給監(jiān)視器。

調(diào)用命令實(shí)現(xiàn)函數(shù)

前面的操作已經(jīng)將處理器注冊(cè)到了cmd中，執(zhí)行后將回復(fù)保存到客戶端的輸出緩沖區(qū)中。

執(zhí)行后續(xù)工作

-1、如果服務(wù)器開啟了慢查詢?nèi)罩竟δ?，那么man插敘你日志模塊會(huì)檢查是否需要為剛剛執(zhí)行完的命令請(qǐng)求添加一條新的慢查詢?nèi)罩尽?/p>

-2、根據(jù)執(zhí)行命令所耗費(fèi)的時(shí)長，更新redisCommand的毫秒屬性，并將命令的引用計(jì)數(shù)+1；

-3、如果服務(wù)器開啟了AOF持久化功能，那么會(huì)將剛剛執(zhí)行的命令請(qǐng)求寫入到AOF緩沖區(qū)中；

-4、如果有其他從服務(wù)器正在復(fù)制當(dāng)前這個(gè)服務(wù)器，那么服務(wù)器會(huì)將剛剛執(zhí)行的命令傳遞給所有從服務(wù)器。

將命令回復(fù)發(fā)送給客戶端

當(dāng)客戶單的套接字變?yōu)榭蓪憼顟B(tài)時(shí)，服務(wù)器就會(huì)執(zhí)行命令回復(fù)處理器，將保存在客戶端輸出緩沖區(qū)中的命令回復(fù)發(fā)送給客戶端，發(fā)送完畢后，回復(fù)處理器會(huì)清空客戶單狀態(tài)的輸出緩沖區(qū)，為處理下一個(gè)命令請(qǐng)求做好準(zhǔn)備。

serverCron函數(shù)

redis服務(wù)器中的serverCron函數(shù)默認(rèn)每隔100ms執(zhí)行一次，這個(gè)函數(shù)負(fù)責(zé)管理服務(wù)器資源，并保持服務(wù)器自身的良好運(yùn)轉(zhuǎn)。

功能：

-1、更新服務(wù)器時(shí)間緩存：會(huì)以100ms的頻率更新unixtime和msTIme；

-2、更新lru時(shí)鐘：服務(wù)器狀態(tài)中的lruclouk屬性保存了副武器的lru時(shí)鐘，默認(rèn)每10秒更新一次的時(shí)鐘緩存，用于計(jì)算鍵的空轉(zhuǎn)時(shí)長，通過與對(duì)象的lru對(duì)比；

-3、更新服務(wù)器每秒執(zhí)行命令次數(shù)：100ms的頻率執(zhí)行；

-4、更新服務(wù)器內(nèi)存峰值記錄：stat_peak_memory記錄了服務(wù)器內(nèi)存峰值的大小，每次執(zhí)行serverCron都會(huì)查看當(dāng)前的內(nèi)存數(shù)量進(jìn)行對(duì)比，判斷是否覆蓋。

-5、處理SIGTERM信號(hào)：在啟動(dòng)時(shí)，redis會(huì)為服務(wù)器進(jìn)程的sigterm信號(hào)關(guān)聯(lián)處理器，處理器會(huì)在服務(wù)器接到信號(hào)時(shí)，打開shutdown_asap標(biāo)識(shí)，每次運(yùn)行serverCron，程序都會(huì)檢測(cè)這個(gè)標(biāo)識(shí)，判斷知否關(guān)閉服務(wù)器。

-6、管理客戶端資源：每次調(diào)用會(huì)檢查超時(shí)客戶端并釋放，如果客戶單在上一次執(zhí)行命令后，輸入緩沖區(qū)的大小超過了一定的長度，那么程序會(huì)釋放客戶單當(dāng)前的輸入緩沖區(qū)，并重新創(chuàng)建一個(gè)默認(rèn)大小的輸入緩沖區(qū)，防止消耗過多內(nèi)存。

-7、管理數(shù)據(jù)庫資源：每次執(zhí)行會(huì)調(diào)用databasesCron，它會(huì)檢查一部分?jǐn)?shù)據(jù)庫，刪除過期鍵，在必要時(shí)對(duì)字典進(jìn)行收縮操作；

-8、執(zhí)行被延遲的BGREWRITEAOF：在執(zhí)行bgsave期間，客戶端發(fā)來bgrewriteaof命令，那么這個(gè)命令會(huì)延遲到bgsave命令執(zhí)行完畢之后；

-9、檢查持久化操作的運(yùn)行狀態(tài)：只要rdb_child_pid和aof_child_pid其中一個(gè)不為-1，就會(huì)執(zhí)行一次wait3，檢查子進(jìn)程是否有信號(hào)發(fā)來服務(wù)器進(jìn)程。其他情況會(huì)判斷是否有bgrewriteaof被延遲了，或者自動(dòng)保存條件被觸發(fā)，或者aof重寫條件被觸發(fā)；

-10、將aof緩沖區(qū)的內(nèi)容寫入aof文件；

-11、關(guān)閉異步客戶端；

-12、增加cronloops計(jì)數(shù)器，每次執(zhí)行都會(huì)+1；

初始化服務(wù)器

-1、初始化服務(wù)器狀態(tài)結(jié)構(gòu)：設(shè)置服務(wù)器運(yùn)行id，設(shè)置默認(rèn)配置文件路徑，設(shè)置默認(rèn)服務(wù)器頻率，設(shè)置服務(wù)器運(yùn)行架構(gòu)，設(shè)置默認(rèn)端口號(hào)，設(shè)置默認(rèn)rdb條件和aof條件，初始化lru時(shí)鐘，創(chuàng)建愛你命令表；

-2、載入配置選項(xiàng)：命令行的參數(shù)，配置文件的設(shè)置；

-3、初始化服務(wù)器數(shù)據(jù)結(jié)構(gòu)：創(chuàng)建客戶端狀態(tài)的鏈表，創(chuàng)建數(shù)據(jù)庫數(shù)組，創(chuàng)建訂閱字典，創(chuàng)建訂閱模式的鏈表，更改慢查詢?nèi)罩镜膕lowlog屬性，更改lua屬性； 為服務(wù)器設(shè)置進(jìn)程信號(hào)處理器，創(chuàng)建愛你共享對(duì)象，打開服務(wù)器監(jiān)聽端口，為serverCron創(chuàng)建時(shí)間事件，如果aof打開，那么打開現(xiàn)有aof文件，否則創(chuàng)建，初始化服務(wù)器的后臺(tái)I/O模塊bio。

還原數(shù)據(jù)庫狀態(tài)

如果開啟了aof，使用aof文件還原數(shù)據(jù)庫狀態(tài)，否則使用rdb文件。

執(zhí)行事件循環(huán)

server.c