PHP 实现异步任务触发与后台持续运行指南

<?php
function triggerRequest($url, $post_data = array(), $cookie = array()){
    $method = "GET";
    // 解析 URL 获取主机、端口及路径
    $url_array = parse_url($url);
    $port = isset($url_array['port']) ? $url_array['port'] : 80;
    
    // 建立到本地服务器的 Socket 连接
    $fp = fsockopen($url_array['host'], $port, $errno, $errstr, 30);
    if (!$fp) {
        return FALSE;
    }
    
    // 拼接请求路径与查询参数
    $getPath = $url_array['path'] . (isset($url_array['query']) ? "?" . $url_array['query'] : "");
    
    // 若有 POST 数据则切换为 POST 方法
    if(!empty($post_data)){
        $method = "POST";
    }
    
    // 构建 Header 基础部分
    $header = $method . " " . $getPath . " HTTP/1.1\r\n";
    $header .= "Host: " . $url_array['host'] . "\r\n";
    $header .= "Connection: Close\r\n"; // 明确连接关闭
    
    // 处理 Cookie
    if(!empty($cookie)){
        $_cookie = NULL;
        foreach($cookie as $k => $v){
            $_cookie .= $k."=".$v."; ";
        }
        // 注意：原示例中使用了 base64_encode，但在标准 HTTP Cookie 头部中通常不需要 Base64，此处保留原始逻辑
        $header .= "Cookie: " . base64_encode($_cookie) . "\r\n";
    }
    
    // 处理 POST 数据
    if(!empty($post_data)){
        $_post = NULL;
        foreach($post_data as $k => $v){
            $_post .= $k."=".$v."&";
        }
        $header .= "Content-Type: application/x-www-form-urlencoded\r\n";
        $header .= "Content-Length: ". strlen($_post) . "\r\n";
        $header .= $_post . "\r\n\r\n";
    } else {
        $header .= "\r\n";
    }
    
    // 发送请求头，不读取响应以保持快速返回
    fwrite($fp, $header);
    fclose($fp);
    return true;
}

// 调用示例：触发 http://localhost/background_task.php
triggerRequest("http://localhost/background_task.php", array('action' => 'start_process'));
?>

<?php
// 1. 忽略用户中断：即使客户端断开连接，脚本也会继续执行
ignore_user_abort(TRUE);

// 2. 取消执行时间限制：防止因脚本运行超过默认 30 秒而被杀死
set_time_limit(0);

// ... 这里编写耗时的业务逻辑 ...
echo "Task started...";

for($i = 0; $i < 10; $i++) {
    sleep(5); // 模拟耗时操作
    // 可选：在此处可以记录日志，因为无法输出给浏览器
}

echo "Task finished.";
?>