PHP & OOP - Webdienste mit PHP nutzen (PHP Tutorial)

GET /index.html HTTP/1.1
Host: www.example.de

HTTP/1.1 302 Found
Date: Tue, 09 Dec 2008 00:15:21 GMT
Server: Apache
Content-Length: (Größe der Index-Seite in Byte)
Content-Type: text/html; charset=iso-8859-1
Connection: close

(Inhalt der Index-Seite)

GET /online.gif?icq=237076093 HTTP/1.1
Host: status.icq.com
…

POST /online.gif HTTP/1.1
Host: status.icq.com
Content-Type: text/html; charset=iso-8859-1

icq=237076093

   private $host;
   private $port;
   private $referrer;
   private $ssl;
   private $logStats;
   private $log;

   public function connect()
   private function login()
   private function auth()
   private function logout()
   private function cmd()
   private function readSock()
   private function divideReply()
   private function getName()
   private function decodeChunked()
   public function head()
   public function get()
   public function post()
   public function log()
   public function __toString()

procedure decodeChunked( String chunked )
   String body = null;
   Integer length = null;
   Integer size = null;
   Array data = null;

   while(true)
      // get next occurrence of CRLF
      pos = find_next("\r\n", chunked);

      if( !(pos === false) AND (size === null) )
         // get the size of following chunk from hex
         size = hexdec(substr(chunked, 0, pos));

         // get the following chunk
         body = body + substr(chunked, pos+2, size);

         // update the content not encoded
         chunk = substr(chunked, pos+2+size);

         // update content-length
         length = length + size;

         // reset chunk-size
         size = null;
      else
         // leave loop
         break;
      endif;
   endwhile;

   add(chunked, data)
   add(length, data)

   return data;
end procedure

<?php

/**
* @class HttpConnect
*
* The HttpConnect class allows easy connecting
* to a server. After connecting to your server
* you are able to send a post, get or a head command.
* So it is possible to send or to get different information
* to or from the server. Finally it is important to mention that
* this class supports secure sockets layer connections (ssl).
*
* @author Andreas Wilhelm
* @version
* Version 0.1, 25.01.2008<br />
* Version 0.2, 04.04.2010 (Now using arrays to create parameter-lists)<br />
* Version 0.3, 06.04.2010 (Added proxy support)<br />
*/
class HttpConnect {

    /**
     * @private
     * The host's name.
     */
    private $host;

    /**
     * @private
     * The port of the ftp-server.
     */
    private $port;
  
    /**
     * @private
     * Indicates if a ssl connection should be used.
     */
    private $ssl;
  
    /**
     * @private
     * The host name of the proxy server.
     */
    private $proxy;
  
    /**
     * @private
     * The port of the proxy server.
     */
    private $proxyport;
  
    /**
     * @private
     * Tip by Denis Wronka, who said, that many servers need a referrer.
     */
    private $referrer;
    
    /**
     * @private
     * The logging status.
     */
    private $logStats;

    /**
     * @private
     * The logging data.
     */
    private $log;

    /**
     * @public
     *
     * Sets the server-variables
     *
     * @param String $host The name of the host.
     * @param Integer $port The used port.
     * @param Boolean $ssl Declares if a secure connection should be used.
     * @param Boolean $log Declares if the connection data should be logged.
     * @param String $referrer The name of the HTTP-Referrer.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     * Version 0.3, 06.04.2010 (Added proxy support)<br />
     */
   public function connect($host='localhost', $port=80, $ssl=false, $proxy=false, $proxyport=443, $log=false, $referrer="PHP/HTTP-Class") {
        // Declare if the connection with the ftp-server should be logged or not.
        $this->logStats = $log;
        
        // Store the host name and password, ...
        $this->host = $host;
        $this->port = $port;
        
        // ... the proxy and its port, ...
        $this->proxy = $proxy;
        $this->proxyport = $proxyport;

        // ... the referrer's name and the connection state.
        $this->ssl = $ssl;
        $this->referrer = $referrer;
   }

