go语言执行grep -v grep爬坑

使用go语言的golang.org/x/crypto/ssh包,执行远程机器上的进程检查命令
ps -ef | grep -s buildapp.sh | grep -v grep一直报错

Error: Process exited with status 1

package main
import (
 "fmt"
 "github.com/pkg/sftp"
 "golang.org/x/crypto/ssh"
 "os"
 "path"
 "time"
)
func main() {
 localFile := "/test"
 remoteDir := "/test/test"
 user := "wanglulu"
 pass := "123123"
 host := "192.168.7.100"
 port := 22
 //创建SSH Client
 sshClient, err := GetSSHClient(user, pass, host, port)
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 defer sshClient.Close()
 //创建SSH Session
 session, err := GetSSHSession(sshClient)
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 defer session.Close()
 //检查是否有构建任务正在执行
 c := `ps -ef | grep -s buildapp.sh | grep -v "grep"`
 resp, err := session.Output(c)
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 fmt.Println("[INFO]", string(resp))
 //创建SSH Session
 sftpClient, err := GetSFTPClient(sshClient)
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 defer sftpClient.Close()
 //传输构建APP需要的资源文件
 srcFile, err := os.Open(localFile)
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 defer srcFile.Close()
 remoteFileName := path.Base(localFile)
 dstFile, err := sftpClient.Create(path.Join(remoteDir, remoteFileName))
 if err != nil {
 fmt.Println("Error:",err)
 return
 }
 defer dstFile.Close()
 buf := make([]byte, 1024)
 for {
 n, _ := srcFile.Read(buf)
 if n == 0 {
 break
 }
 dstFile.Write(buf[0:n])
 }
}
func GetSSHClient(user, password, host string, port int) (*ssh.Client, error) {
 var (
 auth []ssh.AuthMethod
 addr string
 clientConfig *ssh.ClientConfig
 client *ssh.Client
 err error
 )
 // get auth method
 auth = make([]ssh.AuthMethod, 0)
 auth = append(auth, ssh.Password(password))
 clientConfig = &ssh.ClientConfig{
 User: user,
 Auth: auth,
 HostKeyCallback: ssh.InsecureIgnoreHostKey(),
 Timeout: 60 * time.Second,
 }
 // connect to ssh
 addr = fmt.Sprintf("%s:%d", host, port)
 if client, err = ssh.Dial("tcp", addr, clientConfig); err != nil {
 return nil, err
 }
 return client, nil
}
func GetSFTPClient(sshClient *ssh.Client) (*sftp.Client, error) {
 var (
 sftpClient *sftp.Client
 err error
 )
 // create sftp client
 if sftpClient, err = sftp.NewClient(sshClient); err != nil {
 return nil, err
 }
 return sftpClient, nil
}
func GetSSHSession(sshClient *ssh.Client) (*ssh.Session, error) {
 var (
 session *ssh.Session
 err error
 )
 // create session
 if session, err = sshClient.NewSession(); err != nil {
 return nil, err
 }
 return session, nil
}

本文来自:简书

感谢作者:

查看原文:go语言执行grep -v grep爬坑

• 编辑
• 预览