fast-cgi-protocol

typedef struct _fcgi_header {
    unsigned char version;          //表示版本，默认为1
    unsigned char type;             //表示请求包的类型，比如FCGI_BEGIN_REQUEST or FCGI_PARAMS or FCGI_STDIN 等等
    unsigned char requestIdB1;      //表示请求id，请求id是一个16位的整形，这里是高位
    unsigned char requestIdB0;      //表示请求id，请求id是一个16位的整形，这里是低位
    unsigned char contentLengthB1;  //表示body的长度，长度是一个16位的整形，这里是高位
    unsigned char contentLengthB0;  //表示body的长度，长度是一个16位的整形，这里是低位
    unsigned char paddingLength;    //表示填充内容的长度
    unsigned char reserved;         //保留字段，默认为0
} fcgi_header;

typedef enum _fcgi_request_type {
    FCGI_BEGIN_REQUEST      =  1, // [in]
    FCGI_ABORT_REQUEST      =  2, // [in]  (not supported)
    FCGI_END_REQUEST        =  3, // [out]
    FCGI_PARAMS             =  4, // [in]  environment variables
    FCGI_STDIN              =  5, // [in]  post data
    FCGI_STDOUT             =  6, // [out] response
    FCGI_STDERR             =  7, // [out] errors
    FCGI_DATA               =  8, // [in]  filter data (not supported)
    FCGI_GET_VALUES         =  9, // [in]
    FCGI_GET_VALUES_RESULT  = 10  // [out]
} fcgi_request_type;

typedef struct {
    unsigned char version;
    unsigned char type;
    unsigned char requestIdB1;
    unsigned char requestIdB0;
    unsigned char contentLengthB1;
    unsigned char contentLengthB0;
    unsigned char paddingLength;
    unsigned char reserved;
    unsigned char contentData[contentLength];
    unsigned char paddingData[paddingLength];
} FCGI_Record;

<?php
define('FCGI_REQUEST_ID', 1);
define('FCGI_VERSION_1', 1);
define('FCGI_BEGIN_REQUEST', 1);
define('FCGI_RESPONDER', 1);
define('FCGI_END_REQUEST', 3);
define('FCGI_PARAMS', 4);
define('FCGI_STDIN', 5);
define('FCGI_STDOUT', 6);
define('FCGI_STDERR', 7);

define('FCGI_HOST', '127.0.0.1');
define('FCGI_PORT', 9130);

get_main();
//post_main();

function get_main()
{
    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    socket_connect($socket, FCGI_HOST, FCGI_PORT);

    $content_body = '';
    $fcgi_request_id = 1;
    $env = array(
        'SCRIPT_FILENAME' => '/home/users/lihongbin/wwwdata/htdocs/test/index.php',
        'REQUEST_METHOD'  => 'GET',
//        'CONTENT_TYPE' => 'application/x-www-form-urlencoded',
        'CONTENT_LENGTH' => strlen($content_body),
//        'QUERY_STRING' => 'user_id=1&app_id=2000',
//        'REQUEST_URI' => '/rest/2.0/dev?user_id=1&app_id=2000',
    );

    send_request($socket, $content_body, $env, $fcgi_request_id);
    $result = get_response($socket);

    var_dump($result);
    socket_close($socket);
}

function post_main()
{
    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    socket_connect($socket, FCGI_HOST, FCGI_PORT);

    $content_body = 'x=y';
    $fcgi_request_id = 1;
    $env = array(
        'SCRIPT_FILENAME' => '/home/users/lihongbin/wwwdata/htdocs/test/index.php',
        'REQUEST_METHOD'  => 'POST',
        'CONTENT_TYPE' => 'application/x-www-form-urlencoded',
        'CONTENT_LENGTH' => strlen($content_body),
//        'QUERY_STRING' => 'user_id=1&app_id=2000',
//        'REQUEST_URI' => '/rest/2.0/dev?user_id=1&app_id=2000',
    );

    send_request($socket, $content_body, $env, $fcgi_request_id);
    $result = get_response($socket);

    var_dump($result);

    socket_close($socket);
}

