Einfache PHP-Multithreading-Lösung
Wenn wir Projekte durchführen, haben wir einige Anforderungen, insbesondere Daten Die Antwortverarbeitung nimmt viel Zeit in Anspruch. Da es sich bei PHP um eine Skriptsprache mit kurzem Lebenszyklus handelt, ist die Datenverarbeitung von PHP nach den standardmäßigen 30 Sekunden noch nicht abgeschlossen und der Lebenszyklus von PHP ist beendet.
Zu diesem Zeitpunkt müssen Sie eine asynchrone gleichzeitige Verarbeitungsstrategie verwenden, dh mehrere Anforderungen, die von einem PHP-Aufruf ausgegeben werden können, können nicht nacheinander ausgeführt werden, sondern können asynchron ausgeführt werden Gleichzeitig werden einige Anforderungen im Hintergrund verwendet, um Daten zu verarbeiten, und einige Anforderungen werden verwendet, um den Antwortstatus im Hintergrund zu akzeptieren und einige einfache Interaktionen mit Benutzern basierend auf dem Status durchzuführen.
Aber hier kommt das Problem. Wir alle wissen, dass PHP selbst kein Multithreading unterstützt. Wie sollten wir also Multithreading in PHP implementieren?
Drei Methoden der PHP-Simulation, um Multithreading zu erreichen
1. PHP-Multithreading unter Linux
Die folgenden Dinge sind die Quelle Da die Funktion pcntl_fork von PHP von der Implementierung des Betriebssystem-Fork abhängt, gelten die in diesem Artikel behandelten Dinge nur für Linux/Unix. Werfen wir also zunächst einen Blick auf die Verwendung dieser Funktion. Im PHP-Handbuch heißt es:
<?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
}
?>Nach dem Login kopieren
Erstellen Sie einen untergeordneten Prozess über pcntl_fork. Wenn der Rückgabewert -1 ist, ist die Erstellung des untergeordneten Prozesses fehlgeschlagen. Die Erstellung war erfolgreich. Die Prozess-ID wird an den übergeordneten Prozess zurückgegeben, und 0 wird an den untergeordneten Prozess zurückgegeben. Es ist schwer zu verstehen, daher sollte es so geschrieben werden:
<?php
$pid = pcntl_fork();
if($pid == -1){
//创建失败咱就退出呗,没啥好说的
die('could not fork');
}
else{
if($pid){
//从这里开始写的代码是父进程的,因为写的是系统程序,记得退出的时候给个返回值
exit(0);
}
else{
//从这里开始写的代码都是在新的进程里执行的,同样正常退出的话,最好也给一个返回值
exit(0);
}
}
?>Nach dem Login kopieren
Diese Änderung wird Machen Sie es einfacher zu verstehen. Wenn Ihr übergeordneter Prozess wissen möchte, dass der untergeordnete Prozess normal beendet wird, können Sie den vorherigen pcntl_wait hinzufügen.
2. Durch stream_socket_client-Methode
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
Host:" . $host . "
";
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!
";
break;
}
}
print_r($result);
}Nach dem Login kopieren
3. Ersetzen Sie Multithreading durch Multiprozess
function daemon($func_name,$args,$number){
while(true){
$pid=pcntl_fork();
if($pid==-1){
echo "fork process fail";
exit();
}elseif($pid){//创建的子进程
static $num=0;
$num++;
if($num>=$number){
//当进程数量达到一定数量时候，就对子进程进行回收。
pcntl_wait($status);
$num--;
}
}else{ //为0 则代表是子进程创建的，则直接进入工作状态
if(function_exists($func_name)){
while (true) {
$ppid=posix_getpid();
var_dump($ppid);
call_user_func_array($func_name,$args);
sleep(2);
}
}else{
echo "function is not exists";
}
exit();
}
}
}
function worker($args){
//do something
}
daemon('worker',array(1),2);Nach dem Login kopieren
2. Der wirkliche Weg, Multithreading in PHP zu realisieren
Der wirkliche Weg, Multithreading in PHP zu realisieren, kann durch die Installation der PHP-Erweiterung pthread erfolgen.
Klicken Sie hier, um https://github.com/krakjoe/pthreads herunterzuladen. Dieser Download ist jedoch Version 3, die nur mit PHP 7 verwendet werden kann. Wir müssen Version 2 verwenden
Aktualisieren Sie dann die Seite wie folgt und ziehen Sie sie nach unten:
Suchen Sie auf der nächsten Seite Version 2 Seite
Herunterladen, diese Version 2 kann nur mit PHP5 verwendet werden
Herunterladen und installieren:
Oder Sie können direkt wie folgt herunterladen:
cd /tools
wget https://github.com/krakjoe/pthreads/archive/v2.0.10.zip
unzip v2.0.10.zip
cd pthreads-2.0.10
/usr/local/php/bin/phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make
make install
Nach dem Login kopieren
Hinweis : Ihr PHP muss beim Kompilieren aktiviert sein –enable-maintainer-zts
./configure --prefix=/usr/local/php --disable-fileinfo --enable-fpm --with-config- file-path=/etc --with-config-file-scan-dir=/etc/php.d --with-openssl --with-zlib --with-curl --enable-ftp --with-gd - -with-xmlrpc --with-jpeg-dir --with-png-dir --with-freetype-dir --enable-gd-native-ttf --enable-mbstring --with-mcrypt=/usr/local/ libmcrypt --enable-zip --with-mysql=/usr/local/mysql --without-pear --enable-maintainer-zts
vim /etc/php.ini
添加
extension=pthreads.so
Nach dem Login kopieren
php neu starten /etc/init.d/php-fpm restart
Vielen Dank an alle fürs Lesen, ich hoffe, dass Sie viel davon profitieren werden.
Empfohlenes Tutorial: „PHP-Tutorial“
Das obige ist der detaillierte Inhalt vonEinfache PHP-Multithreading-Lösung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
