新闻中心
Go SSH与Cisco设备通信:Pty配置优化解决长命令发送问题

本文详细阐述了使用go语言ssh库连接cisco设备时,发送长命令可能出现的截断问题及其解决方案。通过分析go ssh `requestpty` 函数的参数配置,揭示了终端宽度设置不当是导致命令被错误分割的根本原因,并提供了正确的pty尺寸配置方法,确保长命令能够完整无误地发送和执行。
使用Go SSH库连接Cisco设备
在使用Go语言进行网络设备自动化管理时,SSH是与Cisco等设备交互的常用协议。通常,我们需要通过SSH建立连接,然后模拟终端会话,发送show命令来获取设备状态或配置信息。Go的golang.org/x/crypto/ssh库提供了强大的功能来实现这一点。
一个典型的SSH连接及会话建立流程如下:
- 配置SSH客户端: 设置用户名、认证方式(密码或密钥)、主机密钥回调等。
- 建立连接: 使用ssh.Dial函数连接到目标设备。
- 创建会话: 从客户端创建新的SSH会话。
- 获取I/O管道: 获取会话的标准输入(StdinPipe)和标准输出(StdoutPipe),用于发送命令和接收响应。
- 请求伪终端(PTY): 这是模拟交互式终端的关键步骤,它定义了终端类型、尺寸等。
- 启动Shell: 在会话中启动一个远程Shell。
以下是Go语言实现这些步骤的基本代码结构:
package main
import (
"fmt"
"io"
"log"
"strings"
"time"
"golang.org/x/crypto/ssh"
)
// readUntilPrompt 从SSH输出中读取数据直到遇到指定提示符
func readUntilPrompt(reader io.Reader, prompt string) (string, error) {
var output strings.Builder
buf := make([]byte, 1024)
for {
n, err := reader.Read(buf)
if err != nil {
return "", fmt.Errorf("error reading from sshOut: %v", err)
}
output.Write(buf[:n])
if strings.Contains(output.String(), prompt) {
break
}
}
return output.String(), nil
}
func main() {
// 1. SSH配置
config := &ssh.ClientConfig{
User: "your_username",
Auth: []ssh.AuthMethod{
ssh.Password("your_password"),
},
HostKeyCallback: ssh.InsecureHostKeyCallback, // 生产环境请使用更安全的HostKeyCallback
Timeout: 5 * time.Second,
}
// 2. 建立SSH连接
client, err := ssh.Dial("tcp", "172.16.32.95:22", config)
if err != nil {
log.Fatalf("Failed to dial: %v", err)
}
defer client.Close()
// 3. 创建新的会话
session, err := client.NewSession()
if err != nil {
log.Fatalf("Failed to create session: %v", err)
}
defer session.Close()
// 4. 获取标准输入输出管道
sshOut, err := session.StdoutPipe()
if err != nil {
log.Fatalf("Failed to get stdout pipe: %v", err)
}
sshIn, err := session.StdinPipe()
if err != nil {
log.Fatalf("Failed to get stdin pipe: %v", err)
}
// 5. 请求伪终端 (PTY) - 初始配置(可能导致问题)
modes := ssh.TerminalModes{
ssh.ECHO: 0, // 禁用回显
ssh.TTY_OP_ISPEED: 14400, // input speed = 14.4kbaud
ssh.TTY_OP_OSPEED: 14400, // output speed = 14.4kbaud
}
// 注意:这里的 width 参数可能过小
if err := session.RequestPty("xterm", 80, 40, modes); err != nil { // height=80, width=40
log.Fatalf("Request for pseudo terminal failed: %v", err)
}
// 6. 启动Shell
if err := session.Shell(); err != nil {
log.Fatalf("Failed to start shell: %v", err)
}
// 读取初始欢迎信息和提示符
initialOutput, err := readUntilPrompt(sshOut, "[local]ewag#")
if err != nil {
log.Fatalf("Failed to read initial prompt: %v", err)
}
fmt.Println("--- Initial Output ---")
fmt.Println(initialOutput)
// 发送短命令示例
commandShort := "show clock\r"
fmt.Printf("--- Sending command: %s ---\n", strings.TrimSpace(commandShort))
if _, err := sshIn.Write([]byte(commandShort)); err != nil {
log.Fatalf("Failed to write command: %v", err)
}
responseShort, err := readUntilPrompt(sshOut, "[local]ewag#")
if err != nil {
log.Fatalf("Failed to read short command response: %v", err)
}
fmt.Println(responseShort)
// ... 更多操作 ...
}在上述代码中,session.RequestPty("xterm", 80, 40, modes)这行代码是关键,它请求一个伪终端,并指定了终端类型为xterm,高度为80行,宽度为40列。
长命令截断问题
当使用上述配置发送较短的命令(例如show clock)时,通常不会出现问题,命令能够被完整执行并返回结果。然而,当尝试发送一个较长的命令时,例如show session progress ipsg-service ipsg-gprs-svc,可能会观察到命令在远程设备上被意外截断,导致设备识别为未知命令或语法错误。
以下是截断问题的典型输出示例:
Last login: Tue Jan 14 18:09:19 -0500 2014 on pts/2 from 10.7.7.14. Cisco Systems SSI [local]ewag# show session progress ipsg -service ipsg-gprs-svc Unknown command - "ipsg-service", unrecognized keyword [local]ewag#
从输出中可以看出,发送的命令show session progress ipsg-service ipsg-gprs-svc在ipsg之后被分割成了两部分。这使得Cisco设备无法正确识别完整的命令,从而报错。
问题根源:PTY宽度配置不当
这个问题的根本原因在于session.RequestPty函数中伪终端的宽度(width)参数设置过小。session.RequestPty函数的签名是RequestPty(term string, h, w int, termmodes TerminalModes),其中h代表终端高度,w代表终端宽度。
小云雀
剪映出品的AI视频和图片创作助手
1949
查看详情
当我们将终端宽度设置为一个较小的值(例如40列)时,Go SSH库在模拟终端行为时,可能会在客户端侧对发送的命令进行“换行”处理,以适应这个较小的终端宽度。这意味着,即使我们通过sshIn.Write发送了一个完整的长字符串,SSH客户端在将其传输到远程服务器之前,可能已经根据PTY的宽度限制将其分割成了多行。远程Cisco设备接收到的就是这些被分割的命令片段,而不是一个完整的命令。
解决方案:优化PTY宽度配置
解决这个问题的关键是确保为伪终端配置一个足够大的宽度,或者让远程服务器决定其宽度。
根据实际测试,将PTY宽度设置为一个较大的值(例如200),同时可以将高度设置为0(让服务器决定或使用默认值),可以有效解决命令截断问题。
将原有的Pty请求:
if err := session.RequestPty("xterm", 80, 40, modes); err != nil { // height=80, width=40
log.Fatalf("Request for pseudo terminal failed: %v", err)
}修改为:
// 正确配置:增加宽度,将高度设置为0
if err := session.RequestPty("vt100", 0, 200, modes); err != nil { // height=0, width=200
log.Fatalf("Request for pseudo terminal failed: %v", err)
}修改后的代码片段:
// ... (之前的连接和会话建立代码) ...
// 重新配置并启动会话以应用新的PTY配置
// 注意:PTY只能请求一次,如果要在同一会话中更改,需要重新创建会话或连接
// 假设这里是为了演示,我们重新创建了一个会话
sessionFixed, err := client.NewSession() // 使用同一个client
if err != nil {
log.Fatalf("Failed to create new session for fix: %v", err)
}
defer sessionFixed.Close()
sshOutFixed, err := sessionFixed.StdoutPipe()
if err != nil {
log.Fatalf("Failed to get stdout pipe for fix: %v", err)
}
sshInFixed, err := sessionFixed.StdinPipe()
if err != nil {
log.Fatalf("Failed to get stdin pipe for fix: %v", err)
}
// 优化以上就是Go SSH与Cisco设备通信:Pty配置优化解决长命令发送问题的详细内容,更多请关注其它相关文章!
# 较小
# 游戏网站建设优化推广
# 揭阳小企业网站推广平台
# seo爆款多少分及格
# 厦门抖音seo排名推广
# 网站建设销售实训报告
# 滨州抖音seo服务
# 江门短视频营销推广的
# 开源网站推广方案
# 淘宝seo证据链
# 大余包装厂网络营销推广
# 这是
# 是一个
# 根本原因
# word
# 将其
# 成了
# 客户端
# 转换为
# 设置为
# 文档
# crypto
# ai
# session
# go语言
# golang
# go
相关栏目:
【
科技资讯46185 】
【
网络学院92790 】
相关推荐:
PySpark中高效提取字符串右侧可变长度数字:使用regexp_extract
必由学官方登录入口 必由学教师学生账号快速访问
MAC怎么在地图App里使用“四处看看”_MAC体验部分城市的3D实景街景
Python自定义类排序:解决lambda键值访问TypeError的实践指南
消息称三星明年 2 月正式发布 HBM4,与 SK 海力士同台竞技
mysql密码锁定怎么解锁_mysql密码锁定解锁后修改密码步骤
Bing引擎入口最新2025 Bing搜索免费官方登录
如何使用 Excel 发布器与 Power BI 分享 Excel 洞察
必由学官方网站入口 必由学学生教师共用登录通道
Python异步编程实践:使用Binance API构建实时交易数据流
J*aScript map 方法中处理循环元素为空数组的策略
c++ 命名空间怎么用 c++ namespace使用指南
铁路12306卧铺选择攻略 铁路12306下铺座位预定技巧
最新韩小圈网页版登录入口_官网在线观看官方链接
提升Kafka消费者健壮性:会话超时处理与消息处理语义
Go语言中JSON数据解析与字段访问教程
Tabulator表格日期时间排序问题及自定义解决方案
谷歌浏览器浏览体验优化_谷歌浏览器新版直连永久可用提示
顺丰快件物流信息 官方网站查询入口
J*aScript设计模式实践_j*ascript代码优化
Mac怎么锁定备忘录_Mac备忘录加密设置教程
Excel Power Pivot如何处理XML数据源 构建高级数据模型
优化Log4j2控制台输出性能:解决异步日志瓶颈
文心一言怎样用批量生成做多版文案_文心一言用批量生成做多版文案【批量创作】
React Router 嵌套组件中 URL 重定向问题的解决方案
黑鲨3Pro怎样在相册开漫画风滤镜_iPhone黑鲨3Pro相册开漫画风滤镜【趣味滤镜】
处理动态列数据:J*a ArrayList的正确初始化与字符累加教程
解决 Express.js 中 PUT 请求密码修改失败的路由配置指南
Spring Boot嵌入式服务器与J*a EE:功能支持深度解析
NVIDIA股价11月重挫12%:下月有望好转 但难回5万亿美元巅峰
机构:以往存储涨价周期小米利润率实际上有所改善 能转嫁给消费者等
从J*aScript对象中精确提取指定属性的教程
AWS EC2实例间SQL Server连接超时:安全组配置与故障排除指南
漫蛙Manwa2官网入口地址分享 漫蛙漫画PC版永久访问通道
c++如何使用chrono库处理时间_c++标准库时间与日期操作
TikTok搜索不到用户发布内容怎么办 TikTok用户内容搜索优化方法
Angular响应式表单:实现提交后表单及按钮的禁用与只读化
在Typer应用中优雅地处理和重组任意命令行参数
composer 和 npm/yarn 在管理依赖方面有什么核心思想差异?
EMS快递官网app_中国邮政速递物流手机客户端
向日葵客户端怎么进行远程CentOS控制_向日葵客户端远程CentOS控制操作教程
Django表单提交验证失败后保持字段值不刷新
地铁跑酷免费秒玩入口链接 地铁跑酷小游戏免费秒玩网站
现代化 SciPy 一维插值:interp1d 的替代方案与最佳实践
谷歌浏览器怎么给标签页静音_Chrome标签静音快捷操作
如何使用Node.js csv 包按条件移除含空字段的CSV记录
Django AJAX 文件上传教程:解决图片无法保存到模型的常见问题
Pygame教程:解决用户输入与游戏状态更新不同步问题
蛙漫画网页版全站入口 蛙漫热门作品免费浏览
Yandex搜索引擎官方地址 俄罗斯网络世界的主要入口


