forked from go/golangs_learn
VIVIMAN
3 years ago
4 changed files with 168 additions and 0 deletions
@ -0,0 +1,71 @@ |
|||
package main |
|||
|
|||
import ( |
|||
"fmt" |
|||
"github.com/mitchellh/go-homedir" |
|||
"golang.org/x/crypto/ssh" |
|||
"io/ioutil" |
|||
"log" |
|||
"time" |
|||
) |
|||
|
|||
func main() { |
|||
sshHost := "home.xxx.cn" |
|||
sshUser := "x" |
|||
sshPassword := "xxxxxx" |
|||
sshType := "password" //password 或者 key
|
|||
sshKeyPath := "" //ssh id_rsa.id 路径"
|
|||
sshPort := 22 |
|||
|
|||
//创建sshp登陆配置
|
|||
config := &ssh.ClientConfig{ |
|||
Timeout: time.Second, //ssh 连接time out 时间一秒钟, 如果ssh验证错误 会在一秒内返回
|
|||
User: sshUser, |
|||
HostKeyCallback: ssh.InsecureIgnoreHostKey(), //这个可以, 但是不够安全
|
|||
//HostKeyCallback: hostKeyCallBackFunc(h.Host),
|
|||
} |
|||
if sshType == "password" { |
|||
config.Auth = []ssh.AuthMethod{ssh.Password(sshPassword)} |
|||
} else { |
|||
config.Auth = []ssh.AuthMethod{publicKeyAuthFunc(sshKeyPath)} |
|||
} |
|||
|
|||
//dial 获取ssh client
|
|||
addr := fmt.Sprintf("%s:%d", sshHost, sshPort) |
|||
sshClient, err := ssh.Dial("tcp", addr, config) |
|||
if err != nil { |
|||
log.Fatal("创建ssh client 失败", err) |
|||
} |
|||
defer sshClient.Close() |
|||
|
|||
//创建ssh-session
|
|||
session, err := sshClient.NewSession() |
|||
if err != nil { |
|||
log.Fatal("创建ssh session 失败", err) |
|||
} |
|||
defer session.Close() |
|||
//执行远程命令
|
|||
combo, err := session.CombinedOutput("whoami; cd /; ls -al;echo https://github.com/libragen/felix") |
|||
if err != nil { |
|||
log.Fatal("远程执行cmd 失败", err) |
|||
} |
|||
log.Println("命令输出:", string(combo)) |
|||
|
|||
} |
|||
|
|||
func publicKeyAuthFunc(kPath string) ssh.AuthMethod { |
|||
keyPath, err := homedir.Expand(kPath) |
|||
if err != nil { |
|||
log.Fatal("find key's home dir failed", err) |
|||
} |
|||
key, err := ioutil.ReadFile(keyPath) |
|||
if err != nil { |
|||
log.Fatal("ssh key file read failed", err) |
|||
} |
|||
// Create the Signer for this private key.
|
|||
signer, err := ssh.ParsePrivateKey(key) |
|||
if err != nil { |
|||
log.Fatal("ssh key signer failed", err) |
|||
} |
|||
return ssh.PublicKeys(signer) |
|||
} |
@ -0,0 +1,71 @@ |
|||
package main |
|||
|
|||
import ( |
|||
"fmt" |
|||
"github.com/mitchellh/go-homedir" |
|||
"golang.org/x/crypto/ssh" |
|||
"io/ioutil" |
|||
"log" |
|||
"time" |
|||
) |
|||
|
|||
func main() { |
|||
sshHost := "192.168.1.161" |
|||
sshUser := "hongyun" |
|||
sshPassword := "hhh" |
|||
sshType := "password" //password 或者 key
|
|||
sshKeyPath := "" //ssh id_rsa.id 路径"
|
|||
sshPort := 22 |
|||
|
|||
//创建sshp登陆配置
|
|||
config := &ssh.ClientConfig{ |
|||
Timeout: time.Second, //ssh 连接time out 时间一秒钟, 如果ssh验证错误 会在一秒内返回
|
|||
User: sshUser, |
|||
HostKeyCallback: ssh.InsecureIgnoreHostKey(), //这个可以, 但是不够安全
|
|||
//HostKeyCallback: hostKeyCallBackFunc(h.Host),
|
|||
} |
|||
if sshType == "password" { |
|||
config.Auth = []ssh.AuthMethod{ssh.Password(sshPassword)} |
|||
} else { |
|||
config.Auth = []ssh.AuthMethod{publicKeyAuthFunc(sshKeyPath)} |
|||
} |
|||
|
|||
//dial 获取ssh client
|
|||
addr := fmt.Sprintf("%s:%d", sshHost, sshPort) |
|||
sshClient, err := ssh.Dial("tcp", addr, config) |
|||
if err != nil { |
|||
log.Fatal("创建ssh client 失败", err) |
|||
} |
|||
defer sshClient.Close() |
|||
|
|||
//创建ssh-session
|
|||
session, err := sshClient.NewSession() |
|||
if err != nil { |
|||
log.Fatal("创建ssh session 失败", err) |
|||
} |
|||
defer session.Close() |
|||
//执行远程命令
|
|||
combo, err := session.CombinedOutput("whoami; cd /opt/cn.com.epsoft.qggwy/qggwy/mysql/bin; ./mysql -uroot -padmin") |
|||
if err != nil { |
|||
log.Fatal("远程执行cmd 失败", err) |
|||
} |
|||
log.Println("命令输出:", string(combo)) |
|||
|
|||
} |
|||
|
|||
func publicKeyAuthFunc(kPath string) ssh.AuthMethod { |
|||
keyPath, err := homedir.Expand(kPath) |
|||
if err != nil { |
|||
log.Fatal("find key's home dir failed", err) |
|||
} |
|||
key, err := ioutil.ReadFile(keyPath) |
|||
if err != nil { |
|||
log.Fatal("ssh key file read failed", err) |
|||
} |
|||
// Create the Signer for this private key.
|
|||
signer, err := ssh.ParsePrivateKey(key) |
|||
if err != nil { |
|||
log.Fatal("ssh key signer failed", err) |
|||
} |
|||
return ssh.PublicKeys(signer) |
|||
} |
Loading…
Reference in new issue