    /**
     * @private
     *
     * Connects to the server
     *
     * @param String $host The name of the host.
     * @param Integer $port The used port.
     * @return The connection handle.
     * @throw Exception
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     * Version 0.3, 06.04.2010 (Added proxy support)<br />
     */
    private function login() {
        // Check if a secure connection ...
        if ($this->ssl == true) {
            // ... and a proxy server should be used ...
            if ($this->proxy!=false) {
                $handle = @fsockopen('ssl://'.$this->proxy, $this->proxyport);
            }

            // ... or not ...
            else {
                $handle = @fsockopen('ssl://'.$this->host, $this->port);
            }

            // Check if the connection was established ...
            if (!$handle) {
                // ... and throw an exception if not.
                throw new Exception("SSL-connection failed.\n");
            }
        }

        else {
            // ... and a proxy server should be used ...
            if ($this->proxy!=false) {
                $handle = @fsockopen($this->proxy, $this->proxyport);
            }

            // ... or not ...
            else {
                $handle = @fsockopen($this->host, $this->port);
            }
        
            // Check if the connection was established ...
            if (!$handle) {
                // ... and throw an exception if not.
                throw new Exception("Connection failed.\n");
            }
      }
        
        // Switch to non-blocking mode ...
        @set_socket_blocking($handle, true);
        
        // ... and set the timeout of the control.
        @stream_set_timeout($handle, 0, 200000);
      
      return $handle;
   }

    /**
     * @private
     *
     * Creates a connection to a secured server.
     *
     * @param String $user The user's name.
     * @param String $password The user's password.
     * @return The authentification code.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function auth($user, $password) {      
        // Check if a valid username was given ...
        if( !empty($user) ) {
            // ... and create the authentification code if it is.
            return 'Authorization: Basic '.base64_encode($user.':'.$password)."\r\n";
        }

        // Otherwise return an empty authentification code.
        return '';
    }
  
    /**
     * @private
     *
     * Closes the connection.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */      
    private function logout($handle) {
        fclose($handle);
    }

