conn.close();

下面通過一個小例子來簡單學習一下如何通過ganymed實現連線ssh伺服器並執行指令.

1.直接看工具類：

<span style="font-size:12px;">package com.ilucky.ssh.util;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.charset.Charset;

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;
import ch.ethz.ssh2.StreamGobbler;

/**
 * @author IluckySi
 * @date 20140805
 */
public class SshUtil {

	private Connection connection;

	public SshUtil(SshSetting sshSetting) {
		try {
			//判斷SshSetting中的引數是否為空.
			String ip = sshSetting.getIp();
			String username = sshSetting.getUsername();
			String password = sshSetting.getPassword();
			if (ip == null || username == null || password == null) {
				throw new Exception("SshSetting引數: ip, username和password不能為空!");
			}
			
			//判斷Ssh伺服器是否可以登入.
			connection = new Connection(ip);
			connection.connect();
			boolean isAuthenticated = connection.authenticateWithPassword(username, password);
			if (!isAuthenticated) {
				throw new Exception("SshSetting引數: username和password不正確!");
			}
		} catch (Exception e) {
			System.out.println("獲取Connection發生問題!");
		}
	}

	public String execute(String command) {
		StringBuffer sb = new StringBuffer();
		Session session = null;
		InputStream is  = null;
		InputStreamReader isr = null;
		BufferedReader br = null;
		try {
			//獲取Session會話並執行指令.
			session = connection.openSession();
			session.execCommand(command);
			
			//獲取伺服器上控制檯的返回結果並編碼為UTF-8.
			is = new StreamGobbler(session.getStdout());
			isr = new InputStreamReader(is, Charset.forName("UTF-8"));
			br = new BufferedReader(isr);
			
			//將伺服器返回結果拼接成StringBuffer並返回.
			String buffer = br.readLine();
			while ((buffer = br.readLine()) != null) {
				if (buffer != null) {
					sb.append(buffer.toString() + "\n");
				}
			}
			
			//獲取指令在Ssh伺服器上是否執行成功.
			if(session.getExitStatus() == 0) {
				System.out.println(command + "執行成功!");
			} else {
				System.out.println(command + "執行失敗!");
			}
		} catch (Exception e) {
			System.out.println("執行指令: " + command + "發生問題!");
		} finally {
			try {
				if(br != null) {
					br.close();
					br = null;
				}
				if(isr != null) {
					isr.close();
					isr = null;
				}
				if(is != null) {
					is.close();
					is = null;
				}
				if(session != null) {
					session.close();
					session = null;
				}
			} catch (Exception e) {
				System.out.println("關閉Session發生問題!");
			}
		}
		return sb.toString();
	}
	
	public void finish() {
		try {
			if(connection != null) {
				connection.close();
				connection = null;
			}
		} catch (Exception e) {
			System.out.println("關閉Connection發生問題!");
		}
	}
}
</span>
 

<span style="font-size:12px;">package com.ilucky.ssh.util;

/**
 * @author IluckySi
 * @date 20140805
 */
public class SshSetting {

	private String ip;
	
	private int port;
	
	private String username;
	
	private String password;

	public String getIp() {
		return ip;
	}

	public void setIp(String ip) {
		this.ip = ip;
	}

	public int getPort() {
		return port;
	}

	public void setPort(int port) {
		this.port = port;
	}

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	} 
}
</span>
 

<span style="font-size:12px;">package com.ilucky.ssh;

import java.util.ArrayList;
import java.util.List;

import com.ilucky.ssh.util.SshSetting;
import com.ilucky.ssh.util.SshUtil;

/**
 * @author IluckySi
 * @date 20140805
 */
public class MainTest {

	public static void main(String[] args) {
	    SshSetting sshSetting = new SshSetting();
	    sshSetting.setIp("192.168.73.246");
	    sshSetting.setPort(22); //ssh預設埠是22.
	    sshSetting.setUsername("root");
	    sshSetting.setPassword("Talent123");
	    SshUtil sshUtil = new SshUtil(sshSetting);
	    List<String> commondList = new ArrayList<String>();
	    commondList.add("cd /home");
	    commondList.add("ls");
	    commondList.add("ls -l");
	    for (int i = 0; i < commondList.size(); i++) {
	    	System.out.println(sshUtil.execute(commondList.get(i)));
	    }
	}
}
/**
執行結果:
cd /home執行成功!

ls執行成功!
anaconda-ks.cfg
install.log
install.log.syslog
tap-home
公共的
模板
視訊
圖片
文件
下載
音樂
桌面

ls -l執行成功!
-rw-r--r--. 1 root root  3233 2月  26 17:29 \
-rw-------. 1 root root  1301 8月  30 2013 anaconda-ks.cfg
-rw-r--r--. 1 root root 39043 8月  30 2013 install.log
-rw-r--r--. 1 root root  9936 8月  30 2013 install.log.syslog
drwxr-xr-x. 2 root root  4096 6月  26 10:08 tap-home
drwxr-xr-x. 2 root root  4096 8月  30 2013 公共的
drwxr-xr-x. 2 root root  4096 8月  30 2013 模板
drwxr-xr-x. 2 root root  4096 8月  30 2013 視訊
drwxr-xr-x. 2 root root  4096 8月  30 2013 圖片
drwxr-xr-x. 2 root root  4096 8月  30 2013 文件
drwxr-xr-x. 2 root root  4096 8月  30 2013 下載
drwxr-xr-x. 2 root root  4096 8月  30 2013 音樂
drwxr-xr-x. 2 root root  4096 12月  5 2013 桌面
*/
</span>