本文详解如何使用 goftp 库在 go 中安全并发地执行 ftp 文件上传与文件状态轮询，避免因共享 ftp 连接导致的阻塞与竞态问题，并提供可落地的双连接方案与完整示例代码。
本文详解如何使用 goftp 库在 go 中安全并发地执行 ftp 文件上传与文件状态轮询，避免因共享 ftp 连接导致的阻塞与竞态问题，并提供可落地的双连接方案与完整示例代码。
在 Go 中通过 FTP 协议上传文件并同时监控其上传进度（例如检查远程文件是否存在、大小是否增长），看似简单，实则极易因 FTP 连接复用引发严重并发问题。核心症结在于：goftp.FTP 实例不是并发安全的——其底层 TCP 连接和命令通道不具备多 goroutine 并发调用能力。当两个 goroutine 同时使用同一个 *goftp.FTP 实例（如一个调用 Stor() 上传，另一个调用 List() 查询），会相互阻塞、指令错乱，最终导致上传失败、响应超时或返回空结果（如你观察到的 [] 和 <nil> 错误）。
✅ 正确方案：为并发操作分配独立 FTP 连接
最可靠且符合 FTP 协议设计的方式，是为上传任务和监控任务分别建立独立的 FTP 连接实例。这不仅规避了竞态，也符合 FTP 的“控制连接 + 数据连接”模型——每个逻辑操作应拥有专属会话。
以下是优化后的完整可运行示例（含错误处理、TLS 配置及进度模拟逻辑）：
在 Go 中使用 google/wire 实现编译时依赖注入——wire.NewSet、wire.Build、wire.Bind（接口→实现）、wire.Struct、wire.Value、wire.Interface
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 工具链的基础。