2025-11-19
浏览次数:次
返回列表
User: "your_username",
Auth: []ssh.AuthMethod{
ssh.Password("your_password"),
},
HostKeyCallback: ssh.InsecureHostKeyCallback, // 生产环境请使用更安全的HostKeyCallback
Timeout: 5 * time.Second,
}
// 2. 建立SSH连接
client, err := ssh.Dial("tcp", "172.16.32.95:22", config)
if err != nil {
log.Fatalf("Failed to dial: %v", err)
}
defer client.Close()
// 3. 创建新的会话
session, err := client.NewSession()
if err != nil {
log.Fatalf("Failed to create session: %v", err)
}
defer session.Close()
// 4. 获取标准输入输出管道
sshOut, err := session.StdoutPipe()
if err != nil {
log.Fatalf("Failed to get stdout pipe: %v", err)
}
sshIn, err := session.StdinPipe()
if err != nil {
log.Fatalf("Failed to get stdin pipe: %v", err)
}
// 5. 请求伪终端 (PTY) - 初始配置(可能导致问题)
modes := ssh.TerminalModes{
ssh.ECHO: 0, // 禁用回显
ssh.TTY_OP_ISPEED: 14400, // input speed = 14.4kbaud
ssh.TTY_OP_OSPEED: 14400, // output speed = 14.4kbaud
}
// 注意:这里的 width 参数可能过小
if err := session.RequestPty("xterm", 80, 40, modes); err != nil { // height=80, width=40
log.Fatalf("Request for pseudo terminal failed: %v", err)
}
// 6. 启动Shell
if err := session.Shell(); err != nil {
log.Fatalf("Failed to start shell: %v", err)
}
// 读取初始欢迎信息和提示符
initialOutput, err := readUntilPrompt(sshOut, "[local]ewag#")
if err != nil {
log.Fatalf("Failed to read initial prompt: %v", err)
}
fmt.Println("--- Initial Output ---")
fmt.Println(initialOutput)
// 发送短命令示例
commandShort := "show clock\r"
fmt.Printf("--- Sending command: %s ---\n", strings.TrimSpace(commandShort))
if _, err := sshIn.Write([]byte(commandShort)); err != nil {
log.Fatalf("Failed to write command: %v", err)
}
responseShort, err := readUntilPrompt(sshOut, "[local]ewag#")
if err != nil {
log.Fatalf("Failed to read short command response: %v", err)
}
fmt.Println(responseShort)
// ... 更多操作 ...
}