Docker环境下多PHP应用共享目录文件处理的分布式锁方案咨询

这是个非常典型的分布式文件处理场景，针对你担心的「进程崩溃后锁残留」问题，我给你整理几个实用的优化方案，从简单到进阶都有：

方案一：改进版目录锁（带超时自动清理） #

你的原始目录锁思路没问题，只需要加个超时判断就能解决崩溃残留的问题。核心逻辑是：检查锁目录的创建时间，如果超过预设的处理超时时间，就认为之前的进程已经崩溃，强制清理旧锁再尝试获取新锁。

$lockDir = md5($file) . 'lock';
$lockCreated = false;
// 自定义超时时间，比如300秒（根据你的文件处理时长调整）
$timeout = 300;

if (is_dir($lockDir)) {
    $lockCreationTime = filemtime($lockDir);
    if (time() - $lockCreationTime > $timeout) {
        // 旧锁超时，强制删除
        @rmdir($lockDir);
        $lockCreated = mkdir($lockDir, 0700);
    } else {
        // 锁有效，跳过当前文件
        continue;
    }
} else {
    $lockCreated = mkdir($lockDir, 0700);
}

if ($lockCreated) {
    try {
        $this->performFile($file);
        $this->moveFileToHistory($file);
    } finally {
        // 无论处理成功还是失败，都尝试清理锁
        @rmdir($lockDir);
    }
}

优点：不需要额外依赖，兼容现有共享目录架构；finally块确保正常流程下锁一定会被清理，超时机制处理崩溃残留。

方案二：Redis分布式锁（最可靠的分布式方案） #

如果你的环境已经有Redis服务，或者可以部署一个，这是最推荐的方案。Redis的锁支持原子性设置+自动过期，进程崩溃后锁会自动释放，完美解决残留问题。

实现思路： #

1. 所有Docker容器连接同一个Redis实例（确保网络互通）
2. 用SET命令带NX参数原子性获取锁，同时设置过期时间
3. 处理完成后主动释放锁，避免占用资源

示例代码（用Predis客户端）：

// 初始化Redis客户端（根据你的配置调整）
$redis = new Predis\Client([
    'scheme' => 'tcp',
    'host'   => 'redis-host',
    'port'   => 6379,
]);

$lockKey = 'file_process_lock:' . md5($file);
// 设置锁：仅当key不存在时成功，过期时间300秒，值存当前进程ID（用于后续校验）
$lockAcquired = $redis->set($lockKey, getmypid(), ['NX', 'EX' => 300]);

if ($lockAcquired) {
    try {
        $this->performFile($file);
        $this->moveFileToHistory($file);
    } finally {
        // 仅删除当前进程持有的锁，避免误删其他进程的锁
        $currentHolder = $redis->get($lockKey);
        if ($currentHolder == getmypid()) {
            $redis->del($lockKey);
        }
    }
} else {
    // 锁已被其他容器持有，跳过文件
    continue;
}

优点：完全分布式安全，无锁残留风险；支持更复杂的场景（比如锁续约，如果文件处理时间可能超过过期时间）。

方案三：原子性文件移动（绕开锁的巧妙方案） #

其实可以完全不用锁，利用大多数文件系统（比如ext4、NFSv4）的原子rename操作来实现互斥。核心逻辑是：每个应用尝试把共享目录的文件移动到自己专属的临时目录，移动成功就处理，失败就说明文件已经被其他进程拿走了。

// 每个容器设置唯一ID（可以从环境变量获取，比如Docker启动时传入-e CONTAINER_ID=$(hostname)）
$containerId = getenv('CONTAINER_ID');
$tempDir = '/shared/temp/' . $containerId;
// 确保临时目录存在
mkdir($tempDir, 0700, true);

$targetPath = $tempDir . '/' . basename($file);
// rename操作在支持的文件系统中是原子的，要么成功要么失败，不会出现中间状态
if (rename($file, $targetPath)) {
    try {
        $this->performFile($targetPath);
        $this->moveFileToHistory($targetPath);
    } finally {
        // 清理临时文件（如果处理失败，下次启动可以扫描临时目录重试）
        @unlink($targetPath);
    }
} else {
    // 移动失败，文件已被其他容器处理，跳过
    continue;
}

优点：完全不需要锁机制，无残留问题；原子操作天然避免竞态条件；即使进程崩溃，文件要么在原目录（可被其他容器处理），要么在临时目录（下次启动该容器可以重试）。
注意：要确认你的共享存储支持原子rename，比如NFSv3不支持，这种情况就不能用这个方案。

方案选择建议 #

• 如果不想引入额外服务，优先选原子性文件移动（前提是存储支持），其次是改进版目录锁
• 如果需要更严谨的分布式场景，或者已经有Redis，选Redis分布式锁

内容的提问来源于stack exchange，提问作者Yoyo