当用户中止连接时回滚事务

Question

首先，对不起我的英语，我在谷歌翻译的帮助下写了这篇文章。

我正在尝试使用 PHP 和 Ajax 制作像 Google Wave 这样的应用程序。我有一个 textarea，当用户输入内容时，页面上的 javascript 检测到 oninput 并将 textarea 的内容发送到服务器，服务器将内容存储到数据库中。

我正在做的是，每次我通过 XHR 发送内容时，都有XHR.abort() 总是会中断之前的 XHR 请求。数据库中的数据很好，但有时它存储的是以前的版本。

我知道这是因为 PHP 没有停止执行，即使客户端已经中止，有时前一个请求比上一个请求花费了更多时间并且在最后一个请求之后完成，所以我阅读了函数手册“ignore_user_abort”和“connection_aborted”，但问题仍然存在。

我创建了这个脚本来模拟这种情况，我希望当我中止连接时（按“停止”，关闭选项卡/窗口），数据库上没有任何新数据，但 5 秒后，我仍然有新数据，所以当用户中止连接时我需要帮助来回滚事务。

这是要模拟的脚本（定义了 PDO_DSN、PDO_USER、PDO_PASS）：

<?php
ignore_user_abort(true);

ob_start('ob_gzhandler');

$PDO = new PDO(PDO_DSN, PDO_USER, PDO_PASS, array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8'));

$PDO->beginTransaction();
$query = $PDO->query('INSERT INTO `table` (`content`) VALUES (' . $PDO->quote('test') . ')');
sleep(5);
echo ' ';
ob_flush();
flush();
if (connection_aborted()) {
  $PDO->rollBack();
  exit;
}
$PDO->commit();

ob_end_flush();

Answer 1

如果您发现 XHR.abort() 和 connection_aborted() 不可靠，请考虑发送带外信号以通知正在运行的 PHP 请求它不应提交事务的其他方法。

你在运行APC（或者你可以）吗？

您可以发送另一个 XHR 请求以发出中止信号，而不是调用 XHR.abort()。此请求的目的是在 APC 用户缓存中记录一个特殊键。该键的存在将向正在运行的 PHP 请求表明它应该回滚。

为了完成这项工作，每个 XHR 请求都需要携带一个（相对）唯一的事务标识符，例如作为表单变量。该标识符将随机生成，或根据当前时间生成，并将在初始 XHR 以及“中止”XHR 中发送，并允许中止请求与正在运行的请求相关联。在下面的示例中，事务标识符在表单变量t 中。

“中止”XHR 处理程序示例：

<?php
$uniqueTransactionId = $_REQUEST['t'];
$abortApcKey = 'abortTrans_' . $uniqueTransactionId;

apc_store($uniqueTransactionId, 1, 15);

修改数据库写入 XHR 处理程序示例：

<?php
$PDO = new PDO(PDO_DSN, PDO_USER, PDO_PASS,
               array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8'));

$PDO->beginTransaction();
$query = $PDO->query('INSERT INTO `table` (`content`) VALUES (' . $PDO->quote('test') . ')');

$uniqueTransactionId = $_REQUEST['t'];
$abortApcKey = 'abortTrans_' . $uniqueTransactionId;
if (apc_exists($abortApcKey)) {
  $PDO->rollBack();
  exit;
}

$PDO->commit();

您可能仍有时间问题。中止可能仍然来得太晚而无法停止提交。为了优雅地处理这个问题，您可以修改数据库写入处理程序以记录一个 APC 键，指示事务已提交。然后，中止处理程序可以检查此密钥是否存在，并返回一个有意义的 XHR 中止结果以通知客户端：“抱歉，我来晚了。”

请记住，如果您的应用程序托管在多个实时服务器上，您将需要使用共享缓存，例如 memcached 或 redis，因为 APC 的缓存仅在单台计算机上的进程之间共享。

Answer 2

让浏览器发回您也存储在数据库中的时间戳或运行编号怎么样。并且您的更新可以检查，以便它仅在新时间戳较新时写入。

Answer 3

我在 Javascript 和 Ajax 中多次看到这个问题。如果您在实现 UI 时不是很小心，那么用户可以单击两次和/或浏览器可以触发两次 ajax 调用，从而导致同一条记录两次访问您的数据库。这可能是来自您的 UI 的两个完全不同的 http 请求，因此您需要确保您的服务器端代码可以在将重复项插入数据库之前过滤掉它们。 我的解决方法通常是查询同一用户最近输入的记录，并检查这是否真的是一个新条目。如果这个新记录还没有在数据库中，则插入它，否则忽略。 在 Oracle 中，您可以使用 PL/SQL 来执行 MERGE IF MATCH THEN INSERT 命令，因此您可以在一个查询中处理此问题，但在 MySQL 中，您最好使用两个查询 - 一个查询该用户的现有记录，然后如果没有匹配，则插入另一个。

Answer 4

正如 Marc B 所指出的，如果不向浏览器发送一些输出，PHP 无法检测浏览器是否断开连接。问题是，您在ob_start('ob_gzhandler'); 行启用了输出缓冲，这会阻止PHP 将输出发送到浏览器。

您必须删除该行或添加 ob_end_*（例如：ob_end_flush()）以及 echo/flush 调用。