Bir Web Sunucusu Kodlama Denemesi – 4 : Azra Web Server

<?php

$start = microtime(1);

for($n = 0; $n <= 10000; $n++)
{
    echo $n;
}
$end = microtime(1);
$elapsed = $end - $start;
echo "<br/>vakit(ms): $elapsed";
$fileHandle = fopen('serverBenchmark.txt' , 'a');
fputs($fileHandle , $elapsed . "\n");
fclose($fileHandle);

#! /usr/bin/php-cgi
<?php
/**
 * Azra Web Server
 *
 * Web Server coded in pure PHP
 *
 * @package     Azra Web Server
 * @author      Can Ince
 * @copyright           Copyright (c) 2010, Logikit / Can Ince.
 * @version             0.0.2
 * @license     http://www.opensource.org/licenses/mit-license.php
 * @link        http://can.logikit.net
 */

set_time_limit(0);

interface server
{
    public function setWebRoot($path);
    public function setPort($port);
    public function serve();
}

final class webserver implements server
{
    public $socket;
    private $_port , $_webroot , $_queryString , $_webRootWithoutSlash, $_input , $_file , $_verbose , $_remoteAddr , $_remotePort;
    public function __construct()
    {
        $this->_verbose = 0;
        $_SERVER = array();
        $_COOKIE = array();
    }
   
    public function setPort($port)
    {
        $this->_port = $port;
    }
   
    public function verbose()
    {
        $this->_verbose = 1;
    }
   
    public function setWebRoot($path)
    {
        $this->_webroot = $path . '/';
        $this->_webRootWithoutSlash = $path;
    }
   
    private function _mimeHandler($input)
    {
            $fileinfo = pathinfo($input);
            switch ($fileinfo['extension'])
            {
                case 'png':
                    $mime = "text/png";  
                    break;
               
                case 'jpg':
                case 'jpeg':
                    $mime = "text/jpeg";  
                    break;
               
                case 'gif':
                    $mime = "text/gif";  
                    break;
               
                case 'css':
                    $mime = "text/css";  
                    break;
                   
                case 'swf':
                    $mime = "application/x-shockwave-flash";
                    break;
             
                default:
                    $mime = "text/html; charset=UTF-8";
            }
        return $mime;
    }
   
    private function _handleCode($contents)
    {
         //eval() edilecek kodun başında <?php ya da <? varsa çakar. halledelim.
        $contents = trim($contents);
        if(substr($contents , 0 , 5) == '<?php')
        {
            $contents = substr($contents , 5);
        }
        elseif(substr($contents , 0 , 2) == '<?')
        {
            $contents = substr($contents , 2);
        }
       
        return $contents;
    }
   
    private function _parseGet($str)
    {
        $_GET = array();
        $array = explode('&' , $str);
        foreach($array as $requestItem)
        {
            $itemArray = explode('=' , $requestItem);
            if(!empty($itemArray[0])) $_GET[$itemArray[0]] = $itemArray[1];
        }
        unset($_GET['hyperTextServer_php']); //bunu $_GET'e enjekte ediyor. neden, bilmiyorum...
    }
   
    private function _parsePost($str)
    {
        $_POST = array();
        $array = explode('&' , $str);
        foreach($array as $requestItem)
        {
            $itemArray = explode('=' , $requestItem);
            if(!empty($itemArray[0])) $_POST[$itemArray[0]] = $itemArray[1];
        }
    }
   
    private function _parseCookie($str)
    {
       
        $array = explode('; ' , $str);
        foreach($array as $requestItem)
        {
            $itemArray = explode('=' , $requestItem);
            if(!empty($itemArray[0])) $_COOKIE[$itemArray[0]] = $itemArray[1];
        }
    }
   
    private function _parseRequest($str)
    {
       
        $lines = explode("\n" , $str);
        $rawData = explode(' ' , $lines[0]);
        $_SERVER['REQUEST_METHOD'] = $rawData[0];
        if($_SERVER['REQUEST_METHOD'] == 'POST') $this->_parsePost(end($lines));
        $_SERVER['PHP_SELF'] = $this->_webRootWithoutSlash . $rawData[1];
        $_SERVER['HTTP_HOST'] = substr($lines[1] , 6);
        $_SERVER['HTTP_USER_AGENT'] = substr($lines[2] , 12);
        $_SERVER['HTTP_ACCEPT'] = substr($lines[3] , 8);
        $_SERVER['HTTP_ACCEPT_LANGUAGE'] = substr($lines[4] , 17);
        $_SERVER['HTTP_ACCEPT_ENCODING'] = substr($lines[5] , 17);
        $_SERVER['HTTP_ACCEPT_CHARSET'] = substr($lines[6] , 16);
        $_SERVER['HTTP_KEEP_ALIVE'] = substr($lines[7] , 12);
        $_SERVER['HTTP_CONNECTION'] = substr($lines[8] , 12);
        if(strstr($lines[9] , 'Referer'))
        {
            $_SERVER['HTTP_REFERER'] = substr($lines[9] , 9);
            $_SERVER['HTTP_COOKIE'] = substr($lines[10] , 8);
        }
        else $_SERVER['HTTP_COOKIE'] = substr($lines[9] , 8);
       
        if(!empty($_SERVER['HTTP_COOKIE'])) $this->_parseCookie($_SERVER['HTTP_COOKIE']);
       
        $_SERVER['SERVER_SIGNATURE'] = ' <address>Azra/0.0.1 Server at ' . $_SERVER['HTTP_HOST'] . ' Port ' . $this->_port . '</address>';
        $_SERVER['SERVER_SOFTWARE'] = 'Azra/0.0.1';
        $_SERVER['DOCUMENT_ROOT'] = $this->_webroot;
        $_SERVER['SCRIPT_FILENAME'] = $this->_webRootWithoutSlash . str_replace('./' , '/' , $this->_file);
        $_SERVER['SCRIPT_NAME'] = $this->_file;
        $_SERVER['REQUEST_TIME'] = time();
        $_SERVER['REMOTE_ADDR'] = $this->_remoteAddr;
        $_SERVER['REMOTE_PORT'] = $this->_remotePort;
        if(!empty($this->_queryString)) $_SERVER['QUERY_STRING'] = $this->_queryString;
    }
   
