首页 > 编程语言 >Go实现FTP并发上传与实时进度监控

Go实现FTP并发上传与实时进度监控

来源：互联网 2026-07-01 08:27:07

Go资讯合集

在Go中使用goftp库实现FTP上传与实时进度监控时，需注意goftp.FTP实例非并发安全。正确方案是为上传和监控分别建立独立FTP连接，避免竞态问题。双连接模型平衡了正确性与协议合规性，是构建健壮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) 来获取单文件信息，效率会更高。