PHP项目多进程写入同一文件如何处理

wen PHP项目 2026-07-01 177

本文目录导读：

PHP项目多进程写入同一文件如何处理

使用文件锁（flock）
使用临时文件 + 重命名
使用数据库（推荐方案）
使用消息队列
使用PHP的pcntl扩展
使用文件日志库
最佳实践建议
注意事项

在PHP项目中处理多进程写入同一文件，需要考虑数据完整性和性能,以下是几种常见的解决方案：

使用文件锁（flock）

最基础的解决方案，使用flock函数实现进程间互斥：

<?php
function writeToFile($file, $data) {
    $fp = fopen($file, 'a');
    if (flock($fp, LOCK_EX)) {  // 获取独占锁
        fwrite($fp, $data . PHP_EOL);
        fflush($fp);            // 强制写入
        flock($fp, LOCK_UN);    // 释放锁
    }
    fclose($fp);
}

优点：简单易用，PHP原生支持
缺点：性能较低，不适合高并发场景

使用临时文件 + 重命名

原子操作,避免文件锁的性能问题：

<?php
function atomicWrite($targetFile, $data) {
    $tmpFile = tempnam(dirname($targetFile), 'tmp_');
    file_put_contents($tmpFile, $data . PHP_EOL, FILE_APPEND);
    // 原子重命名
    if (rename($tmpFile, $targetFile)) {
        return true;
    }
    unlink($tmpFile);
    return false;
}

注意：这种方式会覆盖原文件，适合记录日志等场景

使用数据库（推荐方案）

使用Redis、MySQL等数据库处理并发写入：

<?php
// 使用Redis队列
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 生产者：写入队列
$redis->lPush('log_queue', json_encode($data));
// 消费者：单进程从队列中取出写入文件
function processQueue() {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    while ($data = $redis->brPop('log_queue', 5)) {
        file_put_contents('log.txt', $data[1] . PHP_EOL, FILE_APPEND);
    }
}

使用消息队列

专业消息队列系统处理高并发：

<?php
// 使用RabbitMQ
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
$connection = new AMQPStreamConnection('localhost', 5672, 'user', 'pass');
$channel = $connection->channel();
$channel->queue_declare('file_write_queue', false, true, false, false);
// 发送消息
$msg = new AMQPMessage(json_encode(['file' => 'log.txt', 'data' => $data]));
$channel->basic_publish($msg, '', 'file_write_queue');

使用PHP的pcntl扩展

使用进程信号量进行同步：

<?php
// 创建信号量
$sem = sem_get(1, 1);  // 信号量ID，初始值
function semWrite($file, $data) {
    global $sem;
    sem_acquire($sem);  // 获取信号量
    file_put_contents($file, $data . PHP_EOL, FILE_APPEND);
    sem_release($sem);  // 释放信号量
}

使用文件日志库

成熟的日志库通常已经处理了并发问题：

<?php
// 使用Monolog
use Monolog\Logger;
use Monolog\Handler\StreamHandler;
$log = new Logger('app');
$log->pushHandler(new StreamHandler('app.log', Logger::WARNING));
// 多进程写入
$log->warning('This is a warning log');

最佳实践建议

简单场景：使用文件锁

<?php
class SafeFileWriter {
    private $file;
    private $fp;
    public function __construct($file) {
        $this->file = $file;
    }
    public function write($data) {
        $this->fp = fopen($this->file, 'a');
        // 尝试获取锁，最多等待3秒
        if (flock($this->fp, LOCK_EX | LOCK_NB)) {
            fwrite($this->fp, $data . PHP_EOL);
            flock($this->fp, LOCK_UN);
            fclose($this->fp);
            return true;
        }
        // 锁获取失败，可以选择重试或记录错误
        fclose($this->fp);
        return false;
    }
    public function __destruct() {
        if ($this->fp) {
            fclose($this->fp);
        }
    }
}

高并发场景：使用Redis队列

<?php
// 配置
$config = [
    'redis' => [
        'host' => '127.0.0.1',
        'port' => 6379,
        'queue_key' => 'file_write_queue'
    ],
    'file' => '/var/log/app.log'
];
// 多进程生产者
function producer($data) {
    global $config;
    $redis = new Redis();
    $redis->connect($config['redis']['host'], $config['redis']['port']);
    $redis->lPush($config['redis']['queue_key'], json_encode([
        'time' => time(),
        'pid' => getmypid(),
        'data' => $data
    ]));
}
// 单进程消费者（cron job或daemon）
function consumer() {
    global $config;
    $redis = new Redis();
    $redis->connect($config['redis']['host'], $config['redis']['port']);
    while (true) {
        $item = $redis->brPop($config['redis']['queue_key'], 1);
        if ($item) {
            $data = json_decode($item[1], true);
            file_put_contents($config['file'], 
                date('Y-m-d H:i:s', $data['time']) . " [PID:{$data['pid']}] {$data['data']}\n", 
                FILE_APPEND | LOCK_EX
            );
        }
    }
}