SFtp文件处理

最近工作涉及sftp处理文件，写了个工具类，代码已经测试。请需要的同仁自行下载，根据自己需要，修改加工。附件有参考源码及必要jar包。

package nontax.helper;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
 
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 Tonny
 * @since Apr.27 2012
 *
 */
public class SFtpHelper {
	private  JSch jSch = null;
	private  ChannelSftp sftp = null;//sftp主服务
	private  Channel channel = null;
	private  Session session = null;
	
	private  String hostName="127.0.0.1";//远程服务器地址
	private  int    port=22;//端口
	private  String userName="Tonny";//用户名
	private  String password="123";//密码
	public SFtpHelper(String hostName, int port, String userName,
		   String password){
		   this.hostName=hostName;
		   this.port=port;
		   this.userName=userName;
		   this.password=password;
	}
 
	/**
	 * 连接登陆远程服务器
	 * @return
	 */
	public  boolean connect() throws Exception{
		try {
			jSch= new JSch();
			session = jSch.getSession(userName, hostName, port);
			session.setPassword(password);
			
			session.setConfig(this.getSshConfig());
			session.connect();
 
			channel = session.openChannel("sftp");
			channel.connect();
 
			sftp = (ChannelSftp) channel;
			System.out.println("登陆成功:"+sftp.getServerVersion());
			
		} catch (JSchException e) {
			System.err.println("SSH方式连接FTP服务器时有JSchException异常!");
			System.err.println(e.getMessage());
			throw e;
		}
		return true;
	}
	/**
	 * 关闭连接
	 * @throws Exception
	 */
	private void  disconnect() throws Exception {
		try{
			if (sftp.isConnected()) {
				sftp.disconnect();
			}
			if (channel.isConnected()) {
				channel.disconnect();
			}
			if (session.isConnected()) {
				session.disconnect();
			}
		}catch(Exception e){
			throw e;
		}
	 }
	 

	/**
	 * 获取服务配置
	 * @return
	 */
	private Properties getSshConfig()throws Exception{
		Properties sshConfig=null;
		try{
			sshConfig = new Properties();
			sshConfig.put("StrictHostKeyChecking", "no");
			
		}catch(Exception e){
			throw e;
		}
		return sshConfig;
	}
    /**
     * 下载远程sftp服务器文件
     * @param remotePath
     * @param remoteFilename
     * @param localFilename
     * @return
     */
	public  boolean downloadFile(String remotePath,
			String remoteFilename,String localFilename)throws SftpException,
			IOException, Exception{
		FileOutputStream output = null;
		boolean success = false;
		try {
			if (null != remotePath && remotePath.trim() != "") {
				sftp.cd(remotePath);
			}
 
			File localFile = new File(localFilename);
			//有文件和下载文件重名
			if (localFile.exists()) {
				System.err.println("文件: " + localFilename + " 已经存在!");
				return success;
			}
			output = new FileOutputStream(localFile);
			sftp.get(remoteFilename, output);
			success = true;
			System.out.println("成功接收文件,本地路径："+localFilename);
		} catch (SftpException e) {
			System.err.println("接收文件时有SftpException异常!");
			System.err.println(e.getMessage());
			return success;
		} catch (IOException e) {
			System.err.println("接收文件时有I/O异常!");
			System.err.println(e.getMessage());
			return success;
		} finally {
			try {
				if (null != output) {
					output.close();
				}
				//关闭连接
				disconnect();
			} catch (IOException e) {
				System.err.println("关闭文件时出错!");
				System.err.println(e.getMessage());
			}
		}
		return success;
	}
    /**
     * 上传文件至远程sftp服务器
     * @param remotePath
     * @param remoteFilename
     * @param localFileName
     * @return
     */
	public  boolean uploadFile(String remotePath,
			String remoteFilename, String localFileName)throws SftpException,Exception  {
		boolean success = false;
		FileInputStream fis=null;
		try {
			// 更改服务器目录
			if (null != remotePath && remotePath.trim() != "") {
				sftp.cd(remotePath);
			}
			File localFile = new File(localFileName);
			fis = new FileInputStream(localFile);
			// 发送文件
			sftp.put(fis, remoteFilename);
			success = true;
			System.out.println("成功发送文件,本地路径："+localFileName);
		} catch (SftpException e) {
			System.err.println("发送文件时有SftpException异常!");
			e.printStackTrace();
			System.err.println(e.getMessage());
			throw e;
		} catch (Exception e) {
			System.err.println("发送文件时有异常!");
			System.err.println(e.getMessage());
			throw e;
		} finally {
			try {
				if (null != fis) {
					fis.close();
				}
				//关闭连接
				disconnect();
			} catch (IOException e) {
				System.err.println("关闭文件时出错!");
				System.err.println(e.getMessage());
			}
		}
		return success;
	}
 
