Go语言安全文件传输：告别FTP，拥抱SFTP、FTPS与SCP

package main

import (
    "fmt"
    "io"
    "log"
    "os"
    "time"

    "github.com/pkg/sftp"
    "golang.org/x/crypto/ssh"
)

func main() {
    // 1. SSH客户端配置
    // 请替换为您的SFTP服务器信息和凭据
    sshConfig := &ssh.ClientConfig{
        User: "your_username", // SFTP服务器用户名
        Auth: []ssh.AuthMethod{
            ssh.Password("your_password"), // SFTP服务器密码
            // 或者使用公钥认证:
            // ssh.PublicKeys(parsePrivateKey("path/to/your/private_key")),
        },
        // 主机密钥回调函数：用于验证服务器的身份
        // 生产环境中，请务必验证服务器主机密钥，例如使用 ssh.FixedHostKey() 或 ssh.KnownHosts()
        // 这里的 ssh.InsecureIgnoreHostKey() 仅用于开发测试，极不安全，切勿用于生产环境！
        HostKeyCallback: ssh.InsecureIgnoreHostKey(),
        Timeout:         5 * time.Second,
    }

    // 2. 连接到SSH服务器
    serverAddr := "your_sftp_server:22" // SFTP服务器地址和端口 (SSH默认端口22)
    conn, err := ssh.Dial("tcp", serverAddr, sshConfig)
    if err != nil {
        log.Fatalf("无法连接到SSH服务器: %v", err)
    }
    defer conn.Close()

    // 3. 创建SFTP客户端
    client, err := sftp.NewClient(conn)
    if err != nil {
        log.Fatalf("无法创建SFTP客户端: %v", err)
    }
    defer client.Close()

    // 4. 准备本地文件进行上传
    localFilePath := "./local_upload_file.txt"
    remoteFilePath := "/remote/path/to/uploaded_file.txt" // SFTP服务器上的目标路径

    // 创建一个示例本地文件
    dummyFile, err := os.Create(localFilePath)
    if err != nil {
        log.Fatalf("无法创建示例本地文件: %v", err)
    }
    _, _ = dummyFile.WriteString("这是一个通过Go SFTP上传的测试文件内容。\n")
    dummyFile.Close()

    localFile, err := os.Open(localFilePath)
    if err != nil {
        log.Fatalf("无法打开本地文件: %v", err)
    }
    defer localFile.Close()

    // 5. 在SFTP服务器上创建远程文件并写入数据
    remoteFile, err := client.Create(remoteFilePath)
    if err != nil {
        log.Fatalf("无法在远程服务器上创建文件: %v", err)
    }
    defer remoteFile.Close()

    _, err = io.Copy(remoteFile, localFile)
    if err != nil {
        log.Fatalf("文件上传失败: %v", err)
    }

    fmt.Printf("文件 '%s' 已成功上传到 SFTP 服务器的 '%s'\n", localFilePath, remoteFilePath)

    // 清理示例本地文件
    os.Remove(localFilePath)
}

// parsePrivateKey 是一个辅助函数，用于解析SSH私钥文件
// func parsePrivateKey(path string) ssh.Signer {
//  key, err := os.ReadFile(path)
//  if err != nil {
//      log.Fatalf("无法读取私钥文件: %v", err)
//  }
//  signer, err := ssh.ParsePrivateKey(key)
//  if err != nil {
//      log.Fatalf("无法解析私钥: %v", err)
//  }
//  return signer
// }

package main

import (
    "crypto/tls"
    "fmt"
    "io"
    "log"
    "os"
    "time"

    "github.com/jlaffaye/ftp"
)

func main() {
    // FTPS服务器地址，通常隐式FTPS使用端口990，显式FTPS在端口21上协商TLS
    serverAddr := "your_ftps_server:990" // 示例：隐式FTPS

    // TLS配置
    tlsConfig := &tls.Config{
        // 生产环境中，请务必将 InsecureSkipVerify 设为 false，并配置正确的根证书！
        // 否则，您的连接将不验证服务器证书，存在中间人攻击风险。
        InsecureSkipVerify: true,
    }

    // 连接到FTPS服务器
    c, err := ftp.DialTLS(serverAddr, tlsConfig, ftp.DialWithTimeout(5*time.Second))
    if err != nil {
        log.Fatalf("无法连接到FTPS服务器: %v", err)
    }
    defer c.Quit()

    // 登录
    err = c.Login("your_username", "your_password")
    if err != nil {
        log.Fatalf("登录FTPS失败: %v", err)
    }

    // 准备本地文件进行上传
    localFilePath := "./local_ftps_file.txt"
    remoteFilePath := "/remote/path/to/uploaded_ftps_file.txt"

    dummyFile, err := os.Create(localFilePath)
    if err != nil {
        log.Fatalf("无法创建示例本地文件: %v", err)
    }
    _, _ = dummyFile.WriteString("这是一个通过Go FTPS上传的测试文件内容。\n")
    dummyFile.Close()

    localFile, err := os.Open(localFilePath)
    if err != nil {
        log.Fatalf("无法打开本地文件: %v", err)
    }
    defer localFile.Close()

    // 上传文件
    err = c.Stor(remoteFilePath, localFile)
    if err != nil {
        log.Fatalf("文件上传失败: %v", err)
    }

    fmt.Printf("文件 '%s' 已成功上传到 FTPS 服务器的 '%s'\n", localFilePath, remoteFilePath)

    // 清理示例本地文件
    os.Remove(localFilePath)
}