這篇文章主要介紹Memcached中，基於libevent構造的主執行緒和worker執行緒所處理連線的狀態互相轉換的過程（不涉資料的存取等操作），也就是drive_machine的主要業務邏輯了。狀態轉換過程沒有涉及所有狀態，同時，由於自己能力問題，一些狀態轉換還可能有錯，還請各位前輩指正。轉換條件限定：TCP，ASCII協議。（狀態不包括conn_swallow，二進位制協議才會用到此狀態）

1 總攬

首先介紹連線，連線是Memcached自己定義的連線conn。的所有狀態，drive_machine()主要就是對這些狀態的轉換進行操作：

enum conn_states {
    conn_listening,  /**< the socket which listens for connections /主執行緒等待連結*/
    conn_new_cmd,    /**< Prepare connection for next command /worker執行緒等待命令*/
    conn_waiting,    /**< waiting for a readable socket /worker執行緒等待sdf中有可讀資訊*/
    conn_read,       /**< reading in a command line /worker執行緒讀命令*/
    conn_parse_cmd,  /**< try to parse a command from the input buffer /woker執行緒*/
    conn_write,      /**< writing out a simple response /worker執行緒*/
    conn_nread,      /**< reading in a fixed number of bytes /worker執行緒由於命令沒讀完，繼續讀取*/
    conn_swallow,    /**< swallowing unnecessary bytes w/o storing /worker執行緒，ASCII協議不涉及此狀態*/
    conn_closing,    /**< closing this connection */
    conn_mwrite,     /**< writing out many items sequentially /worker執行緒，響應內容中寫出*/
    conn_max_state   /**< Max state value (used for assertion) /用於標記conn_states邊界，超出說明states有錯*/
};

在Memcached.c的main()中，主執行緒以及worker執行緒完成必要初始化，繫結相應libevent事件，隨後主執行緒監聽繫結監聽相應埠，正式做好迴圈的準備。下圖是總體連線狀態的總體轉換圖。

2 接收連線分發給worker執行緒

1. 主執行緒初始化後，連線便進入conn_listening狀態，等待連線。
2. 當有連線連入，主執行緒通過dispatch_conn_new()向管道寫入字元c，將連線分發給某個worker執行緒，worker執行緒收到，連線進入conn_new_cmd等待狀態。

3 資料讀入

1. conn_new_cmd等待新的連線，當連線寫入時，如果當前請求過多，可能對其他worker執行緒造成飢餓，更改事件型別為EV_WRITE，退出。
2. 如果連線不多，且有未讀資料，說明上一次有未處理完的命令，進入conn_parse_cmd，以便繼續處理命令。
3. 如果連線不多，且是新連線，表明沒有未讀資料，則連線進入conn_waiting狀態等待資料（命令）到來。
4. conn_waiting，執行緒等待連線中的後續資料，如果有資料會設定當前socket fd為讀事件EV_READ，確保後續內容的讀入。在conn_read中，呼叫try_read_network()嘗試從socket fd中讀東西，如果沒有資料則返回conn_waiting，如果有資料則進入conn_parse_cmd，等待處理命令。

4 命令解析

相關推薦