脚本之家,脚本语言编程技术及教程分享平台!
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - Golang通过SSH执行交换机操作实现

Golang通过SSH执行交换机操作实现

2020-07-20 11:31moakia Golang

这篇文章主要介绍了Golang通过SSH执行交换机操作实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

简单实现通过输入指令,两步执行交换机命令。

  • 输入执行换机的账号和密码。可以一次输入多个账号和密码,为了方便操作,规定了输入格式。如 用户名;主机IP;密码|用户名;主机IP;密码。举例admin;192.168.56.10;h3csw1|admin;192.168.56.11;h3csw2
  • 输入要执行的命令,以;分割。例如system-view;dis cu;

​ 存在问题:

  • 不够灵活。输入方式限制太死,输入特别字符也可能存在错误。
  • 过于简陋。
  • 功能简单。

​ 不过我的目的已经达到,我主要是了解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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
package main
 
import (
  "bufio"
  "fmt"
  "golang.org/x/crypto/ssh"
  "log"
  "os"
  "strings"
  "sync"
)
 
//获取账号和密码的对应关系
type HostPassword struct {
  Host string
  Username string
  Password string
}
var (
  a,b string //临时存储变量
  commands = []string{} //执行命令组
  hp []HostPassword //保存账号和密码
  wg sync.WaitGroup  //执行goroutine
 
)
func main() {
  //1. 选择交换机
  //2. 输入要执行命令
  //3. 建立会话连接
  //4. 新建session,并执行命令
 
  //1. 选择操作交换机
  // 1.1 输入要执行交换机
  fmt.Println("请输入计划执行命令的交换机账号和密码,账号密码直接使用|分割,多个账号密码之间使用;分割,例如admin;192.168.56.10;h3csw1|admin;192.168.56.11;h3csw2")
  _, err := fmt.Scanln(&a)
  if err != nil {
    log.Fatal("输入错误:",err)
  }
  fmt.Println("请输入要执行的命令行,以;号间隔")
  //1.1.1切割交换机命令
  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 输入要执行命令
  input := bufio.NewReader(os.Stdin)
  b, err := input.ReadString('\n')
  if err != nil {
    log.Fatal("输入错误",err)
  }
  commands = strings.Split(b, ";")
 
  //2. 执行交换机操作
  err = SshSwitch(hp)
  if err != nil {
    log.Fatalln(err)
  }
 
  // 同步等待
  wg.Wait()
}
 
//建立ssh连接
func SshSwitch(hostpasswords []HostPassword) (error){
  //循环获取hostpasswords的账号和密码
  for i,_ := range hp{
    //添加同步组,下面会执行goroutin
    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"},
      }, //添加了很多加密方式,为了应对不同的密码规则
      User:       hp[i].Username,
      Auth:       []ssh.AuthMethod{
        ssh.Password(hp[i].Password),
      },
      HostKeyCallback:  ssh.InsecureIgnoreHostKey(), //此处相当于执行nil,但是并不安全
    }
    client, err := ssh.Dial("tcp",hp[i].Host+":22", config)
    if err != nil {
      log.Fatalln("建立ssh连接错误:",err)
      return err
    }
    //执行goroutine,但是没有返回错误。
    go HandleSession(client, commands,&wg)
 
  }
  return nil
}
 
//建立session,执行命令。
func HandleSession(client *ssh.Client,commands []string,wg *sync.WaitGroup) error {
  //建立session
  session, err := client.NewSession()
  if err != nil {
    log.Fatalln("创建session出错",err)
    return err
  }
  //延迟关闭session
  defer session.Close()
 
  //设置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("创建requestpty出错",err)
    return err
  }
  //设置session的标准输入是stdin
  stdin, err := session.StdinPipe()
  if err != nil {
    log.Fatal("输入错误",err)
    return err
  }
  //设置session的标准输出和错误输出分别是os.stdout,os,stderr.就是输出到后台
  session.Stdout = os.Stdout
  session.Stderr = os.Stderr
  err = session.Shell()
  if err != nil {
    log.Fatal("创建shell出错",err)
    return err
  }
  //将命令依次执行
  for _, cmd := range commands {
    fmt.Println(cmd)
    _, err = fmt.Fprintf(stdin, "%s\n", cmd)
    if err != nil {
      log.Fatal("写入stdin出错",err)
      return err
    }
  }
 
  //执行等待
  err = session.Wait()
  if err != nil {
    log.Fatal("等待session出错",err)
    return err
  }
  //减少同步组的次数
  wg.Done()
  return nil
}

到此这篇关于Golang通过SSH执行交换机操作实现的文章就介绍到这了,更多相关Golang SSH执行交换机内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.51cto.com/9406836/2503197

延伸 · 阅读

精彩推荐
  • GolangGo语言基础单元测试与性能测试示例详解

    Go语言基础单元测试与性能测试示例详解

    这篇文章主要为大家介绍了Go语言基础单元测试与性能测试示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助祝大家多多进步...

    枫少文7812021-12-05
  • Golanggo语言获取系统盘符的方法

    go语言获取系统盘符的方法

    这篇文章主要介绍了go语言获取系统盘符的方法,涉及Go语言调用winapi获取系统硬件信息的技巧,具有一定参考借鉴价值,需要的朋友可以参考下 ...

    无尽海3862020-04-24
  • GolangGo语言range关键字循环时的坑

    Go语言range关键字循环时的坑

    今天小编就为大家分享一篇关于Go语言range关键字循环时的坑,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来...

    benben_20154202020-05-23
  • Golang深入浅析Go中三个点(...)用法

    深入浅析Go中三个点(...)用法

    这篇文章主要介绍了深入浅析Go中三个点(...)用法,需要的朋友可以参考下...

    踏雪无痕SS6472021-11-17
  • GolangGolang实现四种负载均衡的算法(随机,轮询等)

    Golang实现四种负载均衡的算法(随机,轮询等)

    本文介绍了示例介绍了Golang 负载均衡的四种实现,主要包括了随机,轮询,加权轮询负载,一致性hash,感兴趣的小伙伴们可以参考一下...

    Gundy_8442021-08-09
  • GolangGolang 语言极简类型转换库cast的使用详解

    Golang 语言极简类型转换库cast的使用详解

    本文我们通过 cast.ToString() 函数的使用,简单介绍了cast 的使用方法,除此之外,它还支持很多其他类型,在这没有多多介绍,对Golang 类型转换库 cast相关知...

    Golang语言开发栈6112021-12-02
  • GolangGo语言实现自动填写古诗词实例代码

    Go语言实现自动填写古诗词实例代码

    这篇文章主要给大家介绍了关于Go语言实现自动填写古诗词的相关资料,这是最近在项目中遇到的一个需求,文中通过示例代码介绍的非常详细,需要的朋...

    FengY5862020-05-14
  • GolangGO语言字符串处理Strings包的函数使用示例讲解

    GO语言字符串处理Strings包的函数使用示例讲解

    这篇文章主要为大家介绍了GO语言字符串处理Strings包的函数使用示例讲解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加...

    Jeff的技术栈6882022-04-14