org.apache.commons.net.MalformedServerReplyException: Could not parse response code. Server Reply: SSH-2.0-SSH

1、使用commons-net連接ftp報錯，如下所示：

org.apache.commons.net.MalformedServerReplyException: Could not parse response code.
Server Reply: SSH-2.0-SSH
    at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:344)
    at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:300)
    at org.apache.commons.net.ftp.FTP._connectAction_(FTP.java:438)
    at org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:962)
    at org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:950)
    at org.apache.commons.net.SocketClient._connect(SocketClient.java:244)
    at org.apache.commons.net.SocketClient.connect(SocketClient.java:202)
    at com.fline.security.adaptation.utils.FtpUtils.uploadFile(FtpUtils.java:63)
    at com.fline.security.adaptation.utils.FtpUtils.main(FtpUtils.java:29)

其中，使用的commons-net的maven依賴，如下所示：

<!-- https://mvnrepository.com/artifact/commons-net/commons-net -->
<dependency>
    <groupId>commons-net</groupId>
    <artifactId>commons-net</artifactId>
    <version>3.6</version>
</dependency>

案例代碼，參考：https://blog.csdn.net/tengdazhang770960436/article/details/43237369，如下所示：

package com.fline.security.adaptation.utils;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;

public class FtpUtils {

    public static void main(String[] args) throws Exception {

//        // =======上傳測試============
        String localFile = "C:\\Users\\bhlgo\\Downloads\\中國.txt";

        String url = "ip地址";
        int port = 端口號;
        String username = "賬號";
        String password = "密碼";
        String path = "目錄";
        String filename = "中國.txt";
        InputStream input = new FileInputStream(new File(localFile));

        uploadFile(url, port, username, password, path, filename, input);
//        // =======上傳測試============

        // =======下載測試============
//        String localPath = "D:\\";
//        String url = "192.168.120.133";
//        int port = 21;
//        String username ="ftpuser";
//        String password ="ftpuser";
//        String remotePath ="/data/admftp/kw";
//        String fileName = "test.txt";
//        downFile(url, port, username, password, remotePath, fileName, localPath);
        // =======下載測試============

    }

    /**
     * Description: 向FTP服務器上傳文件
     * 
     * @param url      FTP服務器 hostname
     * @param port     FTP服務器端口 默認端 21
     * @param username FTP登錄賬號
     * @param password FTP登錄密碼
     * @param path     FTP服務器保存目錄
     * @param filename 上傳到FTP服務器上的文件名
     * @param input    輸入流
     * @return 成功返回true，否則返回false
     */
    public static boolean uploadFile(String url, int port, String username, String password, String path,
            String filename, InputStream input) {
        boolean success = false;
        FTPClient ftp = new FTPClient();
        try {
            int reply;
            ftp.connect(url, port);// 連接FTP服務器
//            ftp.connect(url);//連接FTP服務器 
            // 如果采用默認端口，可以使用ftp.connect(url)的方式直接連接FTP服務器
            ftp.login(username, password);// 登錄
//            ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
//            ftp.setControlEncoding("GBK");
            reply = ftp.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                ftp.disconnect();
                return success;
            }
            ftp.changeWorkingDirectory(path);
            // 設置文件名上傳的編碼格式為 utf-8
            ftp.storeFile(new String(filename.getBytes("utf-8"), "iso-8859-1"), input);

            input.close();
            ftp.logout();
            success = true;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                }
            }
        }
        return success;
    }

    /**
     * Description: 從FTP服務器下載文件
     * 
     * @param url        FTP服務器hostname
     * @param port       FTP服務器端口
     * @param username   FTP登錄賬號
     * @param password   FTP登錄密碼
     * @param remotePath FTP服務器上的相對路徑
     * @param fileName   要下載的文件名
     * @param localPath  下載后保存到本地的路徑
     * @return
     */
    public static boolean downFile(String url, int port, String username, String password, String remotePath,
            String fileName, String localPath) {
        boolean success = false;
        FTPClient ftp = new FTPClient();
        try {
            int reply;
            ftp.connect(url, port);
            // 如果采用默認端口，可以使用ftp.connect(url)的方式直接連接FTP服務器
            ftp.login(username, password);// 登錄
            reply = ftp.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                ftp.disconnect();
                return success;
            }
            ftp.changeWorkingDirectory(remotePath);// 轉移到FTP服務器目錄
            FTPFile[] fs = ftp.listFiles();
            for (FTPFile ff : fs) {
                String remotFileName = new String(ff.getName().getBytes("iso-8859-1"), "utf-8");
                if (remotFileName.equals(fileName)) {
                    File localFile = new File(localPath + "/" + remotFileName);
                    OutputStream is = new FileOutputStream(localFile);
                    ftp.retrieveFile(ff.getName(), is);
                    is.close();
                }
            }

            ftp.logout();
            success = true;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                }
            }
        }
        return success;
    }

}

2、解決方法

　　使用com.jcraft.jsch.JSch提供的SSH解決方法，參考：https://www.cnblogs.com/biehongli/p/9780652.html。代碼如下：

