摘要：命令發(fā)送格式參數(shù)數(shù)量參數(shù)的字節(jié)數(shù)量參數(shù)的數(shù)據(jù)參數(shù)的字節(jié)數(shù)量參數(shù)的數(shù)據(jù)其中表示舉個例子格式化輸出說明開頭，表示有多少個參數(shù)，例如表示有個參數(shù)開頭，表示參數(shù)的字節(jié)長度，例如表示有個字節(jié)，表示有個字節(jié)每行結(jié)尾通信協(xié)議為回復狀態(tài)回復的第一個字節(jié)是，

*<參數(shù)數(shù)量> CRLF
$<參數(shù) 1 的字節(jié)數(shù)量> CRLF
<參數(shù) 1 的數(shù)據(jù)> CRLF
...
$<參數(shù) N 的字節(jié)數(shù)量> CRLF
<參數(shù) N 的數(shù)據(jù)> CRLF
其中CRLF表示 rn

舉個例子：set name wuzhc

格式化輸出：

*3
$3
set
$4
name
$5
wuzhc

說明：

*開頭，表示有多少個參數(shù)，例如*3表示有3個參數(shù)（set, name, wuzhc）

$開頭，表示參數(shù)的字節(jié)長度，例如$3表示set有3個字節(jié)，$4表示name有4個字節(jié)

每行rn結(jié)尾

通信協(xié)議為：

*3
$3
set
$4
name
$5
wuzhc

狀態(tài)回復（status reply）的第一個字節(jié)是 "+"，例如+OK

錯誤回復（error reply）的第一個字節(jié)是 "-"，例如-No such key

整數(shù)回復（integer reply）的第一個字節(jié)是 ":"，例如:1

批量回復（bulk reply）的第一個字節(jié)是 "$"，例如 $5 wuzhc

多條批量回復（multi bulk reply）的第一個字節(jié)是 "*"，例如*2 $5 wuzhc $3r age

_socket = stream_socket_client(
            "tcp://{$ip}:{$port}",
            $errno,
            $errstr,
            1,
            STREAM_CLIENT_CONNECT
        );
        if (!$this->_socket) {
            exit($errstr);
        }
    }

    /**
     * 執(zhí)行redis命令
     * @param $command
     * @return array|bool|string
     */
    public function exec($command)
    {      
        // 拼裝發(fā)送命令格式
        $command = $this->_execCommand($command);

        // 發(fā)送命令到redis
        fwrite($this->_socket, $command);

        // 解析redis響應內(nèi)容
        return $this->_parseResponse();
    }

    /**
     * 將字符改為redis通訊協(xié)議格式
     * 例如mget name age 格式化為 *3
$4
mget
$4
name
$3
age

     * @param $command
     * @return bool|string
     */
    private function _execCommand($command)
    {
        $line = "";
        $crlf = "
";
        $params = explode(" ", $command);
        if (empty($params)) {
            return $line;
        }

        // 參數(shù)個數(shù)
        $line .= "*" . count($params) . $crlf;

        // 各個參數(shù)拼裝
        foreach ((array)$params as $param) {
            $line .= "$" . mb_strlen($param, "8bit") . $crlf;
            $line .= $param . $crlf;
        }

        return $line;
    }

    /**
     * 解析redis回復
     * @return array|bool|string
     */
    private function _parseResponse()
    {
        $line = fgets($this->_socket); 
        $type = $line[0]; 
        $msg = mb_substr($line, 1, -2, "8bit"); 

        switch ($type) {
            // 狀態(tài)回復
            case "+":
                if ($msg == "OK" || $msg == "PONG") {
                    return true;
                } else {
                    return $msg;
                }
            // 錯誤回復
            case "-":
                exit($msg);
            // 整數(shù)回復
            case ":":
                return $msg;
            // 批量回復
            case "$": // $后面跟數(shù)據(jù)字節(jié)數(shù)(長度)
                $line = fread($this->_socket, (int)$msg + 2); // 數(shù)據(jù)字節(jié)數(shù) + (
)兩個字節(jié)
                return mb_substr($line, 0, -2, "8bit"); // 去除最后兩個字節(jié)
            // 多條批量回復
            case "*": // *表示后面有多少個參數(shù)
                $data = [];
                for ($i = 0; $i < $msg; $i++) {
                    $data[] = $this->_parseResponse();
                }
                return $data;
        }
    }
}

// demo
$client = new Client("127.0.0.1", 6379);
$client->exec("set name wuzhc");
$res = $client->exec("get name");
var_dump($res);