发送 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

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

<?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?¶m=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" :)
...

主要思想是：

• 由用户请求调用的父脚本；
• 父级调用同一服务器（或任何其他服务器）上的子脚本（与父级或另一个相同）并向它们提供请求数据；
• 父级对用户说“确定”并结束；
• 孩子工作。

如果您需要与子进程交互 - 您可以使用数据库作为“通信媒介”：父进程可以读取子进程状态并写入命令，子进程可以读取命令并写入状态。如果您需要多个子脚本 - 您应该在用户端保留子 ID 以区分它们，并在每次您想要检查相应子脚本的状态时将该 ID 发送给父脚本。

我在这里发现 - http://linuxportal.ru/forums/index.php /t/22951/

Answer 5

调用文件服务器上的脚本来执行怎么样，就好像它是在命令行触发的一样？您可以使用 PHP 的 exec 来完成此操作。

Answer 6

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

另请参阅 ignore_user_abort - 但如果您使用，则不需要此功能寄存器关闭函数。在同一页面上，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...

阅读更多内容：
如何在响应ajax请求后继续处理PHP？

Answer 8

可以使用 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 9

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

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

MAY
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 10

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

Answer 11

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

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

在这种情况下，那么是的，使用外部作业队列和/或 cron 就可以了。输入验证后，将作业详细信息插入队列，然后退出。然后可以运行另一个脚本，从队列中获取作业详细信息，并启动较长的进程。亚历克斯·霍万斯基的想法是正确的。

抱歉，我承认我第一次浏览了一下。

Answer 12

我建议最后生成一个新的异步请求，而不是与用户一起继续该过程。

您可以使用此处的答案生成另一个请求：
异步 PHP 调用？

Answer 13

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

output_buffering = off