socket и Online

<?php
header('Content-Type: text/plain;');
 
error_reporting(E_ALL);
 
set_time_limit(0);
 
ob_implicit_flush();
echo "-= Server =-\n\n";
$address = '****';
$port = ***;
 
function send_Message($allclient, $socket, $buf) {
    if ($buf == "<policy-file-request/>\0")
    {
        foreach($allclient as $client)
        {
        socket_write($client, '<?xml version="1.0"?><!DOCTYPE cross-domain-policy SYSTEM "/xml/dtds/cross-domain-policy.dtd"><cross-domain-policy><site-control permitted-cross-domain-policies="master-only"/><allow-access-from domain="*" to-ports="*"/></cross-domain-policy>'."\0");
        }
        socket_close($socket);
    }
 else {
   foreach($allclient as $client) {
       socket_write($client, "$socket wrote: $buf");
   }
 }
}
 
if (($master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) {
   echo "socket_create() failed, reason: " . socket_strerror($master) . "\n";
}
 
socket_set_option($master, SOL_SOCKET,SO_REUSEADDR, 1);
if (($ret = socket_bind($master, $address, $port)) < 0) {
   echo "socket_bind() failed, reason: " . socket_strerror($ret) . "\n";
}
 
if (($ret = socket_listen($master, 5)) < 0) {
   echo "socket_listen() failed, reason: " . socket_strerror($ret) . "\n";
}
 
$read_sockets = array($master);
while (true) {
   $changed_sockets = $read_sockets;
   $num_changed_sockets = socket_select($changed_sockets, $write = NULL, $except = NULL, NULL);
   foreach($changed_sockets as $socket) {
       if ($socket == $master) {
           if (($client = socket_accept($master)) < 0) {
               echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";
               continue;
           } else {
               send_Message($read_sockets, "sistems", "Vhod ".$client."\n");
               array_push($read_sockets, $client);
           }
       } else {
           $bytes = socket_recv($socket, $buffer, 2048, 0);
           if ($bytes == 0) {
               $index = array_search($socket, $read_sockets);
               unset($read_sockets[$index]);
               socket_close($socket);
           }else{
                $allclients = $read_sockets;
                array_shift($allclients);
                send_Message($allclients, $socket, $buffer);
            }
       }
 
   }
}
 
?>

           if ($bytes == 0) {
               $index = array_search($socket, $read_sockets);
               unset($read_sockets[$index]);
               socket_close($socket);
}

$bytes = socket_recv($socket, $buffer, 2048, 0);
           if ($bytes == 0)

$bytes = socket_recv($socket, $buffer, 2048, 0);
           if ($bytes == NULL)

<?php
 
header('Content-Type: text/plain;');
 
error_reporting(E_ALL ^ E_WARNING);//включаем отображение ошибок
 
set_time_limit(0);//чтоб скрипт выполнялся всегда, а не положенные 30 секунд по дефолту
 
ob_implicit_flush();//выводить строки с помощью echo нужно сразу при их выводе, а не после полной загрузки страницы, как это делается по-умолчанию.
 
$port = ****;//порт нашего сервера
 
$address = '*****';
 
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);//создаём дескриптор сокета
 
socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);//задаём опции порта
 
socket_bind($sock, $address, $port);//привязываес этот дескриптор к нашему адресу и порту
 
socket_listen($sock);//начинаем прослушивание сокета
 
$clients = array($sock);// Создаем список всех клиентов, которые будут связаны с нами . Добавляем сокет в этот список
 
  while (true) {
 
    $read = $clients;// создаём копии
 
    if (socket_select($read, $write = NULL, $except = NULL, 0) < 1) //получаем список всех клиентов, если нет клиентов с данными - продолжаем
    continue;
 
    if (in_array($sock, $read)) { //смотрим, есть ли клиенты, пытающиеся соединиться
    $clients[] = $newsock = socket_accept($sock);//соединяемся с клиентом и добавляем дескриптор соединения в массив
    socket_write($newsock, '<?xml version="1.0"?><!DOCTYPE cross-domain-policy SYSTEM "/xml/dtds/cross-domain-policy.dtd"><cross-domain-policy><site-control permitted-cross-domain-policies="master-only"/><allow-access-from domain="*" to-ports="*"/></cross-domain-policy>'."\0");//отсылаем клиенту сообщение, что всё он соединился
    socket_getpeername($newsock, $ip);//запрашиваем ип адрес клиента
          foreach ($clients as $read_socksi){
          socket_write($read_socksi, "new: {$ip}"." \0");
          }
    $key = array_search($sock, $read);//удаляем запись из массива, в котором хранятся соединяющиеся клиенты
    unset($read[$key]);
    }
 
    foreach ($read as $read_sock) {//начинаем смотреть по всем клиентам, которые соединены с нами
    $data = @socket_read($read_sock, 1, PHP_NORMAL_READ);//читаем что пишет клиент
        if ($data === false) {//проверяем, не отсоединился ли клиент
        $key = array_search($read_sock, $clients);//удаляем дескриптор клиента из массива клиентов
        unset($clients[$key]);
          foreach ($clients as $read_socksi){
          socket_write($read_socksi, "drop: {$ip}"." \0");
          }
        continue;//Продолжаем читать сообщения клиентов
        }
 
 
        if (!empty($data)) {//если клиент что-то прислал - отсылаем обратно. В этом месте можно писать свои обработчики команд
          foreach ($clients as $read_sockso){
          socket_write($read_sockso, "{$data}"."");
          }
        }
 
    }
 
  }
 
socket_close($sock);
 
?>