Golang FTP PASS命令在本地运行正常但在ECS上失败怎么办

我会尝试一下，但已经用 telnet 做了一些调试。 从连接到所需 VPN 的本地机器，我可以连接

# telnet ftp.xxxxxxxxx.net 21
Trying xx.xxx.xxx.xxx...
Connected to xxxxxxxxxxx.net.
Escape character is '^]'.
220 ProFTPD 1.3.5 Server (ProFTPD Default Installation) [xx.xxx.xxx.xxx]
USER xxxx
331 Password required for xxxx
PASS xxxxxxxxx
230 User xxx logged in

从另一个 VPC 中的 EC2 机器

Connected to ftp.xxxxxxxxxxxx.net.
Escape character is '^]'.
220 ProFTPD 1.3.5 Server (ProFTPD Default Installation) [xx.xxx.xxx.xxx]
USER xxxx
331 Password required for xxxx
PASS xxxxxxxx
Connection closed by foreign host.

这个问题通常是由于ECS实例的网络环境或安全组配置导致的。以下是几个可能的原因和对应的解决方案：

1. 网络连接问题

ECS实例可能无法建立到FTP服务器的连接，或者连接被中断。

// 增加连接调试信息
conn, err := ftp.DialTimeout(cfg.Host+cfg.Port, time.Second*15)
if err != nil {
    log.Printf("Dial error details: %v", err)
    return nil, fmt.Errorf("ftp dial error: %v", err)
}

// 设置更详细的调试
ftp.DebugFunc = func(msg string) {
    log.Printf("FTP Debug: %s", msg)
}

2. 安全组/防火墙配置

检查ECS安全组是否允许出站连接到FTP服务器的端口（通常是21）。

// 尝试使用不同的端口或模式
// 如果是被动模式问题，可以尝试主动模式
conn, err := ftp.Dial(cfg.Host+cfg.Port)
if err != nil {
    return nil, err
}

// 设置明确的传输模式
conn.SetPasv(false) // 使用主动模式

3. 被动模式问题

FTP被动模式在ECS环境中可能有问题。

// 修改vendor包中的连接处理，添加超时控制
// 在vendor/github.com/jlaffaye/ftp/ftp.go中修改cmd函数：

func (c *ServerConn) cmd(expectCode int, format string, args ...interface{}) (int, string, error) {
    // 添加连接检查
    if c.conn == nil {
        return 0, "", errors.New("connection is nil")
    }
    
    // 设置读写超时
    c.conn.SetDeadline(time.Now().Add(30 * time.Second))
    
    _, err := fmt.Fprintf(c.conn, format, args...)
    if err != nil {
        return 0, "", err
    }
    
    return c.readResponse(expectCode)
}

4. TLS/SSL问题

如果FTP服务器使用TLS，ECS环境可能需要不同的配置。

// 如果使用FTPS，确保TLS配置正确
import (
    "crypto/tls"
    ftps "github.com/jlaffaye/ftp"
)

// 创建自定义TLS配置
tlsConfig := &tls.Config{
    InsecureSkipVerify: true, // 仅用于测试
    MinVersion:         tls.VersionTLS12,
}

// 使用TLS连接
conn, err := ftps.DialTimeout(cfg.Host+cfg.Port, time.Second*15)
if err != nil {
    return nil, err
}

// 显式切换到TLS
err = conn.AuthTLS(tlsConfig)
if err != nil {
    return nil, fmt.Errorf("TLS auth error: %v", err)
}

5. 连接复用问题

ECS容器可能重用连接导致问题。

// 在每次操作后关闭连接
defer func() {
    if conn != nil {
        if err := conn.Quit(); err != nil {
            log.Printf("FTP quit error: %v", err)
        }
    }
}()

// 或者创建新的连接池
type FTPPool struct {
    connections chan *ftp.ServerConn
}

func NewFTPPool(size int, host, port string) (*FTPPool, error) {
    pool := &FTPPool{
        connections: make(chan *ftp.ServerConn, size),
    }
    
    for i := 0; i < size; i++ {
        conn, err := ftp.DialTimeout(host+port, time.Second*15)
        if err != nil {
            return nil, err
        }
        pool.connections <- conn
    }
    
    return pool, nil
}

6. 添加详细的错误处理

// 修改登录函数以捕获更多错误信息
func loginWithRetry(conn *ftp.ServerConn, username, password string, maxRetries int) error {
    var lastErr error
    
    for i := 0; i < maxRetries; i++ {
        err := conn.Login(username, password)
        if err == nil {
            return nil
        }
        
        lastErr = err
        log.Printf("Login attempt %d failed: %v", i+1, err)
        
        // 如果是连接错误，尝试重新连接
        if strings.Contains(err.Error(), "EOF") || 
           strings.Contains(err.Error(), "connection") {
            // 重新建立连接
            conn, err = ftp.DialTimeout(cfg.Host+cfg.Port, time.Second*15)
            if err != nil {
                log.Printf("Reconnection failed: %v", err)
                time.Sleep(2 * time.Second)
                continue
            }
        }
        time.Sleep(1 * time.Second)
    }
    
    return fmt.Errorf("failed after %d retries: %v", maxRetries, lastErr)
}

7. 网络跟踪工具

在ECS容器中添加网络诊断：

// 添加网络连通性测试
func testFTPConnectivity(host, port string) error {
    // 测试TCP连接
    timeout := 15 * time.Second
    conn, err := net.DialTimeout("tcp", host+port, timeout)
    if err != nil {
        return fmt.Errorf("TCP connection failed: %v", err)
    }
    defer conn.Close()
    
    // 读取banner
    conn.SetReadDeadline(time.Now().Add(timeout))
    banner := make([]byte, 1024)
    n, err := conn.Read(banner)
    if err != nil {
        return fmt.Errorf("read banner failed: %v", err)
    }
    
    log.Printf("FTP Banner: %s", string(banner[:n]))
    return nil
}

// 在main函数中调用
if err := testFTPConnectivity(cfg.Host, cfg.Port); err != nil {
    log.Fatalf("Connectivity test failed: %v", err)
}

主要检查ECS安全组出站规则、网络ACL、容器网络模式（awsvpc vs bridge），以及FTP服务器的防火墙设置。EOF错误通常表示连接在认证过程中被意外关闭。