如果大家熟悉Linux的話，一定對ssh,sftp,scp等命令非常熟悉。ssh是一個安全協(xié)議，用來在不同系統(tǒng)或者服務(wù)器之間進(jìn)行安全連接。ssh在連接和傳送的過程中會加密所有的數(shù)據(jù)。但是ssh一般是基于客戶端的或者Linux命令行的。比如客戶端工具:OpenSSH,putty,SSHTectia。在linux系統(tǒng)上大家可以通過sshusername@host命令連接到目標(biāo)主機，但是如果在Java中，如何實現(xiàn)SSH功能呢？更進(jìn)一步如何實現(xiàn)SCP,SFTP的功能呢？目前Java主流操作linux服務(wù)器基本都是基于Jsch與ganymed-ssh2。Jsch與ganymed-ssh2都是用純Java實現(xiàn)SSH-2協(xié)議的一個包。兩者大同小異，下面筆者重點講解下如何在Java代碼中基于Jsch連接并操作linux系統(tǒng)。

目前在湖南移動的日志分析項目中，我們正是基于jsch實現(xiàn)java操作linux服務(wù)器，實現(xiàn)腳本庫的功能。

1、Pom文件中配置相應(yīng)的jsch的jar包

com.jcraft

jsch

0.1.54

2、建立一個SSH會話

publicstatic Session openSession(String sshHost, int sshPort, StringsshUser, String sshPass)

throwsDeployException {

finalJSch jsch = new JSch();

Sessionsession;

try{

session= jsch.getSession(sshUser, sshHost, sshPort);

}catch (JSchException e) {

logger.error(sshHost,e);

thrownew DeployException("創(chuàng)建一個新的session異常");

}

//設(shè)置第一次登錄的時候提示，可選值：(ask| yes | no)

session.setConfig("StrictHostKeyChecking","no");

session.setPassword(sshPass);

try{

session.connect();

}catch (JSchException e) {

logger.error("openSession異常",e);

thrownew DeployException("創(chuàng)建一個新的session異常");

}

returnsession;

}

3、執(zhí)行Shell命令

publicstatic String execCommand(Session session, String cmd, Charsetcharset, long timeout)

throwsDeployException, TimeOutException {

StringBufferresult = new StringBuffer();

ChannelExecexec = null;

try{

exec= (ChannelExec)createChannel(session, ChannelType.EXEC);

cmd= cmd + " 2>&1";

exec.setCommand(cmd);

exec.setInputStream(null);

logger.info(newStringBuilder(exec.getSession().getHost()).append(",執(zhí)行輸出命令：").append(cmd).toString());

try(InputStream stdout = exec.getInputStream()) {

exec.connect();

longstartTime = System.currentTimeMillis();

byte[]tmp = new byte[1024];

while(true) {

while(stdout.available() > 0) {

inti = stdout.read(tmp, 0, 1024);

if(i < 0)

break;

result.append(newString(tmp, 0, i, Charset.defaultCharset()));

}

if(exec.isClosed()) {

if(stdout.available() > 0)

continue;

break;

}

//超時

if(System.currentTimeMillis() - startTime > timeout) {

thrownew TimeOutException("sh命令執(zhí)行超時:"+ cmd);

}

}

}

}catch (TimeOutException t) {

throwt;

}catch (Exception e) {

//result.append(e.getMessage());

logger.error("execCommand異常",e);

thrownew DeployException("ssh 異常",e);

}finally {

close(exec);

}

if(result.length() > 0)

result.deleteCharAt(result.length()- 1);

returnresult.toString();

}

測試執(zhí)行shell命令

運行結(jié)果：

這樣就和在原linux系統(tǒng)中一樣使用shell功能了。

4、創(chuàng)建sftp通道

publicstatic Channel openChannel(Session session, ChannelType channelType)throws DeployException {

Channelchannel;

try{

if(false == session.isConnected()) {

session.connect();

}

channel= session.openChannel(ChannelType.SFTP.getValue());

}catch (JSchException e) {

logger.error(session.getHost(),e);

thrownew DeployException("創(chuàng)建一個新的Channel異常");

}

try{

channel.connect();

}catch (JSchException e) {

logger.error(session.getHost(),e);

thrownew DeployException("創(chuàng)建一個新的Channel異常");

}

return(ChannelSftp)channel;

}

ChannelSftp類是JSch實現(xiàn)SFTP核心類，它包含了所有SFTP的方法，如：

put()：    文件上傳

get()：    文件下載

cd()：     進(jìn)入指定目錄

ls()：     得到指定目錄下的文件列表

rename()： 重命名指定文件或目錄

rm()：     刪除指定文件

mkdir()：  創(chuàng)建目錄

rmdir()：  刪除目錄

等等（這里省略了方法的參數(shù)，put和get都有多個重載方法，大家如需使用請看具體源代碼，這里篇幅有限就不一一列出。

JSch是以多線程方式連接，所以程序在connect后如果不disconnectchannel和session以及相關(guān)stream，進(jìn)程會一直等待，開發(fā)同事在編寫代碼時切記在使用完畢，須在最后finally中disconnect掉所有連接通道。

我們再次回顧總結(jié)下使用Jsch步驟:

1、new一個JSch對象；

2、從JSch對象中獲取Session，用于連接，并設(shè)置連接信息；

3、使用session對象調(diào)用opnChannel("xxx")打開通信信道，并連接；

4、后面就是不同的channel，不同的操作（常用的有三種通道，即ChannelShell、ChannelExec、ChannelSftp，前兩類用于執(zhí)行命令，后一種是用于上傳下載文件）在實際項目中，我們可以基于jsch實現(xiàn)java操作linux服務(wù)器執(zhí)行相應(yīng)的命令，或者上傳下發(fā)刪除文件以及遠(yuǎn)程調(diào)用腳本，最終達(dá)到實現(xiàn)項目自動化運維的這個小目標(biāo)。