PHP文件锁：确保并发数据传输与存储的完整性

const XHR = new XMLHttpRequest();

/**
 * 向服务器发送数据
 * @param {object} data - 需要发送的数据对象
 */
function sendData(data) {
  XHR.open('POST', 'savedata.php');
  XHR.setRequestHeader('Content-type', 'application/x-www-form-urlencoded');
  XHR.send('data=' + JSON.stringify(data));
}

// 示例：每秒发送一次数据
// setInterval(() => {
//   sendData({ timestamp: Date.now(), value: Math.random() });
// }, 1000);

<?php
if (isset($_POST['data'])) {
    $filePath = 'data.json';
    if (file_exists($filePath)) {
        // 1. 读取文件内容
        $fileContent = file_get_contents($filePath);
        $accumulatedData = json_decode($fileContent, true); // true表示返回关联数组

        // 2. 解码新传入的数据
        $newData = json_decode($_POST['data'], true);

        // 3. 添加新数据
        array_push($accumulatedData, $newData);

        // 4. 编码并写回文件
        $encodedAccumulatedData = json_encode($accumulatedData);
        file_put_contents($filePath, $encodedAccumulatedData);
    } else {
        // 如果文件不存在，创建新文件并写入数据
        $newData = json_decode($_POST['data'], true);
        file_put_contents($filePath, json_encode([$newData]));
    }
}
?>

<?php
if (isset($_POST['data'])) {
    $filePath = 'data.json';
    $fp = null; // 文件指针

    // 尝试以读写模式打开文件。如果文件不存在，也会尝试创建。
    // "c+" 模式在文件不存在时创建，存在时打开，并允许读写。
    // 或者使用 "r+" 模式，但需确保文件已存在，否则会失败。
    // 为了简化，我们假设文件可能不存在，并处理这种情况。
    if (!file_exists($filePath)) {
        file_put_contents($filePath, json_encode([])); // 确保文件存在且是一个空的JSON数组
    }

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

    if ($fp) {
        // 尝试获取独占锁。如果文件已被其他进程锁定，此调用将阻塞，直到获取到锁。
        if (flock($fp, LOCK_EX)) {
            // 成功获取锁后，执行文件读写操作

            // 1. 读取文件内容
            // 使用fread而不是file_get_contents，因为file_get_contents可能会在flock之前读取
            $fileContent = stream_get_contents($fp); 
            // 如果文件是空的，stream_get_contents会返回空字符串，需要处理
            $accumulatedData = json_decode($fileContent ?: '[]', true); 

            // 2. 解码新传入的数据
            $newData = json_decode($_POST['data'], true);

            // 3. 添加新数据
            array_push($accumulatedData, $newData);

            // 4. 编码数据
            $encodedAccumulatedData = json_encode($accumulatedData);

            // 5. 清空文件内容，确保从头开始写入新数据
            ftruncate($fp, 0); 
            // 6. 将文件指针重置到文件开头，确保写入从文件开始
            rewind($fp);
            // 7. 写入更新后的JSON数组到文件
            fwrite($fp, $encodedAccumulatedData);

            // 8. 释放文件锁
            flock($fp, LOCK_UN);
        } else {
            // 理论上，由于LOCK_EX是阻塞的，这里很少会被执行。
            // 但作为备用，可以返回错误信息，指示客户端稍后重试。
            http_response_code(503); // Service Unavailable
            echo "无法获取文件锁，请稍后重试。";
        }
        // 关闭文件句柄
        fclose($fp);
    } else {
        http_response_code(500); // Internal Server Error
        echo "无法打开文件进行写入。";
    }
} else {
    http_response_code(400); // Bad Request
    echo "缺少必要的数据。";
}
?>