在redis.c的initServerConfig()方法中,通過調用dictCreate方法初始化server端的命令表。這個命令表是一個hashtable,可以通過key找到相關的命令: initServer()函數在初始化服務端的基本配置時,已經提前創建了客戶端的回調函數。具體的調用為:1.創 ...
在redis.c的initServerConfig()方法中,通過調用dictCreate方法初始化server端的命令表。這個命令表是一個hashtable,可以通過key找到相關的命令:
/* Command table -- we initiialize it here as it is part of the * initial configuration, since command names may be changed via * redis.conf using the rename-command directive. */ server.commands = dictCreate(&commandTableDictType, NULL); server.orig_commands = dictCreate(&commandTableDictType, NULL); populateCommandTable(); server.delCommand = lookupCommandByCString("del"); server.multiCommand = lookupCommandByCString("multi"); server.lpushCommand = lookupCommandByCString("lpush"); server.lpopCommand = lookupCommandByCString("lpop"); server.rpopCommand = lookupCommandByCString("rpop"); |
initServer()函數在初始化服務端的基本配置時,已經提前創建了客戶端的回調函數。具體的調用為:
1.創建客戶端的文件讀事件的回調:acceptTcpHandler/acceptUnixHandler
2.一旦接收到客戶端連接請求後,調用acceptCommonHandler()方法。在接收到客戶端請求後,可以得到客戶端的fd(file description),這個fd在調用acceptCommonHandler時會傳入。
3.acceptCommonHandler內部根據fd調用createClient創建redis客戶端的上下文信息。
4.createClient內部又創建了一個事件回調函數readQueryFromClient,用於讀取客戶端的傳入的信息。
5.readQueryFromClient從客戶端讀取實際的請求內容,然後會做一個初步判斷客戶端的請求內容是否合理。不合理的請求在這裡直接被攔截處理了。這裡判斷請求是否合理主要是判斷網路層面的內容是否合理。如果網路層相關的請求合理的話,調用processInputBuffer方法解析客戶端的請求類型。
6.processInputBuffer會解析客戶端的reqtype是inline還是multibulk的。如果是inline的,調用processInlineBuffer函數類解析出argv/argc;否則調用processMultibulkBuffer。如果argc沒有,直接重置客戶端;否則調用processCommand方法處理客戶端的命令。
7.processCommand首先根據argv的內容,然後調用lookupCommand()方法從server.commands中找到需要執行的命令,然後將找到的命令賦值到client的cmd和lastcmd欄位上。
c->cmd = c->lastcmd = lookupCommand(c->argv[0]->ptr);
8.找到相關的命令後,調用call方法,執行客戶端的命令。執行命令很簡單,因為上一步中已經找到了客戶端的cmd了。每個命令都有一個proc方法,方法接受一個redisclient的參數。這裡只需要調用c->cmd->proc(),然後將c傳入即可。
9.至此,redis執行客戶端命令的過程就算結束了。