使用 Go SSH 库与 Cisco 设备交互：解决长命令截断问题

package main

import (
    "fmt"
    "io"
    "log"
    "strings"
    "time"

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

// SSH配置，实际应用中应从安全方式获取
var config = &ssh.ClientConfig{
    User: "your_username",
    Auth: []ssh.AuthMethod{
        ssh.Password("your_password"),
    },
    HostKeyCallback: ssh.InsecureIgnoreHostKey(), // 生产环境请使用ssh.FixedHostKey或ssh.KnownHosts
    Timeout:         10 * time.Second,
}

func main() {
    // 1. 建立SSH连接
    client, err := ssh.Dial("tcp", "172.16.32.95:22", config)
    if err != nil {
        log.Fatalf("无法连接SSH服务器: %v", err)
    }
    defer client.Close()

    // 2. 创建新的会话
    session, err := client.NewSession()
    if err != nil {
        log.Fatalf("无法创建SSH会话: %v", err)
    }
    defer session.Close()

    // 3. 获取标准输入和标准输出管道
    sshOut, err := session.StdoutPipe()
    if err != nil {
        log.Fatalf("无法获取StdoutPipe: %v", err)
    }
    sshIn, err := session.StdinPipe()
    if err != nil {
        log.Fatalf("无法获取StdinPipe: %v", err)
    }

    // 4. 请求一个伪终端 (PTY)
    // 注意：这里的Pty尺寸是解决问题的关键
    modes := ssh.TerminalModes{
        ssh.ECHO:          0,     // 禁用回显
        ssh.TTY_OP_ISPEED: 14400, // 输入速度
        ssh.TTY_OP_OSPEED: 14400, // 输出速度
    }
    // 初始的错误配置可能类似这样：session.RequestPty("vt100", 80, 40, modes)
    // 正确的配置将在后续章节详细说明
    err = session.RequestPty("vt100", 0, 200, modes) // 示例中正确的配置
    if err != nil {
        log.Fatalf("无法请求PTY: %v", err)
    }

    // 5. 启动Shell
    if err = session.Shell(); err != nil {
        log.Fatalf("无法启动Shell: %v", err)
    }

    // 6. 读取初始欢迎信息和等待命令提示符
    readUntilPrompt(sshOut, "[local]ewag# ") // 假设提示符是 "[local]ewag#"

    // 7. 发送命令并读取响应 (示例：发送短命令)
    fmt.Println("发送短命令: show clock")
    if _, err := sshIn.Write([]byte("show clock\r")); err != nil {
        log.Fatalf("无法写入命令: %v", err)
    }
    readUntilPrompt(sshOut, "[local]ewag# ")

    // 8. 尝试发送长命令 (这里会复现问题，如果PTY宽度设置不当)
    fmt.Println("\n发送长命令: show session progress ipsg-service ipsg-gprs-svc")
    longCommand := "show session progress ipsg-service ipsg-gprs-svc\r"
    if _, err := sshIn.Write([]byte(longCommand)); err != nil {
        log.Fatalf("无法写入长命令: %v", err)
    }
    readUntilPrompt(sshOut, "[local]ewag# ")

    fmt.Println("\n教程执行完毕。")
}

// readUntilPrompt 辅助函数，用于读取SSH输出直到遇到指定的命令提示符
func readUntilPrompt(r io.Reader, prompt string) string {
    buf := make([]byte, 1024)
    var sb strings.Builder
    for {
        n, err := r.Read(buf)
        if err != nil {
            if err == io.EOF {
                break
            }
            log.Printf("读取SSH输出错误: %v", err)
            break
        }
        chunk := string(buf[:n])
        sb.WriteString(chunk)
        fmt.Print(chunk) // 实时打印输出，便于观察
        if strings.Contains(sb.String(), prompt) {
            break
        }
        // 避免无限循环，如果长时间未收到提示符
        if sb.Len() > 4096 { // 限制缓冲大小
            log.Println("输出过长，可能未找到提示符或陷入循环。")
            break
        }
    }
    return sb.String()
}

[local]ewag#
show session progress ipsg
-service ipsg-gprs-svc
Unknown command - "ipsg-service", unrecognized keyword
[local]ewag#

// 错误的Pty配置示例：宽度过小
session.RequestPty("vt100", 80, 40, modes) // 这里将宽度(w)设为40

// 正确的Pty配置示例：提供足够大的宽度
err = session.RequestPty("vt100", 0, 200, modes) // 高度为0，宽度为200
if err != nil {
    log.Fatalf("无法请求PTY: %v", err)
}