如何在 Go 中实现 FTP 上传与实时进度监控并发执行

本文详解如何使用 goftp 库在 go 中安全并发地执行 ftp 文件上传与文件状态轮询，避免因共享 ftp 连接导致的阻塞与竞态问题，并提供可落地的双连接方案与完整示例代码。

在 Go 里用 FTP 协议上传文件，同时还想盯着进度——比如看看远程文件有没有出现、大小是不是在涨——这事儿听起来不复杂，但实际操作起来，一个不小心就会踩进“并发复用连接”的坑里。问题根子在哪儿呢？goftp.FTP 实例本身不是并发安全的。它的底层 TCP 连接和命令通道，根本扛不住多个 goroutine 同时调用。想象一下：一个 goroutine 正用 Stor() 上传文件，另一个 goroutine 同时用 List() 查状态，两边互相抢资源、指令乱套，结果就是上传失败、响应超时，或者你看到的 [] 和 错误直接砸脸上。

所以，正确的做法是什么？其实思路很直接——各干各的，互不干扰。

✅ 正确方案：为并发操作分配独立 FTP 连接

最可靠、也最符合 FTP 协议设计初衷的方法，就是给上传任务和监控任务分别建立独立的 FTP 连接实例。这样一来，竞态条件自然消失，每个逻辑操作都有自己的专属会话，互不打架。

下面是一个优化后的完整可运行示例，包含了错误处理、TLS 配置和进度模拟逻辑，你可以直接拿来用：

package main

import (
    "fmt"
    "log"
    "os"
    "time"
    goftp "github.com/dutchcoders/goftp"
    "crypto/tls"
)

func main() {
    fileName := "example.zip"
    serverAddr := "serverip:port"
    username, password := "userName", "pass"

    // ? 连接 1：专用于上传（Stor）
    ftpUpload, err := goftp.Connect(serverAddr)
    if err != nil {
        log.Fatal("上传连接失败:", err)
    }
    defer ftpUpload.Close()

    // 启用 TLS（若需）
    tlsConfig := &tls.Config{InsecureSkipVerify: true}
    if err = ftpUpload.AuthTLS(*tlsConfig); err != nil {
        log.Printf("TLS 认证警告（非必须）: %v", err)
    }
    if err = ftpUpload.Login(username, password); err != nil {
        log.Fatal("上传登录失败:", err)
    }
    if err = ftpUpload.Cwd("/home/myDir/"); err != nil {
        log.Fatal("上传目录切换失败:", err)
    }

    file, err := os.Open(fileName)
    if err != nil {
        log.Fatal("本地文件打开失败:", err)
    }
    defer file.Close()

    fmt.Println("✅ 开始上传...")
    err = ftpUpload.Stor(fileName, file)
    if err != nil {
        log.Fatal("上传失败:", err)
    }
    fmt.Println("? 上传完成")

    // ? 连接 2：专用于监控（List 轮询）
    ftpMonitor, err := goftp.Connect(serverAddr)
    if err != nil {
        log.Fatal("监控连接失败:", err)
    }
    defer ftpMonitor.Close()

    if err = ftpMonitor.AuthTLS(*tlsConfig); err != nil {
        log.Printf("监控 TLS 认证警告: %v", err)
    }
    if err = ftpMonitor.Login(username, password); err != nil {
        log.Fatal("监控登录失败:", err)
    }
    if err = ftpMonitor.Cwd("/home/myDir/"); err != nil {
        log.Fatal("监控目录切换失败:", err)
    }

    fmt.Println("? 启动远程文件状态监控...")
    ticker := time.NewTicker(2 * time.Second)
    defer ticker.Stop()

    for i := 0; i < 10; i++ { // 最多轮询 10 次（20 秒）
        select {
        case <-ticker.C:
            files, err := ftpMonitor.List(fileName)
            if err != nil {
                log.Printf("查询失败（忽略）: %v", err)
                continue
            }
            if len(files) > 0 {
                fmt.Printf("? 找到文件 %s —— 大小: %d 字节, 修改时间: %s\n",
                    files[0].Name, files[0].Size, files[0].Time)
            } else {
                fmt.Printf("⏳ 远程暂无 %s\n", fileName)
            }
        }
    }
    fmt.Println("✅ 监控结束")
}

⚠️ 关键注意事项

• 千万别共享 FTP 实例：goftp.FTP 不是线程安全的类型，任何并发读写操作——无论是 Stor、List 还是 Cwd——都必须使用独立的连接。
• 连接资源要主动管理：每个 goftp.Connect() 创建的连接都要记得 defer conn.Close()，避免连接泄漏这种低级错误。
• Stor() 是阻塞同步调用：它在内部完成整个数据传输后才返回，所以不需要额外用 goroutine 去包裹它——除非你确实需要做 UI 更新之类的异步响应。你原先代码里 go func(){ ftp.Stor(...) } 的做法，反而增加了调度上的不确定性。
• 监控频率要控制好：FTP 服务器通常不支持高频 LIST 请求，建议轮询间隔至少 1-2 秒；请求太频繁，容易被服务器限速甚至断开连接。
• 生产环境一定要校验凭证和路径：可以用 ftp.Pwd() 验证登录后的工作目录，用 ftp.Stat(fileName) 替代 List(fileName) 来获取单文件信息，效率会更高。

✅ 替代思路（不推荐但可行）

如果服务器连接数实在有限，可以考虑串行化 + 回调通知的方案：先启动上传，在 Stor() 返回后立即触发一次 List 来获取最终状态。但这样做的代价是——你无法实现“上传过程中的实时进度监控”，只适用于“上传完成后再检查结果”的场景。

话说回来，双连接模型在正确性、可维护性和协议合规性之间，实现了最好的平衡。它让上传和监控各司其职，从根源上消除了竞态问题，是构建健壮 FTP 工具链的基础思路。