PHP网站在运行过程中,如果遇到批量发送通知、调用多个第三方接口、生成大体积报表这类耗时操作,同步执行会让页面长时间处于等待状态,用户很容易因为响应慢流失。通过异步加载技术把非核心、耗时的任务剥离到后台处理,前端可以先返回基础页面内容,能大幅提升网站的访问速度和用户体验。

PHP实现异步加载的常用方案
1. 基于curl_multi的多请求并发
如果页面需要调用多个互不依赖的第三方接口获取数据,可以使用curl_multi实现多请求并发,避免串行等待每个接口返回结果。这种方式适合接口调用类的异步场景,不需要额外搭建其他服务。
<?php
// 初始化多个curl句柄
$ch1 = curl_init();
curl_setopt($ch1, CURLOPT_URL, "https://ipipp.com/api/user_info");
curl_setopt($ch1, CURLOPT_RETURNTRANSFER, 1);
$ch2 = curl_init();
curl_setopt($ch2, CURLOPT_URL, "https://ipipp.com/api/order_list");
curl_setopt($ch2, CURLOPT_RETURNTRANSFER, 1);
// 创建curl_multi句柄并添加子句柄
$mh = curl_multi_init();
curl_multi_add_handle($mh, $ch1);
curl_multi_add_handle($mh, $ch2);
// 执行并发请求
$running = null;
do {
curl_multi_exec($mh, $running);
curl_multi_select($mh);
} while ($running > 0);
// 获取所有请求的结果
$result1 = curl_multi_getcontent($ch1);
$result2 = curl_multi_getcontent($ch2);
// 移除并关闭句柄
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);
curl_multi_close($mh);
curl_close($ch1);
curl_close($ch2);
// 处理返回的数据
$data = [
'user_info' => json_decode($result1, true),
'order_list' => json_decode($result2, true)
];
?>2. FastCGI模式下的异步任务投递
PHP的FastCGI进程管理器(FPM)支持通过fastcgi_finish_request()函数先结束当前请求响应,把后续耗时任务放到请求结束后执行。这种方式实现简单,不需要额外组件,适合轻量级的异步任务场景。
<?php
// 先返回前端需要的基础数据
$response = [
'code' => 200,
'msg' => '操作已提交,正在处理中',
'data' => []
];
echo json_encode($response);
// 结束当前FastCGI请求,前端会先收到响应
fastcgi_finish_request();
// 这里开始执行耗时任务,不会影响前端响应
sleep(3); // 模拟耗时操作,比如生成大文件、批量发邮件
file_put_contents('/tmp/async_task.log', '异步任务执行完成:' . date('Y-m-d H:i:s') . PHP_EOL, FILE_APPEND);
?>3. 消息队列配合后台进程处理
对于批量数据导出、海量消息推送这类重量级异步任务,推荐使用消息队列(比如Redis、RabbitMQ)配合后台常驻进程处理。前端提交任务后只把任务信息推到队列,后台进程不断消费队列任务执行,稳定性和扩展性都更好。
前端提交任务的代码示例:
<?php
// 连接Redis作为消息队列
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 接收前端提交的任务参数
$taskData = [
'type' => 'export_order',
'user_id' => 1001,
'start_time' => '2024-01-01',
'end_time' => '2024-01-31'
];
// 把任务推到队列中
$redis->lPush('async_task_queue', json_encode($taskData));
// 返回前端任务已提交
echo json_encode(['code' => 200, 'msg' => '导出任务已提交,请稍后查看结果']);
?>后台消费进程的代码示例:
<?php
// 后台常驻进程,消费队列中的异步任务
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
while (true) {
// 阻塞获取队列中的任务,没有任务时等待
$task = $redis->brPop(['async_task_queue'], 30);
if (empty($task)) {
continue;
}
$taskData = json_decode($task[1], true);
// 根据任务类型执行对应逻辑
if ($taskData['type'] == 'export_order') {
// 执行订单导出逻辑,生成Excel文件
// ... 具体导出代码 ...
file_put_contents('/tmp/export.log', '订单导出完成,用户ID:' . $taskData['user_id'] . PHP_EOL, FILE_APPEND);
}
// 避免进程占用过高CPU,每次循环后短暂休眠
usleep(100000);
}
?>异步加载的性能优化建议
- 合理拆分任务:不要把所有逻辑都放到异步任务中,只把耗时超过500ms的非核心操作异步化,避免后台任务堆积。
- 控制并发数量:使用curl_multi或者多进程处理任务时,要设置合理的并发上限,避免同时发起过多请求把服务器资源耗尽。
- 设置超时时间:所有异步请求、接口调用都要设置合理的超时时间,避免单个任务卡住影响整个队列的处理效率。
- 添加任务监控:对异步任务的执行状态、失败次数做记录,方便排查问题,失败的任务可以设置重试机制,提升任务完成率。
- 资源释放:异步任务执行完成后,及时释放数据库连接、文件句柄等资源,避免资源泄漏影响服务稳定性。
不同场景的方案选择
| 场景类型 | 推荐方案 | 优势 |
|---|---|---|
| 多个第三方接口并发调用 | curl_multi多请求 | 实现简单,不需要额外组件,响应速度快 |
| 轻量级耗时操作(如发单条邮件、生成小文件) | fastcgi_finish_request() | 无额外依赖,代码改动小,上线快 |
| 重量级批量任务(如批量导出、海量推送) | 消息队列+后台进程 | 扩展性强,任务可持久化,稳定性高 |