java使用SFTP上传文件到资源服务器

package cn.test.util; import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.text.SimpleDateFormat;import java.util.Date;import java.util.Properties;import java.util.Vector; import javax.servlet.http.HttpServletRequest; import com.jcraft.jsch.Channel;import com.jcraft.jsch.ChannelSftp;import com.jcraft.jsch.JSch;import com.jcraft.jsch.Session;import com.jcraft.jsch.SftpException; public class MySFTP {  /** * 连接sftp服务器 * @param host 主机 * @param port 端口 * @param username 用户名 * @param password 密码 */ public ChannelSftp connect(String host, int port, String username,  String password) { ChannelSftp sftp = null; try {  JSch jsch = new JSch();  jsch.getSession(username, host, port);  Session sshSession = jsch.getSession(username, host, port);  sshSession.setPassword(password);  Properties sshConfig = new Properties();  sshConfig.put("StrictHostKeyChecking", "no");  sshSession.setConfig(sshConfig);  sshSession.connect();  Channel channel = sshSession.openChannel("sftp");  channel.connect();  sftp = (ChannelSftp) channel; } catch (Exception e) {   } return sftp; }  /** * 上传文件 *  * @param directory *      上传的目录 * @param uploadFile *      要上传的文件 * @param sftp */ public void upload(String directory, String uploadFile, ChannelSftp sftp) { try {  sftp.cd(directory);  File file = new File(uploadFile);  sftp.put(new FileInputStream(file), file.getName()); } catch (Exception e) {  e.printStackTrace(); } }  /** * 下载文件 *  * @param directory *      下载目录 * @param downloadFile *      下载的文件 * @param saveFile *      存在本地的路径 * @param sftp */ public void download(String directory, String downloadFile,  String saveFile, ChannelSftp sftp) { try {  sftp.cd(directory);  File file = new File(saveFile);  sftp.get(downloadFile, new FileOutputStream(file)); } catch (Exception e) {  e.printStackTrace(); } }  /** * 删除文件 *  * @param directory *      要删除文件所在目录 * @param deleteFile *      要删除的文件 * @param sftp */ public void delete(String directory, String deleteFile, ChannelSftp sftp) { try {  sftp.cd(directory);  sftp.rm(deleteFile); } catch (Exception e) {  e.printStackTrace(); } }  public void uploadSFTP(HttpServletRequest request,String[] uploadFiles) throws Exception {  MySFTP mySFTP = new MySFTP();  SFTPUtil sFTPUtil =new SFTPUtil();  ChannelSftp sftp = null;  Session session = null; try {  sftp = mySFTP.connect(SystemConstants.SFTP_host, Integer.parseInt(SystemConstants.SFTP_port), SystemConstants.SFTP_username, SystemConstants.SFTP_password);   for (int i = 0; i < uploadFiles.length; i++) {   Date uploadTime = new Date();   String url=request.getSession().getServletContext().getRealPath("").replaceAll("////", "/");    String uploadFile =url.substring(0, url.lastIndexOf("/"))+uploadFiles[i];//   String saveFile="";   SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");   String ymd = sdf.format(uploadTime);   String relativePath = ymd + "/";   String directory = SystemConstants.SFTP_directory+ relativePath;   sFTPUtil.createDir(directory, sftp);   mySFTP.upload(directory, uploadFile, sftp);   sftp.cd(directory);  }    } catch (Exception e) {   e.printStackTrace();  }finally{  try {   if(sftp != null) {   sftp.disconnect();   }  } catch (Exception e) {   e.printStackTrace();  }  try {   if(session != null) {   session.disconnect();   }  } catch (Exception e) {   e.printStackTrace();  }  }  }  /** * 列出目录下的文件 *  * @param directory *      要列出的目录 * @param sftp * @return * @throws SftpException */ @SuppressWarnings("rawtypes") public Vector listFiles(String directory, ChannelSftp sftp)  throws SftpException { return sftp.ls(directory); } }

package cn.test.util;  import java.text.SimpleDateFormat;import java.util.Date;import java.util.Random;  import org.springframework.web.multipart.MultipartFile;  import com.jcraft.jsch.ChannelSftp;import com.jcraft.jsch.Session;import com.jcraft.jsch.SftpATTRS;import com.jcraft.jsch.SftpException; /**文件上传工具类*/public class SFTPUtil { /** * spring文件上传方法 * */ public static String uploadMultipartFile(MultipartFile file,String fileExt) { SFTPUtil sFTPUtil =new SFTPUtil(); String originalFilename = file.getOriginalFilename(); //生成文件名 Date uploadTime = new Date();  SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");    String ymd = sdf.format(uploadTime);    String relativePath = ymd+"/"; SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss"); String fileName = df.format(uploadTime) + "_" + new Random().nextInt(1000) + "." + fileExt;// String fileName = String.valueOf(new Date().getTime())+ new Random().nextInt(10000)+"."+originalFilename.substring(originalFilename.lastIndexOf(".") + 1); String directory=SystemConstants.SFTP_directory+relativePath; ChannelSftp sftp =null; Session session = null; try {  MySFTP mySFTP = new MySFTP();  sftp = mySFTP.connect(SystemConstants.SFTP_host, Integer.parseInt(SystemConstants.SFTP_port), SystemConstants.SFTP_username, SystemConstants.SFTP_password);  session = sftp.getSession();  sFTPUtil.createDir(directory, sftp);  sftp.cd(directory);  sftp.put(file.getInputStream(), fileName);  sftp.disconnect();  sftp.getSession().disconnect(); } catch (Exception e) {  System.out.println("文件[" + originalFilename + "]上传失败,堆栈轨迹如下:");  e.printStackTrace(); }finally{  try {  if(sftp != null) {   sftp.disconnect();  }  } catch (Exception e) {  e.printStackTrace();  }  try {  if(session != null) {   session.disconnect();  }  } catch (Exception e) {  e.printStackTrace();    }     } String reName=SystemConstants.SFTP_httpBaseUrl+relativePath+fileName; return reName; }   /**  * 创建目录 * @throws Exception   */ public void createDir(String createpath, ChannelSftp sftp) throws Exception {   try {    if (isDirExist(sftp, createpath)) {    sftp.cd(createpath);    }    String pathArry[] = createpath.split("/");    StringBuffer filePath = new StringBuffer("/");    for (String path : pathArry) {    if (path.equals("")) {     continue;    }    filePath.append(path + "/");    if (isDirExist(sftp, filePath.toString())) {     sftp.cd(filePath.toString());    } else {     // 建立目录     sftp.mkdir(filePath.toString());     // 进入并设置为当前目录     sftp.cd(filePath.toString());    }    }    sftp.cd(createpath);   } catch (SftpException e) {   throw new Exception(e.getMessage());  }   }    /**   * 判断目录是否存在   */  public boolean isDirExist(ChannelSftp sftp,String directory) {   boolean isDirExistFlag = false;   try {   SftpATTRS sftpATTRS = sftp.lstat(directory);   isDirExistFlag = true;   return sftpATTRS.isDir();   } catch (Exception e) {   if (e.getMessage().toLowerCase().equals("no such file")) {    isDirExistFlag = false;   }   }   return isDirExistFlag;  } }