curl Requisições GET assincronas com cURL

[Guilherme Luiz 41]

Olá pessoal,

 

Vamos abaixo:
 

Meu carma

Possuo uma aplicação que faz requisições a uma API em Rest via cURL.

Durante o consumo desta API eu tenho diversas requisições e variaveis paralelas que fazem validação, inserção e edição de dados no banco de dados.

Durante este processo, mesmo realizando a utilização de PHP + AngularJS a requisição até ser finalizada, deixa a pagina travada até que venha um response final da API requisitada.

 

Possíveis técnicas a serem utilizadas

Estive estudando algumas técnicas de threading e  sockets, porem o servidor atual que utilizo não possui acesso a biblioteca pthreads para o threading e a utilização via socket não consegui compreender e faze-la funcionar rsrs.

 

O que estou aplicando

Fazendo alguns testes, percebi que ao aplicar o cURL com um timeout de 1 segundo "resolve" o problema porque desta forma realizo o fluxo:

 

1. Capturo todos os dados que serão enviados a API
2. Salvo dados capturados no BD (mysqli)
3. Faço a requisição via cURL com timeout em 1 segundo para um script que fará a leitura destes dados pendentes de envio a API
4. Com os dados capturados, faço a requisição a API e então salvo o retorno e faço as devidas validações ao meu BD em "segundo plano".

 

De ante mão já reparei um "problema" que é justamente na requisição cURL com timeout em 1 segundo porque, uma vez que faço isso eu não tenho um retorno do meu script se ele foi requisitado ou não porque nem o http_code consigo recuperar para poder fazer qualquer tratativa e além disso também acredito que terei problemas no momento que o navegador do usuário atualizar porque a requisição feita será stopada e os dados serão salvos de forma parcial. Então, além destes problemas, temos algum outro "contra" a utilizar desta forma? Ao meu ver o que estou fazendo é mais uma gambiarra do que um código bem executado.

 

O que eu preciso

Uma orientação de como e qual a melhor técnica, tendo em vista minhas limitações de servidor citada acima (em relação ao pthreads), para poder realizar essa requisição GET de forma assíncrona.

 

cURL "async" que estou utilizando

error_reporting(E_ALL);

$url = "www.meusite.com.br/pending/read.php";

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL,$url);
curl_setopt($ch, CURLOPT_FORBID_REUSE, 1);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 0);
curl_setopt($ch, CURLOPT_NOSIGNAL, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, 1);
curl_setopt($ch, CURLOPT_HEADER, 0);
curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'GET');
$result   = curl_exec($ch);

if($result){
  var_dump(curl_getinfo($ch));
}else{
  var_dump(curl_error($ch));
  var_dump(curl_getinfo($ch));
}
var_dump($result);
curl_close($ch);

 

[Guilherme Luiz 41]

Pessoal,

 

Consegui realizar via socket o que preciso vejam o exemplo:

error_reporting(E_ALL);

/* Get the port for the WWW service. */
$service_port = getservbyname('www', 'tcp');

/* Get the IP address for the target host. */
$url     = parse_url("https://www.meusite.com.br/read.php");
$address = gethostbyname($url['host']);

/* Create a TCP/IP socket. */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
} else {
    echo "OK.\n";
}

echo "Attempting to connect to '$address' on port '$service_port'...";
$result = socket_connect($socket, $address, $service_port);
if ($result === false) {
    echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
} else {
    echo "OK.\n";
}

$in = "GET {$url['path']} HTTP/1.1\r\n";
$in .= "Host: {$url['host']}\r\n";
$in .= "Connection: Close\r\n\r\n";
$out = '';

echo "Sending HTTP HEAD request...";
socket_write($socket, $in, strlen($in));
echo "OK.\n";

// echo "Reading response:\n\n";
// while ($out = socket_read($socket, 2048)) {
//     echo $out;
// }

echo "Closing socket...";
socket_close($socket);
echo "OK.\n\n";

Peguei este código do proprio manual do PHP.

Neste modelo eu posso optar por não ler o response que o servidor roda em "segundo-plano" a requisição em GET e tenho o resultado esperado mesmo quando o navegador é fechado e o servidor não "trava" a navegação do usuário.

 

De todas as formas, gostaria de comentários de quem entende um pouco mais sobre estes tipos de requisições para poder me ajudar na formação da logica com foco em melhor desempenho.

[Gabriel Heming 766]

Lendo a sua descrição de problema, mais me parecia um lock de sessão, que se resolve utilizando session_write_close.

 

Valide seu código anterior, antes de realizar as requisições "pesadas" e após realizar todas as modificações em $_SESSION, adicione a função session_write_close.