Java实现FTP上传与下载功能
作者:hehuijava 时间:2021-09-22 18:28:51
本文实例为大家分享了Java实现FTP上传与下载的具体代码,供大家参考,具体内容如下
JAVA操作FTP服务器,只需要创建一个FTPClient即可,所有的操作都封装在FTPClient中,JDK自带的有FTPClient(sun.net.ftp.FtpClient),也可以用第三方的FTPClient,一般使用apache的FTPClient(org.apache.commons.net.ftp.FTPClient),本文将使用apache的FTPClient,API都大同小异
关键依赖:commons-net
对常用操作(上传、下载)封装成工具类
package com.day0322;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
/**
* FTP工具类
* 文件上传
* 文件下载
*/
public class FTPUtil {
private static final Logger log = LoggerFactory.getLogger(FTPUtil.class);
/**
* 设置缓冲区大小4M
**/
private static final int BUFFER_SIZE = 1024 * 1024 * 4;
/**
* 本地字符编码
**/
private static String LOCAL_CHARSET = "GBK";
/**
* UTF-8字符编码
**/
private static final String CHARSET_UTF8 = "UTF-8";
/**
* OPTS UTF8字符串常量
**/
private static final String OPTS_UTF8 = "OPTS UTF8";
/**
* FTP协议里面,规定文件名编码为iso-8859-1
**/
private static final String SERVER_CHARSET = "ISO-8859-1";
private static FTPClient ftpClient = null;
/**
* 连接FTP服务器
*/
private static void login(OaFtp oaFtp) {
ftpClient = new FTPClient();
try {
ftpClient.connect(oaFtp.getIp(), Integer.valueOf(oaFtp.getPort()));
ftpClient.login(oaFtp.getName(), oaFtp.getPwd());
ftpClient.setBufferSize(BUFFER_SIZE);
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
int reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
closeConnect();
}
} catch (Exception e) {
log.error("",e);
throw new RuntimeException(e);
}
}
/**
* 关闭FTP连接
*/
private static void closeConnect() {
if (ftpClient != null && ftpClient.isConnected()) {
try {
ftpClient.logout();
ftpClient.disconnect();
} catch (IOException e) {
log.error("",e);
}
}
}
/**
* FTP服务器路径编码转换
*
* @param ftpPath FTP服务器路径
* @return String
*/
private static String changeEncoding(String ftpPath) {
String directory = null;
try {
if (FTPReply.isPositiveCompletion(ftpClient.sendCommand(OPTS_UTF8, "ON"))) {
LOCAL_CHARSET = CHARSET_UTF8;
}
directory = new String(ftpPath.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
} catch (Exception e) {
log.error("",e);
}
return directory;
}
/**
* 改变工作目录
* 如果没有,则创建工作目录
* @param path
*/
private static void changeAndMakeWorkingDir(String path) {
try {
ftpClient.changeWorkingDirectory("/");
path = path.replaceAll("\\\\","/");
String[] path_array = path.split("/");
for (String s : path_array) {
boolean b = ftpClient.changeWorkingDirectory(s);
if (!b) {
ftpClient.makeDirectory(s);
ftpClient.changeWorkingDirectory(s);
}
}
} catch (IOException e) {
log.error("",e);
throw new RuntimeException(e);
}
}
/**
* 上传
* @param oaFtp
* @param filename
* @param dirPath
* @param in
* @return
*/
public static boolean upload (OaFtp oaFtp, String filename, String dirPath, InputStream in) {
login(oaFtp);
if (!ftpClient.isConnected()) {
return false;
}
boolean isSuccess = false;
if (ftpClient != null) {
try {
if (FTPReply.isPositiveCompletion(ftpClient.sendCommand(OPTS_UTF8, "ON"))) {
LOCAL_CHARSET = CHARSET_UTF8;
}
ftpClient.setControlEncoding(LOCAL_CHARSET);
String path = changeEncoding(dirPath);
changeAndMakeWorkingDir(path);
isSuccess = ftpClient.storeFile(new String(filename.getBytes(), SERVER_CHARSET), in);
} catch (Exception e) {
log.error("",e);
} finally {
closeConnect();
}
}
return isSuccess;
}
/**
* 下载
* @param oaFtp
* @param filename
* @param dirPath
* @param out
* @return
*/
public static void download (OaFtp oaFtp, String filename, String dirPath, FileOutputStream out) {
// 登录
login(oaFtp);
if (ftpClient != null) {
try {
String path = changeEncoding(dirPath);
changeAndMakeWorkingDir(path);
String[] fileNames = ftpClient.listNames();
if (fileNames == null || fileNames.length == 0) {
return;
}
for (String fileName : fileNames) {
String ftpName = new String(fileName.getBytes(SERVER_CHARSET), LOCAL_CHARSET);
if (StringUtils.equals(ftpName,filename)) {
InputStream in = ftpClient.retrieveFileStream(fileName);
IOUtils.copy(in,out);
}
}
} catch (IOException e) {
log.error("",e);
} finally {
closeConnect();
}
}
}
}
测试
1.上传
2.下载
来源:https://blog.csdn.net/hehuihh/article/details/115124225
标签:Java,上传,下载
0
投稿
猜你喜欢
Android WindowManger的层级分析详解
2023-08-05 23:51:40
Java抛出异常与自定义异常类应用示例
2022-10-23 01:58:52
Spring Boot+Shiro实现一个Http请求的Basic认证
2022-06-01 22:22:31
通过Java实现在Word中创建可填充表单
2023-08-05 21:11:40
完整的iOS新浪微博分享功能开发
2023-06-24 14:14:08
Java Collections.shuffle()方法案例详解
2023-11-24 15:53:16
Spring中自定义数据类型转换的方法详解
2022-10-09 02:56:51
Java拦截器Interceptor和过滤器Filte的执行顺序和区别
2022-06-01 20:37:11
Java并发编程预防死锁过程详解
2023-11-09 15:33:58
Spring Cloud Gateway(读取、修改 Request Body)的操作
2023-11-09 19:25:46
java实现支付宝支付接口的调用
2023-10-13 09:43:40
谈谈你可能并不了解的java枚举
2023-11-09 21:08:55
Spring Boot学习入门之AOP处理请求详解
2023-11-27 10:55:17
Java8中的 Lambda表达式教程
2023-10-13 01:32:29
利用Java计算某个日期是星期几
2023-11-17 05:49:42
Java 八种基本类型和基本类型封装类
2023-11-26 14:15:16
SpringCloud整合Nacos实现流程详解
2021-07-04 11:11:09
Java如何使用HTTPclient访问url获得数据
2023-11-12 04:16:21
java文件操作输入输出结构详解
2023-07-30 21:48:30
Java字节码ByteBuddy使用及原理解析上
2023-08-23 19:33:05