- 追加された行はこの色です。
- 削除された行はこの色です。
[[PHP]]
某案件で処理時間の長いWebAPIが１つ有り、それをすぐに返す必要があったため「起動WebAPI」と「結果取得WebAPI」に分けることとなりました。
「起動WebAPI」ではとりあえず受付完了の結果をすぐに返すと共に、裏で非同期処理（マルチスレッド処理、バックグラウンド処理）を動かす必要が出ました。
そこで非同期処理を実現する方法を考察しました。
*curlを用いた非同期処理
-[[[EC studio技術ブログ]PHPでマルチスレッド(バックグラウンド処理、非同期処理)を実現する方法>http://techblog.ecstudio.jp/tech-tips/php-multi.html]]
curlを用いて複数のWebAPIを同時に呼び出し、すべての処理が終わってから処理を続ける方法が書かれています。~
WebAPI１つずつ呼び出すのに比べて処理時間が短くなります。~
またcurl以外に次の方法も有りますが、PHPをCGIモードで動かしているときしか使えないので使えないそうです。(== 多くの場合で利用されるApacheモジュールとして動かしていると使えない)
-pcntl_forkというプロセスをフォーク(複製)することができる関数を利用する方法
-「system('php -f test.php > /dev/null &'); 」といったふうに起動する方法
~
『もちろん長時間動かす時はset_time_limitの設定も忘れずに。ignore_user_abortを使えばバックグラウンド処理も可能です。』だそうです。~
これらの設定は他の方法でも入れるほうがいいようです。
~
便利そうですが、PHP拡張モジュールであるcurlがウェブ側設定によって使えない場合は利用できませんので、
今回案件では使用しませんでした。
*HTTPリダイレクトを用いた非同期処理
-[[[nao pon's Blog]PHPで非同期通信>http://xoops.hypweb.net/modules/UsersWiki/person/nao-pon/blog/2006-11-17]]
HTTPリダイレクトを用いてブラウザへのレスポンスはリダイレクト先で直ぐに返し、バックグラウンド処理はリダイレクト元で続ける方法です。
試してみました。ブラウザからリダイレクト元を呼び出すとHTTPリダイレクト先がすぐに表示されました。~
今回案件ではPHPプログラムでリダイレクト元を呼んだときに、リダイレクト先で作られたXMLデータを返して欲しかったのですが、HTTPレスポンスコード500 Internal Server Errorとなってしまいました。おそらくPHPからの呼び側でHTTPリダイレクトに対応していないためと思われます。
*ソケットで非同期処理を起動
-[[2ch 【PHP】質問スレッドPart2>http://ebi.2ch.net/php/kako/1003/10032/1003283567.html]]
呼び出し元はすぐに返り、バックグラウンドをソケットで起動する方法です。こちらが動作ＯＫでしたので採用しました。
引用
----
35 名前： 電動ナナシ 投稿日： 01/10/23 03:18 ID:We7XcUx8
>>32
まあ要するにスクリプトを非同期で実行したいってことかな。
これでどうかな。async_caller.php から async_called.php を呼ぶコード。
async_caller.php が先に終了するが、called は caller が終了してもバック
グラウンドで実行される。caller に表示されるタイムスタンプが called が
test.dat に記録するタイムスタンプより前であることから確認できるだろう。
Windows2000 + Apache 1.3.20 + PHP 4.0.6 で確認。
async_caller.php
<?php
$fp = fsockopen ("localhost", 80, $errno, $errstr, 5);
if (!$fp) {
echo "Error: $errstr ($errno)<br>\n";
} else {
socket_set_blocking($fp, false);
fputs ($fp, "GET /hoge/async_called.php HTTP/1.0\r\n\r\n");
fclose ($fp);
echo "Current time: " . time() . "<br>\r";
}
?>
async_called.php
<?php
ignore_user_abort();
sleep(10);
$fp = fopen("test.dat", "w");
fputs($fp, time());
fclose($fp);
?>
----
