PHP 异步编程：使用 Swoole 实现高并发任务处理

# 安装依赖
yum install gcc gcc-c++ make autoconf libtool pcre-devel openssl-devel
# 编译安装
pecl install swoole
# 启用扩展（修改php.ini）
echo "extension=swoole.so" >> /etc/php.ini
# 验证
php -m | grep swoole

<?php
// 创建Swoole HTTP服务器
$http = new Swoole\Http\Server("0.0.0.0", 9501);

// 设置服务器参数
$http->set([
    'worker_num' => 4, // 工作进程数
    'task_worker_num' => 2 // 任务进程数
]);

// 接收HTTP请求
$http->on('request', function ($request, $response) use ($http) {
    // 获取用户注册数据
    $username = $request->post['username'];
    $email = $request->post['email'];

    // 投递异步任务（发送邮件）
    $taskId = $http->task([
        'username' => $username,
        'email' => $email
    ]);

    // 立即返回响应
    $response->header('Content-Type', 'application/json');
    $response->end(json_encode([
        'code' => 200,
        'message' => '注册成功，邮件将稍后发送',
        'task_id' => $taskId
    ]));
});

// 处理异步任务
$http->on('task', function ($serv, $taskId, $workerId, $data) {
    // 模拟发送邮件（耗时操作）
    sleep(3);
    $username = $data['username'];
    $email = $data['email'];
    // 实际项目中替换为真实邮件发送逻辑
    file_put_contents('mail.log', "向{$email}发送注册邮件：恭喜{$username}注册成功！\n", FILE_APPEND);
    // 返回任务结果
    return "邮件发送成功";
});

// 任务完成回调
$http->on('finish', function ($serv, $taskId, $data) {
    echo "任务{$taskId}完成：{$data}\n";
});

// 启动服务器
$http->start();
?>

<?php
// 创建Swoole定时器
$timer = Swoole\Timer::tick(5000, function () {
    // 每5秒执行一次数据统计
    $pdo = new PDO("mysql:host=localhost;dbname=php_demo;charset=utf8", "root", "");
    $stmt = $pdo->query("SELECT COUNT(*) as total FROM users");
    $total = $stmt->fetch()['total'];
    $time = date('Y-m-d H:i:s');
    file_put_contents('stat.log', "{$time} - 用户总数：{$total}\n", FILE_APPEND);
    echo "定时任务执行完成：{$time}\n";
});

// 运行1分钟后停止定时器
Swoole\Timer::after(60000, function () use ($timer) {
    Swoole\Timer::clear($timer);
    echo "定时器已停止\n";
});

// 保持进程运行
while (true) {
    sleep(1);
}
?>