PHP 并发文件操作中的数据完整性保障：使用文件锁防止数据丢失

const XHR = new XMLHttpRequest();

function sendData(data) {
  XHR.open('POST', 'savedata.php');
  XHR.setRequestHeader('Content-type', 'application/x-www-form-urlencoded');
  XHR.send('data=' + JSON.stringify(data));
}

<?php
if (isset($_POST['data'])) {
    if (file_exists('data.json')) {
        // 1. 读取文件内容
        $file = file_get_contents('data.json'); 
        $accumulatedData = json_decode($file, true); // 解码为关联数组

        // 2. 处理新数据
        $data = json_decode($_POST['data'], true); // 解码新数据
        array_push($accumulatedData, $data); // 追加新数据

        // 3. 编码并写入文件
        $encodedAccumulatedData = json_encode($accumulatedData);
        file_put_contents('data.json', $encodedAccumulatedData);
    }
}
?>

<?php
if (isset($_POST['data'])) {
    $filePath = 'data.json';

    // 1. 以读写模式打开文件，文件指针位于文件开头
    // 'r+' 模式：以读写方式打开，文件指针指向文件头。如果文件不存在，fopen() 会失败。
    // 'c+' 模式：以读写方式打开，如果文件不存在则创建。
    // 这里选择 'r+' 模式，因为我们通常假设文件已存在。
    $fp = fopen($filePath, "r+"); 

    if ($fp === false) {
        // 文件打开失败处理
        error_log("Failed to open file: " . $filePath);
        http_response_code(500); // 内部服务器错误
        echo "Error: Could not open data file.";
        exit;
    }

    // 2. 获取独占锁：LOCK_EX。如果文件已被其他进程锁定，则当前进程会阻塞，直到获取到锁。
    if (flock($fp, LOCK_EX)) {  
        // 成功获取到独占锁

        // 3. 读取文件内容
        // 注意：file_get_contents 会重新打开并关闭文件。在某些高并发场景下，
        // 更推荐使用 fseek($fp, 0) 和 stream_get_contents($fp) 或 fread($fp, filesize($filePath))
        // 来确保所有操作都在同一个文件句柄上进行，从而避免潜在的细微竞态。
        // 然而，由于 LOCK_EX 已经阻止了其他进程获取锁，file_get_contents 在这里通常是安全的。
        $fileContent = file_get_contents($filePath);
        $accumulatedData = json_decode($fileContent, true);

        // 如果文件为空或解码失败，初始化为空数组
        if ($accumulatedData === null) {
            $accumulatedData = [];
        }

        // 4. 处理新数据
        $newData = json_decode($_POST['data'], true);
        if ($newData !== null) { // 确保新数据解码成功
            array_push($accumulatedData, $newData);
        } else {
            error_log("Invalid JSON data received: " . $_POST['data']);
            // 可以在此处返回错误信息给客户端
        }

        // 5. 编码新数据
        $encodedAccumulatedData = json_encode($accumulatedData, JSON_PRETTY_PRINT); // JSON_PRETTY_PRINT 便于阅读

        // 6. 清空文件内容并写入新数据
        // 在写入之前，将文件指针移到开头并截断文件，确保旧内容被完全清除。
        ftruncate($fp, 0); 
        fseek($fp, 0); // 确保文件指针在文件开头，准备写入
        fwrite($fp, $encodedAccumulatedData);

        // 7. 释放锁
        flock($fp, LOCK_UN);    

        // 8. 关闭文件句柄
        fclose($fp);

        echo "Data saved successfully.";

    } else {
        // 理论上，由于 LOCK_EX 会阻塞，此分支很少执行。
        // 但作为备用，可以在无法获取锁时通知客户端稍后重试。
        error_log("Couldn't acquire file lock for: " . $filePath);
        http_response_code(503); // 服务不可用
        echo "Error: Server is busy, please try again later.";
    }
} else {
    http_response_code(400); // 错误的请求
    echo "Error: No data received.";
}
?>