Golang SSH客户端：实现远程命令执行与输入输出管理

go get golang.org/x/crypto/ssh

import (
    "bytes"
    "fmt"
    "log"

    "golang.org/x/crypto/ssh"
)

func main() {
    // 配置SSH客户端
    config := &ssh.ClientConfig{
        User: "username", // 替换为你的SSH用户名
        Auth: []ssh.AuthMethod{
            ssh.Password("yourpassword"), // 替换为你的SSH密码
        },
        // InsecureIgnoreHostKey 仅用于开发和测试，生产环境中应使用 ssh.FixedHostKey 或 ssh.HostKeyCallback
        // 验证远程主机的密钥以防止中间人攻击。
        HostKeyCallback: ssh.InsecureIgnoreHostKey(), 
    }

    // 远程服务器地址和端口
    addr := "yourserver.com:22" // 替换为你的SSH服务器地址和端口

    // 拨号建立SSH连接
    client, err := ssh.Dial("tcp", addr, config)
    if err != nil {
        log.Fatalf("无法连接到SSH服务器: %v", err)
    }
    defer client.Close() // 确保连接在使用完毕后关闭

    // ... 后续操作
}

    // ... (接上面的main函数代码)

    // 创建一个新的SSH会话
    session, err := client.NewSession()
    if err != nil {
        log.Fatalf("无法创建SSH会话: %v", err)
    }
    defer session.Close() // 确保会话在使用完毕后关闭

    // 配置会话的输出捕获
    var stdoutBuf bytes.Buffer
    var stderrBuf bytes.Buffer
    session.Stdout = &stdoutBuf
    session.Stderr = &stderrBuf

    // 执行远程命令
    command := "/usr/bin/whoami" // 你想在远程服务器上执行的命令
    if err := session.Run(command); err != nil {
        log.Fatalf("远程命令执行失败: %v", err)
    }

    // 打印命令的输出
    fmt.Printf("命令 '%s' 的标准输出:\n%s", command, stdoutBuf.String())
    if stderrBuf.Len() > 0 {
        fmt.Printf("命令 '%s' 的标准错误:\n%s", command, stderrBuf.String())
    }
}

package main

import (
    "bytes"
    "fmt"
    "log"
    "os"

    "golang.org/x/crypto/ssh"
)

func main() {
    // SSH连接配置
    config := &ssh.ClientConfig{
        User: "your_username", // 替换为你的SSH用户名
        Auth: []ssh.AuthMethod{
            ssh.Password("your_password"), // 替换为你的SSH密码
        },
        // 警告：InsecureIgnoreHostKey() 会跳过主机密钥验证，存在安全风险。
        // 在生产环境中，应使用 ssh.FixedHostKey 或从 known_hosts 文件加载主机密钥。
        HostKeyCallback: ssh.InsecureIgnoreHostKey(), 
        // 设置超时，防止长时间阻塞
        Timeout: 10 * time.Second, 
    }

    // 远程服务器地址和端口
    addr := "your_server_ip_or_domain:22" // 替换为你的SSH服务器地址和端口

    fmt.Printf("尝试连接到SSH服务器: %s...\n", addr)

    // 拨号建立SSH连接
    client, err := ssh.Dial("tcp", addr, config)
    if err != nil {
        log.Fatalf("无法连接到SSH服务器 %s: %v", addr, err)
    }
    defer client.Close() // 确保连接在使用完毕后关闭

    fmt.Println("SSH连接成功。")

    // 创建一个新的SSH会话
    session, err := client.NewSession()
    if err != nil {
        log.Fatalf("无法创建SSH会话: %v", err)
    }
    defer session.Close() // 确保会话在使用完毕后关闭

    // 配置会话的输出捕获
    var stdoutBuf bytes.Buffer
    var stderrBuf bytes.Buffer
    session.Stdout = &stdoutBuf
    session.Stderr = &stderrBuf

    // 定义要执行的远程命令
    command := "/usr/bin/whoami" // 例如，获取当前远程用户

    fmt.Printf("在远程服务器上执行命令: '%s'\n", command)

    // 执行远程命令
    if err := session.Run(command); err != nil {
        log.Fatalf("远程命令 '%s' 执行失败: %v", command, err)
    }

    // 打印命令的输出
    fmt.Printf("--- 命令标准输出 ---\n%s", stdoutBuf.String())
    if stderrBuf.Len() > 0 {
        fmt.Printf("--- 命令标准错误 ---\n%s", stderrBuf.String())
    }
    fmt.Println("命令执行完毕。")
}