本文介绍在 go 中通过 ssh 会话原生协议实现安全、可靠的 scp 文件上传，避免直接向子进程 stdin 写入密码导致的阻塞问题，并提供可生产使用的完整示例。
本文介绍在 go 中通过 ssh 会话原生协议实现安全、可靠的 scp 文件上传，避免直接向子进程 stdin 写入密码导致的阻塞问题，并提供可生产使用的完整示例。
在 Go 中调用外部 scp 命令并交互式输入密码看似简单，但实际极易失败——因为 scp（尤其是 OpenSSH 实现）默认从 控制终端（tty） 而非标准输入（stdin）读取密码，以防止密码泄露。因此，即使你成功获取了 cmd.StdinPipe() 并写入密码，scp 进程仍会阻塞等待终端输入，导致程序挂起。
✅ 正确方案：基于 golang.org/x/crypto/ssh 构建 SSH 会话，手动实现 SCP 协议
推荐做法是放弃调用外部 scp，转而使用官方维护的 golang.org/x/crypto/ssh 包建立 SSH 连接，并遵循 SCP 的“发送端协议”（-t 模式）完成文件传输。该方式完全绕过密码交互问题，支持密钥或密码认证（由 SSH 客户端库统一处理），且更安全、可控。
以下是一个健壮、可复用的实现：
import (
"fmt"
"io"
"os"
"path"
"golang.org/x/crypto/ssh"
)
func scpFile(filePath, destinationPath string, session *ssh.Session) error {
defer session.Close()
f, err := os.Open(filePath)
if err != nil {
return fmt.Errorf("failed to open source file %s: %w", filePath, err)
}
defer f.Close()
stat, err := f.Stat()
if err != nil {
return fmt.Errorf("failed to stat file %s: %w", filePath, err)
}
// 启动 goroutine 向 SCP 接收端（remote scp -t）写入协议数据
go func() {
w, err := session.StdinPipe()
if err != nil {
return // 外部 error 已由 session.Run 返回
}
defer w.Close()
// 发送 SCP 协议头：C<mode><size><filename>\n
// 注意：mode 需用八进制格式（如 0644 → %#o 输出为 644）
header := fmt.Sprintf("C%#o %d %s\n", stat.Mode().Perm(), stat.Size(), path.Base(filePath))
if _, err := io.WriteString(w, header); err != nil {
return
}
// 流式传输文件内容
if _, err := io.Copy(w, f); err != nil {
return
}
// 发送 EOF 标记（空字节）
w.Write([]byte{0})
}()
// 在远程执行 'scp -t <dest>' —— 启动接收模式
cmd := fmt.Sprintf("scp -t %s", destinationPath)
if err := session.Run(cmd); err != nil {
return fmt.Errorf("remote scp command failed: %w", err)
}
return nil
}</dest></filename></size></mode>
? 使用前提：构建带认证的 SSH Session
上述函数依赖已建立的 *ssh.Session。你需要先配置 ssh.ClientConfig（支持密码或私钥），再 Dial 并创建 Session：
config := &ssh.ClientConfig{
User: c.username,
Auth: []ssh.AuthMethod{
ssh.Password(c.password), // 或使用 ssh.PublicKeys(...)
},
HostKeyCallback: ssh.InsecureIgnoreHostKey(), // 生产环境请替换为真实验证逻辑
}
client, err := ssh.Dial("tcp", net.JoinHostPort(c.host, c.port), config)
if err != nil {
return err
}
defer client.Close()
session, err := client.NewSession()
if err != nil {
return err
}
defer session.Close()
⚠️ 注意事项与最佳实践
-
不要硬编码
InsecureIgnoreHostKey：生产环境必须校验服务器公钥（例如通过ssh.FixedHostKey或自定义回调）。 -
权限与路径安全：确保
destinationPath经过严格校验，避免路径遍历（如../）。 -
大文件处理：
io.Copy默认缓冲，对超大文件建议显式设置bufio.Writer提升性能。 -
错误传播：goroutine 中的写入错误无法直接返回，需结合
session.Wait()或上下文超时增强可观测性。 -
替代方案：若仅需简单文件传输，也可考虑
github.com/pkg/sftp库，它封装了更高级的 SFTP API，比手动 SCP 协议更易维护。
该方案彻底规避了子进程 stdin 交互陷阱，将认证与传输解耦，符合 Go 的云原生工程实践——用库代替 shell 脚本，用类型安全代替字符串拼接。
