FTP下载文件后写入磁盘异常：写入文件为空但Reader非空

我来帮你分析下这个问题，我之前也遇到过类似的情况，大概率是ftp连接与Reader的生命周期管理、复制过程中的错误处理不到位，或是传输模式配置有问题导致的。咱们一步步拆解排查：

常见问题点与解决方案 #

1. 连接/Reader的生命周期顺序错误 #

ftp库的Retr()返回的Reader是和当前ftp连接绑定的，如果在读取完成前就关闭了ftp连接（比如client.Quit()提前执行），Reader会直接失效，导致读取不到内容。

修正建议：确保client.Quit()的延迟执行在Reader关闭之后，同时显式关闭Retr返回的Reader。

2. 忽略了io.Copy的返回值 #

很多时候我们会直接调用io.Copy但不检查错误和写入字节数，这会导致即使复制过程出错（比如网络中断），也无法及时发现，最终得到空文件。

3. 未配置正确的传输模式 #

如果下载的是二进制文件（图片、压缩包等），默认的文本传输模式可能会导致内容被篡改，甚至出现空文件的情况，需要切换到二进制传输模式。

修正后的完整代码示例 #

import (
    "fmt"
    "io"
    "log"
    "os"

    "github.com/jlaffaye/ftp"
)

func pullFileByFTP(fileID, server string, port int64, username, password, path, file string) error {
    // 连接FTP服务器
    client, err := ftp.Dial(fmt.Sprintf("%s:%d", server, port))
    if err != nil {
        return fmt.Errorf("dial ftp server failed: %w", err)
    }
    // 延迟关闭连接，但确保在Reader读取完成后执行
    defer func() {
        if quitErr := client.Quit(); quitErr != nil {
            log.Printf("warning: quit ftp client failed: %v", quitErr)
        }
    }()

    // 登录服务器
    if err := client.Login(username, password); err != nil {
        return fmt.Errorf("login ftp server failed: %w", err)
    }

    // 切换到目标目录
    if err := client.ChangeDir(path); err != nil {
        return fmt.Errorf("change to target dir failed: %w", err)
    }

    // 配置二进制传输模式，避免二进制文件内容损坏
    if err := client.SetTransferMode(ftp.TransferModeBinary); err != nil {
        return fmt.Errorf("set binary transfer mode failed: %w", err)
    }
    // 开启被动模式，适配大多数服务器的网络配置
    client.EnterPassive()

    // 获取文件读取器
    fileReader, err := client.Retr(file)
    if err != nil {
        return fmt.Errorf("retrieve file from ftp failed: %w", err)
    }
    // 延迟关闭读取器，释放ftp连接资源
    defer func() {
        if closeErr := fileReader.Close(); closeErr != nil {
            log.Printf("warning: close ftp file reader failed: %v", closeErr)
        }
    }()

    // 创建本地文件
    localFile, err := os.Create(file)
    if err != nil {
        return fmt.Errorf("create local file failed: %w", err)
    }
    defer func() {
        if closeErr := localFile.Close(); closeErr != nil {
            log.Printf("warning: close local file failed: %v", closeErr)
        }
    }()

    // 复制文件内容到本地，检查写入字节数和错误
    writtenBytes, err := io.Copy(localFile, fileReader)
    if err != nil {
        return fmt.Errorf("copy file content failed: %w", err)
    }
    if writtenBytes == 0 {
        return fmt.Errorf("no bytes copied, local file is empty")
    }

    // 强制刷新文件缓冲区到磁盘，避免内容还在内存中未写入
    if syncErr := localFile.Sync(); syncErr != nil {
        return fmt.Errorf("sync local file to disk failed: %w", syncErr)
    }

    log.Printf("successfully downloaded file, wrote %d bytes", writtenBytes)
    return nil
}

额外排查建议 #

• 添加详细日志：在关键步骤（比如获取Reader、复制前后）打印日志，确认每个环节的执行状态和字节数，方便定位问题。
• 手动验证Reader内容：在调用io.Copy前，可以尝试用io.ReadAll(fileReader)读取全部内容，打印长度或者写入临时Buffer，确认Reader确实有内容（注意：读取后需要重新获取Reader，因为Reader是单向的）。

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