import paramiko
  # 實例化SSHClient
  client = paramiko.SSHClient()
 
  # 自動添加策略，保存服務(wù)器的主機名和密鑰信息，如果不添加，那么不再本地know_hosts文件中記錄的主機將無法連接
  client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 
  # 連接SSH服務(wù)端，以用戶名和密碼進行認證
  client.connect(hostname='192.168.1.1', port=22, username='root', password='123456')
 
  # 打開一個Channel并執(zhí)行命令
  stdin, stdout, stderr = client.exec_command('df -h ') # stdout 為正確輸出，stderr為錯誤輸出，同時是有1個變量有值
 
  # 打印執(zhí)行結(jié)果
  print(stdout.read().decode('utf-8'))
 
  # 關(guān)閉SSHClient
  client.close()

#!/usr/bin/env python3
import sys
import getpass
import paramiko
import threading
import os
#創(chuàng)建函數(shù)實現(xiàn)遠程連接主機、服務(wù)器密碼以及在遠程主機上執(zhí)行的命令的功能
def remote_comm(host, pwd, command):
#創(chuàng)建用于連接ssh服務(wù)器的實例
  ssh = paramiko.SSHClient()
#設(shè)置自動添加主機密鑰
  ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
#連接ssh服務(wù)器，添加連接的主機、用戶名、密碼填好,捕獲異常，有異常則跳出函數(shù)
  try:
   ssh.connect(hostname=host, username='root', password=pwd)
  except:
   return 
#在ssh服務(wù)器上執(zhí)行指定命令，返回3項類文件對象，分別是，輸入、輸出、錯誤
  stdin, stdout, stderr = ssh.exec_command(command)
#讀取輸出
  out = stdout.read()
#讀取錯誤
  error = stderr.read()
#如果有輸出
  if out:
#打印主機輸出內(nèi)容
    print('[%s] OUT:\n%s' % (host, out.decode('utf8')))
#如果有錯誤
  if error:
#打印主機錯誤信息
    print('[%s] ERROR:\n%s' % (host, error.decode('utf8')))
#程序結(jié)束
  ssh.close()
if __name__ == '__main__':
#設(shè)定sys.argv長度，確保remote_comm函數(shù)中參數(shù)數(shù)量
  if len(sys.argv) != 3:
    print('Usage: %s ipaddr_file "command"' % sys.argv[0])
    exit(1)
#判斷命令行上輸入如果不是文件，確保輸入的是文件 
  if not os.path.isfile(sys.argv[1]):
    print('No such file:', sys.argv[1])
    exit(2)
#fname為存儲遠程主機ip的文件，用sys.argv方法，可以在執(zhí)行腳本時再輸入文件名，更為靈活
  fname = sys.argv[1]
#command為在遠程主機上執(zhí)行的命令，用sys.argv方法，可以在執(zhí)行腳本時再輸入相應(yīng)命令，command為remote_comm函數(shù)第三個參數(shù)
  command = sys.argv[2]
#通過getpass輸入遠程服務(wù)器密碼，pwd為remote_comm函數(shù)第二個參數(shù)
  # pwd = getpass.getpass()
  pwd='Taren1.bgsn'
#打開存有遠程主機ip的文件
  with open(fname) as fobj:
#將遍歷文件將ip以列表形式存入ips，line.strip()可以去掉每行ip后\n
    ips = [line.strip() for line in fobj]
#循環(huán)遍歷列表，獲取ip地址，ip為remote_comm函數(shù)第一個參數(shù)
  for ip in ips:
#將讀取到的ip地址作為remote_comm函數(shù)實際參數(shù)傳遞給函數(shù)，ips中有幾個ip地址循環(huán)幾次
#創(chuàng)建多線程
    t = threading.Thread(target=remote_comm, args=(ip, pwd, command))
#啟用多線程
    t.start()

[root@room9pc01 ~]#nmap -n -sP 176.130.7.0/24 | grep 176 | awk '{print $5}' > /mnt/server_addr.txt
[root@room9pc01 ~]#cat /mnt/server_addr.txt
Nmap scan report for 176.130.7.1
Nmap scan report for 176.130.7.24
Nmap scan report for 176.130.7.46
Nmap scan report for 176.130.7.53
Nmap scan report for 176.130.7.57

[root@room9pc01 mnt]# python3 ssh.py server_addr.txt 'who'
[176.130.7.57] OUT:
student :0      2019-12-02 09:04 (:0)
student pts/0    2019-12-02 15:03 (:0)
[176.130.7.169] OUT:
student :0      2019-12-02 08:17 (:0)
student pts/0    2019-12-02 08:23 (:0)
student pts/4    2019-12-02 08:24 (:0)
[176.130.7.162] OUT:
student :0      2019-12-02 08:17 (:0)
student pts/0    2019-12-02 15:03 (:0)
[176.130.7.178] OUT:
student :0      2019-12-02 08:06 (:0)