    /**
     * @private
     *
     * Sends a command to the server
     *
     * @param String $cmd The command which should be transmit to the server.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function cmd($handle, $cmd) {
        // Send the command to the server ...
        fputs($handle, $cmd);

        // ... and create a log entry.
        $this->log("> $cmd");
    }
  
    /**
     * @private
     *
     * Reads out the response from the server
     *
     * @return The server's response.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function readSock($handle) {
        // Initialize an empty server response, ...
        $response = "";

        // ... read all response data from the connection handle ...
        while(!feof($handle)) {
            $response .= fread($handle, 1025);
        }
      
        // ... and write a log message.
        $this->log($response);
      
        return $response;
    }
        
    /**
     * @private
     *
     * Spilts up the reply into the different information
     *
     * @param String $reply
     * @return The array that contains all response data.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function divideReply( $reply ) {  
        // Check the HTTP-Version and status-code.
        if( !preg_match('/^HTTP\/(1\.[01]) ([1-5][0-9]{2})/', $reply, $match) ) {
            return false;
        }
      
        // Now split header and body, ...
        $hb = strpos($reply, "\r\n")+2;
        $cb = strpos($reply, "\r\n\r\n")+4;
      
        // ... write the data into an array, ...
        $parsed = array(
            'HTTP_VERSION'  => $match[1],
            'STATUS_CODE'   => $match[2],
            'HEADER_FIELDS' => array(),
            'CONTENT'       => (string) substr($reply, $cb)
        );
      
        // ... split up the single header fields,
        $headerFields = explode("\r\n", preg_replace('/\x0D\x0A[\x09\x20]+/', ' ', substr($reply, $hb, $cb-$hb-4)));

        // ... and add them into the headers-array.
        foreach( $headerFields as $headerField ) {
            if( preg_match('/([^:]+):(.+)/m', $headerField, $match) ) {
                $parsed['HEADER_FIELDS'][$this->getName($match[1])] = trim($match[2]);
            }
        }

        // Finally check if tranfere-encoding is chunked ...
        if( isset($parsed['HEADER_FIELDS']['Transfer-Encoding']) && $parsed['HEADER_FIELDS']['Transfer-Encoding'] == 'chunked' ) {
            // ... and encode the chunked data if needed.
            return $this->decodeChunked($parsed);
        }
      
        return $parsed;
    }
  
    /**
     * @private
     *
     * Returns the name of a received HTTP-header-field
     *
     * @param String $string The full header.
     * @return The name of the header field.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function getName($string) {
        return preg_replace('/(?<=^|[\x09\x20\x2D])./e', 'strtoupper("\0")', strtolower(trim($string)));
    }  
  
    /**
     * @private
     *
     * Decodes body in chunked encoding
     *
     * @param Array $chunked The chunked data received from the server.
     * @return The data array.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function decodeChunked($chunked) {
        // Initialize vars holding the content and the content size.
        $body = '';
        $length = NULL;
        $size = NULL;
      
        // Save the chunked body to a variable ...
        $chunk = $chunked['CONTENT'];

        while(true) {
            // Get the next occurrence of CRLF ...
            $pos = @strpos($chunk, "\r\n", 0);

            // ... and check if it occured or if it is an empty line.
            if(!($pos === false) && $size === NULL) {
                // If there is some content, get the its size, ...
                $size = hexdec(substr($chunk, 0, $pos));
            
                // ... read the chunk, ...
                $body .= substr($chunk, $pos+2, $size);
            
                // ... update the content not encoded ...
                $chunk = substr($chunk, $pos+2+$size);
            
                // ... and the content-length ...
                $length += $size;
            
                // ... and reset the chunk-size.
                $size = NULL;
            }
        
            else {
                // If there is no line to read stop looping.
                break;
            }
        }
      
        // After fetching the content, add it to the data array ...
        $chunked['CONTENT'] = $body;
      
        // ... refresh the content-length ...
        $chunked['HEADER_FIELDS']['Content-Length'] = $length;
      
        // ... and change the Transfere-Encoding.
        $chunked['HEADER_FIELDS']['Transfer-Encoding'] = 'token';
  
        return $chunked;
    }  
        
    /**
     * @public
     *
     * Returns the HTTP-header like a GET or POST reply but without the file
     *
     * @param String $uri The uri to send the request to.
     * @param Array $params The url parameters.
     * @param Array $cookies The cookies.
     * @param String $user The user's name.
     * @param String $password The user's password.
     * @return The data reponse array.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     * Version 0.2, 04.04.2010 (Now using arrays to create parameter-lists)<br />
     * Version 0.3, 06.04.2010 (Added proxy support)<br />
     */
    public function head($uri='/', $params=array(), $cookies=array(), $user=null, $password=null) {
        // Log onto the server, ...
        $handle = $this->login();
      
        // ... and create the authorization-string.
        $auth = $this->auth($user, $password);
      
        // Now prepare the uri for the request, ...
        if (empty($uri) || ($uri{0}!='/')) {
            $uri = '/' . $uri;
        }
            
        // ... check if parameters are given ...
        if ( !empty($params) ) {
            // ... and prepare them for the request.
            $paramData = '?';
            foreach($params as $key => $val) {
                $paramData .= $key . '=' . $val . '&';
            }
        }
      
        else {
            $paramData = '';
        }
      
        // Check if cookies are given ...
        if ( !empty($cookies) ) {
            // ... and prepare them for the request.
            $cookieData = "Cookie: ";
            foreach($cookies as $key => $val) {
                $cookieData .= $key . '=' . $val . ';';
            }
            $cookieData .= "\r\n";
        }
      
        else {
            $cookieData = '';
        }
      
        // Now prepare the host-data, ...
        $host = $this->host;

        // ... add the port ...
        if ($this->port != 80) {
            $host .= ':'.$this->port;
        }

        // ... and the right prefix if needed ...
        if ($this->proxy!=false) {
            if ($this->ssl==true) {
                $uri='https://'.$host.$uri;
            }

            else {
                $uri='http://'.$host.$uri;
            }
        }
      
        // ... and send the request to the server.
        $this->cmd($handle, "HEAD $uri"."$paramData HTTP/1.1\r\n");
        $this->cmd($handle, "Host: $host\r\n".$cookieData.$auth);
        $this->cmd($handle, "User-Agent: ".$this->referrer."\r\n");
        $this->cmd($handle, "Connection: close\r\n\r\n");
      
        // Finally get the server's response, ...
        $reply = $this->readSock($handle);
      
        // ... close the connection to the server ...
        $this->logout($handle);
      
        // ... and create the result array.
        $data = $this->divideReply($reply);
      
        return $data;
    }
        
