使用go語言的第三方包：github.com/pkg/sftp和golang.org/x/crypto/ssh實現文件和文件夾傳輸。
1、創建connect方法：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
func connect(user, password, host string, port int) (*sftp.Client, error) { var ( auth []ssh.AuthMethod addr string clientConfig *ssh.ClientConfig sshClient *ssh.Client sftpClient *sftp.Client err error ) // get auth method auth = make([]ssh.AuthMethod, 0) auth = append(auth, ssh.Password(password)) clientConfig = &ssh.ClientConfig{ User: user, Auth: auth, Timeout: 30 * time.Second, HostKeyCallback: ssh.InsecureIgnoreHostKey(), //ssh.FixedHostKey(hostKey), } // connet to ssh addr = fmt.Sprintf("%s:%d", host, port) if sshClient, err = ssh.Dial("tcp", addr, clientConfig); err != nil { return nil, err } // create sftp client if sftpClient, err = sftp.NewClient(sshClient); err != nil { return nil, err } return sftpClient, nil} |
2、上傳文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
func uploadFile(sftpClient *sftp.Client, localFilePath string, remotePath string) { srcFile, err := os.Open(localFilePath) if err != nil { fmt.Println("os.Open error : ", localFilePath) log.Fatal(err) } defer srcFile.Close() var remoteFileName = path.Base(localFilePath) dstFile, err := sftpClient.Create(path.Join(remotePath, remoteFileName)) if err != nil { fmt.Println("sftpClient.Create error : ", path.Join(remotePath, remoteFileName)) log.Fatal(err) } defer dstFile.Close() ff, err := ioutil.ReadAll(srcFile) if err != nil { fmt.Println("ReadAll error : ", localFilePath) log.Fatal(err) } dstFile.Write(ff) fmt.Println(localFilePath + " copy file to remote server finished!")} |
3、上傳文件夾
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
func uploadDirectory(sftpClient *sftp.Client, localPath string, remotePath string) { localFiles, err := ioutil.ReadDir(localPath) if err != nil { log.Fatal("read dir list fail ", err) } for _, backupDir := range localFiles { localFilePath := path.Join(localPath, backupDir.Name()) remoteFilePath := path.Join(remotePath, backupDir.Name()) if backupDir.IsDir() { sftpClient.Mkdir(remoteFilePath) uploadDirectory(sftpClient, localFilePath, remoteFilePath) } else { uploadFile(sftpClient, path.Join(localPath, backupDir.Name()), remotePath) } } fmt.Println(localPath + " copy directory to remote server finished!")} |
4、上傳測試
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
func DoBackup(host string, port int, userName string, password string, localPath string, remotePath string) { var ( err error sftpClient *sftp.Client ) start := time.Now() sftpClient, err = connect(userName, password, host, port) if err != nil { log.Fatal(err) } defer sftpClient.Close() _, errStat := sftpClient.Stat(remotePath) if errStat != nil { log.Fatal(remotePath + " remote path not exists!") } backupDirs, err := ioutil.ReadDir(localPath) if err != nil { log.Fatal(localPath + " local path not exists!") } uploadDirectory(sftpClient, localPath, remotePath) elapsed := time.Since(start) fmt.Println("elapsed time : ", elapsed)} |
補充：go實現ssh遠程機器并傳輸文件
核心依賴包：
golang.org/x/crypto/ssh
github.com/pkg/sftp
其中golang.org/x/crypto/ssh 可從github上下載，
下載地址：https://github.com/golang/crypto
ssh連接源碼（這里是根據秘鑰連接）:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
var keypath = "key/id_rsa"//獲取秘鑰func publicKey(path string) ssh.AuthMethod { keypath, err := homedir.Expand(path) if err != nil { fmt.Println("獲取秘鑰路徑失敗", err) } key, err1 := ioutil.ReadFile(keypath) if err1 != nil { fmt.Println("讀取秘鑰失敗", err1) } signer, err2 := ssh.ParsePrivateKey(key) if err2 != nil { fmt.Println("ssh 秘鑰簽名失敗", err2) } return ssh.PublicKeys(signer)}//獲取ssh連接func GetSSHConect(ip, user string, port int) (*ssh.Client) { con := &ssh.ClientConfig{ User: user, Auth: []ssh.AuthMethod{publicKey(keypath)}, HostKeyCallback: func(hostname string, remote net.Addr, key ssh.PublicKey) error { return nil }, } addr := fmt.Sprintf("%s:%d", ip, port) client, err := ssh.Dial("tcp", addr, con) if err != nil { fmt.Println("Dail failed: ", err) panic(err) } return client}// 遠程執行腳本func Exec_Task(ip, user, localpath, remotepath string) int { port := 22 client := GetSSHConect(ip, user, port) UploadFile(ip, user, localpath, remotepath, port) session, err := client.NewSession() if err != nil { fmt.Println("創建會話失敗", err) panic(err) } defer session.Close() remoteFileName := path.Base(localpath) dstFile := path.Join(remotepath, remoteFileName) err1 := session.Run(fmt.Sprintf("/usr/bin/sh %s", dstFile)) if err1 != nil { fmt.Println("遠程執行腳本失敗", err1) return 2 } else { fmt.Println("遠程執行腳本成功") return 1 }} |
文件傳輸功能：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
//獲取ftp連接func getftpclient(client *ssh.Client) (*sftp.Client) { ftpclient, err := sftp.NewClient(client) if err != nil { fmt.Println("創建ftp客戶端失敗", err) panic(err) } return ftpclient}//上傳文件func UploadFile(ip, user, localpath, remotepath string, port int) { client := GetSSHConect(ip, user, port) ftpclient := getftpclient(client) defer ftpclient.Close() remoteFileName := path.Base(localpath) fmt.Println(localpath, remoteFileName) srcFile, err := os.Open(localpath) if err != nil { fmt.Println("打開文件失敗", err) panic(err) } defer srcFile.Close() dstFile, e := ftpclient.Create(path.Join(remotepath, remoteFileName)) if e != nil { fmt.Println("創建文件失敗", e) panic(e) } defer dstFile.Close() buffer := make([]byte, 1024) for { n, err := srcFile.Read(buffer) if err != nil { if err == io.EOF { fmt.Println("已讀取到文件末尾") break } else { fmt.Println("讀取文件出錯", err) panic(err) } } dstFile.Write(buffer[:n]) //注意，由于文件大小不定，不可直接使用buffer，否則會在文件末尾重復寫入，以填充1024的整數倍 } fmt.Println("文件上傳成功")}//文件下載func DownLoad(ip, user, localpath, remotepath string, port int) { client := GetSSHConect(ip, user, port) ftpClient := getftpclient(client) defer ftpClient.Close() srcFile, err := ftpClient.Open(remotepath) if err != nil { fmt.Println("文件讀取失敗", err) panic(err) } defer srcFile.Close() localFilename := path.Base(remotepath) dstFile, e := os.Create(path.Join(localpath, localFilename)) if e != nil { fmt.Println("文件創建失敗", e) panic(e) } defer dstFile.Close() if _, err1 := srcFile.WriteTo(dstFile); err1 != nil { fmt.Println("文件寫入失敗", err1) panic(err1) } fmt.Println("文件下載成功")} |
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持服務器之家。如有錯誤或未考慮完全的地方，望不吝賜教。
原文鏈接：https://blog.csdn.net/fu_qin/article/details/78741854
