PHP怎么实现文件自动同步到云端 文件自动同步方案详解

<?php

// 引入云存储SDK (这里以阿里云OSS为例)
require_once __DIR__ . '/vendor/autoload.php';

use OSS\OssClient;
use OSS\Core\OssException;

// 配置
$accessKeyId = 'your_access_key_id';
$accessKeySecret = 'your_access_key_secret';
$endpoint = 'your_endpoint';
$bucket = 'your_bucket_name';
$monitorDir = '/path/to/your/local/directory';

try {
    $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
} catch (OssException $e) {
    echo "OSS connection failed: " . $e->getMessage() . PHP_EOL;
    exit(1);
}

// 使用inotify监控目录
$fd = inotify_init();
inotify_add_watch($fd, $monitorDir, IN_CREATE | IN_MODIFY | IN_DELETE);

while (true) {
    $events = inotify_read($fd);
    if ($events) {
        foreach ($events as $event) {
            $filename = $monitorDir . '/' . $event['name'];
            if ($event['mask'] & IN_CREATE) {
                echo "File created: " . $filename . PHP_EOL;
                uploadFile($ossClient, $bucket, $filename);
            } elseif ($event['mask'] & IN_MODIFY) {
                echo "File modified: " . $filename . PHP_EOL;
                uploadFile($ossClient, $bucket, $filename);
            } elseif ($event['mask'] & IN_DELETE) {
                echo "File deleted: " . $filename . PHP_EOL;
                deleteFile($ossClient, $bucket, $filename);
            }
        }
    }
    usleep(100000); // 100ms
}

function uploadFile($ossClient, $bucket, $filename) {
    try {
        $object = str_replace(dirname($filename) . '/', '', $filename);
        $ossClient->uploadFile($bucket, $object, $filename);
        echo "Uploaded: " . $filename . " to OSS: " . $object . PHP_EOL;
    } catch (OssException $e) {
        echo "Upload failed: " . $e->getMessage() . PHP_EOL;
    }
}

function deleteFile($ossClient, $bucket, $filename) {
    try {
        $object = str_replace(dirname($filename) . '/', '', $filename);
        $ossClient->deleteObject($bucket, $object);
        echo "Deleted: " . $filename . " from OSS: " . $object . PHP_EOL;
    } catch (OssException $e) {
        echo "Delete failed: " . $e->getMessage() . PHP_EOL;
    }
}

fclose($fd);

?>