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

命令請求的執(zhí)行過程 當(dāng)服務(wù)器與客戶端的連接套接字因為客戶端的寫入而變得可讀時，服務(wù)器將調(diào)用命令請求處理器來執(zhí)行以下操作：

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

-2、對輸入緩沖區(qū)中的命令請求進行分析，提取出命令請求中包含的命令參數(shù)，以及命令參數(shù)的個數(shù)，然后分別將參數(shù)和參數(shù)個數(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，如果是的話，說明用戶輸入的命令名字找不到實現(xiàn)，返回錯誤；

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

serverCron函數(shù)

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

功能：

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

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

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

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

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

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

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

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

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

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

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

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

初始化服務(wù)器

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

-2、載入配置選項：命令行的參數(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è)置進程信號處理器，創(chuàng)建愛你共享對象，打開服務(wù)器監(jiān)聽端口，為serverCron創(chuàng)建時間事件，如果aof打開，那么打開現(xiàn)有aof文件，否則創(chuàng)建，初始化服務(wù)器的后臺I/O模塊bio。

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

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

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

server.c