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

本文实例为大家分享了java实现SFTP上传文件到资源服务器工具类，供大家参考，具体内容如下

首先得创建连接sftp服务器的公共类MySftp.java：

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);
 }

}

上传图片时，调用SFTPUtil类中的uploadMultipartFile方法即可。

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;
 }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。