    /**
     * @public
     *
     * Returns the HTTP-header and the output of the file.
     *
     * @param String $uri The uri to send the request to.
     * @param Array $params The url parameters.
     * @param Array $cookies The cookies.
     * @param String $user The user's name.
     * @param String $password The user's password.
     * @return The data reponse array.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     * Version 0.2, 04.04.2010 (Now using arrays to create parameter-lists)<br />
     * Version 0.3, 06.04.2010 (Added proxy support)<br />
     */
    public function get($uri='/', $params=array(), $cookies=array(), $user=null, $password=null) {
        // Log onto the server, ...
        $handle = $this->login();
      
        // ... and create the authorization-string.
        $auth = $this->auth($user, $password);
      
        // Now prepare the uri for the request, ...
        if (empty($uri) || ($uri{0}!='/')) {
            $uri = '/' . $uri;
        }
            
        // ... check if parameters are given ...
        if ( !empty($params) ) {
            // ... and prepare them for the request.
            $paramData = '?';
            foreach($params as $key => $val) {
                $paramData .= $key . '=' . $val . '&';
            }
        }
      
        else {
            $paramData = '';
        }
      
        // Check if cookies are given ...
        if ( !empty($cookies) ) {
            // ... and prepare them for the request.
            $cookieData = "Cookie: ";
            foreach($cookies as $key => $val) {
                $cookieData .= $key . '=' . $val . ';';
            }
            $cookieData .= "\r\n";
        }
      
        else {
            $cookieData = '';
        }
      
        // Now prepare the host-data, ...
        $host = $this->host;

        // ... add the port ...
        if ($this->port != 80) {
            $host .= ':'.$this->port;
        }

        // ... and the right prefix if needed ...
        if ($this->proxy!=false) {
            if ($this->ssl==true) {
                $uri='https://'.$host.$uri;
            }

            else {
                $uri='http://'.$host.$uri;
            }
        }
      
        // ... and send the request to the server.
        $this->cmd($handle, "GET $uri"."$paramData HTTP/1.1\r\n");
        $this->cmd($handle, "Host: $host\r\n".$cookieData.$auth);
        $this->cmd($handle, "User-Agent: ".$this->referrer."\r\n");
        $this->cmd($handle, "Connection: close\r\n\r\n");
      
        // Finally get the server's response, ...
        $reply = $this->readSock($handle);
      
        // ... close the connection to the server ...
        $this->logout($handle);
      
        // ... and create the result array.
        $data = $this->divideReply($reply);
      
        return $data;
    }

