PHP.SU

Программирование на PHP, MySQL и другие веб-технологии

PHP.SU Портал

Главная

Помощь

Поиск

Поиск Яндекс Вакансии

Пользователи

Здравствуйте, Гость

( Вход · Регистрация · Правила форума )

Забыли пароль?

Ajax & sockets

Форумы портала PHP.SU » PHP » Программирование на PHP » Работа с сетью (Модераторы: OrmaJever, Саныч)

Страниц (1): [1]

Без описания

Поиск в теме | Версия для печати

Slavenin	Отправлено: 04 Октября, 2012 - 12:00:03
Посетитель Покинул форум Сообщений всего: 285 Дата рег-ции: Май 2010 Откуда: Тверь Помог: 4 раз(а)	Всем доброго времени суток! Написал на 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(); js Спойлер (Отобразить) 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); } }); } ----- http://www[dot]i2p2[dot]de/index_ru[dot]html

Slavenin	Отправлено: 04 Октября, 2012 - 14:46:41
Посетитель Покинул форум Сообщений всего: 285 Дата рег-ции: Май 2010 Откуда: Тверь Помог: 4 раз(а)	победа но из разряда "где мой бубен"... Проблема решается путем запуска сервера в отдельном потоке через stream_socket_client с отключенной блокировкой stream_set_blocking( $s, 0 ); в результате сервер запускается в отдельном потоке, скрипт не ждет ответа и удачно завершается, можно слать запросы... вот бы еще кто-то просветил какого ... нужно серверу без этого шаманства ----- http://www[dot]i2p2[dot]de/index_ru[dot]html

keltstr	Отправлено: 05 Января, 2013 - 00:52:21
Новичок Покинул форум Сообщений всего: 16 Дата рег-ции: Янв. 2013 Помог: 0 раз(а)	сервер на win ? режим PHP ?

DeepVarvar	Отправлено: 05 Января, 2013 - 01:13:28
Активный участник Покинул форум Сообщений всего: 10377 Дата рег-ции: Дек. 2008 Откуда: Альфа Центавра Помог: 353 раз(а)	Slavenin пишет: и пробую снова чего-нибудь ему отправить. Он запускается(вижу в логах) Вот тут подробнее пожалуйста о последовательности действий, я не понял. Но по сути, да, если вы проведете эксперимент и будете коннектиться до порта, на котором висит сокет, четез браузер напрямую, быстро обновляя F5, то увидите, что счетчик обращений показывает не корректные результаты. Дело в том что браузер по причине "оптимизации" (тваюмать) его работы не ждет синхронизированного ответа на конкретно отправленный запрос, а принимает тот, который пришел от сервера сейчас, и ему не важно, что от сервера летят еще пять ответов. Лечение отсутствует. Ставьте памятник великим кодерам хрома, мазилы, оперы и с некоторых пор осла... вуаля. Хотя более низкий уровень, TCP, как бы обязывает синхронизацию пакетов ----- Шта? Репозиторий?

Поиск в теме | Версия для печати

Страниц (1): [1]

Сейчас эту тему просматривают: 0 (гостей: 0, зарегистрированных: 0)

« Работа с сетью »

Все гости форума могут просматривать этот раздел.
Только зарегистрированные пользователи могут создавать новые темы в этом разделе.
Только зарегистрированные пользователи могут отвечать на сообщения в этом разделе.