package com.fline.aic.utils;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Properties;
import java.util.Vector;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;

/**
 *
 * @Description TODO
 * @author biehl
 * @Date 2018年10月11日 上午10:20:11
 *
 * 說明:exec用於執行命令;sftp用於文件處理
 */
public class SSHRemoteCall {

    // 私有的對象
    private static SSHRemoteCall sshRemoteCall;

    /**
     * 私有的構造方法
     */
    private SSHRemoteCall() {
    }

    // 懶漢式,線程不安全,適合單線程
    public static SSHRemoteCall getInstance() {
        if (sshRemoteCall == null) {
            sshRemoteCall = new SSHRemoteCall();
        }
        return sshRemoteCall;
    }

    // 懶漢式,線程安全,適合多線程
    public static synchronized SSHRemoteCall getInstance2() {
        if (sshRemoteCall == null) {
            sshRemoteCall = new SSHRemoteCall();
        }
        return sshRemoteCall;
    }

    private static final int DEFAULT_PORT = 22;// 默認端口號
    private int port;// 端口號

    private static String ipAddress = "192.168.110.130";// ip地址
    private static String userName = "root";// 賬號
    private static String password = "hadoop";// 密碼

    private Session session;// JSCH session
    private boolean logined = false;// 是否登陸

    /**
     * 構造方法,可以直接使用DEFAULT_PORT
     *
     * @param ipAddress
     * @param userName
     * @param password
     */
    public SSHRemoteCall(String ipAddress, String userName, String password) {
        this(ipAddress, DEFAULT_PORT, userName, password);
    }

    /**
     * 構造方法,方便直接傳入ipAddress,userName,password進行調用
     *
     * @param ipAddress
     * @param port
     * @param userName
     * @param password
     */
    public SSHRemoteCall(String ipAddress, int port, String userName, String password) {
        super();
        this.ipAddress = ipAddress;
        this.userName = userName;
        this.password = password;
        this.port = port;
    }

    /**
     * 遠程登陸
     *
     * @throws Exception
     */
    public void sshRemoteCallLogin(String ipAddress, String userName, String password) throws Exception {
        // 如果登陸就直接返回
        if (logined) {
            return;
        }
        // 創建jSch對象
        JSch jSch = new JSch();
        try {
            // 獲取到jSch的session, 根據用戶名、主機ip、端口號獲取一個Session對象
            session = jSch.getSession(userName, ipAddress, DEFAULT_PORT);
            // 設置密碼
            session.setPassword(password);

            // 方式一,通過Session建立連接
            // session.setConfig("StrictHostKeyChecking", "no");
            // session.connect();

            // 方式二,通過Session建立連接
            // java.util.Properties;
            Properties config = new Properties();
            config.put("StrictHostKeyChecking", "no");
            session.setConfig(config);// 為Session對象設置properties
            // session.setTimeout(3000);// 設置超時
            session.connect();//// 通過Session建立連接

            // 設置登陸狀態
            logined = true;
        } catch (JSchException e) {
            // 設置登陸狀態為false
            logined = false;
            throw new Exception(
                    "主機登錄失敗, IP = " + ipAddress + ", USERNAME = " + userName + ", Exception:" + e.getMessage());
        }
    }

    /**
     * 關閉連接
     */
    public void closeSession() {
        // 調用session的關閉連接的方法
        if (session != null) {
            // 如果session不為空,調用session的關閉連接的方法
            session.disconnect();
        }

    }

    /**
     * 執行相關的命令
     *
     * @param command
     * @throws IOException
     */
    public void execCommand(String command) throws IOException {
        InputStream in = null;// 輸入流(讀)
        Channel channel = null;// 定義channel變量
        try {
            // 如果命令command不等於null
            if (command != null) {
                // 打開channel
                //說明：exec用於執行命令;sftp用於文件處理
                channel = session.openChannel("exec");
                // 設置command
                ((ChannelExec) channel).setCommand(command);
                // channel進行連接
                channel.connect();
                // 獲取到輸入流
                in = channel.getInputStream();
                // 執行相關的命令
                String processDataStream = processDataStream(in);
                // 打印相關的命令
                System.out.println("1、打印相關返回的命令: " + processDataStream);
            }
        } catch (JSchException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (in != null) {
                in.close();
            }
            if (channel != null) {
                channel.disconnect();
            }
        }

    }

    /**
     * 對將要執行的linux的命令進行遍歷
     *
     * @param in
     * @return
     * @throws Exception
     */
    public String processDataStream(InputStream in) throws Exception {
        StringBuffer sb = new StringBuffer();
        BufferedReader br = new BufferedReader(new InputStreamReader(in));
        String result = "";
        try {
            while ((result = br.readLine()) != null) {
                sb.append(result);
                // System.out.println(sb.toString());
            }
        } catch (Exception e) {
            throw new Exception("獲取數據流失敗: " + e);
        } finally {
            br.close();
        }
        return sb.toString();
    }

