PHP относится к языкам, в которых поддержка многопоточности отсутствует. Но, есть немало задач, в которых она была бы очень полезна. В большинстве случаев вам не нужно порождать и создавать новых потоков вообще и можно получить отличную производительность и без этого.

Сокеты

Очень полезная штука, когда вам надо дёргать чужие страницы или просто посылать запросы к другим сайтам.

Недавно поступил заказ на скрипт, который будет дёргать информацию с одного сайта, сохранять в базу, а потом переносить на другой. Порой скрипт делает запросы к 100+ страницам. Если этот скрипт бы выполнялся последовательно, то заняло бы много времени.

В этом деле поможет функция stream_socket_client

Прелесть в том, что, создавая запросы к сайтам этой функцией в асинхронном режиме, нам не придётся ждать ответа. Задача состоит из двух частей.

Создать сокеты
$flag = STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT; $sockets=array(); $id=0; $timeout = 60; $convenient_read_block=8192; $result=array(); $url = array(); for($i=$this->beg_ID;$i<=$this->end_ID;++$i) { $fp = stream_socket_client('tcp://'.$host.':'.$this->port, $err, $errstr, 8, $flag); if (!$fp) { echo 'httpPost error: '.$errstr; return NULL; } else { stream_set_blocking($fp, 0); $sockets[$id++] = $fp; $url[$id-1] = $i; } }

Как видно, создаются сокеты и ссылки на них сохраняются в массиве $sockets. Теперь необходимо организовать прослушку ответов.

Ждём ответа

В некоторых источниках видел исходники, где функция на запись в сокет вызывается сразу после создания(применяли к $fp). На самом деле необходимо организовать прослушку на готовность сокета и к чтению, и к записи.

//создаём массивы сокетов для прослушки $toRead = $toWrite = $sockets; //пока есть сокеты, чтение с которых мы ждём while (count($toRead) > 0) { $read=$toRead; $write=$toWrite; stream_select($read, $write, $e=null, $timeout); //есть сокеты, готовые к записи if (count($write)) { foreach ($write as $w) { $id=array_search($w, $sockets); //$query="GET /product.php?pid=PD".$id." HTTP/1.0\r\n". $query="GET /product.php?pid=PD0".$url[$id]." HTTP/1.0\r\n". "Host: ".$host."\r\n". "User-Agent: Mozilla/5.0 (Windows NT 5.1; rv:2.0.1) Gecko/20100101 Firefox/4.0.1\r\n". "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*\/*;q=0.8". "Accept-Language: ru-ru,ru;q=0.8,en-us;q=0.5,en;q=0.3\r\n". "Accept-Encoding: gzip, deflate\r\n". "Accept-Charset: windows-1251,utf-8;q=0.7,*;q=0.7\r\n". "Connection: close\r\n\r\n"; fwrite($w, $query); unset($toWrite[array_search($w, $toWrite)]); } } //есть сокеты, готовые к чтению if (count($read)) { foreach ($read as $r) { $id=array_search($r, $sockets); if(!isset($result[$id])) $result[$id]=''; $data=fread($r, $convenient_read_block); if (strlen($data) == 0) { fclose($r); unset($toRead[array_search($r, $toRead)]); } else { $result[$id] .= $data; } } } }

Мы используем функцию stream_select() для ожидания возникновения событий на открытых сокетах. Вы можете ожидать готовности чтения, записи или исключительных событий (параметр первый, второй и третий соответственно). stream_select() будет ждать $timeout секунд пока событие не появится – когда же это случится, функция будет модифицировать массивы, которые Вы ей передали, так что они будут содержать идентификаторы сокетов, удовлетворяющих Вашему критерию.

Ну, как примечание, скажу, что доступна эта прелесть с PHP 5.

Комментарии

comments powered by Disqus