    /**
     * @public
     *
     * Returns the HTTP-header and the output of the file.
     *
     * @param String $uri The uri to send the request to.
     * @param Array $params The url parameters.
     * @param Array $cookies The cookies.
    * @param Array $fileparams The parameters of a file handle.
    * @param Array $mimes The mime-types that belong to the file handles.
     * @param String $user The user's name.
     * @param String $password The user's password.
     * @return The data reponse array.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     * Version 0.2, 04.04.2010 (Now using arrays to create parameter-lists)<br />
     * Version 0.3, 06.04.2010 (Added proxy support)<br />
     */
    public function post($uri='/', $params=array(), $cookies=array(), $fileparams=array(), $mimes=array(), $user=null,$password=null) {
        // Log onto the server, ...
        $handle = $this->login();
      
        // ... and create the authorization-string.
        $auth = $this->auth($user, $password);
      
        // Now prepare the uri for the request, ...
        if (empty($uri) || ($uri{0}!='/')) {
            $uri = '/' . $uri;
        }
            
        // ... check if parameters are given ...
        if ( !empty($params) ) {
            // ... and prepare them for the request.
            $paramData = '?';
            foreach($params as $key => $val) {
                $paramData .= $key . '=' . $val . '&';
            }
        }
      
        else {
            $paramData = '';
        }
      
        // Check if cookies are given ...
        if ( !empty($cookies) ) {
            // ... and prepare them for the request.
            $cookieData = "Cookie: ";
            foreach($cookies as $key => $val) {
                $cookieData .= $key . '=' . $val . ';';
            }
            $cookieData .= "\r\n";
        }
      
        else {
            $cookieData = '';
        }
      
        // Now prepare the host-data, ...
        $host = $this->host;

        // ... add the port if needed ...
        if ($this->port != 80) {
            $host .= ':'.$this->port;
        }

        // ... and add the right prefix.
        if ($this->proxy!=false) {
            if ($this->ssl==true) {
                $uri='https://'.$host.$uri;
            }

            else {
                $uri='http://'.$host.$uri;
            }
        }

        // Check if file parameters are given, ...
        if ( empty($fileparams) ) {
            // ... check if post parameters are given.
            if ( !empty($params) ) {
                // If post parameters are given, get the content length, ...
                $length = strlen($paramData);
            
                // ... and send the request to the server.
                $this->cmd($handle, "POST ".$uri." HTTP/1.1\r\n");
                $this->cmd($handle, "Host: $host\r\n".$cookieData.$auth);
                $this->cmd($handle, "User-Agent: ".$this->referrer."\r\n");
                $this->cmd($handle, "Connection: close\r\n");
                $this->cmd($handle, "Content-Type: application/x-www-form-urlencoded\r\n");
                $this->cmd($handle, "Content-Length: ".$length."\r\n\r\n".$paramData);
            }

            else {
                // Send the request without parameters.
                $this->cmd($handle, "POST ".$uri." HTTP/1.1\r\n");
                $this->cmd($handle, "Host: $host\r\n".$cookieData.$auth);
                $this->cmd($handle, "User-Agent: ".$this->referrer."\r\n");
                $this->cmd($handle, "Connection: close\r\n");
            }
        }
      
      else {
            // If there are file parameters given, fill empty mimetype-spaces with standard-mimetype.
            while (count($mimeparam) < count($fparam)) {
                $mimes[]='application/octet-stream';
            }        
        
            // Create a boundary, that could be used to seperate the different blocks holding the parameters.
            $boundary = md5(uniqid());

            // Then initialize the content block, ...
            $content = '';        
        
            // ... start a counter ...
            $key = 0;

            // ... and create a content block for each file.
            foreach($fileparams as $name => $fname) {
                $fp = fopen($fname, 'r');
                $fcontent = fread($fp, filesize($fname));
                $content .= '--'.$boundary."\r\n";
                $content .= 'Content-Disposition: form-data; name="'.$name.'"; filename="'.$fname.'"'."\r\n";
                $content .= 'Content-Type: '.$mimes[$key]."\r\n\r\n";
                $content .= $filecontent."\r\n";
  
                $key++;
            }
        
            // The prepare the blocks for the post parameters.
         foreach($params as $name => $value) {
                $content .= '--'.$boundary."\r\n";
                $content .= 'Content-Disposition: form-data; name="'.$name.'"'."\r\n\r\n";
            
                if (!empty($value)) {
                    $content .= $value."\r\n";
                }
            }
        
            $content .= '--'.$boundary."--\r\n";
        
            // Finally get the length of the content block, ...
            $length = strlen($content);
        
            //  ... send the standard data ...
            $this->cmd($handle, "POST ".$uri." HTTP/1.1\r\n");
            $this->cmd($handle, "Host: $host\r\n".$cookieData.$auth);
            $this->cmd($handle, "User-Agent: ".$this->referrer."\r\n");
            $this->cmd($handle, "Connection: close\r\n");                  
                  
            // ... and after that send the the parameters and file-parameters.
            $this->cmd($handle, "Content-Type: multipart/form-data; boundary=".$boundary."\r\n");
            $this->cmd($handle, "Content-Length: ".$length."\r\n\r\n");
            $this->cmd($handle, $content);
        }
      
        // After all get the server's response, ...
        $reply = $this->readSock($handle);
      
        // ... close the connection to the server ...
        $this->logout($handle);
      
        // ... and create the result array.
        $data = $this->divideReply($reply);
      
        return $data;
    }
            
    /**
     * @private
     *
     * Saves all request and responses to and from the server.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    private function log($str) {
        // Check if data should be logged ...
        if($this->logStats) {
            // ... and log them if needed.
            $this->log .= "$str<br />";
        }
    }
            
    /**
     * @public
     *
     * Returns the currently logged data.
     *
     * @return The logging output.
     *
     * @author Andreas Wilhelm
     * @version
     * Version 0.1, 25.01.2008<br />
     */
    public function __toString() {
        return $this->log;
    }
}

?>

<?php

try {
    // Include the http request handler ...
    require_once("HttpConnect.php");

    // ... and create an instance.
    $http = new HttpConnect();

    // Now connect to the icq.com login server ...
    $http->connect("wwp.icq.com", 80, false, false, 443, true);

    // ... and send the data to the script.
    $data = $http->head("/scripts/online.dll", array("icq" => "237076093", "img" => "5"));

    // Now get the right online state ...
    if ( strstr($data['HEADER_FIELDS']['Location'], 'online0') ) {
        $status = "<img src=\"http://status.icq.com/5/online0.gif\" alt=\"offline\" \>Avedo is offline.";
    }
  
    elseif (strstr($data['HEADER_FIELDS']['Location'], 'online1')) {
        $status = "<img src=\"http://status.icq.com/5/online1.gif\" alt=\"online\" \>Avedo is online.";
    }

    else {
        $status = "<img src=\"http://status.icq.com/5/online2.gif\" alt=\"N/A\" \>Avedo is N/A.";
    }
  
    // ... and print it.
    echo $status;
}

catch(Exception $e) {
    echo $e->getMessage();
}

?>