<?php   

class SocketServer

{

    var $ip;

    var $port;     

    

    var $masterSocket;

    

    var $logger;

    

    private $currentSockets;

    

    function __construct($ip, $port)

    {

        $this->ip = $ip;

        $this->port = $port;             

        

        $this->logger = Logger::getInstance();

        

        $this->initSocket();

        $this->currentSockets = array();

        

        $this->currentSockets[] = $this->masterSocket;    

        

        $this->listenToSockets();

    }

    

    private function initSocket()

    {                                                                                             

     

        if (($this->masterSocket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) 

        {

            $this->logger->log("[SocketServer] "."socket_create() failed, reason: " . socket_strerror($this->masterSocket));

        }

         

        socket_set_option($this->masterSocket, SOL_SOCKET,SO_REUSEADDR, 1);

                         

        if (($ret = socket_bind($this->masterSocket, $this->ip, $this->port)) < 0) {

        

            $this->logger->log("[SocketServer] "."socket_bind() failed, reason: " . socket_strerror($ret));

        

        }

         

         

        if (($ret = socket_listen($this->masterSocket, 5)) < 0) {

        

            $this->logger->log("[SocketServer] "."socket_listen() failed, reason: " . socket_strerror($ret));    

        }

    }

    

    private function parseRequest($socket, $data)

    {

        if(substr($data,0, 22) == "<policy-file-request/>")

        {

            echo "POLICY FILE REQUEST\n";

            $crossFile = file("crossdomain.xml");

            $crossFile = join('',$crossFile);

            $this->sendMessage(array($socket),$crossFile);            

            return;

        }    

        else

        {

            //Here you handle the request

        }

    }     

    

    public function sendMessage( $message)

    {

        $message .= "\0";                      

    

        foreach($this->currentSockets as $socket)

        {

            if($socket === NULL)

                continue;

                

            socket_write($socket, $message, strlen($message)); 

            socket_getpeername($socket, $newClientAddress);

            $this->logger->log("[SocketServer] Wrote : ".$message." to ". $newClientAddress);

            

        }

    }

    public function closeConnection()

    {

        foreach($this->currentSockets as $socket)

        {

            if ($socket != $this->masterSocket) {

                 socket_getpeername($socket, $newClientAddress);  

                 $this->logger->log("[SocketServer] "."REMOVING CLIENT ". $newClientAddress);

                socket_close($socket);       

            }

        }

        $this->logger->close();    

        exit;

    }

    

    private function listenToSockets()

    {                                                             

        while (true) {

        

            $changed_sockets = $this->currentSockets;

         

            $num_changed_sockets = socket_select($changed_sockets, $write = NULL, $except = NULL, NULL);

         

            foreach($changed_sockets as $socket) 

            {

                if ($socket == $this->masterSocket) {

                    if (($client = socket_accept($this->masterSocket)) < 0) {

                        $this->logger->log("[SocketServer] "."socket_accept() failed: reason: " . socket_strerror($socket));

                        continue;

                    } else {

                        // NEW CLIENT HAS CONNECTED

                        $this->currentSockets[] = $client;

                        socket_getpeername($client, $newClientAddress);

                        $this->logger->log("[SocketServer] "."NEW CLIENT ".$client." [IP: ".$newClientAddress."]"); 

                                                                      

                    }

                } else {

                     $bytes = socket_recv($socket, $buffer, 4096, 0);

         

                    if ($bytes == 0) {

                        

                        // CLIENT HAS DISCONNECTED

                        socket_getpeername($client, $newClientAddress);  

                        $this->logger->log("[SocketServer] "."REMOVING CLIENT ". $newClientAddress);

                        $index = array_search($socket, $this->currentSockets);

                        

                        // Remove Socket from List

                        unset($this->currentSockets[$index]); 

                        

                        

                        socket_close($socket);

                        //exit;   

                    

                    }else{   

                        // CLIENT HAS SENT DATA

                        $this->parseRequest($socket, $buffer);

                    }

                }

            }

        }

    }

}

?>

<?php

class Logger

{

    private static $instance;

    var $Fnm;

    var $inF;

    var $ptr;

    

    public static function getInstance()

    {

        if(!isset($instance))

            $instance = new Logger();

            

        return $instance;

    }

    

    function __construct()

    {

        $this->Fnm = 'log.txt';

        $this->inF = fopen($this->Fnm, 'w');

        $this->ptr = ftell($this->inF);

    }

    

    function log($message)

    {

        $message =  "[".date('Y-m-d at h:i:s')."] ".$message."<br/>\n";

        

        fputs($this->inF, $message);

 

    }

    

    function close()

    {

        fclose($this->inF);     

    }

}

?>

<?php

    require_once('SocketServer.php');

    require_once('Logger.php');   



    $mySocketServer = new SocketServer('192.168.1.4','1986');