	 /**
     * 上传文件至远程sftp服务器
     * @param remotePath
     * @param remoteFilename
     * @param input
     * @return
     */
	public  boolean uploadFile(String remotePath,
			String remoteFilename, InputStream input)throws SftpException,Exception  {
		boolean success = false;
		try {
			// 更改服务器目录
			if (null != remotePath && remotePath.trim() != "") {
				sftp.cd(remotePath);
			}
 
			// 发送文件
			sftp.put(input, remoteFilename);
			success = true;
		} catch (SftpException e) {
			System.err.println("发送文件时有SftpException异常!");
			e.printStackTrace();
			System.err.println(e.getMessage());
			throw e;
		} catch (Exception e) {
			System.err.println("发送文件时有异常!");
			System.err.println(e.getMessage());
			throw e;
		} finally {
			try {
				if (null != input) {
					input.close();
				}
				//关闭连接
				disconnect();
			} catch (IOException e) {
				System.err.println("关闭文件时出错!");
				System.err.println(e.getMessage());
			}
	
		}
		return success;
	}
	/**
	 * 删除远程文件
	 * @param remotePath
	 * @param remoteFilename
	 * @return
	 * @throws Exception 
	 */
	public  boolean deleteFile(String remotePath, String remoteFilename) throws Exception {
		boolean success = false;
		try {
			// 更改服务器目录
			if (null != remotePath && remotePath.trim() != "") {
				sftp.cd(remotePath);
			}
 
			// 删除文件
			sftp.rm(remoteFilename);
			System.err.println("删除远程文件"+remoteFilename+"成功!");
			success = true;
		} catch (SftpException e) {
			System.err.println("删除文件时有SftpException异常!");
			e.printStackTrace();
			System.err.println(e.getMessage());
			return success;
		} catch (Exception e) {
			System.err.println("删除文件时有异常!");
			System.err.println(e.getMessage());
			return success;
		} finally {
			//关闭连接
			disconnect();
		}
		return success;
	}

	public String getHostName() {
		return hostName;
	}

	public void setHostName(String hostName) {
		this.hostName = hostName;
	}

	public int getPort() {
		return port;
	}

	public void setPort(int port) {
		this.port = port;
	}

	public String getUserName() {
		return userName;
	}

	public void setUserName(String userName) {
		this.userName = userName;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}
	/**
	 *测试方法
	 *
	 */
	public static void main(String [] args){
		try{
			SFtpHelper  sftp=new SFtpHelper("192.168.1.2",22,"ftp","sftp_test");
			System.out.println(new StringBuffer().append(" 服务器地址: ").append(sftp.getHostName()).append(" 端口：")
					   .append(sftp.getPort()).append("用户名：").append(sftp.getUserName()).append("密码:")
						 .append(sftp.getPassword().toString()));
			sftp.connect();
//			sftp.downloadFile("\\", "test.txt", "D:\\work\\test.txt");
//			sftp.uploadFile("\\", "test.txt", "D:\\work\\readMe.txt");
//			sftp.deleteFile("\\", "test.txt");
		}catch(Exception e){
			System.out.println("异常信息：" + e.getMessage());
		}
	}
}