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

朱雀 2022-11-10 01:17 371阅读 0赞

本文实例为大家分享了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) \{