连接关闭后继续 php 脚本答案

【问题标题】：Continue php script after connection close连接关闭后继续 php 脚本
【发布时间】：2013-04-24 00:45:48
【问题描述】：

我正在尝试在页面/连接关闭后继续执行 PHP 脚本。

用户将每 1 小时轮询一次脚本，我想返回一些 json 输出并希望在后台继续脚本。我正在使用共享主机，但无法使用 cron 作业。

这是我尝试过的。

ob_start();

ignore_user_abort();

echo "JSON_OUTPUT GOES HERE";

$ob_length = ob_get_length();

header("Content-Type : text/plain",TRUE);
header("Content-Length : $ob_length",TRUE);
header("Connection : Close",TRUE);

flush();
ob_flush();
ob_end_flush();

sleep(3);

echo "You cant see me..";

exit();

我正在使用 Codeigniter 框架，但它无法在我的实时服务器上运行。它等待 3 秒，然后也输出 You cant see me..。

请帮帮我。

注意

项目托管在 LINUX/WINDOWS/WAMP-SERVER 共享主机中。

【问题讨论】：

我可以看到的第一个错误我必须在发送任何实际输出之前调用 header() 函数，无论是通过普通 HTML 标记、文件中的空白行还是来自 PHP php manual
@lucky88 OP 已经在使用output buffering。
为什么不使用 cron 在后台运行 PHP 脚本（或者更好的是，shell 脚本或更适合类似守护进程的任务），并让 poll 脚本简单地查询其进度？感觉更优雅。
@Pekka웃 原因：共享 Godaddy 服务器。
Godaddy 不是限制脚本的最大运行时间吗？脚本在后台做什么？

标签： php codeigniter output-buffering

【解决方案1】：

经过一些研究，我得到了它的工作，有时它可能对其他人有用。

function closeOutput($stringToOutput){   
        set_time_limit(0);
        ignore_user_abort(true);
        header("Connection: close\r\n");
        header("Content-Encoding: none\r\n");  
        ob_start();          
        echo $stringToOutput;   
        $size = ob_get_length();   
        header("Content-Length: $size",TRUE);  
        ob_end_flush();
        ob_flush();
        flush();   
}

你可以像这样使用它

$outputContent = 'Contentent Goes Here...';

closeOutput( $outputContent );

sleep(5);

//do some background works ...

exit();

【讨论】：

完美...其他解决方案对我不起作用。我猜是 \r\n、内容编码标头和其他小而重要的更改有所不同。
尝试了很多其他解决方案。 \r\n 似乎是这里的钉子，+1
请注意，此 hack 会破坏 HTTP Keep-Alive，并且不适用于 HTTP/2。

【解决方案2】：

首先，不要在Connection 之后和: 之前使用空格，它应该是Header: value 而不是Header : value。其次，Connection: close 不要强制浏览器停止获取当前响应并显示空白页。这里http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html 第 14.10 章指出：Connection: close in either the request or the response header fields indicates that the connection SHOULD NOT be considered 'persistent' (section 8.1) after the current request/response is complete

如果您的代码有效，您如何尝试：

ignore_user_abort();
header("Content-Type: text/plain; charset=UTF-8");

// just to try show following echo immediately, working depends on server configuration
while (@ob_end_flush()); 

echo date('Y-m-d H:i:s'), PHP_EOL;

echo "JSON_OUTPUT GOES HERE", PHP_EOL;

sleep(10); // 10 seconds so you can close browser tab before

// this file should be created after 10 seconds, even after you closed browser tab
// also check if permissions to write to __DIR__ are set for apache.
file_put_contents(__DIR__ . '/tmp.txt', "Text after 10 sec");

exit;

在浏览器中打开这个 php 文件并在 2-3 秒后关闭选项卡（即使您在屏幕上看不到任何内容），稍等片刻并检查文件是否已创建。它在我的 linux 机器上运行。

【讨论】：

那我为什么要使用header函数？？用户需要感觉到连接已关闭，他可以继续做另一件事，这也是一个私有 URL，只能通过我们的一个应用程序访问。
在脚本中间显示信息“connection closed go do things”可能与服务器高度相关。有服务器配置或输出压缩等因素，甚至浏览器可以缓冲脚本的输出。所以在脚本结束之前显示它真的很难甚至是不可能的。在这里阅读：pl1.php.net/manual/en/function.flush.php

【解决方案3】：

由于 Red 发布的这种很酷的可能性，我编写了一个小型实用程序类，它提供了一个队列，您可以在其中添加闭包以供以后执行：

<?php

namespace Company\Project\Utilities;

/**
 * Class ContinueUtility
 *
 * @package Company\Project\Utilities
 */
class ContinueUtility {
/**
 * Stored tasks
 * @var array
 */
static protected $tasks = array();

/** Constant for new line in HTTP Header */
const HEADER_NEW_LINE = "\r\n";

/**
 * Add task (closure/function) to queue, with set arguments
 *
 * @param \Closure $task
 * @param array $arguments
 * @return void
 */
public static function addTask(\Closure $task, array $arguments = array()) {
    self::$tasks[] = array(
        'closure' => $task,
        'arguments' => $arguments
    );
}

/**
 * Returns TRUE if tasks has been set, otherwise FALSE
 *
 * @return boolean
 */
public static function hasTasks() {
    return !empty(self::$tasks);
}

/**
 * Clear all previous set tasks
 *
 * @return void
 */
protected static function clearTasks() {
    self::$tasks = array();
}

/**
 * Execute all previous set tasks
 *
 * @return void
 */
protected static function executeTasks() {
    foreach (self::$tasks as $task) {
        call_user_func_array($task['closure'], $task['arguments']);
    }
}

/**
 * Execute and clear all previous set tasks
 *
 * @return void
 */
public static function executeAndClearTasks() {
    self::executeTasks();
    self::clearTasks();
}

/**
 * Closes the HTTP connection to client immediately and outputs given string.
 *
 * @param string $instantOutput
 * @return void
 */
public static function closeConnection($instantOutput = '') {
    set_time_limit(0);
    ignore_user_abort(TRUE);
    header('Connection: close' . self::HEADER_NEW_LINE);
    header('Content-Encoding: none' . self::HEADER_NEW_LINE);
    ob_start();
    echo $instantOutput;
    $size = ob_get_length();
    header('Content-Length: ' . $size, TRUE);
    ob_end_flush();
    ob_flush();
    flush();
}
}

这是您将新任务添加到队列的方式：

use Company\Project\Utilities\ContinueUtility;

$a = 4;
$b = 5;
ContinueUtility::addTask(function($a, $b){
    sleep(5);
    $c = a + b;
    file_put_contents(__DIR__ . '/whatever.log', $a . '+' . $b . '=' . $c);
}, array(
    $a, $b
));

这就是您触发执行所有先前添加的任务的方式：

ContinueUtility::closeConnection('Ready.');
ContinueUtility::executeAndClearTasks();

【讨论】：

它在我目前正在使用的项目中完美运行。我向智能手机发送推送通知，但是对于 APNS（苹果），有时需要 30 秒才能发出消息。这意味着，直到这 30 秒，HTTP 请求才会完成。现在请求立即完成，通知将在后台发送:)

【解决方案4】：

如果您使用的是 PHP-FPM，更简洁、更通用的解决方案是简单地执行 fastcgi_finish_request();

来自 PHP.net 的文档

此函数将所有响应数据刷新到客户端并完成请求。这允许在不打开与客户端的连接的情况下执行耗时的任务。

这就是 Symfony 处理其onTerminate 的方式。

【讨论】：