Ftp实现上传文件至远程服务器，Java工作经验6年

commons-net

commons-net

3.3

2.Ftp工具类

import com.turing.JavaBean.FtpInformation;

import org.apache.commons.net.ftp.FTPClient;

import org.apache.commons.net.ftp.FTPReply;

import org.springframework.stereotype.Component;

import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;

import java.io.InputStream;

import java.util.UUID;

/**

• &＃64;Author: 又蠢又笨的懒羊羊程序猿

• &＃64;CreateTime: 2021年07月22日 12:39:47

*/

&＃64;Component //这就是我们刚才加入的依赖

public class FtpUtil {

/**

• ftp服务器ip地址

*/

private static final String FTP_ADDRESS &＃61; “39.103.203.27”;

/**

• 端口号

*/

private static final int FTP_PORT &＃61; 21;

/**

• 用户名

*/

private static String FTP_USERNAME;

/**

• 密码

*/

private static String FTP_PASSWORD;

/**

• 路径都是/home/加上用户名

*/

private static String FTP_BASEPATH &＃61; “/home/”;

/**

• 参数传过来了文件和文件的输入流

• &＃64;param file

• &＃64;return

• &＃64;throws Exception

*/

public static String uploadFile(FtpInformation ftpInformation,MultipartFile file)throws Exception {

FTP_USERNAME &＃61; ftpInformation.getFTP_USERNAME();

FTP_PASSWORD &＃61; ftpInformation.getFTP_PASSWORD();

if ("/home/".equals(FTP_BASEPATH))

{

FTP_BASEPATH &＃61; FTP_BASEPATH&＃43;FTP_USERNAME&＃43;"/";

}

//获取上传的文件流

InputStream inputStream &＃61; file.getInputStream();

//获取上传的文件名

String filename &＃61; file.getOriginalFilename();

//获取文件后缀

String suffix &＃61; filename.substring(filename.lastIndexOf("."));

//使用UUID拼接后缀,定义一个不重复的文件名

String finalName &＃61; UUID.randomUUID() &＃43; suffix;

//这是最开始引入的依赖里的方法

FTPClient ftp &＃61; new FTPClient();

ftp.setControlEncoding(“utf-8”);

try {

int reply;

// 连接FTP服务器

ftp.connect(FTP_ADDRESS, FTP_PORT);

// 登录

ftp.login(FTP_USERNAME, FTP_PASSWORD);

//连接成功会的到一个返回状态码

reply &＃61; ftp.getReplyCode();

//可以输出看一下是否连接成功

System.out.println(reply);

//设置文件类型

ftp.setFileType(FTPClient.BINARY_FILE_TYPE);

//修改操作空间

ftp.changeWorkingDirectory(FTP_BASEPATH);

//对了这里说明一下你所操作的文件夹必须要有可读权限&＃xff0c;chomd 777 文件夹名//这里我就是用的我的home文件夹

//这里开始上传文件

ftp.storeFile(finalName, inputStream);

if (!FTPReply.isPositiveCompletion(reply)) {

ftp.disconnect();

System.out.println(“连接失败”);

return null;

}

System.out.println(“连接成功&＃xff01;”);

inputStream.close();

ftp.logout();

return FTP_BASEPATH&＃43;finalName;

} catch (Exception e) {

e.printStackTrace();

System.out.println(“ERROR:”&＃43;e.getMessage());

} finally {

if (ftp.isConnected()) {

try {

ftp.disconnect();

} catch (IOException ioe) {

}

}

}

return null;

}

}

import lombok.AllArgsConstructor;

import lombok.Data;

/**

• &＃64;Author: 又蠢又笨的懒羊羊程序猿

• &＃64;CreateTime: 2021年07月24日 13:07:19

*/

&＃64;Data

&＃64;AllArgsConstructor

public class FtpInformation

{

private String FTP_USERNAME;

private String FTP_PASSWORD;

}

//记住添加请求头,否则无法接收文件

&＃64;PostMapping(value &＃61; “/uploadFile”, headers &＃61; “content-type&＃61;multipart/form-data”)

&＃64;ResponseBody

&＃64;ApiOperation("上传

【一线大厂Java面试题解析&＃43;后端开发学习笔记&＃43;最新架构讲解视频&＃43;实战项目源码讲义】浏览器打开&＃xff1a;qq.cn.hn/FTf 免费领取


文件")

public ResponseBean uploadFile(FtpInformation ftpInformation, &＃64;RequestParam(“files”) MultipartFile[] files)

{

List list &＃61; new ArrayList<>();

for (MultipartFile file : files) {

try {

//调用自定义的FTP工具类上传文件

String finalName &＃61; FtpUtil.uploadFile(ftpInformation,file);

if (StringUtils.isEmpty(finalName))

{

throw new Exception(“Upload Error”);

}

list.add(finalName);

} catch (Exception e) {

log.error(“ERROR:{}”,e.getMessage());

return new ResponseBean(HttpStatusCode.INTERNAL_SERVER_ERROR,null);

}

}

return new ResponseBean(HttpStatusCode.Success,list);

}