PHP异步任务处理实战：使用Swoole实现高性能后台任务
在Web开发中，处理耗时任务（如发送邮件、生成报表等）时，同步执行会导致用户等待时间过长。本文将介绍如何使用PHP的Swoole扩展实现高性能的异步任务处理。
1. Swoole简介与安装
Swoole是PHP的协程高性能网络通信引擎，提供了异步、并行编程能力。安装方法：
pecl install swoole
# 或在Docker中使用
docker pull phpswoole/swoole
2. 基础异步任务实现
下面是一个简单的异步任务服务器实现：
$server = new SwooleServer(‘0.0.0.0’, 9501);
// 异步任务处理回调
$server->on(‘task’, function ($serv, $taskId, $workerId, $data) {
// 模拟耗时任务
sleep(2);
file_put_contents(‘task.log’, “Task {$taskId} completed: {$data}n”, FILE_APPEND);
return “Task {$taskId} result”;
});
// 任务完成回调
$server->on(‘finish’, function ($serv, $taskId, $data) {
echo “Task {$taskId} finished: {$data}n”;
});
// 收到请求时投递任务
$server->on(‘receive’, function ($serv, $fd, $reactorId, $data) {
$taskId = $serv->task($data);
$serv->send($fd, “Task {$taskId} dispatchedn”);
});
$server->start();
?>
3. 实际应用案例：异步邮件发送
结合常见的邮件发送场景，实现不阻塞主流程的异步发送：
// 在Web应用中投递邮件发送任务
$swooleClient = new SwooleClient(SWOOLE_SOCK_TCP);
if ($swooleClient->connect(‘127.0.0.1’, 9501, 0.5)) {
$mailData = json_encode([
‘to’ => ‘user@example.com’,
‘subject’ => ‘订单确认’,
‘body’ => ‘感谢您的购买…’
]);
$swooleClient->send($mailData);
}
// 任务服务器中的邮件处理
$server->on(‘task’, function ($serv, $taskId, $workerId, $data) {
$mail = json_decode($data, true);
// 实际发送邮件逻辑
mail($mail[‘to’], $mail[‘subject’], $mail[‘body’]);
return “Mail to {$mail[‘to’]} sent”;
});
?>
4. 高级特性：协程任务
Swoole 4.0+支持协程，可以更高效地处理IO密集型任务：
SwooleRuntime::enableCoroutine();
go(function () {
$result = [];
$waitGroup = new SwooleCoroutineWaitGroup();
// 任务1
$waitGroup->add();
go(function () use (&$result, $waitGroup) {
$result[‘data1’] = file_get_contents(‘http://api.example.com/data1’);
$waitGroup->done();
});
// 任务2
$waitGroup->add();
go(function () use (&$result, $waitGroup) {
$result[‘data2’] = file_get_contents(‘http://api.example.com/data2’);
$waitGroup->done();
});
$waitGroup->wait();
print_r($result);
});
?>
通过Swoole实现异步任务处理，可以显著提升PHP应用的并发能力和响应速度，特别适合处理高并发的后台任务场景。
