java 遠(yuǎn)程執(zhí)行Shell命令-通過Jsch連接

JSch是Java Secure Channel的縮寫驱犹。JSch是一個SSH2的純Java實現(xiàn)匹厘。它允許你連接到一個SSH服務(wù)器,并且可以使用端口轉(zhuǎn)發(fā)维哈,X11轉(zhuǎn)發(fā)绳姨,文件傳輸?shù)龋?dāng)然你也可以集成它的功能到你自己的應(yīng)用程序阔挠。

本文只介紹如何使用JSch實現(xiàn)的SFTP功能飘庄。

SFTP是Secure File Transfer Protocol的縮寫,安全文件傳送協(xié)議购撼」蛳鳎可以為傳輸文件提供一種安全的加密方法。SFTP 為 SSH的一部份迂求,是一種傳輸文件到服務(wù)器的安全方式碾盐。SFTP是使用加密傳輸認(rèn)證信息和傳輸?shù)臄?shù)據(jù),所以揩局,使用SFTP是非常安全的毫玖。但是,由于這種傳輸方式使用了加密/解密技術(shù),所以傳輸效率比普通的FTP要低得多付枫,如果您對網(wǎng)絡(luò)安全性要求更高時烹玉,可以使用SFTP代替FTP。(來自百度的解釋)

要使用JSch阐滩,需要下載它的jar包春霍,請從官網(wǎng)下載它:http://www.jcraft.com/jsch/

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

put(): 文件上傳

get(): 文件下載

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

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

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

rm(): 刪除指定文件

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

rmdir(): 刪除目錄

等等(這里省略了方法的參數(shù)址儒,put和get都有多個重載方法,具體請看源代碼衅疙,這里不一一列出莲趣。)

JSch支持三種文件傳輸模式:

傳輸模式名 描述
OVERWRITE 完全覆蓋模式,這是JSch的默認(rèn)文件傳輸模式饱溢,即如果目標(biāo)文件已經(jīng)存在喧伞,傳輸?shù)奈募⑼耆采w目標(biāo)文件,產(chǎn)生新的文件绩郎。
RESUME 恢復(fù)模式潘鲫,如果文件已經(jīng)傳輸一部分,這時由于網(wǎng)絡(luò)或其他任何原因?qū)е挛募鬏斨袛嗬哒龋绻乱淮蝹鬏斚嗤奈募嚷兀瑒t會從上一次中斷的地方續(xù)傳。
APPEND 追加模式状植,如果目標(biāo)文件已存在浊竟,傳輸?shù)奈募⒃谀繕?biāo)文件后追加。

1津畸、引入jar包

<dependency>
 <groupId>com.jcraft</groupId>
 <artifactId>jsch</artifactId>
 <version>0.1.54</version> 
</dependency>

2振定、實際例子

package com.bluemoon.executor.core.executor;

import com.bluemoon.executor.core.log.XxlJobLogger;
import com.jcraft.jsch.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.nio.charset.Charset;

public class JSchExecutor {
    private static Logger log = LoggerFactory.getLogger(JSchExecutor.class);

    private String charset = "UTF-8"; // 設(shè)置編碼格式
    private String user; // 用戶名
    private String passwd; // 登錄密碼
    private String host; // 主機IP
    private int port = 22; //默認(rèn)端口
    private JSch jsch;
    private Session session;

    private ChannelSftp sftp;

    /**
     *
     * @param user 用戶名
     * @param passwd 密碼
     * @param host 主機IP
     */
    public JSchExecutor(String user, String passwd, String host ) {
        this.user = user;
        this.passwd = passwd;
        this.host = host;
    }

    /**
     *
     * @param user 用戶名
     * @param passwd 密碼
     * @param host 主機IP
     */
    public JSchExecutor(String user, String passwd, String host , int port ) {
        this.user = user;
        this.passwd = passwd;
        this.host = host;
        this.port = port;
    }

