Jsch - Java实现的SFTP文件上传_jsch 上传限速

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

jar包:

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

 ChannelSftp类:

ChannelSftp类是JSch实现SFTP核心类，它包含了所有SFTP的方法，如：

put()：      文件上传

get()：      文件下载

cd()：       进入指定目录

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

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

rm()：       删除指定文件

mkdir()：    创建目录

rmdir()：    删除目录

JSch支持三种文件传输模式：

实现文件上传可以调用ChannelSftp对象的put方法。ChannelSftp中有12个put方法的重载方法：

创建ChannelSftp对象:

编写一个工具类，传入ip，用户名及密码得到一个SFTP channel对象，即ChannelSftp的实例对象，在应用程序中就可以使用该对象来调用SFTP的各种操作方法。

SFTPChannel.java

 
import java.util.Map;
import java.util.Properties;
 
import org.apache.log4j.Logger;
 
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
 
public class SFTPChannel {
    Session session = null;
    Channel channel = null;
 
    private static final Logger LOG = Logger.getLogger(SFTPChannel.class.getName());
 
    public ChannelSftp getChannel(Map<String, String> sftpDetails, int timeout) throws JSchException {
 
        String ftpHost = sftpDetails.get(SFTPConstants.SFTP_REQ_HOST);
        String port = sftpDetails.get(SFTPConstants.SFTP_REQ_PORT);
        String ftpUserName = sftpDetails.get(SFTPConstants.SFTP_REQ_USERNAME);
        String ftpPassword = sftpDetails.get(SFTPConstants.SFTP_REQ_PASSWORD);
 
        int ftpPort = SFTPConstants.SFTP_DEFAULT_PORT;
        if (port != null && !port.equals("")) {
            ftpPort = Integer.valueOf(port);
        }
 
        JSch jsch = new JSch(); // 创建JSch对象
        session = jsch.getSession(ftpUserName, ftpHost, ftpPort); // 根据用户名，主机ip，端口获取一个Session对象
        LOG.debug("Session created.");
        if (ftpPassword != null) {
            session.setPassword(ftpPassword); // 设置密码
        }
        Properties config = new Properties();
        config.put("StrictHostKeyChecking", "no");
        session.setConfig(config); // 为Session对象设置properties
        session.setTimeout(timeout); // 设置timeout时间
        session.connect(); // 通过Session建立链接
        LOG.debug("Session connected.");
 
        LOG.debug("Opening Channel.");
        channel = session.openChannel("sftp"); // 打开SFTP通道
        channel.connect(); // 建立SFTP通道的连接
        LOG.debug("Connected successfully to ftpHost = " + ftpHost + ",as ftpUserName = " + ftpUserName
                + ", returning: " + channel);
        return (ChannelSftp) channel;
    }
 
    public void closeChannel() throws Exception {
        if (channel != null) {
            channel.disconnect();
        }
        if (session != null) {
            session.disconnect();
        }
    }
}

SFTPConstants：

SFTPConstans.java

package com.longyg.sftp;
 
public class SFTPConstants {
    public static final String SFTP_REQ_HOST = "host";
    public static final String SFTP_REQ_PORT = "port";
    public static final String SFTP_REQ_USERNAME = "username";
    public static final String SFTP_REQ_PASSWORD = "password";
    public static final int SFTP_DEFAULT_PORT = 22;
    public static final String SFTP_REQ_LOC = "location";
}

简单实例方法：

 
    public void putResource(String firmwarePath,String name, byte[] data) {
        SFTPChannel channel = new SFTPChannel();
        Map<String, String> sftpDetails = new HashMap<String, String>();
        // 设置主机ip，端口，用户名，密码
        sftpDetails.put(SFTPConstants.SFTP_REQ_HOST, sshHostS);
        sftpDetails.put(SFTPConstants.SFTP_REQ_USERNAME, sshNameD);
        sftpDetails.put(SFTPConstants.SFTP_REQ_PASSWORD, sshPassD);
        sftpDetails.put(SFTPConstants.SFTP_REQ_PORT, sshPortD);
        ChannelSftp chSftp = null;
        try {
			chSftp = channel.getChannel(sftpDetails, 60000);
			chSftp.put(firmwarePath+name, firmwarePath+name, ChannelSftp.OVERWRITE);
		} catch (JSchException e) {
			logger.info("JSchException JSchException：" + e);
		} catch (Exception e) {
			logger.info("Exception Exception：" + e);
		}finally {
			chSftp.quit();
			try {
				channel.closeChannel();
			} catch (Exception e) {
			}
		}
    }

 

Jsch支持在文件传输时对传输进度的监控。可以实现JSch提供的SftpProgressMonitor接口来完成这个功能。由于业务不需要，此处省略，继续学习可以参考原文章。

 原文章参考：http://www.cnblogs.com/longyg/archive/2012/06/25/2556576.html