如何使用 stream_supports_lock 确保文件复制过程中不发生并发冲突

M66 2025-06-27

在进行文件操作时，尤其是复制大文件或在多线程环境下复制文件时，可能会遇到并发冲突的问题。一个常见的并发问题是文件在复制过程中被其他进程访问或修改，这不仅可能导致文件损坏，还可能产生不可预期的错误。在 PHP 中，可以通过使用 stream_supports_lock() 函数来避免这一问题。本文将介绍如何使用该函数确保文件复制过程中不发生并发冲突。

什么是 stream_supports_lock() 函数？

stream_supports_lock() 是 PHP 的一个内置函数，用于检查指定的流是否支持文件锁。文件锁是用于控制多个进程或线程对同一文件的访问的一种机制，避免多个进程同时写入或读取文件时发生冲突。stream_supports_lock() 函数可以帮助开发者在进行文件操作之前，确认是否可以使用文件锁来确保数据的安全性。

函数原型：

<span><span><span class="hljs-keyword">bool</span></span><span> </span><span><span class="hljs-title function_ invoke__">stream_supports_lock</span></span><span> ( resource </span><span><span class="hljs-variable">$stream</span></span><span> )
</span></span>

参数：该函数接受一个参数 $stream，它是一个有效的文件流资源，通常通过 fopen() 函数获得。
返回值：如果流支持文件锁，函数返回 true，否则返回 false。

如何使用 stream_supports_lock() 防止并发冲突

步骤 1：打开源文件和目标文件

在进行文件复制之前，首先需要打开源文件和目标文件。这可以通过 PHP 的 fopen() 函数来完成，并确保以读写模式打开文件。

<span><span><span class="hljs-variable">$sourceFile</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fopen</span></span><span>(</span><span><span class="hljs-string">"source.txt"</span></span><span>, </span><span><span class="hljs-string">"r"</span></span><span>);
</span><span><span class="hljs-variable">$destFile</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fopen</span></span><span>(</span><span><span class="hljs-string">"destination.txt"</span></span><span>, </span><span><span class="hljs-string">"w"</span></span><span>);
</span></span>

步骤 2：检查流是否支持文件锁

在进行任何文件操作之前，使用 stream_supports_lock() 检查文件流是否支持锁。如果不支持文件锁，考虑使用其他方式来避免并发冲突（例如，使用数据库锁或应用级的并发控制）。

<span><span><span class="hljs-keyword">if</span></span><span> (</span><span><span class="hljs-title function_ invoke__">stream_supports_lock</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>) &amp;&amp; </span><span><span class="hljs-title function_ invoke__">stream_supports_lock</span></span><span>(</span><span><span class="hljs-variable">$destFile</span></span><span>)) {
    </span><span><span class="hljs-comment">// 支持锁，继续操作</span></span><span>
} </span><span><span class="hljs-keyword">else</span></span><span> {
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"文件流不支持锁，无法确保并发安全！"</span></span><span>;
    </span><span><span class="hljs-keyword">exit</span></span><span>;
}
</span></span>

步骤 3：应用文件锁

如果文件流支持锁，接下来我们可以使用 flock() 函数对源文件和目标文件进行加锁。flock() 函数允许你在文件操作期间加锁，从而避免其他进程或线程同时访问文件。

<span><span><span class="hljs-keyword">if</span></span><span> (</span><span><span class="hljs-title function_ invoke__">flock</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>, LOCK_SH) &amp;&amp; </span><span><span class="hljs-title function_ invoke__">flock</span></span><span>(</span><span><span class="hljs-variable">$destFile</span></span><span>, LOCK_EX)) {
    </span><span><span class="hljs-keyword">while</span></span><span> (!</span><span><span class="hljs-title function_ invoke__">feof</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>)) {
        </span><span><span class="hljs-variable">$data</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fgets</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>);
        </span><span><span class="hljs-title function_ invoke__">fwrite</span></span><span>(</span><span><span class="hljs-variable">$destFile</span></span><span>, </span><span><span class="hljs-variable">$data</span></span><span>);
    }
    </span><span><span class="hljs-comment">// 释放锁</span></span><span>
    </span><span><span class="hljs-title function_ invoke__">flock</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>, LOCK_UN);
    </span><span><span class="hljs-title function_ invoke__">flock</span></span><span>(</span><span><span class="hljs-variable">$destFile</span></span><span>, LOCK_UN);
} </span><span><span class="hljs-keyword">else</span></span><span> {
    </span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"无法获取文件锁，操作失败！"</span></span><span>;
    </span><span><span class="hljs-keyword">exit</span></span><span>;
}
</span></span>

LOCK_SH：共享锁，允许其他进程以只读模式访问文件。
LOCK_EX：独占锁，禁止其他进程访问文件。
LOCK_UN：解除锁定。

步骤 4：关闭文件流

完成文件复制后，记得关闭文件流，以释放系统资源。

<span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$sourceFile</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$destFile</span></span><span>);
</span></span>

总结

通过使用 stream_supports_lock() 和 flock() 函数，PHP 提供了有效的文件锁机制，可以确保在文件复制过程中不会发生并发冲突。通过合理的文件锁控制，可以保证数据的完整性，避免文件损坏或复制错误。对于多进程或多线程的文件操作，使用文件锁是确保并发安全的一个重要手段。