Redis服務(wù)器負(fù)責(zé)與多個(gè)客戶端建立網(wǎng)絡(luò)連接,處理客戶端發(fā)送三個(gè)的命令請(qǐng)求,在數(shù)據(jù)庫(kù)中爆粗你客戶單執(zhí)行命令所產(chǎn)生的數(shù)據(jù),并通過(guò)資源管理來(lái)維持服務(wù)器自身的運(yùn)轉(zhuǎn)。
命令請(qǐng)求的執(zhí)行過(guò)程 當(dāng)服務(wù)器與客戶端的連接套接字因?yàn)榭蛻舳说膶?xiě)入而變得可讀時(shí),服務(wù)器將調(diào)用命令請(qǐng)求處理器來(lái)執(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,如果是的話,說(shuō)明用戶輸入的命令名字找不到實(shí)現(xiàn),返回錯(cuò)誤;
-2、根據(jù)cmd屬性指向的arity屬性,檢查命令參數(shù)是否正確,不正確返回錯(cuò)誤;
-3、檢查客戶的江岸是否已經(jīng)通過(guò)了身份驗(yàn)證,未通過(guò)身份驗(yàn)證的客戶單只能執(zhí)行auth命令,如果未通過(guò)客戶端執(zhí)行其他命令,返回錯(cuò)誤;
-4,如果服務(wù)器打開(kāi)了maxmemory功能,那么在執(zhí)行命令之前,先檢查副武器的內(nèi)存占用情況,并在有需要的時(shí)候回收內(nèi)存,從而使得接下來(lái)的命令可以順利執(zhí)行,如果回收失敗,那么返回錯(cuò)誤;
-5、如果服務(wù)器上一次執(zhí)行bgsave出錯(cuò),并且打開(kāi)了stop-writes-on-bgsave-error功能,而且即將執(zhí)行一個(gè)寫(xiě)命令,返回錯(cuò)誤;
-6、如果客戶端正在訂閱頻道,或者正在訂閱模式,那么服務(wù)器智慧執(zhí)行客戶端發(fā)來(lái)的訂閱相關(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ā)來(lái)的shutdown nosave命令和script kill命令,其他拒絕;
-9、如果客戶端正在進(jìn)行事務(wù),那么服務(wù)器智慧執(zhí)行客戶端發(fā)來(lái)的事務(wù)相關(guān)命令,其他命令進(jìn)隊(duì)列;
-10、如果服務(wù)器打開(kāi)了監(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ù)器開(kāi)啟了慢查詢?nèi)罩竟δ?,那么man插敘你日志模塊會(huì)檢查是否需要為剛剛執(zhí)行完的命令請(qǐng)求添加一條新的慢查詢?nèi)罩尽?/p>
-2、根據(jù)執(zhí)行命令所耗費(fèi)的時(shí)長(zhǎng),更新redisCommand的毫秒屬性,并將命令的引用計(jì)數(shù)+1;
-3、如果服務(wù)器開(kāi)啟了AOF持久化功能,那么會(huì)將剛剛執(zhí)行的命令請(qǐng)求寫(xiě)入到AOF緩沖區(qū)中;
-4、如果有其他從服務(wù)器正在復(fù)制當(dāng)前這個(gè)服務(wù)器,那么服務(wù)器會(huì)將剛剛執(zhí)行的命令傳遞給所有從服務(wù)器。
將命令回復(fù)發(fā)送給客戶端
當(dāng)客戶單的套接字變?yōu)榭蓪?xiě)狀態(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í)長(zhǎng),通過(guò)與對(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í),打開(kāi)shutdown_asap標(biāo)識(shí),每次運(yùn)行serverCron,程序都會(huì)檢測(cè)這個(gè)標(biāo)識(shí),判斷知否關(guān)閉服務(wù)器。
-6、管理客戶端資源:每次調(diào)用會(huì)檢查超時(shí)客戶端并釋放,如果客戶單在上一次執(zhí)行命令后,輸入緩沖區(qū)的大小超過(guò)了一定的長(zhǎng)度,那么程序會(huì)釋放客戶單當(dāng)前的輸入緩沖區(qū),并重新創(chuàng)建一個(gè)默認(rèn)大小的輸入緩沖區(qū),防止消耗過(guò)多內(nèi)存。
-7、管理數(shù)據(jù)庫(kù)資源:每次執(zhí)行會(huì)調(diào)用databasesCron,它會(huì)檢查一部分?jǐn)?shù)據(jù)庫(kù),刪除過(guò)期鍵,在必要時(shí)對(duì)字典進(jìn)行收縮操作;
-8、執(zhí)行被延遲的BGREWRITEAOF:在執(zhí)行bgsave期間,客戶端發(fā)來(lái)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ā)來(lái)服務(wù)器進(jìn)程。其他情況會(huì)判斷是否有bgrewriteaof被延遲了,或者自動(dòng)保存條件被觸發(fā),或者aof重寫(xiě)條件被觸發(fā);
-10、將aof緩沖區(qū)的內(nèi)容寫(xiě)入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)建愛(ài)你命令表;
-2、載入配置選項(xiàng):命令行的參數(shù),配置文件的設(shè)置;
-3、初始化服務(wù)器數(shù)據(jù)結(jié)構(gòu):創(chuàng)建客戶端狀態(tài)的鏈表,創(chuàng)建數(shù)據(jù)庫(kù)數(shù)組,創(chuàng)建訂閱字典,創(chuàng)建訂閱模式的鏈表,更改慢查詢?nèi)罩镜膕lowlog屬性,更改lua屬性; 為服務(wù)器設(shè)置進(jìn)程信號(hào)處理器,創(chuàng)建愛(ài)你共享對(duì)象,打開(kāi)服務(wù)器監(jiān)聽(tīng)端口,為serverCron創(chuàng)建時(shí)間事件,如果aof打開(kāi),那么打開(kāi)現(xiàn)有aof文件,否則創(chuàng)建,初始化服務(wù)器的后臺(tái)I/O模塊bio。
還原數(shù)據(jù)庫(kù)狀態(tài)
如果開(kāi)啟了aof,使用aof文件還原數(shù)據(jù)庫(kù)狀態(tài),否則使用rdb文件。
執(zhí)行事件循環(huán)
server.c
評(píng)論
查看更多