AJAXで`curl_multi_init`の結果を、順次HTMLへ出力することは可能でしょうか？

Question

前提・実現したいこと

curl_multi_initで並列してレスポンスを取得し、それを順次HTMLへ出力する方法を知りたいです。
宜しくお願い致します。

発生している問題・エラーメッセージ

curl_multi_initで並列してレスポンスを取得する処理を実装したところなのですが、先の疑問が生じました。
これをHTMLに順次出力するにはどうしたらいいのか？という疑問です。

順次出力できないなら、せっかく並列で取得したレスポンスなのに、意味ないじゃん！と思ったのですが…方法が思いつきません。

該当のソースコード

例えば次のJSは、buttonのクリックでPHPのsearch_allが発動します。search_allが複数のcURLを平行して実行するので、そのレスポンスを次のJSのresponseで順次HTMLへ出力、ということをイメージしています。

$(document).on('click','button',function() {
	$.ajax({
		url : 'http://www...',
		type: 'POST',				
		data: { action: 'search_all' }
	}).done( function( response ) {
		// ここでPHPの search_all の結果を順次受け取り、HTMLに出力したい
	});
});

次がsearch_allになります。コメントでJSに返すとあるところで、上記JSのresponseに返したいのですが…

function search_all(){

	// curl_multiハンドラを用意
	$TIMEOUT = 10;
	$mh = curl_multi_init();
	
	// 送信データ
	$data = array(
	  array( 'name' => 'a', 'data' => 1 ),
	  array( 'name' => 'b', 'data' => 2 ),
	);
	
	// 送信データごとにcURLを実行
	foreach ($data as $d) {
		$ch = curl_init();
		curl_setopt_array($ch, array(
			CURLOPT_URL            => 'http://www...',
			CURLOPT_RETURNTRANSFER => true,
			CURLOPT_TIMEOUT        => $TIMEOUT,
			CURLOPT_CONNECTTIMEOUT => $TIMEOUT,
			CURLOPT_HTTPHEADER     => array('Content-Type: application/json'),
			CURLOPT_CUSTOMREQUEST  => 'POST',
			CURLOPT_POSTFIELDS     => json_encode($d, JSON_PRETTY_PRINT)
		));
		curl_multi_add_handle($mh, $ch);
	}

	// リクエストを開始する
	do {
		$stat = curl_multi_exec($mh, $running); //multiリクエストスタート
	} while ($stat === CURLM_CALL_MULTI_PERFORM);

	// レスポンスをcurl_multi_selectで待つ
	do switch (curl_multi_select($mh, $TIMEOUT)) { //イベントが発生するまでブロック

		case -1: //selectに失敗
			usleep(10); //ちょっと待ってからretry
			do {
				$stat = curl_multi_exec($mh, $running);
			} while ($stat === CURLM_CALL_MULTI_PERFORM);
			continue 2;

		case 0:  //タイムアウト
			continue 2; //ここではcontinueでリトライ

		default: //どれかが成功 or 失敗した
			do {
				$stat = curl_multi_exec($mh, $running); //ステータスを更新
			} while ($stat === CURLM_CALL_MULTI_PERFORM);

			do if ($raised = curl_multi_info_read($mh, $remains)) {
				
				// JSに返す
				$response = curl_multi_getcontent($raised['handle']);
				if ($response === false) {
					echo 'ERROR!!!';
				} else {
					echo json_decode($response, true);
				}
				
				curl_multi_remove_handle($mh, $raised['handle']);
				curl_close($raised['handle']);
			} while ($remains);

	} while ($running);
	curl_multi_close($mh);	
}

試したこと

根本的に、一回のAJAXのリクエストで、「PHPの結果を順次JSに返す」ことなどできないだろう、という考えを持っています。

で結局、「PHPの結果を順次JSに返す」方法が思いつきませんので、ひとまずはcurl_multi_initでなく普通のcurl_initにして、jQeury側で以下のように非同期に複数実行し、順次その結果を出力していく手はずでできました。

