package com.stylefeng.guns.core.util;
import com.stylefeng.guns.modular.trip.util.UUIDUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.net.ftp.FTPClient;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.List;
@Slf4j
public class FTPUtil {
private static String ftpIp = "192.168.0.1";
private static String ftpUser = "my";
private static String ftpPass = "12345678";
public FTPUtil(String ip, int port, String user, String pwd){
this.ip = ip;
this.port = port;
this.user = user;
this.pwd = pwd;
}
/**
* 这个是对外开放的接口
* @param fileList
* @return
* @throws IOException
*/
public static boolean uploadFile(List<File> fileList) throws IOException {
FTPUtil ftpUtil = new FTPUtil(ftpIp,21,ftpUser,ftpPass);
log.info("开始连接ftp服务器");
boolean result = ftpUtil.uploadFile("img",fileList);
log.info("开始连接ftp服务器,结束上传,上传结果:{}");
return result;
}
private boolean uploadFile(String remotePath,List<File> fileList) throws IOException {
boolean uploaded = true;
FileInputStream fis = null;
//连接FTP服务器
if(connectServer(this.ip,this.port,this.user,this.pwd)){
try {
ftpClient.changeWorkingDirectory(remotePath);
ftpClient.setBufferSize(1024);
ftpClient.setControlEncoding("UTF-8");
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
ftpClient.enterLocalPassiveMode();
for(File fileItem : fileList){
fis = new FileInputStream(fileItem);
ftpClient.storeFile(UUIDUtils.getUUID()+"."+fileItem.getName().split("\\.")[1],fis);
ftpClient.storeFile(fileItem.getName(),fis);
}
} catch (IOException e) {
log.error("上传文件异常",e);
uploaded = false;
e.printStackTrace();
} finally {
fis.close();
ftpClient.disconnect();
}
}
return uploaded;
}
private boolean connectServer(String ip,int port,String user,String pwd){
boolean isSuccess = false;
ftpClient = new FTPClient();
try {
ftpClient.connect(ip);
isSuccess = ftpClient.login(user,pwd);
} catch (IOException e) {
log.error("连接FTP服务器异常",e);
}
return isSuccess;
}
private String ip;
private int port;
private String user;
private String pwd;
private FTPClient ftpClient;
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getPwd() {
return pwd;
}
public void setPwd(String pwd) {
this.pwd = pwd;
}
public FTPClient getFtpClient() {
return ftpClient;
}
public void setFtpClient(FTPClient ftpClient) {
this.ftpClient = ftpClient;
}
public static void main(String[] args) {
}
}
public class FileUpLoad {
public static void main(String[] args) {
File file = new File("C:\\aa.txt");
try {
boolean status = FTPUtil.uploadFile(Lists.newArrayList(file));
System.out.println(status);
} catch (IOException e) {
e.printStackTrace();
}
}
}