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

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

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

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

在 Go 中通过 FTP 协议上传文件并同时监控其上传进度（例如检查远程文件是否存在、大小是否增长），看似简单，实则极易因 FTP 连接复用引发严重并发问题。核心症结在于：goftp.FTP 实例不是并发安全的——其底层 TCP 连接和命令通道不具备多 goroutine 并发调用能力。当两个 goroutine 同时使用同一个 *goftp.FTP 实例（如一个调用 Stor() 上传，另一个调用 List() 查询），会相互阻塞、指令错乱，最终导致上传失败、响应超时或返回空结果（如你观察到的 [] 和错误）。

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

最可靠且符合 FTP 协议设计的方式，是为上传任务和监控任务分别建立独立的 FTP 连接实例。这不仅规避了竞态，也符合 FTP 的“控制连接 + 数据连接”模型——每个逻辑操作应拥有专属会话。

以下是优化后的完整可运行示例（含错误处理、TLS 配置及进度模拟逻辑）：

Golang Spf13 Viper

Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。

下载

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  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) 获取单文件信息更高效。