高效使用PHP上传文件到多个SFTP服务器的教程

<?php

// 服务器配置
$host = 'shell.example.com';
$port = 22;
$username = 'your_username';
$password = 'your_password';

// 本地文件路径和远程目标路径
$localFile = '/path/to/local/file.txt'; // 待上传的本地文件
$remoteFile = '/path/to/remote/directory/file.txt'; // 远程服务器上的目标路径

echo "尝试连接到 SFTP 服务器: {$host}:{$port}\n";

// 1. 建立SSH连接
$connection = ssh2_connect($host, $port);

if (!$connection) {
    die("错误：无法连接到 SSH 服务器。\n");
}

echo "SSH 连接成功。\n";

// 2. 身份验证
if (!ssh2_auth_password($connection, $username, $password)) {
    die("错误：SSH 身份验证失败。\n");
}

echo "SSH 身份验证成功。\n";

// 3. 初始化SFTP子系统
$sftp = ssh2_sftp($connection);

if (!$sftp) {
    die("错误：无法初始化 SFTP 子系统。\n");
}

echo "SFTP 子系统初始化成功。\n";

// 4. 构建SFTP文件流URI并打开文件进行写入
// ssh2.sftp://[resource_id]/path/to/file
// intval($sftp) 将资源ID转换为整数，这是ssh2.sftp:// 协议所要求的
$sftpStreamUrl = 'ssh2.sftp://' . intval($sftp) . $remoteFile;

echo "尝试打开远程文件流: {$sftpStreamUrl}\n";

// 使用fopen以写入模式打开远程文件流
$remoteStream = @fopen($sftpStreamUrl, 'w');

if (!$remoteStream) {
    die("错误：无法打开远程文件进行写入。请检查路径或权限。\n");
}

echo "远程文件流打开成功。开始上传文件...\n";

// 5. 将本地文件内容写入远程文件流
$localFileContent = file_get_contents($localFile);
if ($localFileContent === false) {
    die("错误：无法读取本地文件内容。\n");
}

if (fwrite($remoteStream, $localFileContent) === false) {
    die("错误：写入远程文件失败。\n");
}

echo "文件 '{$localFile}' 已成功上传到 '{$remoteFile}'。\n";

// 6. 关闭远程文件流
fclose($remoteStream);

// 注意：SSH连接会在脚本结束时自动关闭，但显式关闭是一个好习惯。
// ssh2_disconnect($connection); // 实际应用中可以根据需要调用

?>

<?php

// SFTP服务器配置列表
$sftpServers = [
    [
        'host' => 'server1.example.com',
        'port' => 22,
        'username' => 'user1',
        'password' => 'pass1',
        'remote_base_path' => '/var/www/html/uploads/' // 服务器1的远程目标基础路径
    ],
    [
        'host' => 'server2.example.com',
        'port' => 22,
        'username' => 'user2',
        'password' => 'pass2',
        'remote_base_path' => '/home/user2/public_html/files/' // 服务器2的远程目标基础路径
    ],
    // 更多服务器...
];

// 待上传的本地文件列表
$localFilesToUpload = [
    '/path/to/local/report.pdf',
    '/path/to/local/image.jpg',
    '/path/to/local/data.csv',
];

?>

<?php

/**
 * 上传单个文件到指定的SFTP服务器
 *
 * @param array $serverConfig 服务器配置 (host, port, username, password, remote_base_path)
 * @param string $localFilePath 本地文件完整路径
 * @return bool 上传成功返回 true，失败返回 false
 */
function uploadFileToSftp(array $serverConfig, string $localFilePath): bool
{
    $host = $serverConfig['host'];
    $port = $serverConfig['port'];
    $username = $serverConfig['username'];
    $password = $serverConfig['password'];
    $remoteBasePath = rtrim($serverConfig['remote_base_path'], '/') . '/'; // 确保以斜杠结尾

    $fileName = basename($localFilePath); // 获取文件名
    $remoteFilePath = $remoteBasePath . $fileName; // 远程目标完整路径

    echo "--------------------------------------------------------\n";
    echo "尝试上传 '{$fileName}' 到 '{$host}'...\n";

    // 1. 建立SSH连接
    $connection = @ssh2_connect($host, $port);
    if (!$connection) {
        error_log("错误：无法连接到 SSH 服务器 {$host}:{$port}");
        echo "连接失败。\n";
        return false;
    }

    // 2. 身份验证
    if (!@ssh2_auth_password($connection, $username, $password)) {
        error_log("错误：SSH 身份验证失败 for {$username}@{$host}");
        echo "身份验证失败。\n";
        // 显式断开连接，避免资源泄露
        // ssh2_disconnect($connection); // ssh2_connect 失败时可能无需断开
        return false;
    }

    // 3. 初始化SFTP子系统
    $sftp = @ssh2_sftp($connection);
    if (!$sftp) {
        error_log("错误：无法初始化 SFTP 子系统 for {$host}");
        echo "SFTP 初始化失败。\n";
        return false;
    }

    // 4. 构建SFTP文件流URI并打开文件进行写入
    $sftpStreamUrl = 'ssh2.sftp://' . intval($sftp) . $remoteFilePath;
    $remoteStream = @fopen($sftpStreamUrl, 'w');

    if (!$remoteStream) {
        error_log("错误：无法打开远程文件 {$remoteFilePath} 在 {$host} 进行写入。请检查路径或权限。");
        echo "打开远程文件失败。\n";
        return false;
    }

    // 5. 将本地文件内容写入远程文件流
    $localFileContent = @file_get_contents($localFilePath);
    if ($localFileContent === false) {
        error_log("错误：无法读取本地文件内容: {$localFilePath}");
        echo "读取本地文件失败。\n";
        fclose($remoteStream); // 关闭已打开的远程流
        return false;
    }

    if (fwrite($remoteStream, $localFileContent) === false) {
        error_log("错误：写入远程文件 {$remoteFilePath} 在 {$host} 失败。");
        echo "写入远程文件失败。\n";
        fclose($remoteStream); // 关闭已打开的远程流
        return false;
    }

    echo "文件 '{$fileName}' 已成功上传到 '{$host}:{$remoteFilePath}'。\n";

    // 6. 关闭远程文件流
    fclose($remoteStream);

    // ssh2_disconnect($connection); // 在循环中，如果连接是临时的，可以在这里断开。
                                   // 如果希望保持连接复用，则不在这里断开。
    return true;
}

?>

<?php

// 假设 $sftpServers 和 $localFilesToUpload 数组已定义如上

$uploadResults = [];

foreach ($localFilesToUpload as $localFilePath) {
    if (!file_exists($localFilePath)) {
        echo "警告：本地文件 '{$localFilePath}' 不存在，跳过。\n";
        continue;
    }

    foreach ($sftpServers as $serverConfig) {
        $serverIdentifier = "{$serverConfig['username']}@{$serverConfig['host']}";
        $success = uploadFileToSftp($serverConfig, $localFilePath);
        $uploadResults[] = [
            'file' => basename($localFilePath),
            'server' => $serverIdentifier,
            'status' => $success ? '成功' : '失败'
        ];
    }
}

echo "\n--- 上传总结 ---\n";
foreach ($uploadResults as $result) {
    echo "文件: {$result['file']}, 服务器: {$result['server']}, 状态: {$result['status']}\n";
}

?>