    /**
     * 連接到指定的IP
     *
     * @throws JSchException
     */
    public void connect() throws JSchException {
        jsch = new JSch();
        session = jsch.getSession(user, host, port);
        session.setPassword(passwd);
        java.util.Properties config = new java.util.Properties();
        config.put("StrictHostKeyChecking", "no");
        session.setConfig(config);
        session.connect();
        Channel channel = session.openChannel("sftp");
        channel.connect();
        sftp = (ChannelSftp) channel;
        log.info("連接到SFTP成功。host: " + host);
    }
    /**
     * 關(guān)閉連接
     */
    public void disconnect(){
        if (sftp != null && sftp.isConnected()) {
            sftp.disconnect();
        }
        if(session != null && session.isConnected()){
            session.disconnect();
        }
    }
    /**
     * 執(zhí)行一條命令
     */
    public int execCmd(String command) throws Exception{
        XxlJobLogger.log( "開始執(zhí)行命令:" + command);
        int returnCode  = -1;
        BufferedReader reader = null;
        Channel channel = null;

        channel = session.openChannel("exec");
        ((ChannelExec) channel).setCommand(command);
        channel.setInputStream(null);
        ((ChannelExec) channel).setErrStream(System.err);
        InputStream in = channel.getInputStream();
        reader = new BufferedReader(new InputStreamReader(in));//中文亂碼貌似這里不能控制肉拓,看連接的服務(wù)器的

        channel.connect();
        System.out.println("The remote command is: " + command);
        String buf ;
        while ((buf = reader.readLine()) != null) {
            XxlJobLogger.log(buf);
        }
        reader.close();
        // Get the return code only after the channel is closed.
        if (channel.isClosed()) {
            returnCode = channel.getExitStatus();
        }
        XxlJobLogger.log( "Exit-status:" + returnCode );

       /* StringBuffer buf = new StringBuffer( 1024 );
        byte[] tmp = new byte[ 1024 ];
        while ( true ) {
            while ( in.available() > 0 ) {
                int i = in.read( tmp, 0, 1024 );
                if ( i < 0 ) break;
                buf.append( new String( tmp, 0, i ) );
            }
            if (  channel.isClosed() ) {
                res = channel.getExitStatus();
                XxlJobLogger.log( "Exit-status:" + res );
                System.out.println( "Exit-status:" + res );
                break;
            }
            TimeUnit.MILLISECONDS.sleep(100);
        }
        XxlJobLogger.log( buf.toString() );*/

        channel.disconnect();
        return returnCode;
    }

