私たちがプロジェクトに取り組んでいたとき、いくつかの要件があり、特にデータの応答処理に時間がかかりました。PHP 自体がマルチスレッドをサポートしていないことは誰もが知っていますが、PHP でマルチスレッドを実装するにはどうすればよいでしょうか。 ?
1. Linux での PHP マルチスレッド
以下の内容は、PHP の pcntl_fork 関数から派生したものであるため、この記事で説明されている内容のみが当てはまります。 Linux /unix に。まず、この関数の使用法を見てみましょう。<?php
$pid = pcntl_fork();if ($pid == -1) {
die('could not fork');
} else if ($pid) {
// we are the parent
pcntl_wait($status); /
/Protect against Zombie children} else {
// we are the child}?>
戻り値が -1 の場合、サブプロセスの作成は失敗しました。成功した場合は、親プロセスにはプロセスIDが返され、子プロセスには0が返されます。 <?php
$pid = pcntl_fork();if($pid == -1){ //创建失败咱就退出呗,没啥好说的
die('could not fork');
}else{ if($pid){ //从这里开始写的代码是父进程的,因为写的是系统程序,记得退出的时候给个返回值
exit(0);
} else{ //从这里开始写的代码都是在新的进程里执行的,同样正常退出的话,最好也给一个返回值
exit(0);
}
}?>
このように変更すると分かりやすくなります。親プロセスは子プロセスが正常に終了したことを知りたい場合、前の pcntl_wait に Go を追加できます。
2. stream_socket_client メソッドを通してfunction sendStream() {
$english_format_number = number_format($number, 4, '.', '');
echo $english_format_number;
exit();
$timeout = 10;
$result = array();
$sockets = array();
$convenient_read_block = 8192;
$host = "test.local.com";
$sql = "select waybill_id,order_id from xm_waybill where status>40 order by update_time desc limit 1 ";
$data = Yii::app()->db->createCommand($sql)->queryAll();
$id = 0;
foreach ($data as $k => $v) {
if ($k % 2 == 0) {
$send_data[$k]['body'] = NoticeOrder::getSendData($v['waybill_id']);
} else {
$send_data[$k]['body'] = array($v['order_id'] => array('extra' => 16));
}
$data = json_encode($send_data[$k]['body']);
$s = stream_socket_client($host . ":80", $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT | STREAM_CLIENT_CONNECT);
if ($s) {
$sockets[$id++] = $s;
$http_message = "GET /php/test.php?data=" . $data . " HTTP/1.0\r\nHost:" . $host . "\r\n\r\n";
fwrite($s, $http_message);
} else {
echo "Stream " . $id . " failed to open correctly.";
}
}
while (count($sockets)) {
$read = $sockets;
stream_select($read, $w = null, $e = null, $timeout);
if (count($read)) {
/* stream_select generally shuffles $read, so we need to
compute from which socket(s) we're reading. */
foreach ($read as $r) {
$id = array_search($r, $sockets);
$data = fread($r, $convenient_read_block);
if (strlen($data) == 0) {
echo "Stream " . $id . " closes at " . date('h:i:s') . ".<br> ";
fclose($r);
unset($sockets[$id]);
} else {
$result[$id] = $data;
}
}
} else {
/* A time-out means that *all* streams have failed
to receive a response. */
echo "Time-out!\n";
break;
}
}
print_r($result);
}
3. マルチプロセスを通してマルチスレッドを置き換える
概要: php マルチスレッドでは利用できません。実は、誰もが知っていることですが、さまざまな方法で実装できます。この記事では、PHP でのマルチスレッドの実装方法を紹介します。お役に立てれば!
関連する推奨事項:
PHPマルチスレッドの実装例
以上がPHPマルチスレッドシミュレーション実装の3つの方法の紹介の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。