Golang通過SSH執(zhí)行交換機(jī)操作實(shí)現(xiàn)

package main

import (
  "bufio"
  "fmt"
  "golang.org/x/crypto/ssh"
  "log"
  "os"
  "strings"
  "sync"
)

//獲取賬號和密碼的對應(yīng)關(guān)系
type HostPassword struct {
  Host string
  Username string
  Password string
}
var (
  a,b string //臨時(shí)存儲變量
  commands = []string{} //執(zhí)行命令組
  hp []HostPassword //保存賬號和密碼
  wg sync.WaitGroup  //執(zhí)行g(shù)oroutine

)
func main() {
  //1. 選擇交換機(jī)
  //2. 輸入要執(zhí)行命令
  //3. 建立會(huì)話連接
  //4. 新建session，并執(zhí)行命令

  //1. 選擇操作交換機(jī)
  // 1.1 輸入要執(zhí)行交換機(jī)
  fmt.Println("請輸入計(jì)劃執(zhí)行命令的交換機(jī)賬號和密碼,賬號密碼直接使用|分割，多個(gè)賬號密碼之間使用;分割,例如admin;192.168.56.10;h3csw1|admin;192.168.56.11;h3csw2")
  _, err := fmt.Scanln(a)
  if err != nil {
    log.Fatal("輸入錯(cuò)誤:",err)
  }
  fmt.Println("請輸入要執(zhí)行的命令行，以；號間隔")
  //1.1.1切割交換機(jī)命令
  switchgroups := strings.Split(a, "|")
  length := len(switchgroups)
  hp = make([]HostPassword,length)
  for i,singleswitch := range switchgroups{
    hp[i]=HostPassword{}
    switchsplit := strings.Split(singleswitch, ";")
    hp[i].Username=switchsplit[0]
    hp[i].Host=switchsplit[1]
    hp[i].Password=switchsplit[2]
  }

  // 1.2 輸入要執(zhí)行命令
  input := bufio.NewReader(os.Stdin)
  b, err := input.ReadString('\n')
  if err != nil {
    log.Fatal("輸入錯(cuò)誤",err)
  }
  commands = strings.Split(b, ";")

  //2. 執(zhí)行交換機(jī)操作
  err = SshSwitch(hp)
  if err != nil {
    log.Fatalln(err)
  }

  // 同步等待
  wg.Wait()
}

//建立ssh連接
func SshSwitch(hostpasswords []HostPassword) (error){
  //循環(huán)獲取hostpasswords的賬號和密碼
  for i,_ := range hp{
    //添加同步組，下面會(huì)執(zhí)行g(shù)oroutin
    wg.Add(1)
    config := ssh.ClientConfig{
      Config:      ssh.Config{
        Ciphers:    []string{"aes128-ctr", "aes192-ctr", "aes256-ctr", "aes128-gcm@openssh.com", "arcfour256", "arcfour128", "aes128-cbc", "3des-cbc", "aes192-cbc", "aes256-cbc"},
      }, //添加了很多加密方式，為了應(yīng)對不同的密碼規(guī)則
      User:       hp[i].Username,
      Auth:       []ssh.AuthMethod{
        ssh.Password(hp[i].Password),
      },
      HostKeyCallback:  ssh.InsecureIgnoreHostKey(), //此處相當(dāng)于執(zhí)行nil，但是并不安全
    }
    client, err := ssh.Dial("tcp",hp[i].Host+":22", config)
    if err != nil {
      log.Fatalln("建立ssh連接錯(cuò)誤:",err)
      return err
    }
    //執(zhí)行g(shù)oroutine，但是沒有返回錯(cuò)誤。
    go HandleSession(client, commands,wg)

  }
  return nil
}

//建立session，執(zhí)行命令。
func HandleSession(client *ssh.Client,commands []string,wg *sync.WaitGroup) error {
  //建立session
  session, err := client.NewSession()
  if err != nil {
    log.Fatalln("創(chuàng)建session出錯(cuò)",err)
    return err
  }
  //延遲關(guān)閉session
  defer session.Close()

  //設(shè)置terminalmodes的方式
  modes := ssh.TerminalModes{
    ssh.ECHO:     0,   // disable echoing
    ssh.TTY_OP_ISPEED: 14400, // input speed = 14.4kbaud
    ssh.TTY_OP_OSPEED: 14400, // output speed = 14.4kbaud
  }
  //建立偽終端
  err = session.RequestPty("xterm",80,40,modes)
  if err != nil {
    log.Fatal("創(chuàng)建requestpty出錯(cuò)",err)
    return err
  }
  //設(shè)置session的標(biāo)準(zhǔn)輸入是stdin
  stdin, err := session.StdinPipe()
  if err != nil {
    log.Fatal("輸入錯(cuò)誤",err)
    return err
  }
  //設(shè)置session的標(biāo)準(zhǔn)輸出和錯(cuò)誤輸出分別是os.stdout,os,stderr.就是輸出到后臺
  session.Stdout = os.Stdout
  session.Stderr = os.Stderr
  err = session.Shell()
  if err != nil {
    log.Fatal("創(chuàng)建shell出錯(cuò)",err)
    return err
  }
  //將命令依次執(zhí)行
  for _, cmd := range commands {
    fmt.Println(cmd)
    _, err = fmt.Fprintf(stdin, "%s\n", cmd)
    if err != nil {
      log.Fatal("寫入stdin出錯(cuò)",err)
      return err
    }
  }

  //執(zhí)行等待
  err = session.Wait()
  if err != nil {
    log.Fatal("等待session出錯(cuò)",err)
    return err
  }
  //減少同步組的次數(shù)
  wg.Done()
  return nil
}