Wie kann ich mit der PHP-Curl-Multithread-Anfrage dafür sorgen, dass jeder Thread die Ergebnisse sofort nach Abschluss der Anfrage ausgibt, anstatt darauf zu warten, dass alle Anfragen abgeschlossen sind, und sie dann zusammen auszugeben?

Es gibt eine test.html im Stammverzeichnis der Website und der Inhalt ist nur eine Textdemo.

<code>    demo
</code>

---

Das ist curl.php

<code><php?

//设置curl
$chArr=[];
for($i=0;$i<500;$i++){
    $chArr[$i]=curl_init("http://dev.site/test.html");
    curl_setopt($chArr[$i],CURLOPT_RETURNTRANSFER,1);
}

//创建curl
$mh = curl_multi_init(); 
foreach($chArr as $k => $ch){
    curl_multi_add_handle($mh,$ch); 
}

$running = null;

do{
    curl_multi_exec($mh,$running); 
}while($running > 0); 

//启动多线程
foreach($chArr as $k => $ch){
    $result[$k]= curl_multi_getcontent($ch);  

    //在这里输出内容
    echo "$result[$k]\n"      
    
    curl_multi_remove_handle($mh,$ch);
}

curl_multi_close($mh); 


</code>

---

Die Parallelitätszahl ist auf 500 eingestellt, sodass das Ergebnis nach ca. 10 Sekunden Wartezeit ausgegeben wird. Während der Wartezeit antwortet das Programm nicht.

Der Effekt, den ich erreichen möchte, besteht darin, dass jedes Mal, wenn eine Curl-Thread-Anfrage abgeschlossen ist, sofort ein Ergebnis im Terminal ausgegeben werden kann: Dämon.

Wie sollten Sie es umsetzen? Wenn PHP es nicht implementieren kann, sind NodeJs- und Python-Lösungen akzeptabel, vielen Dank

Antwortinhalt:

Es gibt eine test.html im Stammverzeichnis der Website und der Inhalt ist nur eine Textdemo.

<code>    demo
</code>

---

Das ist curl.php

<code><php?

//设置curl
$chArr=[];
for($i=0;$i<500;$i++){
    $chArr[$i]=curl_init("http://dev.site/test.html");
    curl_setopt($chArr[$i],CURLOPT_RETURNTRANSFER,1);
}

//创建curl
$mh = curl_multi_init(); 
foreach($chArr as $k => $ch){
    curl_multi_add_handle($mh,$ch); 
}

$running = null;

do{
    curl_multi_exec($mh,$running); 
}while($running > 0); 

//启动多线程
foreach($chArr as $k => $ch){
    $result[$k]= curl_multi_getcontent($ch);  

    //在这里输出内容
    echo "$result[$k]\n"      
    
    curl_multi_remove_handle($mh,$ch);
}

curl_multi_close($mh); 


</code>

---

Die Parallelitätszahl ist auf 500 eingestellt, sodass das Ergebnis nach ca. 10 Sekunden Wartezeit ausgegeben wird. Während der Wartezeit antwortet das Programm nicht.

Der Effekt, den ich erreichen möchte, besteht darin, dass jedes Mal, wenn eine Curl-Thread-Anfrage abgeschlossen ist, sofort ein Ergebnis im Terminal ausgegeben werden kann: Dämon.

Wie sollten Sie es umsetzen? Wenn PHP es nicht implementieren kann, sind NodeJs- und Python-Lösungen akzeptabel, vielen Dank

nodejs ist asynchron

Sie können ob_start() und ob_flush() verwenden, vorausgesetzt, die Standardgröße beträgt 4 KB. Wenn sie nicht deaktiviert ist, ist sie ungültig, da Sie zu wenig Inhalt haben. Wenn über einen Browser darauf zugegriffen wird, gibt es keine Lösung, da der Browser noch über einen Puffer verfügt und dieser zu klein ist, wird der Effekt nicht sichtbar. Der folgende Test ist in der Befehlszeile in Ordnung. Wenn die Seite keine ini_set-Berechtigung hat, gehen Sie direkt zu php.ini und setzen Sie „output_buffering=0“. Die Schleife wird übrigens 500 Mal ausgeführt auf 2 Sekunden und php5.4 dauert 28 Sekunden.

<code class="php"><?php
ini_set('output_buffering', 0);
ob_start();
$chArr=[];
for($i=0;$i<500;$i++){
    $chArr[$i]=curl_init("http://dev.site/test.html");
    curl_setopt($chArr[$i],CURLOPT_RETURNTRANSFER,1);
}


$mh = curl_multi_init();
foreach($chArr as $k => $ch){
    curl_multi_add_handle($mh,$ch);
}

$running = null;

do{
    curl_multi_exec($mh,$running);
}while($running > 0);


foreach($chArr as $k => $ch){
    $result[$k]= curl_multi_getcontent($ch);
    echo "$result[$k]\n";
    ob_flush();
    flush();
    sleep(1);
    curl_multi_remove_handle($mh,$ch);
}
ob_end_flush();
curl_multi_close($mh);</code>

Obwohl es multithreaded ist, ist es synchron, nicht asynchron. PHP scheint keine asynchronen Fähigkeiten zu haben