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

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

(0)

相关推荐

  • Java原生服务器接收上传文件 不使用MultipartFile类

    由于工作中 使用 MultipartFile 与现有的一些上传文件组件冲突 所以使用其他的接收上传文件的方法. 首先我把 MultipartFile 类的配置文件注释掉. <!-- <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"> <property name="defaul

  • Java实现ftp上传下载、删除文件及在ftp服务器上传文件夹的方法

    一个JAVA 实现FTP功能的代码,包括了服务器的设置模块,并包括有上传文件至FTP的通用方法.下载文件的通用方法以及删除文件.在ftp服务器上传文件夹.检测文件夹是否存在等,里面的有些代码对编写JAVA文件上传或许有参考价值,Java FTP主文件代码: package ftpDemo; import java.io.DataOutputStream; import java.io.InputStream; import java.io.OutputStream; import sun.net

  • java实现上传文件到服务器和客户端

    JAVA编写一个可以上传文件的服务器和客户端,具体内容如下 服务端 class Server { public static void main(String[] args) throws Exception { //建立服务端Socket ServerSocket ss = new ServerSocket(10005); //接收客户端Socket Socket fileLoaderSocket = ss.accept(); //打印连接信息 String ip = fileLoaderSo

  • Java远程连接Linux服务器并执行命令及上传文件功能

    最近再开发中遇到需要将文件上传到Linux服务器上,至此整理代码笔记. 此种连接方法中有考虑到并发问题,在进行创建FTP连接的时候将每一个连接对象存放至 ThreadLocal<Ftp> 中以确保每个线程之间对FTP的打开与关闭互不影响. package com.test.utils; import java.io.BufferedInputStream; import java.io.File; import java.io.FileFilter; import java.io.FileIn

  • Java上传文件到服务器端的方法

    Web文件上传采用POST的方式,与POST提交表单不同的是,上传文件需要设置FORM的enctype属性为multipart/form-data.由于上传的文件会比较大,因此需要设置该参数指定浏览器使用二进制上传.如果不设置,enctype属性默认为application/x-www-form-urlencoded,使用浏览器将使用ASCII向服务器发送数据,导致发送文件失败. 上传文件要使用文件域(<input type='file'/>,并把FORM的Enctype设置为multipar

  • Java实现上传文件图片到指定服务器目录

    具体代码如下所示: ***web.xml*** <?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xm

  • Java使用SFTP上传文件到服务器的简单使用

    最近用到SFTP上传文件查找了一些资料后自己做了一点总结,方便以后的查询.具体代码如下所示: /** * 将文件上传到服务器 * * @param filePath * 文件路径 * @param channelSftp * channelSftp对象 * @return */ public static boolean uploadFile(String filePath, ChannelSftp channelSftp) { OutputStream outstream = null; In

  • Java上传文件图片到服务器的方法

    这里我记录一个比较简单方便操作的JAVA上传文件图片到服务器并且保存,具体内容如下 首先是页面html的   我这是提交一个文件和类型 <div style="border: 1px solid red;"> 我是添加一张临时图片得到微信的media_id保存数据库! <form action="xxxxxxxxm" enctype="multipart/form-data" method="post">

  • java web FTPClient实现上传文件到指定服务器

    FPClient 实现上传文件到指定服务器,供大家参考,具体内容如下 调用 FileInputStream in=new FileInputStream(new File(fileUrl)); moveFile("10.3.3.**", 21, "username", "password", path, filename, in); 方法 /** * Description: 向FTP服务器上传文件 * @param url FTP服务器host

  • Java实现跨服务器上传文件功能

    前几天做个项目,本身客户端和管理员端是写在一起的,共用一台服务器,客户上传的文件都是存在服务器的硬盘上的.老龙提出要把客户端和管理员端分离,这时候用户上传的附件的存储就出现问题了.显然,把大到几百M的apk文件存到数据库不现实,查了半天,在两端建立ftp服务器传文件是最快的方法. 具体流程是,用户登录外网客户端,上传文件到外网的服务器硬盘上,在此同时,文件通过外网服务器访问内网管理员服务器的ftp服务器,传到内网服务器的硬盘上.这样内网服务器可以对上传的文件进行加密签名工作,之后也通过ftp的方

随机推荐