Форумы портала PHP.SU :: Версия для печати

1. Slavenin - 04 Октября, 2012 - 12:00:03 - перейти к сообщению

Всем доброго времени суток!
Написал на php сокет-сервер. Все здорово, все работает... При прямом обращении по нужным адресам.

Дальше начинается "уличная магия"... В том случае, если сервер уже запущен, когда я дергаю его ajax`ом все хорошо. Если же сервер не запущен, то я его запускаю и пробую снова чего-нибудь ему отправить. Он запускается(вижу в логах), но... и это самое странное, даже после принудительного завершения ajax-запроса(на запуск) второй(с сообщением до сервера не доходит)... тупо висит в сетевой активности, такое ощущение, что он встает в некую очередь и ждет завершения скрипта сервера, так как если сервак тормознуть, то запрос выполняется.

Помогите пожалуйста, второй день не могу понять, что происходит...

Сервер

Спойлер (Отобразить)

PHP:
скопировать код в буфер обмена

$this->log("старт: " .time()  . "\n");
                set_time_limit( 60 );
                ob_implicit_flush();
 
                $address = $_SERVER['HTTP_HOST'];
 
                if( ($sock = socket_create( AF_INET, SOCK_STREAM, SOL_TCP )) === false )
                {
                        $this->log("ошибка создания сокета: " . socket_strerror( socket_last_error() ) . "\n");
                        exit();
                }
 
                $this->log("сокет создан\n");
 
                if( socket_bind( $sock, $address, $this->port ) === false )
                {
                        $this->log("socket_bind() не удался: причина: " . socket_strerror( socket_last_error( $sock ) ) . "\n");
                        exit();
                }
 
                $this->log("сокет привязан\n");
 
                if( socket_listen( $sock, 2 ) === false )
                {
                        $this->log("socket_listen() не удался: причина: " . socket_strerror( socket_last_error( $sock ) ) . "\n");
                        exit();
                }
 
                $this->log("сокет слушается\n");
 
                $mess_flag = false;
 
                do
                {
                        $read = array( );
                        $read[ ] = $sock;
 
                        $read = array_merge( $read, $this -> clients );
 
                        // Set up a blocking call to socket_select
                        $write = NULL;
                        $except = NULL;
 
                        if($mess_flag)
                        {
                                //проверяем клиентов на активность и удаляем неактивных
                                foreach($this->last_messages as $key => $value)
                                {
                                        if((time() - $value) > 3)
                                        {
                                                unset($this->last_messages[$key]);
                                                $this -> updCountUser();
                                        }
 
                                        $this->log("простой : " . (time() - $value) . "\n");
                                }
 
                                if( ! count( $this->last_messages ) )
                                {
                                        $this -> updCountUser();
                                        break;
                                }
                        }
 
                        //$this->log("до выбора\n");
                        if( socket_select( $read, $write, $except, 1 ) < 1 )
                        {
                                continue;
                        }
 
                        //$this->log("после выбора\n");
 
                        // Handle new Connections
                        if( in_array( $sock, $read ) )
                        {
 
                                if( ($msgsock = socket_accept( $sock )) === false )
                                {
                                        $this->log("socket_accept() не удался причина: " . socket_strerror( socket_last_error( $sock ) ) . "\n");
                                        break;
                                }
                                $this -> clients[ ] = $msgsock;
                                $key = array_keys( $this -> clients, $msgsock );
 
                                $msg = "1\n";
                                socket_write( $msgsock, $msg, strlen( $msg ) );
 
                                $this->log("ответили пользователю\n");
                        }
 
                        // читаем клиентов
                        foreach( $this -> clients as $key => $client )
                        {
                                if( in_array( $client, $read ) )
                                {
                                        if( false === ($buf = socket_read( $client, 2048, PHP_NORMAL_READ )) )
                                        {
                                                $this->log("socket_read() не удался причина: " . socket_strerror( socket_last_error( $client ) ) . "\n");
                                                break 2;
                                        }
                                        if( ! $buf = trim( $buf ) )
                                        {
                                                continue;
                                        }
 
                                        $this->messages[$key]['message'] .= $buf;
                                        $this->messages[$key]['time'] = time();
 
                                        if( $buf == 'shutdown' )
                                        {
                                                socket_close( $client );
                                                $this -> clients = array();
                                                $this -> updCountUser();
                                                break 2;
                                        }
 
                                        //конец сообщения
                                        if(strstr($buf, "#{end}"))
                                        {
 
                                                $mess_flag = true;
 
                                                $match = array();
                                                preg_match('/.*\#\{start\}(.*)\#\{end\}/iu', $this->messages[$key]['message'], $match);
 
                                                $str = json_decode($match[1]);
                                                $this->log("текст: {$str}\n");
 
                                                $match = array();
                                                preg_match('/.*\{id:(.*)\}/iu', $str, $match);
                                                $id = $match[1];
 
                                                $this->last_messages[$id] = time();
 
                                                unset( $this -> clients[ $key ] );
                                                unset( $this -> messages[ $key ] );
                                                socket_close( $client );
 
                                                $this -> updCountUser();
                                                $this->log("сообщение от: {$id} \n");
 
                                                $this->log("клиент отсоединен\n");
 
                                                break;
                                        }
                                }
                        }
                }
                while( true );
 
                $this->log("стоп: " .time()  . "\n=====\n");
                socket_close( $sock );

клиент

Спойлер (Отобразить)

PHP:
скопировать код в буфер обмена

$address = gethostbyname( $_SERVER['HTTP_HOST'] );
 
                $socket = socket_create( AF_INET, SOCK_STREAM, SOL_TCP );
                if( $socket === false )
                {
                        $this->log("Не удалось выполнить socket_create(): причина: " . socket_strerror( socket_last_error() ) . "\n");
                        exit();
                }
 
                $result = socket_connect( $socket, $address, $this->port );
                if( $result === false )
                {
                        $this->log("Не удалось выполнить socket_connect().\nПричина: " . socket_strerror( socket_last_error( $socket ) ) . "\n");
                        exit();
                }
                else
                {
                        $this->log("Соединение установлено.\n");
                }
 
                $in      = "HEAD / HTTP/1.1\r\n";
                $in .= "Host: {$_SERVER['HTTP_HOST']}\r\n";
                $in .= "Authorization: Basic " . base64_encode( "devlogin:devpass1" ) . "\r\n";
                $in .= "Connection: Close\r\n";
                $in .= "Content-Type: text/html; charset=utf-8\r\n\r\n";
                $in .= "#{start}" .json_encode( '{id:' .session_id() . '}' ) . "#{end}\r\n";
                //$in .= "shutdown\r\n";
                $out = '';
 
                $this->log("Отправляем  HTTP HEAD запрос...\n");
                socket_write( $socket, $in, strlen( $in ) );
 
                while( $out = socket_read( $socket, 2048 ) )
                {
                        echo $out;
                }
 
                $this->log("Закрываем сокет...\n");
                socket_close( $socket );
                exit();

Спойлер (Отобразить)

CODE (javascript):
скопировать код в буфер обмена

window.onload = function()
{
        $.ajax({
                type: "GET",
                url: "/ru/socet_client/index.php",
                data: {},
                timeout: 1000,
                success: function(data) {
                        if(data !== '1\n')
                        {
                                jqxhr = $.ajax({
                                        type: "GET",
                                        url: "/ru/socket_server/index.php",
                                        data: {},
                                        timeout: 1000,
                                        success: function(data) {
                                                alert('Ready');
                                        },
                                        error: function(jqXHR, textStatus, errorThrown){
                                                alert('error_server ' + textStatus + ' ' + errorThrown);
                                        }
                                });
                                setTimeout(postAjax, 1500);
                        }
                },
                error: function(jqXHR, textStatus, errorThrown){
                        alert('error_client ' + textStatus + ' ' + errorThrown);
                }
        });
};
 
function postAjax()
{
        jqxhr.abort();
        $.ajax({
                type: "GET",
                url: "/ru/socet_client/index.php",
                data: {},
                //timeout: 1000,
                success: function(data) {
                        alert(data);
                },
                error: function(jqXHR, textStatus, errorThrown){
                        alert('error_server ' + textStatus + ' ' + errorThrown);
                }
        });
}