使用JSch实现SFTP文件传输

一、实例代码 

package com.summer.util;import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
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;
import com.jcraft.jsch.SftpException;/*** 通过SFTP通道实现文件的上传与下载* * @author Administrator* */
public class SFTPUtil {private Logger log = Logger.getLogger(SFTPUtil.class);private static Session session;private static Channel channel;private static ChannelSftp sftp;/*** 创建SFTP通道* * @param username*            访问SFTP服务器的用户名* @param host*            SFTP服务器的IP* @param port*            SFTP服务器的端口号* @param password*            访问SFTP服务器的密码* @param timeOut*            访问SFTP服务器超时时间,单位：毫秒*/public ChannelSftp getSFTPConnection(String username, String host,int port, String password, int timeOut) {try {JSch jsch = new JSch();// 参数为sftp服务器的IP、PORT、USERNAME、PASSWORD// getSession(String username, String host, int port), 默认端口号是22session = jsch.getSession(username, host, port);session.setPassword(password);Properties config = new Properties();// Jsch优先使用RSA key type密钥的方式登陆// 此处使用用户名和密码方式登录config.put("StrictHostKeyChecking", "no");session.setConfig(config);// 设置访问超时时间session.connect(timeOut);log.info("连接会话开启成功！");// 创建sftp通信通道channel = session.openChannel("sftp");channel.connect();log.info("SFTP连接成功");sftp = (ChannelSftp) channel;// sftp.quit();} catch (JSchException e) {log.error("创建sftp通道失败");log.error(e.getMessage());} finally {// sftp通道需返回给调用者，所以fianlly中不能关闭，需在调用后关闭/** if (sftp != null) sftp.disconnect(); if (channel != null)* channel.disconnect(); if (session != null) session.disconnect();*/}return sftp;}/*** 使用SFTP通道上传文件* * @param sftp* @param sourceFile*            要上传的源文件* @param destFile*            目标文件* @return 上传成功返回true，失败返回false*/public boolean fileUpload(ChannelSftp sftp, String sourceFile,String destFile) {OutputStream outstream = null;InputStream instream = null;try {// 以下代码实现从本地上传一个文件到服务器/usr/uploadFileName.txt文件，如果要实现下载，对换以下流就可以了outstream = sftp.put(destFile);instream = new FileInputStream(new File(sourceFile));byte b[] = new byte[1024];int n;while ((n = instream.read(b)) != -1) {outstream.write(b, 0, n);}outstream.flush();log.info("文件上传成功");return true;// sftp.disconnect();// sftp.quit();} catch (IOException e) {log.error("文件上传失败");log.error(e.getMessage());return false;} catch (SftpException e) {log.error("文件上传失败");log.error(e.getMessage());return false;} finally {try {if (instream != null)instream.close();if (outstream != null)outstream.close();if (sftp != null)sftp.disconnect();} catch (IOException e) {log.error("关闭流失败");log.error(e.getMessage());}}}/*** 断开连接，关闭资源*/public void close() {if (sftp != null)sftp.disconnect();if (channel != null)channel.disconnect();if (session != null)session.disconnect();}/*** 测试* @param args*/public static void main(String[] args) {SFTPUtil util = new SFTPUtil();ChannelSftp sftp = util.getSFTPConnection("root", "192.168.11.1", 22,"root", 30000);util.fileUpload(sftp, "C:/svn=.txt", "/usr/test.txt");util.close();}}

二、JSch实现SFTP功能一些主要类的介绍