PHP实现多SFTP服务器文件快速上传教程

<?php

/**
 * 将本地文件上传到指定的SFTP服务器
 *
 * @param string $host SFTP服务器地址
 * @param int $port SFTP服务器端口，默认为22
 * @param string $username 用户名
 * @param string $password 密码
 * @param string $localFilePath 本地文件完整路径
 * @param string $remoteFilePath 远程服务器上的目标文件路径
 * @return bool 上传成功返回true，失败返回false
 */
function uploadFileToSftp(
    string $host,
    int $port,
    string $username,
    string $password,
    string $localFilePath,
    string $remoteFilePath
): bool {
    echo "尝试连接SFTP服务器: {$host}:{$port}...\n";

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

    // 2. 用户认证
    if (!ssh2_auth_password($connection, $username, $password)) {
        error_log("SSH认证失败到 {$host}，用户名: {$username}");
        echo "错误: SSH认证失败，请检查用户名和密码。\n";
        return false;
    }
    echo "SSH认证成功。\n";

    // 3. 开启SFTP子系统
    $sftp = ssh2_sftp($connection);
    if (!$sftp) {
        error_log("无法开启SFTP子系统到 {$host}");
        echo "错误: 无法开启SFTP子系统。\n";
        return false;
    }
    echo "SFTP子系统开启成功。\n";

    // 检查本地文件是否存在
    if (!file_exists($localFilePath)) {
        error_log("本地文件不存在: {$localFilePath}");
        echo "错误: 本地文件不存在。\n";
        return false;
    }

    echo "准备上传文件 {$localFilePath} 到 {$remoteFilePath}...\n";

    // 4. 使用SFTP流进行文件上传
    $localStream = fopen($localFilePath, 'rb'); // 以二进制读取模式打开本地文件
    if (!$localStream) {
        error_log("无法打开本地文件进行读取: {$localFilePath}");
        echo "错误: 无法打开本地文件。\n";
        return false;
    }

    // 使用ssh2.sftp://协议包装器打开远程文件进行写入
    // intval($sftp) 将SFTP资源转换为整数ID，供流包装器使用
    $remoteStream = fopen('ssh2.sftp://' . intval($sftp) . $remoteFilePath, 'wb');
    if (!$remoteStream) {
        error_log("无法打开远程文件进行写入: {$remoteFilePath}");
        echo "错误: 无法打开远程文件。\n";
        fclose($localStream); // 关闭本地文件流
        return false;
    }

    // 逐块写入数据
    $bytesWritten = 0;
    while (!feof($localStream)) {
        $buffer = fread($localStream, 8192); // 读取8KB数据块
        $bytesWritten += fwrite($remoteStream, $buffer);
    }

    // 关闭文件流
    fclose($localStream);
    fclose($remoteStream);

    echo "文件上传完成。共写入 {$bytesWritten} 字节。\n";

    // 注意：ssh2_connect返回的连接资源会在脚本结束时自动关闭，
    // 但在长时间运行的脚本中，手动关闭可能是个好习惯。
    // ssh2_disconnect($connection); // 目前没有ssh2_disconnect函数，连接会在PHP脚本执行结束时自动关闭。
                                   // 如果需要更精细的控制，可以考虑使用长连接。

    return true;
}

// --- 使用示例 ---
$sftpHost = 'your_sftp_server.com'; // 替换为您的SFTP服务器地址
$sftpPort = 22;
$sftpUsername = 'your_username';     // 替换为您的SFTP用户名
$sftpPassword = 'your_password';     // 替换为您的SFTP密码

$localFile = '/path/to/your/local/file.txt'; // 替换为本地要上传的文件路径
$remoteFile = '/path/on/remote/server/uploaded_file.txt'; // 替换为远程服务器上的目标路径

if (uploadFileToSftp($sftpHost, $sftpPort, $sftpUsername, $sftpPassword, $localFile, $remoteFile)) {
    echo "文件 {$localFile} 已成功上传到 {$sftpHost}:{$remoteFile}\n";
} else {
    echo "文件上传失败。\n";
}

?>

<?php

// 引入之前定义的 uploadFileToSftp 函数
// require_once 'sftp_upload_function.php'; // 如果函数定义在单独文件中

/**
 * 将本地文件上传到多个SFTP服务器
 *
 * @param array $servers 包含每个服务器配置的数组，每个配置应包含 host, port, username, password
 * @param string $localFilePath 本地文件完整路径
 * @param string $remoteFilePath 远程服务器上的目标文件路径
 */
function uploadFileToMultipleSftpServers(
    array $servers,
    string $localFilePath,
    string $remoteFilePath
): void {
    echo "开始向多个SFTP服务器上传文件: {$localFilePath}\n";

    foreach ($servers as $index => $server) {
        echo "\n--- 处理服务器 #" . ($index + 1) . ": {$server['host']} ---\n";

        $host = $server['host'];
        $port = $server['port'] ?? 22; // 默认端口22
        $username = $server['username'];
        $password = $server['password'];

        if (uploadFileToSftp($host, $port, $username, $password, $localFilePath, $remoteFilePath)) {
            echo "成功上传到 {$host}\n";
        } else {
            echo "上传到 {$host} 失败！\n";
        }
    }
    echo "\n所有服务器上传尝试完成。\n";
}

// --- 使用示例 ---
$sftpServers = [
    [
        'host' => 'sftp1.example.com',
        'port' => 22,
        'username' => 'user1',
        'password' => 'pass1'
    ],
    [
        'host' => 'sftp2.example.com',
        'port' => 22,
        'username' => 'user2',
        'password' => 'pass2'
    ],
    // 可以添加更多服务器配置
    [
        'host' => 'sftp3.example.com',
        'port' => 2222, // 示例：不同端口
        'username' => 'user3',
        'password' => 'pass3'
    ]
];

$localFileToUpload = '/path/to/your/local/document.pdf'; // 替换为本地要上传的文件
$remoteDestinationPath = '/remote/uploads/document.pdf'; // 替换为远程服务器上的目标路径

uploadFileToMultipleSftpServers($sftpServers, $localFileToUpload, $remoteDestinationPath);

?>

// 在函数内部使用 error_log() 记录错误
error_log("SFTP上传失败到 {$host}：原因描述");

// 使用公钥/私钥进行认证
if (!ssh2_auth_pubkey_file(
    $connection,
    $username,
    '/path/to/your/public/key.pub',  // 公钥文件路径
    '/path/to/your/private/key',     // 私钥文件路径
    'passphrase_for_private_key'     // 如果私钥有密码，提供密码
)) {
    error_log("SSH公钥认证失败到 {$host}，用户名: {$username}");
    echo "错误: SSH公钥认证失败。\n";
    return false;
}
echo "SSH公钥认证成功。\n";