请教一个 golang 连接 ssh 的问题

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

The Go Programming Language

? http://golang.org/

? Go Playground

Go Projects

? Revel Web Framework

（腾讯云最新优惠活动来了：云产品限时1折，云服务器低至88元/年，点击这里立即抢购：9i0i.cn/qcloud，更有2860元代金券免费领取，付款直接抵现金用，点击这里立即领取：9i0i.cn/qcloudquan）

（福利推荐：你还在原价购买阿里云服务器？现在阿里云0.8折限时抢购活动来啦！4核8G企业云服务器仅2998元/3年，立即抢购>>>：9i0i.cn/aliyun）

首先需求是调用 ssh 访问腾讯云云实例执行 A 脚本，然后对此云实例进行重启，开机完成后再执行 B 脚本。从执行 A ，重启到开机都没有问题，但是在执行 B 脚本前新建 session 时，调用 client.NewSession()方法一直返回 error:EOF ，实在是定位不到问题，求大佬指教。

我的 ssh 连接逻辑抽取的方法：

func SSHConnect(host string) (*ssh.Client, error) {
    var (
       addr         string
       clientConfig *ssh.ClientConfig
       client       *ssh.Client
       err          error
    )

    homePath, err := os.UserHomeDir()
    if err != nil {
       return nil, err
    }
    key, err := ioutil.ReadFile(path.Join(homePath, ".ssh", "id_rsa"))
    zap.L().Info("key", zap.String("path", path.Join(homePath, ".ssh", "id_rsa")))
    if err != nil {
       return nil, err
    }
    signer, err := ssh.ParsePrivateKey(key)
    if err != nil {
       return nil, err
    }

    clientConfig = &ssh.ClientConfig{
       User: "root",
       Auth: []ssh.AuthMethod{
          ssh.PublicKeys(signer),
       },
       Timeout:         30 * time.Second,
       HostKeyCallback: ssh.InsecureIgnoreHostKey(),
    }

    // connect to ssh
    addr = fmt.Sprintf("%s:%d", host, 22)

    if client, err = ssh.Dial("tcp", addr, clientConfig); err != nil {
       //err = errors.Wrapf(err, "")
       return nil, err
    }

    return client, nil
}

调用 ssh 执行脚本 A：

var connectShut *ssh.Client
var sessionShut *ssh.Session
connectShut, err = util.SSHConnect(*ip[0])
if err != nil {
    zap.L().Error("mysqlToggleWorker SSHConnect error", zap.Error(err), zap.Any("ip", *ip[0]))
    return err
}
sessionShut, err = connectShut.NewSession()
if err != nil {
    zap.L().Error("mysqlToggleWorker NewSession error", zap.Error(err), zap.Any("ip", *ip[0]))
    return err
}
shCommand := "sh " + shPath
output, err := sessionShut.CombinedOutput(shCommand)
if err != nil {
    zap.L().Error("mysqlToggleWorker Run error", zap.Error(err), zap.Any("ip", *ip[0]), 
    zap.Any("shCommand", shCommand), zap.String("result", string(output)))
}
err = sessionShut.Close()
if err != nil || err != io.EOF {
    zap.L().Error("mysqlToggleWorker sessionShut.Close() error", zap.Error(err), zap.Any("ip", *ip[0]))
}
err = connectShut.Close()
if err != nil {
    zap.L().Error("mysqlToggleWorker connectShut.Close() error", zap.Error(err), zap.Any("ip", *ip[0]))
}

省略重启的过程，下面开始调用脚本 B：

var connectStart *ssh.Client
var sessionStart *ssh.Session
connectStart, err = util.SSHConnect(*ip[0])
sessionStart, err = connectStart.NewSession()
if err != nil {
    zap.L().Error("mysqlToggleWorker DescribeInstancesStatus error", zap.Error(err), zap.Any("ip", *ip[0]))
    return err
}

此时返回的 err 为：{"error": "EOF", "ip": "10.1.0.1"}
百思不得其解，求大佬指教～

8 条回复 ? 2024-03-28 17:59:50 +08:00