Uma coisa é uma função rodar de modo assíncrono, outra coisa é fazer uma chamada para algo externo sem esperar uma resposta (ou pegar a resposta posteriormente), eu não vou entrar em detalhes porque para ser sincero eu não conheço a fundo Guzzle.
PHP só tem realmente suporte a Threads com PThread, ainda sim é possivel simular algo. Pessoalmente não vejo necessidade de rodar uma função de maneira assíncrona em um script PHP que processa uma página web, talvez eu não entenda bem a necessidade disto, creio que talvez em uma aplicação CLI (Command-line interface/interface de linha de comando) que use PHP seria mais interessante, já que poderia executar múltiplas tarefas e ficar rodando infinitamente (ou até todos "eventos" terminarem).
Chamar um script PHP sem esperar ele responder
Falando independente da necessidade, um exemplo o qual seria algo semelhante ao "assíncrono" (na verdade é um processo totalmente a parte) seria chamar um script PHP através de outro script em modo CLI, ficaria algo como:
/**
* Iniciar script em outro processo
*
* @param string $script Define a localização do script
* @param string $php_exe Define a localização do interpretador (opcional)
* @param string $php_ini Define a localização do php.ini (opcional)
* @return void
*/
function processPhpScript($script, $php_exe = 'php', $php_ini = null) {
$script = realpath($script);
$php_ini = $php_ini ? $php_ini : php_ini_loaded_file();
if (stripos(PHP_OS, 'WIN') !== false) {
/* Windows OS */
$exec = 'start /B cmd /S /C ' . escapeshellarg($php_exe . ' -c ' . $php_ini . ' ' . $script) . ' > NUL';
} else {
/* nix OS */
$exec = escapeshellarg($php_exe) . ' -c ' . escapeshellarg($php_ini) . ' ' . escapeshellarg($script . ' >/dev/null 2>&1');
}
$handle = popen($exec, 'r');
if ($handle) {
pclose($handle);
}
}
processPhpScript('pasta/script1.php');
processPhpScript('pasta/script2.php');
Se estiver em windows os scripts serão executados como se estivessem no CMD com o comando start
para que não precise esperar:
start /B cmd /S /C "c:\php\php.exe -c c:\php\php.ini c:\documents\user\pasta\script1.php" > NUL
start /B cmd /S /C "c:\php\php.exe -c c:\php\php.ini c:\documents\user\pasta\script2.php" > NUL
Se estiver em um ambiente unix-like irão executar com para gravar a saída em /dev/null
ao invés de retornar para o output
php -c /etc/php/php.ini /home/user/pasta/script1.php >/dev/null 2>&1
php -c /etc/php/php.ini /home/user/pasta/script2.php >/dev/null 2>&1
Isto fará com que o teu script que chamou a função processPhpScript
não precise esperar a resposta.
Curl e fsockopen
Eu creio que quando falamos de assíncrono em Guzzle na verdade estamos falando de requisições externas do qual não precisa esperar a resposta porque não a deseja ou de múltiplas requisições que trabalham de maneira concorrente ao mesmo tempo e vão sendo entregues conforme vão terminando, o próprio Curl consegue fazer algo assim:
<?php
// Inicia dois CURLs
$ch1 = curl_init("https://pt.stackoverflow.com/");
$ch2 = curl_init("https://meta.pt.stackoverflow.com/");
//Esta parte é apenas devido ao SSL, é tudo apenas um exemplo
curl_setopt($ch1, CURLOPT_SSL_VERIFYHOST, 0);
curl_setopt($ch2, CURLOPT_SSL_VERIFYPEER, 0);
curl_setopt($ch1, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch2, CURLOPT_RETURNTRANSFER, 1);
//Inicia o manipulador e adiciona o curls
$mh = curl_multi_init();
curl_multi_add_handle($mh, $ch1);
curl_multi_add_handle($mh, $ch2);
//Executa as requisições simultaneamente
$running = null;
do {
curl_multi_exec($mh, $running);
} while ($running);
//Finaliza o manipulador
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);
curl_multi_close($mh);
//Pega o conteúdo
$response1 = curl_multi_getcontent($ch1);
$response2 = curl_multi_getcontent($ch2);
//Exibe as respostas
echo $response1, PHP_EOL;
echo $response2, PHP_EOL;
Agora se observar bem, requisitamos duas requisições ao mesmo tempo, ainda sim para se obter a resposta foi necessário esperar tudo. Creio que no Guzzle o requestAsync
deve trabalhar com algo como o Promisse, que o que ele vai conseguindo obter ele vai enviando para uma resposta em um callback, eu não conheço muito o curl, talvez seja possivel checar qual item no curl_init
terminou, mas irei dar uma sugestão com fsockopen
, é apenas um exemplo básico:
<?php
function createRequest($url, &$failno, &$failstr) {
$parsed = parse_url($url);
$isHttps = $parsed['scheme'] == 'https';
$host = ($isHttps ? 'ssl://' : '') . $parsed['host'];
$port = isset($parsed['port']) ? $parsed['port'] : ($isHttps ? 443 : 80);
$socket = fsockopen($host, $port, $errorno, $errorstr);
echo $host, $port;
if ($socket) {
$out = "GET " . $parsed['path'] . " HTTP/1.1\r\n";
$out .= "Host: " . $parsed['host'] . "\r\n";
$out .= "Connection: close\r\n\r\n";
fwrite($socket, $out);
return $socket;
}
return false;
}
function checkStatus(&$promisses, \Closure &$done) {
if (empty($promisses)) {
return false;
}
$nocomplete = false;
foreach ($promisses as &$promisse) {
if (feof($promisse['socket']) === false) {
$nocomplete = true;
$promisse['response'] .= fgets($promisse['socket'], 1024);
} else if ($promisse['complete'] === false) {
$promisse['complete'] = true;
$done($promisse['url'], $promisse['response']);
}
}
return $nocomplete;
}
function promisseRequests(array $urls, \Closure $done, \Closure $fail)
{
$promisses = array();
foreach ($urls as $url) {
$current = createRequest($url, $errorno, $errorstr);
if ($current) {
$promisses[] = array(
'complete' => false,
'response' => '',
'socket' => $current,
'url' => $url
);
} else {
$fail($url, $errorno, $errorstr);
}
}
$processing = true;
while ($processing) {
$processing = checkStatus($promisses, $done);
}
}
// Inicia dois CURLs
$urls = array(
'http://localhost/',
'http://localhost/inphinit/'
);
promisseRequests($urls, function ($url, $response) {
var_dump('Sucesso:', $url, $response);
}, function ($url, $errorno, $errorstr) {
var_dump('Falhou:', $url, $errorno, $errorstr);
});
No geral o que eu fiz foi fazer as requisições trabalharem ao mesmo tempo, o que acho interessante disto é que você consegue obter o resultado que primeiro terminar e já manipular como desejar, mas creio que nem sempre é útil.
Aonde Thread seria interessante
Ambos exemplos que citei acima não são threads, um é um processo a parte que evita ter que esperar (já que a chamada é totalmente a perte) e o outro se trata de multiplas requisições HTTP e a que terminar primeiro chama o Closure
, mas falando de threads de verdade (ou proximo disto) o unico local que eu vejo que talvez ele seria interessante é com um script PHP que fica rodando continuamente, por exemplo um script CLI como já citei ou um Socket para trabalhar com WebSocket (que por sinal também é um CLI).
Vou usar como exemplo o WebSocket, um servidor socket manipula várias chamadas e ele responde ao websocket só quando desejar, imaginando que 5 pessoas se conectem ao socket através de WebSocket fazendo pedidos seria interessante mover os pedidos para Threds e entrega-los somente quando terminado, caso contrário teria que processa-los na medida do que foi pedido e então o usuário que fez um pedido simples acaba tendo que esperar os usuários que fizeram pedidos mais demorados de processar, com o Thread isso poderia melhorar um pouco, ajudando a trabalhar a concorrência (claro se o script for bem escrito).
Assim que possivel eu postarei um exemplo com WebSocket
Instalando PThreads
Ele pode ser instalado via PECL, usando o comando:
pecl install pthreads
Mas se não tiver Pecl pode tentar e usando Windows pode baixar os binários aqui http://windows.php.net/downloads/pecl/releases/pthreads/, mas se usa Mac OSX, Linux ou não tem o binário para a sua versão do PHP e não tem o PECL, então terá que compilar após baixar de https://github.com/krakjoe/pthreads, claro que o executável PHP tem que ter sido compilado em sua máquina também e pelo mesmo compilador (não vou entrar em detalhes pois este não é o foco da pergunta)
Message Queue
ou algo parecido. Talvez valha a pena dar uma olhada.set_time_limit
, na minha opinião.