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));
}

// 假设在短时间内多次调用 sendData(someObject);
// 例如：
// sendData({ id: 1, value: 'test1' });
// sendData({ id: 2, value: 'test2' });

if (isset($_POST['data'])) {
    if (file_exists('data.json')) {
        $file = file_get_contents('data.json'); // 进程A读取文件
        $accumulatedData = json_decode($file); // 进程A解码数据
        $data = json_decode($_POST['data']);
        array_push($accumulatedData, $data); // 进程A修改数据
        $encodedAccumulatedData = json_encode($accumulatedData);
        file_put_contents('data.json', $encodedAccumulatedData); // 进程A写入文件
    }
}

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

    // 检查文件是否存在，如果不存在则创建空JSON数组
    if (!file_exists($filePath)) {
        file_put_contents($filePath, json_encode([]));
    }

    // 以读写模式打开文件
    $fp = fopen($filePath, "r+");

    if ($fp === false) {
        // 文件打开失败，可能是权限问题
        error_log("Error: Could not open file for locking: " . $filePath);
        http_response_code(500); // Internal Server Error
        echo "Server error: Could not process data.";
        exit;
    }

    // 尝试获取独占锁（LOCK_EX）。如果文件已被锁定，此调用将阻塞直到获取锁。
    if (flock($fp, LOCK_EX)) {
        // 成功获取锁，现在可以安全地读取和修改文件

        // 读取文件当前内容
        // 注意：在获取锁后重新读取文件内容至关重要，以确保获取的是最新数据
        $fileContent = stream_get_contents($fp, -1, 0); // 从文件开头读取所有内容
        if (empty($fileContent)) {
            $accumulatedData = [];
        } else {
            $accumulatedData = json_decode($fileContent, true); // true表示返回关联数组
            if (json_last_error() !== JSON_ERROR_NONE) {
                // JSON解析错误，可能是文件损坏
                error_log("Error: data.json contains invalid JSON. Resetting file. Error: " . json_last_error_msg());
                $accumulatedData = [];
            }
        }

        $newData = json_decode($_POST['data'], true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            // 客户端发送的JSON数据无效
            error_log("Error: Invalid JSON data received from client. Data: " . $_POST['data']);
            http_response_code(400); // Bad Request
            echo "Invalid data format.";
            // 释放锁并关闭文件
            flock($fp, LOCK_UN);
            fclose($fp);
            exit;
        }

        // 确保 $accumulatedData 是一个数组
        if (!is_array($accumulatedData)) {
            $accumulatedData = [];
        }

        // 追加新数据
        array_push($accumulatedData, $newData);
        $encodedAccumulatedData = json_encode($accumulatedData);

        // 写入之前，将文件指针移到开头并截断文件，清除旧内容
        rewind($fp); // 将文件指针移到文件开头
        ftruncate($fp, 0); // 截断文件，清除所有内容

        // 将新JSON数据写入文件
        fwrite($fp, $encodedAccumulatedData);

        // 释放锁
        flock($fp, LOCK_UN);
        echo "Data saved successfully.";

    } else {
        // 理论上，由于LOCK_EX是阻塞的，此分支很少执行，除非发生系统级错误。
        // 但为了健壮性，仍应处理。
        error_log("Error: Could not acquire file lock for " . $filePath);
        http_response_code(503); // Service Unavailable
        echo "Server is busy, please try again later.";
    }

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

} else {
    http_response_code(400); // Bad Request
    echo "No data received.";
}
?>