使用ganymed工具调用ssh2

  1 package com.eshore.framework.util;
  2 
  3 
  4 
  5 import java.io.BufferedReader;
  6 import java.io.File;
  7 import java.io.FileInputStream;
  8 import java.io.IOException;
  9 import java.io.InputStream;
 10 import java.io.InputStreamReader;
 11 import java.util.ArrayList;
 12 import java.util.List;
 13 
 14 import ch.ethz.ssh2.Connection;
 15 import ch.ethz.ssh2.Session;
 16 import ch.ethz.ssh2.StreamGobbler;
 17 import ch.ethz.ssh2.log.Logger;
 18 /**
 19  * shell脚本调用类
 20  * @author clear
 21  *
 22  */
 23 public class SshBasic{
 24     
 25     //连接，登陆
 26     public Connection login(String hostname,int port,String username,String password){
 27 
 28         //获取连接
 29         Connection conn = new Connection(hostname, port);
 30         try {
 31             //连接
 32             conn.connect();
 33             //输入账号密码登陆
 34             boolean isAuthenticated = conn.authenticateWithPassword(username, password);
 35             //登陆失败，返回错误
 36             if(isAuthenticated == false){
 37                 throw new IOException("isAuthentication failed.");
 38             }
 39         } catch (IOException e) {
 40             
 41             e.printStackTrace();
 42         }
 43         
 44         return conn;
 45     }
 46     //获取Session
 47     public Session getSession(Connection conn){
 48         Session sess = null;
 49         try {
 50             sess = conn.openSession();
 51         } catch (IOException e) {
 52             // TODO Auto-generated catch block
 53             e.printStackTrace();
 54         }
 55         return sess;
 56     }
 57     //获取控制台打印信息
 58     public String printCmd(String path,Connection conn,Session sess, String date, String city){
 59         String txt = "";
 60         try {
 61             sess.execCommand("chmod 755 "+path+" && "+path+" "+date+" "+city);
 62             //打印信息
 63             InputStream stdout = new StreamGobbler(sess.getStdout());
 64             //打印错误
 65             InputStream stderr = new StreamGobbler(sess.getStderr());
 66             BufferedReader brout = new BufferedReader(new InputStreamReader(stdout,"UTF-8"));
 67             BufferedReader brerr = new BufferedReader(new InputStreamReader(stderr,"UTF-8"));
 68             while(true){
 69                 String line = brout.readLine();
 70                 if(line==null){
 71                     break;
 72                 }
 73                 txt += line+"<br/>";
 74                 System.out.println(line);
 75             }
 76             while(true){
 77                 String line = brerr.readLine();
 78                 if(line==null){
 79                     break;
 80                 }
 81                 txt += line+"<br/>";
 82                 System.out.println(line);
 83             }
 84         } catch (IOException e) {
 85             // TODO Auto-generated catch block
 86             e.printStackTrace();
 87         }
 88         
 89         return txt;
 90     }
 91 
 92     public static void main(String[] args) {
 93         
 94         SshBasic m = new SshBasic();
 95         //连接并登陆
 96         Connection conn = m.login("132.122.1.51", 22, "srglweb", "srglweb123");
 97         //获取Session
 98         Session sess = m.getSession(conn);
 99         //获取控制台信息
100         String cmd = m.printCmd("shelltest/two.sh", conn,sess,"20140905","200");
101         System.out.println("cmd:"+cmd);
102         System.out.println("--->"+sess);
103         //判断会话是否成功
104         int result = sess.getExitStatus();//如果成功返回0
105         System.out.println("result:"+result);
106         sess.close();
107         conn.close();
108     }
109 
110 }