我正在try 使用golang.org/x/crypto/ssh建立SSH连接，我有点惊讶的是，我似乎找不到如何使NewSession函数超时的方法(实际上，我没有看到任何方法来超时任何东西).当我try 连接到出现问题的服务器时，它会挂起很长一段时间.我已经写了一些使用select和time.After的东西，但感觉就像是黑客攻击.我还没有try 的一件事是将底层的net.Conn保留在我的 struct 中，并继续执行Conn.SetDeadline()个调用.我还没有try 过这一点，因为我不知道crypto/ssh库是否覆盖了这个或类似的东西.
有没有人有好办法让这个库停用的服务器超时？或者有没有人知道更好的图书馆？
使用ssh包透明地处理这个问题的一种方法是，通过定制的net.Conn创建一个空闲超时的连接，为您设置截止日期.然而，这将导致连接上的后台读取超时，因此我们需要使用ssh keepalives来保持连接打开.根据您的使用情况，简单地使用ssh keepalives作为死机连接的alert 可能就足够了.
// Conn wraps a net.Conn, and sets a deadline for every read
// and write operation.
type Conn struct {
net.Conn
ReadTimeout time.Duration
WriteTimeout time.Duration
}
func (c *Conn) Read(b []byte) (int, error) {
err := c.Conn.SetReadDeadline(time.Now().Add(c.ReadTimeout))
if err != nil {
return 0, err
}
return c.Conn.Read(b)
}
func (c *Conn) Write(b []byte) (int, error) {
err := c.Conn.SetWriteDeadline(time.Now().Add(c.WriteTimeout))
if err != nil {
return 0, err
}
return c.Conn.Write(b)
}
然后，你可以使用net.DialTimeout或net.Dialer来获得连接，将其包装在带有超时的Conn中，然后将其传递到ssh.NewClientConn.
func SSHDialTimeout(network, addr string, config *ssh.ClientConfig, timeout time.Duration) (*ssh.Client, error) {
conn, err := net.DialTimeout(network, addr, timeout)
if err != nil {
return nil, err
}
timeoutConn := &Conn{conn, timeout, timeout}
c, chans, reqs, err := ssh.NewClientConn(timeoutConn, addr, config)
if err != nil {
return nil, err
}
client := ssh.NewClient(c, chans, reqs)
// this sends keepalive packets every 2 seconds
// there's no useful response from these, so we can just abort if there's an error
go func() {
t := time.NewTicker(2 * time.Second)
defer t.Stop()
for range t.C {
_, _, err := client.Conn.SendRequest("keepalive@golang.org", true, nil)
if err != nil {
return
}
}
}()
return client, nil
}