发送 HTTP 响应后继续 PHP 执行

Question

如何让 PHP 5.2（以 apache mod_php 运行）向客户端发送完整的 HTTP 响应，然后再继续执行操作一分钟？

长篇大论：

我有一个 PHP 脚本，它必须执行几个长的数据库请求并发送电子邮件，这需要 45 到 60 秒才能运行。此脚本由我无法控制的应用程序调用。我需要应用程序报告从 PHP 脚本收到的任何错误消息（主要是无效参数错误）。

应用程序的超时延迟小于 45 秒（我不知道确切的值），因此将 PHP 脚本的每次执行都注册为错误。因此，我需要 PHP 尽可能快地向客户端发送完整的 HTTP 响应（理想情况下，输入参数一经验证），然后运行数据库和电子邮件处理。

我正在运行 mod_php，所以pcntl_fork 不可用。我可以通过将要处理的数据保存到数据库并从cron 运行实际过程来解决这个问题，但我正在寻找更短的解决方案。

Answer 1

我的“特殊脚本”工具箱中有这个 sn-p，但它丢失了（当时云并不常见），所以我正在寻找它并提出了这个问题，惊讶地发现它不见了，我搜索了更多，然后回到这里发布它：

<?php
 ob_end_clean();
 header("Connection: close");
 ignore_user_abort(); // optional
 ob_start();
 echo ('Text the user will see');
 $size = ob_get_length();
 header("Content-Length: $size");
 ob_end_flush(); // Strange behaviour, will not work
 flush();            // Unless both are called !
 session_write_close(); // Added a line suggested in the comment
 // Do processing here 
 sleep(30);
 echo('Text user will never see');
?>

我实际上在几个地方使用它。那里完全有道理：银行链接正在返回成功付款的请求，当发生这种情况时，我必须调用很多服务并处理大量数据。这有时需要超过 10 秒，但 banklink 有固定的超时时间。所以我承认了银行链接并为他指明了出路，并在他已经离开时做我的事情。

Answer 2

让处理初始请求的脚本在处理队列中创建一个条目，然后立即返回。然后，创建一个单独的进程（可能通过 cron）定期运行队列中待处理的任何作业。

Answer 3

你需要的是这种设置

Answer 4

可以对自己或任何其他脚本使用“http fork”。我的意思是这样的：

// parent sript, called by user request from browser

// create socket for calling child script
$socketToChild = fsockopen("localhost", 80);

// HTTP-packet building; header first
$msgToChild = "POST /sript.php?&param=value&<more params> HTTP/1.0\n";
$msgToChild .= "Host: localhost\n";
$postData = "Any data for child as POST-query";
$msgToChild .= "Content-Length: ".strlen($postData)."\n\n";

// header done, glue with data
$msgToChild .= $postData;

// send packet no oneself www-server - new process will be created to handle our query
fwrite($socketToChild, $msgToChild);

// wait and read answer from child
$data = fread($socketToChild, $dataSize);

// close connection to child
fclose($socketToChild);
...

现在是子脚本：

// parse HTTP-query somewhere and somehow before this point

// "disable partial output" or 
// "enable buffering" to give out all at once later
ob_start();

// "say hello" to client (parent script in this case) disconnection
// before child ends - we need not care about it
ignore_user_abort(1);

// we will work forever
set_time_limit(0);

// we need to say something to parent to stop its waiting
// it could be something useful like client ID or just "OK"
...
echo $reply;

// push buffer to parent
ob_flush();

// parent gets our answer and disconnects
// but we can work "in background" :)
...

主要思想是：

• 用户请求调用的父脚本；
• 父级调用同一服务器（或任何其他服务器）上的子脚本（与父级或另一个相同）并向它们提供请求数据；
• 父母对用户说好的并结束；
• 儿童作品。

如果您需要与孩子互动 - 您可以使用 DB 作为“通信媒介”：父母可以读取孩子状态并写入命令，孩子可以读取命令和写入状态。如果您需要多个子脚本 - 您应该在用户端保留子 id 以区分它们，并在每次要检查各个子的状态时将该 id 发送给父。

我在这里找到了 - http://linuxportal.ru/forums/index.php/t/22951/

Answer 5

如果调用文件服务器上的脚本来执行，就好像它是在命令行中触发的一样？您可以使用 PHP 的 exec 来做到这一点。

Answer 6

您可以使用 PHP 函数 register-shutdown-function，该函数将在脚本完成与浏览器的对话后执行某些操作。

