<?php
      header('Content-Type: text/plain;');
      set_time_limit(0);
      ob_implicit_flush();      
   echo "-= Server =-\n\n";
     
$NULL           = NULL;
$adres          = "localhost";
$port           = 1024;
$max_clients    = 3;
$sockets_clients = array();
$creat         = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
$rez            = true;

   echo 'Create socket ... ';
    if(!$creat){
      die("socket_create() failed\n") ;
    }else{
      echo "OK\n";
    }
     
$rez &= @socket_bind($creat, $adres, $port);
   echo 'Bind socket ... ';
    if(!$rez){
      die("socket_bind() failed\n") ;
    }else{
      echo "OK\n";
    }

$rez &= @socket_listen($creat);
   echo 'Listen socket ... ';
    if(!$rez){
      die("socket_listen() failed\n") ;
    }else{
      echo "OK\n";
    }
   echo "Accepting of socket ... OK\n";
$abort = false;
$read = array($creat);
     
while(!$abort){
      $num_changed = socket_select($read, $NULL, $NULL, 0, 10);
      /* Изменилось что-нибудь? */
      if ($num_changed){
          /* Изменился ли главный сокет (новое подключение) */
          if(in_array($creat, $read)){
                  if(count($sockets_clients) < $max_clients){
                          $sockets_clients[]= socket_accept($creat);
                          echo " Accept socket (" . count($sockets_clients)  . " of $max_clients clients)\n";
                          // socket_write($sockets_clients[count($sockets_clients)-1], "Hello, Client!", 15);
                          echo "  Say to ".count($sockets_clients)." client: Hello, Client!\n";
                  }
          }        
          /* Цикл по всем клиентам с проверкой изменений в каждом из них */
          foreach($sockets_clients as $key => $client){

              /* Новые данные в клиентском сокете? Прочитать и ответить */
              if(in_array($client, $read)){
                  $input = socket_read($client, 1024);
                    
                  /*Блок отправления данных клиентам*/
                  for ($i=0; $i<>count($sockets_clients); $i++){
                    if($sockets_clients[$i]!=$client){
                      socket_write($sockets_clients[$i],"$input") ;
                    }
                  }
                    /*close socket, if message = bye*/                     
                  if($input == 'bye'){
                      echo "Close socket ... OK\n";
                      socket_close($creat);
                      $abort = true;
                  }               
             
              }// END IF in_array            
           
          } // END FOREACH
         
      } // END IF ($num_changed)
        
                      
      $read = $sockets_clients;
      $read[] = $creat;
} // END WHILE
?>

         /* connect to socket */
var socket = new Socket("localhost", 1024);
      socket.connect;   
   socket.flush;
         
           /* state of connect to socket */        
socket.addEventListener(Event.CONNECT,socketConnected);
   function socketConnected(e:Event):void{
   trace("client - socket connected", socket.connected);
   }
     
           /* read the string from the socket*/
socket.addEventListener(ProgressEvent.SOCKET_DATA,socketData);
   function socketData(e:ProgressEvent):void{
   var x1='';
   var y1='';
   var read_socket=socket.readUTFBytes(socket.bytesAvailable);
    if (read_socket.indexOf('x')==0){
     for (var i=1; i<read_socket.length; i++){   
      x1=x1+read_socket.charAt(i);   
           }
    sqr.x=Number(x1);   
    }
    if (read_socket.indexOf('y')==0){
     for (i=1; i<read_socket.length; i++){   
      y1=y1+read_socket.charAt(i);   
           }
    sqr.y=Number(y1);   
    }
   trace(read_socket);   
   }
      
      

         /*Move to sqr*/
var speed:Number = 5;
stage.addEventListener(KeyboardEvent.KEY_DOWN, downn);

   function downn(e:KeyboardEvent): void{
   if (e.keyCode==37){
    socket.writeUTFBytes('x'+sqr_i.x);        //write to socket
    socket.flush();
    sqr_i.x -= speed;
   }if(e.keyCode==39){
    socket.writeUTFBytes('x'+sqr_i.x);
    socket.flush();
    sqr_i.x += speed;
   }if(e.keyCode==38){
    socket.writeUTFBytes('y'+sqr_i.y);
    socket.flush();
    sqr_i.y -= speed;
   }if(e.keyCode==40){
    socket.writeUTFBytes('y'+sqr_i.y);
    socket.flush();
    sqr_i.y += speed;
   }   
   }

      
// socket.writeUTFBytes('bye');

/*sqr.addEventListener(Event.ENTER_FRAME, sqr_move);
   function sqr_move(e:Event): void{
    sqr.y=Number(socket.readUTFBytes(socket.bytesAvailable));    
   }*/
                       
            
       /*close to socket*/
   socket.close;