    /**
     * 上傳文件 可參考:https://www.cnblogs.com/longyg/archive/2012/06/25/2556576.html
     *
     * @param directory
     *            上傳文件的目錄
     * @param uploadFile
     *            將要上傳的文件
     */
    public void uploadFile(String directory, String uploadFile) {
        try {
            // 打開channelSftp
            ChannelSftp channelSftp = (ChannelSftp) session.openChannel("sftp");
            // 遠程連接
            channelSftp.connect();
            // 創建一個文件名稱問uploadFile的文件
            File file = new File(uploadFile);
            // 將文件進行上傳(sftp協議)
            // 將本地文件名為src的文件上傳到目標服務器,目標文件名為dst,若dst為目錄,則目標文件名將與src文件名相同.
            // 采用默認的傳輸模式:OVERWRITE
            channelSftp.put(new FileInputStream(file), directory, ChannelSftp.OVERWRITE);
            // 切斷遠程連接
            channelSftp.exit();
            System.out.println("2、" + file.getName() + " 文件上傳成功.....");
        } catch (JSchException e) {
            e.printStackTrace();
        } catch (SftpException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }

    }

    /**
     * 下載文件 采用默認的傳輸模式：OVERWRITE
     *
     * @param src
     *            linux服務器文件地址
     * @param dst
     *            本地存放地址
     * @throws JSchException
     * @throws SftpException
     */
    public void fileDownload(String src, String dst) throws JSchException, SftpException {
        // src 是linux服務器文件地址,dst 本地存放地址
        ChannelSftp channelSftp = (ChannelSftp) session.openChannel("sftp");
        // 遠程連接
        channelSftp.connect();
        // 下載文件,多個重載方法
        channelSftp.get(src, dst);
        // 切斷遠程連接,quit()等同於exit(),都是調用disconnect()
        channelSftp.quit();
        // channelSftp.disconnect();
        System.out.println("3、" + src + " ,下載文件成功.....");
    }

    /**
     * 刪除文件
     *
     * @param directory
     *            要刪除文件所在目錄
     * @param deleteFile
     *            要刪除的文件
     * @param sftp
     * @throws SftpException
     * @throws JSchException
     */
    public void deleteFile(String directoryFile) throws SftpException, JSchException {
        // 打開openChannel的sftp
        ChannelSftp channelSftp = (ChannelSftp) session.openChannel("sftp");
        // 遠程連接
        channelSftp.connect();
        // 刪除文件
        channelSftp.rm(directoryFile);
        // 切斷遠程連接
        channelSftp.exit();
        System.out.println("4、" + directoryFile + " 刪除的文件.....");
    }

    /**
     * 列出目錄下的文件
     *
     * @param directory
     *            要列出的目錄
     * @param sftp
     * @return
     * @throws SftpException
     * @throws JSchException
     */
    public Vector listFiles(String directory) throws JSchException, SftpException {
        ChannelSftp channelSftp = (ChannelSftp) session.openChannel("sftp");
        // 遠程連接
        channelSftp.connect();
        // 顯示目錄信息
        Vector ls = channelSftp.ls(directory);
        System.out.println("5、" + ls);
        // 切斷連接
        channelSftp.exit();
        return ls;
    }

    public static void main(String[] args) {
        // 連接到指定的服務器
        try {
            // 1、首先遠程連接ssh
            SSHRemoteCall.getInstance().sshRemoteCallLogin(ipAddress, userName, password);
            // 打印信息
            System.out.println("0、連接192.168.110.130,ip地址: " + ipAddress + ",賬號: " + userName + ",連接成功.....");

            // 2、執行相關的命令
            // 查看目錄信息
            // String command = "ls /home/hadoop/package ";
            // 查看文件信息
            // String command = "cat /home/hadoop/package/test ";
            // 查看磁盤空間大小
            // String command = "df -lh ";
            // 查看cpu的使用情況
            // String command = "top -bn 1 -i -c ";
            // 查看內存的使用情況
            String command = "free ";
            SSHRemoteCall.getInstance().execCommand(command);

            // 3、上傳文件
            String directory = "/home/hadoop/package/poi.xlsx";// 目標文件名
            String uploadFile = "E:\\poi.xlsx";// 本地文件名
            SSHRemoteCall.getInstance().uploadFile(directory, uploadFile);

            // 4、下載文件
            // src 是linux服務器文件地址,dst 本地存放地址,采用默認的傳輸模式：OVERWRITE
            //test為文件名稱哈
            String src = "/home/hadoop/package/test";
            String dst = "E:\\";
            SSHRemoteCall.getInstance().fileDownload(src, dst);

            // 5、刪除文件
            String deleteDirectoryFile = "/home/hadoop/package/test";
            SSHRemoteCall.getInstance().deleteFile(deleteDirectoryFile);

            // 6、展示目錄下的文件信息
            String lsDirectory = "/home/hadoop/package";
            SSHRemoteCall.getInstance().listFiles(lsDirectory);

            // 7、關閉連接
            SSHRemoteCall.getInstance().closeSession();
        } catch (Exception e) {
            // 打印錯誤信息
            System.err.println("遠程連接失敗......");
            e.printStackTrace();
        }
    }

}