怎么在java中利用SFTP上傳文件到資源服務(wù)器

怎么在java中利用SFTP上傳文件到資源服務(wù)器？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來(lái)學(xué)習(xí)下，希望你能有所收獲。

首先得創(chuàng)建連接sftp服務(wù)器的公共類(lèi)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服務(wù)器
 * @param host 主機(jī)
 * @param port 端口
 * @param username 用戶(hù)名
 * @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
 *      要?jiǎng)h除文件所在目錄
 * @param deleteFile
 *      要?jiǎng)h除的文件
 * @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);
 }
 
}

上傳圖片時(shí)，調(diào)用SFTPUtil類(lèi)中的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;

 
/**文件上傳工具類(lèi)*/
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;
 }
 
 
 /**
  * 創(chuàng)建目錄
 * @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()); 
    // 進(jìn)入并設(shè)置為當(dāng)前目錄 
    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; 
 } 
}

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注億速云行業(yè)資訊頻道，感謝您對(duì)億速云的支持。