package main import ( "fmt" "go-ssh/ssh" "io" "os" ) const ( user = "user" ip_port = "ip_port" password = "Passwd" ) func main() { PassWd := []ssh.AuthMethod{ssh.Password(password)} Conf := ssh.ClientConfig{User: user, Auth: PassWd} Client, err := ssh.Dial("tcp", ip_port, &Conf) if err != nil { fmt.Println(nil) } defer Client.Close() if session, err := Client.NewSession(); err == nil { defer session.Close() go func() { Buf := make([]byte, 1024) w, _ := session.StdinPipe() defer w.Close() File, _ := os.Open("FilePath") info, _ := File.Stat() fmt.Fprintln(w, "C0644", info.Size(), "Des_Name") for { n, err := File.Read(Buf) fmt.Fprint(w, string(Buf[:n])) if err != nil { if err == io.EOF { return } else { panic(err) } } } }() if err := session.Run("/usr/bin/scp -qrt /mnt"); err != nil { if err != nil { if err.Error() != "Process exited with: 1. Reason was: ()" { fmt.Println(err.Error()) } } } } }
有疑问加站长微信联系(非本文作者)