    /**
     * 執(zhí)行相關(guān)的命令
     */
    public void execCmd() {
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

        String command = "";
        BufferedReader reader = null;
        Channel channel = null;

        try {
            while ((command = br.readLine()) != null) {
                channel = session.openChannel("exec");
                ((ChannelExec) channel).setCommand(command);
                channel.setInputStream(null);
                ((ChannelExec) channel).setErrStream(System.err);

                channel.connect();
                InputStream in = channel.getInputStream();
                reader = new BufferedReader(new InputStreamReader(in,
                        Charset.forName(charset)));
                String buf = null;
                while ((buf = reader.readLine()) != null) {
                    System.out.println(buf);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (JSchException e) {
            e.printStackTrace();
        } finally {
            try {
                reader.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            channel.disconnect();
        }
    }

    /**
     * 上傳文件
     */
    public void uploadFile(String local,String remote) throws Exception {
        File file = new File(local);
        if (file.isDirectory()) {
            throw new RuntimeException(local + "  is not a file");
        }

        InputStream inputStream = null;
        try {
            String rpath = remote.substring(0,remote.lastIndexOf("/")+1);
            if (!isDirExist(rpath)){
                createDir(rpath);
            }
            inputStream = new FileInputStream(file);
            sftp.setInputStream(inputStream);
            sftp.put(inputStream, remote);
        } catch (Exception e) {
            throw e;
        }finally{
            if(inputStream != null){
                inputStream.close();
            }
        }
    }
    /**
     * 下載文件
     */
    public void downloadFile(String remote,String local) throws Exception{
        OutputStream outputStream = null;
        try {
            sftp.connect(5000);
            outputStream = new FileOutputStream(new File(local));
            sftp.get(remote, outputStream);
            outputStream.flush();
        } catch (Exception e) {
            throw e;
        }finally{
            if(outputStream != null){
                outputStream.close();
            }
        }
    }

    /**
     * 移動到相應(yīng)的目錄下
     * @param pathName 要移動的目錄
     * @return
     */
    public boolean changeDir(String pathName){
        if(pathName == null || pathName.trim().equals("")){
            log.debug("invalid pathName");
            return false;
        }
        try {
            sftp.cd(pathName.replaceAll("\\\\", "/"));
            log.debug("directory successfully changed,current dir=" + sftp.pwd());
            return true;
        } catch (SftpException e) {
            log.error("failed to change directory",e);
            return false;
        }
    }

    /**
     * 創(chuàng)建一個文件目錄后频,mkdir每次只能創(chuàng)建一個文件目錄
     * 或者可以使用命令mkdir -p 來創(chuàng)建多個文件目錄
     */
    public void createDir(String createpath) {
        try {
            if (isDirExist(createpath)) {
                sftp.cd(createpath);
                return;
            }
            String pathArry[] = createpath.split("/");
            StringBuffer filePath = new StringBuffer("/");
            for (String path : pathArry) {
                if (path.equals("")) {
                    continue;
                }
                filePath.append(path + "/");
                if (isDirExist(filePath.toString())) {
                    sftp.cd(filePath.toString());
                } else {
                    // 建立目錄
                    sftp.mkdir(filePath.toString());
                    // 進(jìn)入并設(shè)置為當(dāng)前目錄
                    sftp.cd(filePath.toString());
                }
            }
            sftp.cd(createpath);
        } catch (SftpException e) {
            throw new RuntimeException("創(chuàng)建路徑錯誤:" + createpath);
        }
    }


    /**
     * 判斷目錄是否存在
     * @param directory
     * @return
     */
    public boolean isDirExist(String directory)
    {
        boolean isDirExistFlag = false;
        try
        {
            SftpATTRS sftpATTRS = sftp.lstat(directory);
            isDirExistFlag = true;
            return sftpATTRS.isDir();
        }
        catch (Exception e)
        {
            if (e.getMessage().toLowerCase().equals("no such file"))
            {
                isDirExistFlag = false;
            }
        }
        return isDirExistFlag;
    }
  
}

3、用法

public static void main(String[] args) {
    JSchExecutor jSchUtil = new JSchExecutor( "user", "password#","192.168.243.21");
    try {
        jSchUtil.connect();
        jSchUtil.uploadFile("C:\\data\\applogs\\bd-job\\jobhandler\\2020-03-07\\employee.py","/data/applogs/bd-job-777/jobhandler/2018-09-15/employee.py");
        //jSchUtil.execCmd("python /data/bluemoon/kettle/runScript/ods/fact_org_employee.py 'so you is wahek 哈哈哈快遞放假塑料袋放進(jìn)了'");
        jSchUtil.execCmd("python /data/applogs/bd-job/jobhandler/gluesource/employee.py 中文名稱");
        //jSchUtil.execCmd("cat /data/applogs/bd-job/jobhandler/test");
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        jSchUtil.disconnect();
    }

}

4暖途、實時返回打印的日志
在實際開發(fā)中卑惜,需要執(zhí)行一個python文檔,里面含有多條的python語句丧肴,可能耗時1個小時才能執(zhí)行完残揉,這種情況需要能夠?qū)崟r的返回日志信息胧后,看看python到底執(zhí)行到哪一步芋浮。
使用ChannelShell可與服務(wù)器保持連接狀態(tài),可交互信息
用法:

 /**
     * 實時打印日志信息
     */
    public int shellCmd(String command) throws Exception{
        XxlJobLogger.log( "開始執(zhí)行命令:" + command);
        int returnCode  = -1;
        ChannelShell channel=(ChannelShell) session.openChannel("shell");
        InputStream in = channel.getInputStream();
        channel.setPty(true);
        channel.connect();
        OutputStream os = channel.getOutputStream();
        os.write((command + "\r\n").getBytes());
        os.write("exit\r\n".getBytes());
        os.flush();
        XxlJobLogger.log("The remote command is:{}" ,command);
        byte[] tmp=new byte[1024];
        while(true) {
            while (in.available() > 0) {
                int i = in.read(tmp, 0, 1024);
                if (i < 0) break;
                XxlJobLogger.log(new String(tmp, 0, i));
            }
            if (channel.isClosed()) {
                if (in.available() > 0) continue;
                returnCode = channel.getExitStatus();
                XxlJobLogger.log("exit-status: " + channel.getExitStatus());
                break;
            }
            try{Thread.sleep(1000);}catch(Exception ee){}
        }
        os.close();
        in.close();
        channel.disconnect();
        session.disconnect();
        return returnCode;
    }

參考:https://www.cnblogs.com/longyg/archive/2012/06/25/2556576.html

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市纸巷,隨后出現(xiàn)的幾起案子镇草,更是在濱河造成了極大的恐慌,老刑警劉巖瘤旨,帶你破解...
    沈念sama閱讀 211,561評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件梯啤,死亡現(xiàn)場離奇詭異,居然都是意外死亡存哲,警方通過查閱死者的電腦和手機因宇,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,218評論 3 385
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來祟偷,“玉大人察滑,你說我怎么就攤上這事⌒蕹Γ” “怎么了贺辰?”我有些...
    開封第一講書人閱讀 157,162評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長嵌施。 經(jīng)常有香客問我饲化,道長,這世上最難降的妖魔是什么吗伤? 我笑而不...
    開封第一講書人閱讀 56,470評論 1 283
  • 正文 為了忘掉前任吃靠,我火速辦了婚禮,結(jié)果婚禮上足淆,老公的妹妹穿的比我還像新娘撩笆。我一直安慰自己,他們只是感情好缸浦,可當(dāng)我...
    茶點故事閱讀 65,550評論 6 385
  • 文/花漫 我一把揭開白布夕冲。 她就那樣靜靜地躺著,像睡著了一般裂逐。 火紅的嫁衣襯著肌膚如雪歹鱼。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,806評論 1 290
  • 那天卜高,我揣著相機與錄音弥姻,去河邊找鬼。 笑死掺涛,一個胖子當(dāng)著我的面吹牛庭敦,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播薪缆,決...
    沈念sama閱讀 38,951評論 3 407
  • 文/蒼蘭香墨 我猛地睜開眼秧廉,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起疼电,我...
    開封第一講書人閱讀 37,712評論 0 266
  • 序言:老撾萬榮一對情侶失蹤嚼锄,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后蔽豺,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體区丑,經(jīng)...
    沈念sama閱讀 44,166評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,510評論 2 327
  • 正文 我和宋清朗相戀三年修陡,在試婚紗的時候發(fā)現(xiàn)自己被綠了沧侥。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,643評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡魄鸦,死狀恐怖正什,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情号杏,我是刑警寧澤婴氮,帶...
    沈念sama閱讀 34,306評論 4 330
  • 正文 年R本政府宣布,位于F島的核電站盾致,受9級特大地震影響主经,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜庭惜,卻給世界環(huán)境...
    茶點故事閱讀 39,930評論 3 313
  • 文/蒙蒙 一罩驻、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧护赊,春花似錦惠遏、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,745評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至判耕,卻和暖如春透绩,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背壁熄。 一陣腳步聲響...
    開封第一講書人閱讀 31,983評論 1 266
  • 我被黑心中介騙來泰國打工帚豪, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人草丧。 一個月前我還...
    沈念sama閱讀 46,351評論 2 360
  • 正文 我出身青樓狸臣,卻偏偏與公主長得像,于是被迫代替她去往敵國和親昌执。 傳聞我的和親對象是個殘疾皇子烛亦,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,509評論 2 348

推薦閱讀更多精彩內(nèi)容