coder

SFTP和Channel

2018-05-20  本文已影响0人  小灰灰_加油

SFTP是Secure File Transfer Protocol的缩写,安全文件传送协议。可以为传输文件提供一种安全的加密方法。SFTP为SSH的一部份,是一种传输文件到服务器的安全方式。SFTP是使用加密传输认证信息和传输的数据,所以,使用SFTP是非常安全的。但是,由于这种传输方式使用了加密/解密技术,所以传输效率比普通的FTP要低得多,如果您对网络安全性要求更高时,可以使用SFTP代替FTP。

1.实现依赖Jsch-0.1.54.jar

可以在mvn repository 依赖到项目来,我使用的依赖如下:

<!-- https://mvnrepository.com/artifact/com.jcraft/jsch -->
<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.54</version>
</dependency>

2.引入Jar包之后,我们就先可配置化我们SFTP的一些参数

新建 config.properties

work order photo SFTP config.

sftp.ip=10.32.233.111
sftp.port=22
sftp.userName=root
sftp.password=kaifa123
sftp.timeout=60000
sftp.src=D:\ftpLocalFile
sftp.dst= /opt/soft/sftp/
sftp.retryTime=3
@see ConfigEntity#getSftpXXX() 方法将从config.properties文件读取相应配置信息

3.封装创建获得SFTP服务器的连接的方法及释放连接的方法

解释一下SFTP的整个调用过程,这个过程就是通过Ip、Port、Username、Password获取一个Session,然后通过Session打开SFTP通道(获得SFTP Channel对象),再在建立通道(Channel)连接,最后我们就是通过这个Channel对象来调用SFTP的各种操作方法.总是要记得,我们操作完SFTP需要手动断开Channel连接与Session连接。

直接贴相应的方法代码:
    /**
     * 获得SFTP Channel
     * @return ChannelSftp Instance
     * @throws JSchException
     */
    public ChannelSftp getChannel() throws JSchException {
        String ftpHost = config.getSftpIp();
        int ftpPort = config.getSftpPort();
        String ftpUserName = config.getSftpUserName();
        String ftpPassword = config.getSftpPassword();
        // 创建JSch对象
        JSch jsch = new JSch();
        // 根据用户名,主机ip,端口获取一个Session对象
        session = jsch.getSession(ftpUserName, ftpHost, ftpPort);
        //logger.info("Session created.");
        if (ftpPassword != null) {
            // 设置密码
            session.setPassword(ftpPassword);
        }
        Properties configTemp = new Properties();
        configTemp.put("StrictHostKeyChecking", "no");
        // 为Session对象设置properties
        session.setConfig(configTemp);
        // 设置timeout时间
        session.setTimeout(config.getSftpTimeout());
        session.connect();
        // 通过Session建立链接
        // 打开SFTP通道
        channel = session.openChannel("sftp");
        // 建立SFTP通道的连接
        channel.connect();
        logger.info("Connected successfully to ftpHost = " + ftpHost + ",as ftpUserName = " + ftpUserName + ", returning: " + channel);
        return (ChannelSftp) channel;
    }

    /**
     * 断开SFTP Channel、Session连接
     * @throws Exception
     */
    public void closeChannel() throws Exception {
        if (channel != null) {
            channel.disconnect();
        }
        if (session != null) {
            session.disconnect();
        }
        logger.info("disconnected SFTP successfully!");
    }

    @Autowired
    private ConfigEntity config; //Ignore this

4.调用代码示例

ChannelSftp chSftp = getChannel();
// 本地文件名
String src = config.getSftpLocalPath() + orderPhoto.getNewPhotoName();
// 目标文件名
String dst = config.getSftpDstPath() + orderPhoto.getNewPhotoName();
chSftp.put(src, dst, ChannelSftp.OVERWRITE);
chSftp.quit();
closeChannel();

Jsch-0.1.54.jar 学习了解

ChannelSftp类是JSch实现SFTP核心类,它包含了所有SFTP的方法,如:
文件上传put(),文件下载get(),进入指定目录cd().
得到指定目录下的文件列表ls().
重命名指定文件或目录rename().
删除指定文件rm(),创建目录mkdir(),删除目录rmdir().
大家引用方法时可以快速参考一下,具体传参需参考源码~

最后还要提一下的就是JSch支持的三种文件传输模式:

——–End Learning———-

二、Java实现FTP文件上传(一般是Windows使用)

直接上代码
/**
 * 连接到服务器
 * @return true 连接服务器成功,false 连接服务器失败
 */
    public boolean connectServer() {
        boolean flag = true;
        if (ftpClient == null) {
            int reply;
            try {
                if(true){
                    ftpClient = new FTPClient();
                    ftpClient.connect(config.getFtpIp(),config.getFtpPort());
                    ftpClient.login(config.getFtpUserName(), config.getFtpPassword());
                    reply = ftpClient.getReplyCode();
                    ftpClient.setDataTimeout(60000);
                    if (!FTPReply.isPositiveCompletion(reply)) {
                        ftpClient.disconnect();
                        logger.info("FTP server refuse connect!");
                        flag = false;
                    }
                }else{
                    flag = false;
                }
            } catch (SocketException e) {
                flag = false;
                e.printStackTrace();
                logger.info("Login ftp server " + config.getFtpIp() + " failed,connect timeout!");
                logger.error("Login ftp server " + config.getFtpIp() + " failed",e);
            } catch (IOException e) {
                flag = false;
                e.printStackTrace();
                logger.info("Login ftp server  " + config.getFtpIp() + " failed,FTP server couldn't open!");
                logger.error("Login ftp server " + config.getFtpIp() + " failed",e);
            }
        }
        return flag;
    }

    public boolean disConnectServer() {
        boolean flag = true;
        if (ftpClient != null) {
            try{
                ftpClient.logout();
                ftpClient.disconnect();
            }catch (Exception e){
                flag = false;
                logger.info("Disconnect ftp server  " + config.getFtpIp() + " failed!");
                logger.error("Disconnect ftp server  " + config.getFtpIp() + " failed",e);
            }
        }
        return flag;
    }

    /**
     * @param remoteFile
     * @param localFile
     * @return
     * @throws IOException
     */
    public boolean uploadFile(String remoteFile, File localFile)
            throws IOException {
        boolean flag = false;
     /*   File file = new File("D://"+UUID.randomUUID()+".jpg");
        if (!file.exists()) {
            file.createNewFile();
        }*/
        InputStream in = new FileInputStream(localFile);
        // IOUtils.copy(in,new FileOutputStream(file));
        //String remote = new String(remoteFile.getBytes("GBK"),"iso-8859-1");
        /*ftpClient.setBufferSize(1024*1024);
        ftpClient.setControlEncoding("utf-8");
        ftpClient.enterLocalPassiveMode();*/
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
        ftpClient.changeWorkingDirectory("/picture/pp");
        if (ftpClient.storeFile(remoteFile, in)) {
            flag = true;
            logger.info(localFile.getAbsolutePath() + "upload successfully!");
        } else {
            logger.info(localFile.getAbsolutePath() + "upload failed!");
        }
        in.close();
        return flag;
    }

    /**
     * 上传单个文件,并重命名
     * @param local  --本地文件路径
     * @param remote --本地文件父文件夹路径
     * @return true 上传成功,false 上传失败
     * @throws IOException
     */
    public boolean uploadFile(String local, String remote) throws IOException {
        boolean flag = true;
        String remoteFileName = remote;
        File f = new File(local);
        if (!uploadFile(remoteFileName, f)) {
            flag = false;
        }
        return flag;
    }
上一篇 下一篇

猜你喜欢

热点阅读