    private function _handle404()
    {
        return "<title>UHU 404</title><h2>UHU 404</h2>Iın-ıın-ıın-ıın-cav-cav-cav-cav-oooooo - oooooo - zört - zört - zört -zört (araba alarmı efekti) Çok afedersin müdürüm ama yok öyle bir dosya.";
    }
   
    public function openSocket()
    {
        $this->socket = @socket_create_listen($this->_port);
        if (!$this->socket)
        {
            echo "Soket olamiyor!\n";
            exit;
        }
        $this->_loadConfigHandler();
    }
   
    private function _loadCOnfigHandler()
    {
        $directoryConfigCandidate = $this->_webroot . '/.ConfigHandler.php';
       
        if ($directoryConfigCandidate && is_readable($directoryConfigCandidate))
        {
            require ($directoryConfigCandidate);
        }      
    }
   
    public function serve()
    {

        while (1) //daire-i ilanihaye!
        {
            $client = socket_accept($this->socket);
            socket_getpeername($client , $remoteAddr , $remotePort);
            $this->_remoteAddr = $remoteAddr;
            $this->_remotePort = $remotePort;
            $input = $this->_input = trim(socket_read ($client, 4096));
           
            if($this->_verbose == 1) echo $input;
           
            $input = explode(" " , $input);
            $input = $input[1];

            if(class_exists('ConfigHandler'))
            {
                $configHandler = new ConfigHandler($input , $this->_webroot);
 
                //konvansiyonumuza göre rewrite işi $configHandler'ın url özelliğinde bulunmalı
                if($configHandler->url != NULL) $input = realpath($configHandler->url);
            }
             
            $mime = $this->_mimeHandler($input);
               
            if ($input == "" || $input == '/')
            {
                $input = "/index.html";
            }
            $input = ".$input";
            $input = str_replace('//' , '/' , $input);
            $inputArray = explode('?' , $input);
            $this->_file = $inputArray[0];
           
            $input = $this->_webroot . $this->_file;
            if (file_exists($input) && is_readable($input))
            {
                if($this->_verbose == 1) echo "Dosya: $input\n";
                 
                $contents = file_get_contents($input);
                if(strstr($input , '.php'))
                {
                    if(!empty($inputArray[1])) $this->_queryString = $inputArray[1];
                   
                    $this->_parseGet($this->_queryString);
                    $this->_parseRequest($this->_input);
                   
                    $_REQUEST = array_merge($_GET , $_POST , $_COOKIE);
                   
                    $contents = $this->_handleCode($contents);
                   
                    //PHP çalıştıktan sonra sonucu echo etmesini değil, $contents stringine atmasını istiyoruz.
                    ob_start();
                    eval($contents);
                    //gidip $contents'in üstüne yazmak doğru alışkanlık değil ama yeni değişken register etmek istemiyorum
                    $contents = ob_get_contents();
                    ob_end_clean();
                }
                $output = "HTTP/1.0 200 OK\r\nServer: HyperTextServer\r\nConnection: close\r\nContent-Type: $mime\r\n\r\n$contents";
            }
            else
            {
                $contents = $this->_handle404();
                $output = "HTTP/1.0 404 OBJECT NOT FOUND\r\nServer: HyperTextServer\r\nConnection: close\r\nContent-Type: text/html; charset=UTF-8\r\n\r\n$contents";
            }
            socket_write($client, $output);
            socket_close ($client);
        }
        socket_close ($this->socket);
    }
   
    public function start()
    {
        $pids = array();

        $this->openSocket();
        for($i = 0; $i < 10; $i++)
        {
            $pids[$i] = pcntl_fork();
           
                if(!$pids[$i])
                {
                    // child process
                    $this->serve();
                    exit();
                }
        }
       
        for($i = 0; $i < 10; $i++)
        {
            pcntl_waitpid($pids[$i], $status, WUNTRACED);
        }
    }
}

$server = new webserver();
$server->setWebRoot('/var/www/act');
$server->verbose(); //ayrıntıları stdout'a echo et.
$server->setPort(8115);
$server->start();