PHP实现高效多SFTP服务器文件上传教程

sudo pecl install ssh2

extension=ssh2.so

extension=php_ssh2.dll

php -m | grep ssh2

<?php
$host = 'your_sftp_host.com';
$port = 22; // SFTP默认端口

$connection = ssh2_connect($host, $port);

if (!$connection) {
    die("无法连接到SSH服务器: {$host}\n");
}
echo "成功连接到SSH服务器: {$host}\n";
?>

<?php
// ... (之前的连接代码)

$username = 'your_username';
$password = 'your_password';

if (!ssh2_auth_password($connection, $username, $password)) {
    die("SSH身份验证失败: 用户名或密码错误\n");
}
echo "SSH身份验证成功\n";
?>

<?php
// ... (之前的连接和认证代码)

$sftp = ssh2_sftp($connection);

if (!$sftp) {
    die("无法开启SFTP子系统\n");
}
echo "SFTP子系统已开启\n";
?>

<?php
// ... (之前的连接、认证和SFTP开启代码)

$localFilePath = '/path/to/local/file.txt'; // 本地待上传文件路径
$remoteFilePath = '/path/to/remote/directory/file.txt'; // SFTP服务器目标路径

// 打开本地文件进行读取
$localStream = @fopen($localFilePath, 'r');
if (!$localStream) {
    die("无法打开本地文件进行读取: {$localFilePath}\n");
}

// 打开SFTP目标文件进行写入
// 注意：intval($sftp) 将SFTP资源转换为其整数ID，用于构建协议路径
$remoteStream = @fopen('ssh2.sftp://' . intval($sftp) . $remoteFilePath, 'w');
if (!$remoteStream) {
    fclose($localStream);
    die("无法打开SFTP目标文件进行写入: {$remoteFilePath}\n");
}

// 将本地文件内容写入SFTP目标文件
$bytesWritten = stream_copy_to_stream($localStream, $remoteStream);

if ($bytesWritten === false) {
    echo "文件上传失败: {$localFilePath} -> {$remoteFilePath}\n";
} else {
    echo "文件上传成功: {$localFilePath} -> {$remoteFilePath} ({$bytesWritten} 字节)\n";
}

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

// 关闭SSH连接 (可选，脚本结束会自动关闭)
// ssh2_disconnect($connection); 
?>

<?php

/**
 * 封装SFTP文件上传逻辑
 *
 * @param string $host SSH服务器地址
 * @param int $port SSH端口 (默认为22)
 * @param string $username SSH用户名
 * @param string $password SSH密码
 * @param string $localFilePath 本地文件路径
 * @param string $remoteFilePath 远程SFTP目标路径
 * @return bool 上传是否成功
 */
function uploadFileToSftp(
    string $host,
    int $port,
    string $username,
    string $password,
    string $localFilePath,
    string $remoteFilePath
): bool {
    echo "尝试连接到 {$host}...\n";
    $connection = ssh2_connect($host, $port);
    if (!$connection) {
        error_log("无法连接到SSH服务器: {$host}");
        return false;
    }

    echo "正在认证用户 {$username}...\n";
    if (!ssh2_auth_password($connection, $username, $password)) {
        error_log("SSH身份验证失败于 {$host}，用户 {$username}");
        return false;
    }

    echo "正在开启SFTP子系统...\n";
    $sftp = ssh2_sftp($connection);
    if (!$sftp) {
        error_log("无法开启SFTP子系统于 {$host}");
        return false;
    }

    echo "正在上传文件 {$localFilePath} 到 {$host}:{$remoteFilePath}...\n";
    $localStream = @fopen($localFilePath, 'r');
    if (!$localStream) {
        error_log("无法打开本地文件进行读取: {$localFilePath}");
        return false;
    }

    $remoteStream = @fopen('ssh2.sftp://' . intval($sftp) . $remoteFilePath, 'w');
    if (!$remoteStream) {
        fclose($localStream);
        error_log("无法打开SFTP目标文件进行写入于 {$host}:{$remoteFilePath}");
        return false;
    }

    $bytesWritten = stream_copy_to_stream($localStream, $remoteStream);

    fclose($localStream);
    fclose($remoteStream);

    if ($bytesWritten === false) {
        error_log("文件上传失败: {$localFilePath} -> {$host}:{$remoteFilePath}");
        return false;
    } else {
        echo "文件上传成功: {$localFilePath} -> {$host}:{$remoteFilePath} ({$bytesWritten} 字节)\n";
        return true;
    }
}

// 1. 定义SFTP服务器配置列表
$sftpServers = [
    [
        'host' => 'sftp1.example.com',
        'port' => 22,
        'username' => 'user1',
        'password' => 'pass1',
        'remote_base_path' => '/uploads/server1/'
    ],
    [
        'host' => 'sftp2.example.com',
        'port' => 22,
        'username' => 'user2',
        'password' => 'pass2',
        'remote_base_path' => '/data/files/'
    ],
    // 可以添加更多服务器
];

// 2. 定义待上传文件列表
$filesToUpload = [
    '/tmp/report_2023_01.pdf',
    '/tmp/logs_summary.txt',
    // 确保这些本地文件存在
];

// 3. 遍历服务器和文件，执行上传
foreach ($sftpServers as $serverConfig) {
    foreach ($filesToUpload as $localFile) {
        $fileName = basename($localFile);
        $remotePath = $serverConfig['remote_base_path'] . $fileName;

        echo "--- 开始处理服务器: {$serverConfig['host']}，文件: {$localFile} ---\n";
        $success = uploadFileToSftp(
            $serverConfig['host'],
            $serverConfig['port'],
            $serverConfig['username'],
            $serverConfig['password'],
            $localFile,
            $remotePath
        );

        if (!$success) {
            echo "!!! 上传到 {$serverConfig['host']} 失败，文件 {$localFile} !!!\n";
        }
        echo "--- 处理结束 ---\n\n";
    }
}

echo "所有文件上传任务完成。\n";

?>