另请参阅ignore_user_abort - 但如果您使用 register_shutdown_function，则不需要此功能。在同一页面上，set_time_limit(0) 将防止您的脚本超时。

Answer 7

对于这个简单的任务，使用队列、exec 或 cron 将是过度杀伤力。 没有理由不留在同一个脚本中。 这种组合对我很有效：

        ignore_user_abort(true);
        $response = "some response"; 
        header("Connection: close");
        header("Content-Length: " . mb_strlen($response));
        echo $response;
        flush(); // releasing the browser from waiting
        // continue the script with the slow processing here...

阅读更多： How to continue process after responding to ajax request in PHP?

Answer 8

您可以在服务器和服务器之间创建一个 http 请求。 （不需要浏览器）。 创建后台 http 请求的秘诀是设置一个非常小的超时，因此忽略响应。

这是我为此目的使用的一个工作函数：

五月 31 PHP异步后台请求 在 PHP 中创建异步请求的另一种方法（模拟后台模式）。

 /**
  * Another way to make asyncronous (o como se escriba asincrono!) request with php
  * Con esto se puede simpular un fork en PHP.. nada que envidarle a javita ni C++
  * Esta vez usando fsockopen
  * @author PHPepe
  * @param  unknown_type $url
  * @param  unknown_type $params
  */
 function phpepe_async($url, $params = array()) {
  $post_params = array(); 
     foreach ($params as $key => &$val) {
       if (is_array($val)) $val = implode(',', $val);
         $post_params[] = $key.'='.urlencode($val);
     }
     $post_string = implode('&', $post_params);

     $parts=parse_url($url);

     $fp = fsockopen($parts['host'],
         isset($parts['port'])?$parts['port']:80,
         $errno, $errstr, 30);

     $out = "POST ".$parts['path']." HTTP/1.1\r\n";
     $out.= "Host: ".$parts['host']."\r\n";
     $out.= "Content-Type: application/x-www-form-urlencoded\r\n";
     $out.= "Content-Length: ".strlen($post_string)."\r\n";
     $out.= "Connection: Close\r\n\r\n";
     if (isset($post_string)) $out.= $post_string;

     fwrite($fp, $out);
     fclose($fp);
 }

 // Usage:
 phpepe_async("http://192.168.1.110/pepe/feng_scripts/phprequest/fork2.php");

有关更多信息，您可以查看 http://www.phpepe.com/2011/05/php-asynchronous-background-request.html

Answer 9

可以为此使用 cURL，但超时时间很短。这将是您的主文件：

<?php>
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, "http://example.com/processor.php");
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
    curl_setopt($ch, CURLOPT_TIMEOUT_MS, 10);      //just some very short timeout
    curl_exec($ch);
    curl_close($ch);
?>

这是你的处理器文件：

<?php
    ignore_user_abort(true);                       //very important!
    for($x = 0; $x < 10; $x++)                     //do some very time-consuming task
        sleep(10);
?>

如您所见，上面的脚本会在很短的时间（本例中为 10 毫秒）后超时。 CURLOPT_TIMEOUT_MS 可能不会像这样工作，在这种情况下，它将等效于 curl_setopt($ch, CURLOPT_TIMEOUT, 1)。

因此，当处理器文件被访问时，无论用户（即调用文件）是否中止连接，它都会执行其任务。

当然你也可以在页面之间传递GET或POST参数。

Answer 10

您可以将这些函数拆分为三个脚本。 1.启动进程并通过exec或command调用第二个，这也可以通过http调用运行。 2.第二个将运行数据库处理，最后将启动最后一个 3. 最后一封会发邮件

Answer 11

呸，我误解了你的要求。看起来他们实际上是：

• 脚本从您无法控制的外部来源接收输入
• 脚本处理和验证输入，让外部应用知道它们是否正确并终止会话。
• 脚本启动一个长时间运行的进程。

在这种情况下，是的，使用外部作业队列和/或 cron 会起作用。验证输入后，将作业详细信息插入队列，然后退出。然后可以运行另一个脚本，从队列中获取作业详细信息，并启动更长的过程。 Alex Howansky 的想法是正确的。

抱歉，我承认我第一次略读了一点。

Answer 12

我建议在最后产生一个新的异步请求，而不是继续与用户一起处理。

您可以使用此处的答案生成另一个请求： Asynchronous PHP calls?

Answer 13

在您的 Apache php.ini 配置文件中，确保禁用输出缓冲：

output_buffering = off