Java使用Sftp和Ftp实现对文件的上传和下载
sftp和ftp两种方式区别，还不清楚的，请自行百度查询，此处不多赘述。完整代码地址在结尾！！
第一步，导入maven依赖
<!-- FTP依赖包 --> <dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.6</version> </dependency> <!-- SFTP依赖包 --> <dependency> <groupId>com.jcraft</groupId> <artifactId>jsch</artifactId> <version>0.1.55</version> </dependency> <dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.6</version> </dependency>
第二步，创建并编写SftpUtils类，运行main方法查看效果，如下
import com.jcraft.jsch.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.util.Properties;
import java.util.Vector;
/**
* @Description: sftp上传下载工具类
* @Author: jinhaoxun
* @Date: 2020/1/16 16:13
* @Version: 1.0.0
*/
@Slf4j
public class SftpUtils {
public static void main(String[] args) throws Exception {
log.info("测试开始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
// 1
File file = new File("E:\\2.xlsx");
InputStream inputStream = new FileInputStream(file);
SftpUtils.uploadFile("", "", "", 22, "/usr/local",
"/testfile/", "test.xlsx", null, inputStream);
// 2
SftpUtils.downloadFile("", "", "", 22,null,
"/usr/local/testfile/", "test.csv","/Users/ao/Desktop/test.csv");
// 3
SftpUtils.deleteFile("", "", "", 22,null,
"/usr/local/testfile/", "test.xlsx");
// 4
Vector<?> fileList = SftpUtils.getFileList("", "", "",
22, null,"/usr/local/testfile/");
log.info(fileList.toString());
log.info("测试结束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
}
/**
* @Author: jinhaoxun
* @Description: 下载文件
* @param userName 用户名
* @param password 密码
* @param host ip
* @param port 端口
* @param basePath 根路径
* @param filePath 文件路径（加上根路径）
* @param filename 文件名
* @param privateKey 秘钥
* @param input 文件流
* @Date: 2020/1/16 21:23
* @Return: void
* @Throws: Exception
*/
public static void uploadFile(String userName, String password, String host, int port, String basePath,
String filePath, String filename, String privateKey, InputStream input) throws Exception {
Session session = null;
ChannelSftp sftp = null;
// 连接sftp服务器
try {
JSch jsch = new JSch();
if (privateKey != null) {
// 设置私钥
jsch.addIdentity(privateKey);
}
session = jsch.getSession(userName, host, port);
if (password != null) {
session.setPassword(password);
}
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
Channel channel = session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
} catch (JSchException e) {
e.printStackTrace();
}
// 将输入流的数据上传到sftp作为文件
try {
sftp.cd(basePath);
sftp.cd(filePath);
} catch (SftpException e) {
//目录不存在，则创建文件夹
String [] dirs=filePath.split("/");
String tempPath=basePath;
for(String dir:dirs){
if(null== dir || "".equals(dir)){
continue;
}
tempPath+="/"+dir;
try{
sftp.cd(tempPath);
}catch(SftpException ex){
sftp.mkdir(tempPath);
sftp.cd(tempPath);
}
}
}
//上传文件
sftp.put(input, filename);
//关闭连接 server
if (sftp != null) {
if (sftp.isConnected()) {
sftp.disconnect();
}
}
//关闭连接 server
if (session != null) {
if (session.isConnected()) {
session.disconnect();
}
}
}
/**
* @Author: jinhaoxun
* @Description: 下载文件
* @param userName 用户名
* @param password 密码
* @param host ip
* @param port 端口
* @param privateKey 秘钥
* @param directory 文件路径
* @param downloadFile 文件名
* @param saveFile 存在本地的路径
* @Date: 2020/1/16 21:22
* @Return: void
* @Throws: Exception
*/
public static void downloadFile(String userName, String password, String host, int port, String privateKey, String directory,
String downloadFile, String saveFile) throws Exception{
Session session = null;
ChannelSftp sftp = null;
// 连接sftp服务器
try {
JSch jsch = new JSch();
if (privateKey != null) {
// 设置私钥
jsch.addIdentity(privateKey);
}
session = jsch.getSession(userName, host, port);
if (password != null) {
session.setPassword(password);
}
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
Channel channel = session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
} catch (JSchException e) {
e.printStackTrace();
}
if (directory != null && !"".equals(directory)) {
sftp.cd(directory);
}
File file = new File(saveFile);
sftp.get(downloadFile, new FileOutputStream(file));
}
/**
* @Author: jinhaoxun
* @Description: 下载文件
* @param userName 用户名
* @param password 密码
* @param host ip
* @param port 端口
* @param privateKey 秘钥
* @param directory 文件路径
* @param downloadFile 文件名
* @Date: 2020/1/16 21:21
* @Return: byte[]
* @Throws: Exception
*/
public static byte[] downloadFile(String userName, String password, String host, int port, String privateKey,
String directory, String downloadFile) throws Exception{
Session session = null;
ChannelSftp sftp = null;
// 连接sftp服务器
try {
JSch jsch = new JSch();
if (privateKey != null) {
// 设置私钥
jsch.addIdentity(privateKey);
}
session = jsch.getSession(userName, host, port);
if (password != null) {
session.setPassword(password);
}
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
Channel channel = session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
} catch (JSchException e) {
e.printStackTrace();
}
if (directory != null && !"".equals(directory)) {
sftp.cd(directory);
}
InputStream is = sftp.get(downloadFile);
byte[] fileData = IOUtils.toByteArray(is);
return fileData;
}
/**
* @Author: jinhaoxun
* @Description: 删除文件
* @param userName 用户名
* @param password 密码
* @param host ip
* @param port 端口
* @param privateKey 秘钥
* @param directory 文件路径
* @param deleteFile 文件名
* @Date: 2020/1/16 21:24
* @Return: void
* @Throws: Exception
*/
public static void deleteFile(String userName, String password, String host, int port, String privateKey,
String directory, String deleteFile) throws Exception{
Session session = null;
ChannelSftp sftp = null;
// 连接sftp服务器
try {
JSch jsch = new JSch();
if (privateKey != null) {
// 设置私钥
jsch.addIdentity(privateKey);
}
session = jsch.getSession(userName, host, port);
if (password != null) {
session.setPassword(password);
}
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
Channel channel = session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
} catch (JSchException e) {
e.printStackTrace();
}
sftp.cd(directory);
sftp.rm(deleteFile);
}
/**
* @Author: jinhaoxun
* @Description: 列出目录下的文件
* @param userName 用户名
* @param password 密码
* @param host ip
* @param port 端口
* @param privateKey 秘钥
* @param directory 要列出的目录
* @Date: 2020/1/16 21:25
* @Return: java.util.Vector<?>
* @Throws: Exception
*/
public static Vector<?> getFileList(String userName, String password, String host, int port, String privateKey,
String directory) throws Exception {
Session session = null;
ChannelSftp sftp = null;
// 连接sftp服务器
try {
JSch jsch = new JSch();
if (privateKey != null) {
// 设置私钥
jsch.addIdentity(privateKey);
}
session = jsch.getSession(userName, host, port);
if (password != null) {
session.setPassword(password);
}
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
Channel channel = session.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
} catch (JSchException e) {
e.printStackTrace();
}
return sftp.ls(directory);
}
}
第三步，创建并编写FtpUtils类，运行main方法查看效果，如下
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import java.io.*;
/**
* @Description: ftp上传下载工具类
* @Author: jinhaoxun
* @Date: 2020/1/16 15:46
* @Version: 1.0.0
*/
@Slf4j
public class FtpUtils {
public static void main(String[] args) throws Exception {
log.info("测试开始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
// 1
File file = new File("E:\\2.xlsx");
InputStream inputStream = new FileInputStream(file);
FtpUtils.uploadFile("", 21, "", "", "/usr/local",
"/testfile/", "test.xlsx", inputStream);
// 2
FtpUtils.downloadFile("", 21, "", "","/usr/local/testfile/",
"test.csv", "/Users/ao/Desktop/test.csv");
log.info("测试结束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
}
/**
* @Author: jinhaoxun
* @Description: 向FTP服务器上传文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param userName FTP登录账号
* @param password FTP登录密码
* @param basePath FTP服务器基础目录
* @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为basePath+filePath
* @param filename 上传到FTP服务器上的文件名
* @param input 本地要上传的文件的 输入流
* @Date: 2020/1/16 19:31
* @Return: boolean
* @Throws: Exception
*/
public static boolean uploadFile(String host, int port, String userName, String password, String basePath,
String filePath, String filename, InputStream input) throws Exception{
boolean result = false;
FTPClient ftp = new FTPClient();
try {
int reply;
// 连接FTP服务器
ftp.connect(host, port);
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
// 登录
ftp.login(userName, password);
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
return result;
}
//切换到上传目录
if (!ftp.changeWorkingDirectory(basePath+filePath)) {
//如果目录不存在创建目录
String[] dirs = filePath.split("/");
String tempPath = basePath;
for (String dir : dirs) {
if (null == dir || "".equals(dir)){
continue;
}
tempPath += "/" + dir;
if (!ftp.changeWorkingDirectory(tempPath)) {
if (!ftp.makeDirectory(tempPath)) {
return result;
} else {
ftp.changeWorkingDirectory(tempPath);
}
}
}
}
//设置上传文件的类型为二进制类型
ftp.setFileType(FTP.BINARY_FILE_TYPE);
//上传文件
if (!ftp.storeFile(filename, input)) {
return result;
}
input.close();
ftp.logout();
result = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException ioe) {
}
}
}
return result;
}
/**
* @Author: jinhaoxun
* @Description: 从FTP服务器下载文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param userName FTP登录账号
* @param password FTP登录密码
* @param remotePath FTP服务器上的相对路径
* @param fileName 要下载的文件名
* @param localPath 下载后保存到本地的路径
* @Date: 2020/1/16 19:34
* @Return: boolean
* @Throws: Exception
*/
public static boolean downloadFile(String host, int port, String userName, String password, String remotePath,
String fileName, String localPath) throws Exception {
boolean result = false;
FTPClient ftp = new FTPClient();
try {
int reply;
ftp.connect(host, port);
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
// 登录
ftp.login(userName, password);
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
return result;
}
// 转移到FTP服务器目录
ftp.changeWorkingDirectory(remotePath);
FTPFile[] fs = ftp.listFiles();
for (FTPFile ff : fs) {
if (ff.getName().equals(fileName)) {
java.io.File localFile = new File(localPath + "/" + ff.getName());
OutputStream is = new FileOutputStream(localFile);
ftp.retrieveFile(ff.getName(), is);
is.close();
}
}
ftp.logout();
result = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftp.isConnected()) {
try {
ftp.disconnect();
} catch (IOException ioe) {
}
}
}
return result;
}
}
完整代码地址：https://github.com/luoyusoft/java-demo
注：此工程包含多个包，FtpUtils代码均在com.luoyu.java.ftp包下
注：此工程包含多个包，SftpUtils代码均在com.luoyu.java.sftp包下
到此这篇关于Java使用Sftp和Ftp实现对文件的上传和下载的文章就介绍到这了,更多相关Java使用Sftp和Ftp文件上传和下载内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！
相关推荐
-
Java使用SFTP上传文件到服务器的简单使用
最近用到SFTP上传文件查找了一些资料后自己做了一点总结,方便以后的查询.具体代码如下所示: /** * 将文件上传到服务器 * * @param filePath * 文件路径 * @param channelSftp * channelSftp对象 * @return */ public static boolean uploadFile(String filePath, ChannelSftp channelSftp) { OutputStream outstream = null; In
-
Java8实现FTP及SFTP文件上传下载
有网上的代码,也有自己的理解,代码备份 一般连接windows服务器使用FTP,连接linux服务器使用SFTP.linux都是通过SFTP上传文件,不需要额外安装,非要使用FTP的话,还得安装FTP服务(虽然刚开始我就是这么干的). 另外就是jdk1.8和jdk1.7之前的方法有些不同,网上有很多jdk1.7之前的介绍,本篇是jdk1.8的 添加依赖Jsch-0.1.54.jar <!-- https://mvnrepository.com/artifact/com.jcraft/jsch -
-
JAVA SFTP文件上传、下载及批量下载实例
1.jsch官方API查看地址(附件为需要的jar) http://www.jcraft.com/jsch/ 2.jsch简介 JSch(Java Secure Channel)是一个SSH2的纯Java实现.它允许你连接到一个SSH服务器,并且可以使用端口转发,X11转发,文件传输等,当然你也可以集成它的功能到你自己的应用程序. SFTP(Secure File Transfer Protocol)安全文件传送协议.可以为传输文件提供一种安全的加密方法.SFTP 为 SSH的一部份,是一种传输
-
Java使用sftp定时下载文件的示例代码
sftp简介 sftp是Secure File Transfer Protocol的缩写,安全文件传送协议.可以为传输文件提供一种安全的网络的加密方法.sftp 与 ftp 有着几乎一样的语法和功能.SFTP 为 SSH的其中一部分,是一种传输档案至 Blogger 伺服器的安全方式.其实在SSH软件包中,已经包含了一个叫作SFTP(Secure File Transfer Protocol)的安全文件信息传输子系统,SFTP本身没有单独的守护进程,它必须使用sshd守护进程(端口号默认是22)
-
java实现sftp客户端上传文件以及文件夹的功能代码
1.依赖的jar文件 jsch-0.1.53.jar 2.登录方式有密码登录,和密匙登录 代码: 主函数: import java.util.Properties; import com.cloudpower.util.Login; import com.util.LoadProperties; public class Ftp { public static void main(String[] args) { Properties properties = LoadProperties.ge
-
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使用Sftp和Ftp实现对文件的上传和下载
sftp和ftp两种方式区别,还不清楚的,请自行百度查询,此处不多赘述.完整代码地址在结尾!! 第一步,导入maven依赖 <!-- FTP依赖包 --> <dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.6</version> </dependency> <!
-
Java利用Socket和IO流实现文件的上传与下载
目录 背景概述 核心技术 Config Client Server UploadRunnableImpl DownloadRunnableImpl 背景概述 本文利用Socket编程和IO流技术实现文件的上传与下载. 核心技术 1.TCP 2.Socket 3.FileInputStream与FileOutputStream 4.DataInputStream与DataOutputStream 5.多线程 Config package com.io14; /** * 本文作者:谷哥的小弟 * 博
-
Java实现FTP文件的上传和下载功能的实例代码
FTP 是File Transfer Protocol(文件传输协议)的英文简称,而中文简称为"文传协议".用于Internet上的控制文件的双向传输.同时,它也是一个应用程序(Application).基于不同的操作系统有不同的FTP应用程序,而所有这些应用程序都遵守同一种协议以传输文件.在FTP的使用当中,用户经常遇到两个概念:"下载"(Download)和"上传"(Upload)."下载"文件就是从远程主机拷贝文件至自己
-
java eclipse 中文件的上传和下载示例解析
文件的上传与下载(一) 在实现文件上传和下载之前我们需要做一些准备工作,在Apache官网去下载文件上传下载的两个组件,下载链接这里给出:common-fileupload组件下载:http://commons.apache.org/proper/commons-fileupload/ common-io组件下载:http://commons.apache.org/proper/commons-io/根据自己需求下载对应版本 一.创建工程 将所需要的两个开发包导入到工程项目中如图: 二.代码编写
-
在SpringMVC框架下实现文件的上传和下载示例
在eclipse中的javaEE环境下:导入必要的架包 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" xsi:schemaLocation=&
-
SpringMVC实现文件的上传和下载实例代码
前些天一位江苏经贸的学弟跟我留言问了我这样一个问题:"用什么技术来实现一般网页上文件的上传和下载?是框架还是Java中的IO流".我回复他说:"使用SpringMVC框架可以做到这一点,因为SpringMVC为文件的上传提供了直接的支持,但需要依赖Apache提供Commons FileUpload组件jar包."鉴于这个问题,我上网也百度了一下,网上很多都是介绍的使用IO流来实现文件的上传和下载,也有说到框架的,但介绍的并不是很完整,今天小钱将和大家介绍使用Spr
-
Servlet实现文件的上传与下载
前言: 文件的上传和下载在日常开发中很是常见,那么这一功能是如何实现的呢,下面我给大家介绍一下 实现条件: 1.需要一个form标签,method为post请求 2.form的encType属性值为multipart/form-data 3.input标签的type=file 4.需要的jar包() 工程目录: 具体实现: UploadServlet.java(上传) import org.apache.commons.fileupload.FileItem; import org.apache
-
JavaWeb实现文件的上传与下载
JavaWeb实现文件的上传与下载,供大家参考,具体内容如下 第一步:导包 导入commons-fileupload-1.3.3.jar和commons-io-2.4.jar两个依赖包 第二步:编写前端页面 1.提交页面 index.jsp <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> <%@ tagl
-
Spring Boot使用GridFS实现文件的上传和下载方式
目录 使用GridFS实现文件的上传和下载 首先了解一下怎么用命令操作GridFS 使用Spring Boot操作GridFS Spring Boot中使用GridFS 什么是GridFS 在SpringBoot中使用GridFS 使用GridFS实现文件的上传和下载 在这篇博客中,我们将展示如何使用Spring Boot中使用mongodb自带的文件存储系统GridFS实现文件的上传和下载功能 首先了解一下怎么用命令操作GridFS 安装mongodb sudo apt-get install
-
Android Http实现文件的上传和下载
最近做一个项目,其中涉及到文件的上传和下载功能,大家都知道,这个功能实现其实已经烂大街了,遂.直接从网上荡了一堆代码用,结果,发现网上的代码真是良莠不齐,不是写的不全面,就是有问题,于是自己重新整理了一番,把它们发出来,希望更多人能受用. 文件上传 通过org.apache.commons.httpclient.HttpClient来实现文件上传,该jar包可以直接从网上所搜.下载. /** * @param mContext 上下文 * @param targetUrl 文件上传地址 * @p