function search_single(){
	// curl_initを実行する関数
}

var func = $.when( search_single() ).done( function( response ){
	// ここで順次HTMLに出力する
});
funcs.push( func );

$.when.apply(null, funcs).then(
	// 順次出力が全部終わったときの処理
);

このように、まぁギリギリできましたので最悪これでもいいのですが、やはりcurl_multi_initを使っての方法が気になっています。

それができなければ何のためのcURLの並列なのか？と疑問だからです。PHP側の処理は並列で早くはなりますが、結局HTMLへの出力がまとめて一回でしかできないのなら意味ないじゃん！っていう感じがします。

なのでcurl_multi_initで並列してレスポンスを取得し、それを順次HTMLへ出力する方法を知りたい。となったのですが、いかがなものでしょうか。

補足情報（FW/ツールのバージョンなど）

なし

Answer 1

せっかく並列で取得したレスポンスなのに、意味ないじゃん！

そんなことはありません。１つ1秒のcurlを3本取得するとき
非同期処理なら1秒ですが、同期なら3秒かかります

Comments

[yambejp]

PHP側の処理として

<?PHP
set_time_limit( 0 );
for($i=0;$i<3;$i++){
sleep(1);
print $i;
@ob_flush();
@flush();
}
みたいなバッファを貯めずに出力してみてください。

[yambejp]

これを、jsで非同期に受け取るにはこう

fetch(url).then(res => {
const reader = res.body.getReader();
const stream = new Response(
new ReadableStream({
start(controller) {
(async()=>{
let result = await reader.read();
while (!result.done) {
const value = result.value;
console.log(new TextDecoder().decode(value));
controller.enqueue(value);
result = await reader.read();
}
controller.close();
})();
}
})
);
return stream;
}).then(res=>res.text()).then(res=>{console.log("end")});

[nippon]

できるんですか？！

一瞬期待しましたが、残念。

コンソールの表示ですが、1秒ずつ次の表示がされると思ったのですが、

0
1
2
end

しかしこうではなく、3秒待ってから一気に

012
end

となり、1秒ずつにはならなかったです。

ob_fhash調べてみますとできそうな感触はしたんですけどねぇ…

まぁ質問みたいに連続でJSをリクエストするよりも、setIntervalで定期的に見に行く方がまだマシですかね。

[nippon]

マニュアル
https://www.php.net/manual/ja/function.flush.php
に
> flush() はウェブサーバーのバッファリング手法を上書きすることはできません
とあるので、このせいでしょうかね。うーんレンタルサーバー残念すぎる。

[yambejp]

apache、phpのバージョン、ブラウザの種類によって若干バッファの考え方が
違う場合があるので微妙ですね
ダミーでスペースを大量に吐いてやるというのもよくある手段です

<?PHP
set_time_limit( 0 );
print str_repeat(" ",1024);
for($i=0;$i<3;$i++){
@ob_flush();
@flush();
sleep(1);
print $i;
}

flush処理が先に来ているのは最初にダミーをはいているからです

[yambejp]

受け取り側もダミー文字列がきたときは無視しないといけないのでこう

fetch(url).then(res => {
const reader = res.body.getReader();
const stream = new Response(
new ReadableStream({
start(controller) {
(async()=>{
let result = await reader.read();
while (!result.done) {
const value = result.value;
const v=new TextDecoder().decode(value);
if(!/^\s{1024}$/.test(v)){
console.log(v);
}
controller.enqueue(value);
result = await reader.read();
}
controller.close();
})();
}
})
);
return stream;
}).then(res=>res.text()).then(res=>{console.log("end")});

[nippon]

そういうテクニックもあるんですか。たぶんレンタルサーバーのせいでそれもできませんでしたけど、めちゃ勉強になりました。ありがとうございました。