我正在使用go scp,并试图复制到solarwinds服务器(windows服务器(,但出现等待超时错误,而我尝试了命令行scp,它运行良好。
此外,我发现在删除err := a.Session.Run(fmt.Sprintf("%s -qt %q", a.RemoteBinary, remotePat)
行中的-q选项后在go scp库中的CopyPassThru
函数中,没有等待超时错误,但远程服务器上的文件为空
我无法通过命令行SSH到solarwinds服务器。
代码剪切如下
package main
import (
"fmt"
scp "github.com/bramvdbogaerde/go-scp"
"golang.org/x/crypto/ssh"
"os"
"strings"
"time"
)
func main() {
// Use SSH key authentication from the auth package
// we ignore the host key in this example, please change this if you use this library
// create ssh client config
var authParam ssh.AuthMethod
authParam = ssh.Password("1234")
clientConfig := &ssh.ClientConfig{
User: "admin",
Auth: []ssh.AuthMethod{
authParam,
},
HostKeyCallback: ssh.InsecureIgnoreHostKey(),
Timeout:time.Minute,
}
// For other authentication methods see ssh.ClientConfig and ssh.AuthMethod
// Create a new SCP client
client := scp.NewClient("10.154.92.32:22", clientConfig)
// Connect to the remote server
err := client.Connect()
if err != nil {
fmt.Println("Couldn't establish a connection to the remote server ", err)
return
}
// Close client connection after the file has been copied
defer client.Close()
// Finally, copy the file over
// Usage: CopyFile(fileReader, remotePath, permission)
fileString := "testing n"
myReader := strings.NewReader(fileString)
err = client.CopyFile(myReader, "/test", "0777")
if err != nil {
fmt.Println("Error while copying file ", err)
}
}
对于任何对scp
包有问题的人(我也有问题(,这是一个使用cat
传输单个文件的解决方案。它只使用ssh
包。
这个想法是使用没有参数的cat从标准输入中读取。在会话对象中,我们提供本地文件作为标准输入。然后,我们用>
将cat的输出管道传输到所需的文件。
相反的方式类似,这次我们截取会话对象的标准输出。我们对远程文件进行cat操作,并将会话的标准输出复制到本地文件中。
这是代码:
package main
import (
"bytes"
"errors"
"os"
"golang.org/x/crypto/ssh"
)
func main() {
config := &ssh.ClientConfig{
HostKeyCallback: ssh.InsecureIgnoreHostKey(),
User: "user",
Auth: []ssh.AuthMethod{ssh.Password("password")},
}
client, err := ssh.Dial("tcp", "10.0.0.1:22", config)
if err != nil {
panic(err)
}
defer client.Close()
err = setFile(client, "local/file", "remote/file")
if err != nil {
panic(err)
}
err = getFile(client, "remote/file", "local/file")
if err != nil {
panic(err)
}
}
func setFile(client *ssh.Client, from, to string) error {
f, err := os.Open(from)
if err != nil {
return err
}
defer f.Close()
session, err := client.NewSession()
if err != nil {
return err
}
defer session.Close()
session.Stdin = f
var stderr bytes.Buffer
session.Stderr = &stderr
err = session.Run("cat > '" + to + "'")
if err != nil && stderr.Len() > 0 {
err = errors.New(err.Error() + ": " + string(stderr.Bytes()))
}
return err
}
func getFile(client *ssh.Client, from, to string) error {
f, err := os.Create(to)
if err != nil {
return err
}
defer f.Close()
session, err := client.NewSession()
if err != nil {
return err
}
defer session.Close()
session.Stdout = f
var stderr bytes.Buffer
session.Stderr = &stderr
err = session.Run("cat '" + from + "'")
if err != nil && stderr.Len() > 0 {
err = errors.New(err.Error() + ": " + string(stderr.Bytes()))
}
return err
}