java的sftp文件传输_java使用SFTP上传文件到资源服务器方法详解
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;
}
}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持码农之家。
以上就是本次给大家分享的关于java的全部知识点内容总结,大家还可以在下方相关文章里找到相关文章进一步学习,感谢大家的阅读和支持。
java的sftp文件传输_java使用SFTP上传文件到资源服务器方法详解相关推荐
- java上传下载_Java文件上传与文件下载实现方法详解
本文实例讲述了Java文件上传与文件下载实现方法.分享给大家供大家参考,具体如下: Java文件上传 数据上传是客户端向服务器端上传数据,客户端向服务器发送的所有请求都属于数据上传.文件上传是数据上传 ...
- java中flush函数作用_Java语言中flush()函数作用及使用方法详解
最近在学习io流,发现每次都会出现flush()函数,查了一下其作用,起作用主要如下 //------–flush()的作用--------– 笼统且错误的回答: 缓冲区中的数据保存直到缓冲区满后才写 ...
- java 上传文件服务_java代码实现上传文件到文档服务器、下载文档服务器文件
需要完成下载->修改->上传这三个步骤 平台有提供对应的api吗? /** 首先我们来理解下关于文档的api 文档相关api都在这2个package下面 package :com.just ...
- python第三方库文件传输_python3 post方式上传文件。
import requests url = 'http://www.test.com/doFile.php' #url = 'http://www.test.com/doPost.php' #file ...
- 大文件传输解决方案:分片上传 / 下载限速
前言 不少项目中会遇到上传下载视频.更新包.应用程序等文件,此类文件的共同点就是十分巨大,我在项目中遇到过 4G 左右的文件同时 100 多台机器下载,此时如果用 post 上传和下载想一下都不可能, ...
- vue method ajax上传文件,前端上传文件追根溯源_和_antd_vue上传文件实例
背景 平,过现前个能文使近记接的端问对字用近记接时工作中经常会遇到需要上传文件的情况,如果你用ant design 或者element ,它们都提供了上传的组件. 我们分别来看一下element 和 ...
- xshell往linux传文件,Xshell向Linux服务器上传文件的详细步骤
相信Linux用户对Xshell远程管理软件都不陌生的,不过对于一些新手朋友来讲,向Linux服务器上传文件可能还存在难度,这里小编就分享了Xshell向Linux服务器上传文件的详细步骤,下面一起来 ...
- 在Ubuntu终端使用mkdir创建文件夹后Xftp不能上传文件到文件夹中的问题解决方法
问题描述 在Ubuntu终端上使用mkdir创建文件夹后使用Xftp上传文件失败 原因分析: 权限问题 解决方案: chmod 777 File
- java ssh 服务器文件传输_java使用SFTP上传文件到资源服务器
本文实例为大家分享了java实现SFTP上传文件到资源服务器工具类,供大家参考,具体内容如下 首先得创建连接sftp服务器的公共类MySftp.java: package cn.test.util; ...
最新文章
- 揭秘深度强化学习的研究哲学:乐观主义与悲观主义
- torch.Tensor和torch.tensor的区别
- 线上服务CPU100%问题快速定位实战--转
- 关于JavaScript语句后面的分号
- java文件不存在就创建_Java中创建并写文件的5种方式
- 案例讲清如何构建“What-if分析”,教你轻松玩转动态参数
- java.lang包有哪些类_Java中Lang包的工具类有哪些
- 是网关吗_智能家居网关功能这么多,你都知道吗?
- mysql 5.5 替换字符_MySQL replace函数替换字符串语句的用法
- py导入包异常跳出_Python:尝试从导入的包导入模块时出现“ModuleNotFoundError”
- Linux文件导出到Windows乱码的问题
- loadrunner 11 的下载和安装
- 人工鱼群算法及其python实现过程
- sql语句 两表关联查询计算数量
- 怎么把mov格式转换成mp4?
- php微信提现到零钱,PHP实现微信提现(企业付款到零钱)
- 30岁程序媛在一家公司工作八年后,告别“体制化”终于跳槽,别再妄想靠公司养老了!
- 无线上外网,有线上内网的方式
- 4.2.7. Aggregate Expressions
- Mezzanine多site管理问题