function send_request($socket, $content_body, $env, $fcgi_request_id)
{
    $content_body_len = strlen($content_body);

    //step1 FCGI_BEGIN_REQUEST
    $begin_request_body = get_begin_request_body();
    $begin_request_header = get_header(FCGI_BEGIN_REQUEST, $fcgi_request_id, 8, 0);
    $record = $begin_request_header . $begin_request_body;
    socket_write($socket, $record);

    //step2 FCGI_PARAMS
    $params_body = '';
    //$env['CONTENT_LENGTH'] = $content_body_len;
    foreach($env as $key => $value)
    {
        $params_body .= get_params_key_len($key) . get_params_key_len($value) . $key . $value;
    }
    $params_body_len = strlen($params_body);
    $params_pad_body_len = get_pad_len($params_body_len);
    $params_header = get_header(FCGI_PARAMS, $fcgi_request_id, $params_body_len, $params_pad_body_len);
    $params_pad_body = get_pad_data($params_pad_body_len);
    $record = $params_header . $params_body . $params_pad_body;
    socket_write($socket, $record);

    $params_empty_body_header = get_header(FCGI_PARAMS, $fcgi_request_id, 0, 0);
    socket_write($socket, $params_empty_body_header);

    //step3 FCGI_STDIN
    if($content_body_len > 0)
    {
        $stdin_pad_body_len = get_pad_len($content_body_len);
        $stdin_header = get_header(FCGI_STDIN, $fcgi_request_id, $content_body_len, $stdin_pad_body_len);
        $record = $stdin_header . $content_body . get_pad_data($stdin_pad_body_len);
        socket_write($socket, $record);
    }
    $stdin_empty_header = get_header(FCGI_STDIN, $fcgi_request_id, 0, 0);
    socket_write($socket, $stdin_empty_header);
}

function get_response($socket)
{
    $result = array();
    $stdout_response_body = '';
    $stderr_response_body = '';
    while(1)
    {
        $header = socket_read($socket, 8);
        $header = unpack("Cversion/Ctype/nrequestId/ncontentLength/CpaddingLength/Creserved", $header);
        $response_body_len = $header['contentLength'];
        $response_pad_len = $header['paddingLength'];
        $type = $header['type'];

        $response_body = read_body($socket, $response_body_len);
        $response_pad_body = read_body($socket, $response_pad_len);

        if($type == FCGI_END_REQUEST)
        {
            $result['end']['response_header'] = $header;
            $result['end']['response_body'] = unpack("NappStatus/CprotocolStatus/C3reserved", $response_body);
            break;
        }
        else if($type == FCGI_STDOUT)
        {
            $stdout_response_body .= $response_body;
            $result['stdout']['last_response_header'] = $header;
        }
        else if($type == FCGI_STDERR)
        {
            $stderr_response_body .= $response_body;
            $result['stderr']['last_response_header'] = $header;
        }
    }

    if(empty($stdout_response_body) === false)
    {
        list($header, $body) = explode("\r\n\r\n", $stdout_response_body);
        $result['stdout']['response_body']['header'] = get_http_header_info($header);
        $result['stdout']['response_body']['body'] = $body;
    }

    if(empty($stderr_response_body) === false)
    {
        $result['stderr']['response_body'] = $stderr_response_body;
    }

    return $result;
}

function get_http_header_info($header)
{
    $arr = explode("\r\n", $header);
    foreach($arr as $item)
    {
        $arr_item = explode(":", $item);

        if(count($arr_item) == 2)
        {
            $key = trim($arr_item[0]);
            $value = trim($arr_item[1]);
            $arr_header[$key] = $value;
        }
    }
    return $arr_header;
}

function get_begin_request_body()
{
    return pack("nC6", FCGI_RESPONDER, 0, 0, 0, 0, 0, 0);
}

function get_header($type, $request_id, $content_len, $pad_len, $reserved = 0)
{
    return pack("C2n2C2", FCGI_VERSION_1, $type, $request_id, $content_len, $pad_len, $reserved);
}

function get_pad_len($body_len)
{
    $left = $body_len % 8;
    if ($left == 0)
    {
        return 0;
    }
    return 8 - $left;
}

function get_pad_data($pad_len)
{
    $data = '';
    for($i = 0; $i < $pad_len; ++$i)
    {
        $data .= chr(0);
    }
    return $data;
}

function get_params_key_len($key)
{
    $len = strlen($key);
    if($len > 0x7f)
    {
        $b0 = $len & 0xff;
        $b1 = ($len >> 8) & 0xff;
        $b2 = ($len >> 16) & 0xff;
        $b3 = ($len >> 24) & 0xff;

        $b3 = $b3 | 0x80;
        $bin = pack("C4", $b3, $b2, $b1, $b0);
    }
    else
    {
        $bin = pack("C", $len);
    }
    return $bin;
}

function read_body($socket, $len)
{
    $body = "";
    while($len)
    {
        $buf = socket_read($socket, $len);
        $len -= strlen($buf);
        $body .= $buf;
    }
    return $body;
}