PHP通过扩展实现多线程并发，主要方案有：使用pcntl_fork创建多进程处理独立任务；采用pthreads（已废弃）或parallel扩展实现多线程；利用Swoole等协程框架进行高并发编程；结合消息队列异步处理任务。
PHP实现多线程，简单来说，就是让PHP脚本能够同时执行多个任务，提高程序的运行效率。虽然PHP本身是单线程的，但我们可以通过一些扩展和技巧来实现并发执行的效果。
解决方案
PHP本身不直接支持多线程，但可以通过以下几种方式实现类似多线程的效果：
-
使用
pcntl
扩展 (适用于Linux/Unix)：立即学习“PHP免费学习笔记（深入）”；
pcntl
扩展允许你创建和管理进程，从而实现并发执行。每个进程都可以执行独立的PHP代码。注意：
BJXSHOP网上购物系统 - 书店版下载BJXSHOP购物管理系统是一个功能完善、展示信息丰富的电子商店销售平台；针对企业与个人的网上销售系统；开放式远程商店管理；完善的订单管理、销售统计、结算系统；强力搜索引擎支持；提供网上多种在线支付方式解决方案；强大的技术应用能力和网络安全系统 BJXSHOP网上购物系统 - 书店版，它具备其他通用购物系统不同的功能，有针对图书销售而进行开发的一个电子商店销售平台，如图书ISBN，图书目录
pcntl
扩展只能在Linux/Unix环境下使用。- 父进程需要使用
pcntl_wait()
等待子进程结束，否则可能出现僵尸进程。 - 子进程需要使用
exit()
退出，避免子进程继续执行父进程的代码。
-
使用
pthreads
扩展 (已废弃，不推荐)：pthreads
扩展曾经是PHP中实现多线程的官方解决方案，但由于其复杂性和稳定性问题，已经被废弃。不建议在新项目中使用。 -
使用消息队列 (如RabbitMQ, Redis)：
将任务放入消息队列，然后使用多个PHP进程或脚本从队列中取出任务并执行。这种方式可以实现异步处理和并发执行。
// 生产者 (将任务放入队列) $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $task = ['type' => 'send_email', 'data' => ['email' => 'test@example.com', 'content' => 'Hello!']]; $redis->lPush('task_queue', json_encode($task)); $redis->close(); // 消费者 (从队列中取出任务并执行) $redis = new Redis(); $redis->connect('127.0.0.1', 6379); while (true) { $task = $redis->rPop('task_queue'); if ($task) { $task = json_decode($task, true); // 处理任务 if ($task['type'] == 'send_email') { // 发送邮件的逻辑 echo "发送邮件到： " . $task['data']['email'] . "\n"; sleep(2); // 模拟发送邮件的耗时 } } else { sleep(1); // 队列为空，休息一下 } } $redis->close();注意：
- 需要安装和配置消息队列服务 (如RabbitMQ, Redis)。
- 需要编写生产者和消费者脚本。
- 可以使用多个消费者脚本并发处理任务。
-
使用外部工具 (如Gearman)：
Gearman是一个通用的应用程序框架，可以将任务分发给多个worker进程执行。
-
使用Swoole/RoadRunner等协程框架：
这些框架提供了更高级的并发模型，允许在一个进程内创建多个协程，从而实现高并发。
use Swoole\Coroutine as Co; Co\run(function () { for ($i = 0; $i < 3; $i++) { Co::create(function () use ($i) { echo "协程 {$i}: 开始执行...\n"; Co::sleep(rand(1,3)); echo "协程 {$i}: 执行完毕\n"; }); } });注意：
- Swoole需要安装扩展。
- 协程是用户态的线程，切换开销比系统线程小得多。
- 需要理解协程的原理和使用方法。
如何选择合适的PHP多线程方案？
选择哪种方案取决于你的具体需求：
-
简单任务，Linux/Unix环境：
pcntl
扩展可能是一个不错的选择。 - 需要异步处理，高并发： 消息队列或者Swoole/RoadRunner等协程框架更适合。
- 跨平台需求： 消息队列或者Gearman等外部工具可能更合适。
- 避免使用
pthreads
扩展，因为它已经被废弃。
使用pcntl扩展时，如何避免僵尸进程？
僵尸进程是指子进程已经结束，但父进程没有调用
wait()或
waitpid()函数来回收子进程的资源，导致子进程的进程描述符仍然保留在系统中。
避免僵尸进程的方法：
-
在父进程中使用
pcntl_wait()
或pcntl_waitpid()
等待子进程结束。 这是最常用的方法。$pid = pcntl_fork(); if ($pid) { // 父进程 pcntl_wait($status); // 等待任意子进程结束 // 或者 // pcntl_waitpid($pid, $status); // 等待指定pid的子进程结束 echo "父进程：子进程已完成\n"; } else { // 子进程 // ... exit(0); } -
使用信号处理函数
pcntl_signal()
注册SIGCHLD
信号的处理函数。 当子进程结束时，系统会发送SIGCHLD
信号给父进程，父进程可以在信号处理函数中回收子进程的资源。pcntl_signal(SIGCHLD, function($signo) { while (pcntl_waitpid(-1, $status, WNOHANG) > 0) { // 回收所有已结束的子进程 } });注意：
WNOHANG
选项表示如果没有子进程结束，pcntl_waitpid()
函数会立即返回，不会阻塞父进程。- 信号处理函数应该尽可能简单，避免执行耗时操作。
-
忽略
SIGCHLD
信号。 这会让系统自动回收子进程的资源。pcntl_signal(SIGCHLD, SIG_IGN);
注意： 这种方法不推荐使用，因为它可能会导致一些问题。
消息队列如何保证任务的可靠性？
消息队列通常提供以下机制来保证任务的可靠性：
持久化： 将消息存储到磁盘上，即使消息队列服务重启，消息也不会丢失。
确认机制 (ACK)： 消费者在成功处理完任务后，需要向消息队列发送确认消息 (ACK)。如果消息队列没有收到ACK，它会将消息重新放入队列，等待其他消费者处理。
死信队列 (DLQ)： 如果消息处理失败多次 (例如，达到最大重试次数)，消息会被放入死信队列。可以定期检查死信队列，处理失败的任务。
事务： 一些消息队列支持事务，可以保证消息的发送和消费的原子性。
不同的消息队列实现这些机制的方式可能略有不同，具体可以参考消息队列的文档。
例如，在使用Redis作为消息队列时，可以使用
BRPOPLPUSH命令来实现原子性的消息获取和备份，从而保证任务的可靠性。
// 从task_queue获取任务，并备份到processing_queue
$task = $redis->brpoplpush('task_queue', 'processing_queue', 0); // 0表示永久阻塞，直到有任务
if ($task) {
$task = json_decode($task, true);
// 处理任务
// ...
// 任务处理成功，从processing_queue移除
$redis->lRem('processing_queue', $task, 0); // 0表示移除所有匹配的元素
} else {
// 队列为空
}如果在处理任务的过程中发生错误，可以不移除
processing_queue中的任务，稍后重新处理或者转移到死信队列。
