使用IIS方式搭建FTP
Windows下使用FileZilla搭建FTP
1、与FTP服务器建立连接
/**
* 初始化客户端并完成对服务端的连接
* @param server 服务端地址
* @param port 端口号
* @param username 用户名
* @param password 密码
* @param path 远程路径 值可以为空
* @throws SocketException
* @throws IOException
*/
public static FTPClient connectServer(String server, int port, String username,String password, String path) {
if(null == path){
path = "";
}
try {
FTPClient ftp = new FTPClient();
//下面四行代码必须要，而且不能改变编码格式，否则不能正确下载中文文件
// 如果使用serv-u发布ftp站点，则需要勾掉“高级选项”中的“对所有已收发的路径和文件名使用UTF-8编码”
ftp.setControlEncoding("GBK");
FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
conf.setServerLanguageCode("zh");
ftp.configure(conf);
ftp.connect(server, port);
ftp.setDataTimeout(120000);
// 判断ftp是否存在
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
ftp.disconnect(); // 如果不存在，断开ftp连接
log.warn(server + " FTP拒绝连接");
}
// 登陆ftp
boolean flag = ftp.login(username, password);
if (flag) {
log.info("FTP登录成功。");
}else {
log.error("FTP登录失败。");
}
// 根据输入的路径，切换工作目录。这样ftp端的路径就可以使用相对路径了
if (path.length() != 0) {
if (path != null && !"".equals(path.trim())) {
// 对路径按照‘/’进行切割，一层一层的进入
String[] pathes = path.split("/");
for (String onepath : pathes) {
if (onepath == null || "".equals(onepath.trim())) {
continue;
}
if (!ftp.changeWorkingDirectory(onepath)) {
ftp.makeDirectory(onepath);
boolean flagDir = ftp.changeWorkingDirectory(onepath);
log.info(ftp.printWorkingDirectory());
if (flagDir) {
log.info("成功连接ftp目录：" + ftp.printWorkingDirectory());
} else {
log.error("未能连接ftp目录：" + ftp.printWorkingDirectory());
}
}
}
}
}
return ftp;
}catch(SocketException e){
e.printStackTrace();
return null;
}
catch (IOException e) {
e.printStackTrace();
return null;
}
}
2、返回目录下的所有文件（包括文件夹）
/**
* 返回给定目录下的所有文件（包括文件夹）
* @param path
* @return FTPFile组成的集合
* @throws IOException
*/
public static List<String> getFileList(FTPClient ftp,String path) throws IOException {
ftp.changeWorkingDirectory(path);//切换对应路径下
log.info("FTP当前目录:"+ftp.printWorkingDirectory());
FTPFile[] ftpFiles = ftp.listFiles(); // ftpFiles.length返回当前目录下的文件数
List retList = new ArrayList();
if (ftpFiles == null || ftpFiles.length == 0) {
return retList;
}
for (int i = 0; i < ftpFiles.length; i++) {
FTPFile ftpFile = ftpFiles[i];
// if (ftpFile.isFile()) { // 判断是否为文件，这样返回的就是所有的文件名
// retList.add(ftpFile.getName());
// }
retList.add(ftpFile.getName());
}
return retList;
}
3、获取指定路径下的所有文件（不管多少文件夹下）
/**
* 递归遍历文件夹以及子文件夹的文件
* 获取指定路径下的所有文件（不管多少文件夹下）
* @param pathName
* @param filePathList
* @throws IOException
*/
public static void getFileListRecursion(FTPClient ftp,String pathName, List<String> filePathList) throws IOException {
if(null == pathName){
pathName = "/";
}else{
pathName = pathName.replace("\\", "/");
}
if(!pathName.startsWith("/")){
pathName ="/"+pathName;
}
if(!pathName.endsWith("/")){
pathName = pathName + "/";
}
ftp.changeWorkingDirectory(pathName);
FTPFile[] files = ftp.listFiles();
for (int i = 0; i < files.length; i++) {
if (files[i].isFile()) {
log.info("得到文件:" + files[i].getName());
log.info("--------------");
filePathList.add(ftp.printWorkingDirectory()+"/"+files[i].getName());
} else if (files[i].isDirectory()) {
getFileListRecursion(ftp,pathName + files[i].getName() + "/", filePathList);
}
}
}
4、删除指定目录（递归）
/**
* 删除指定目录下的所有文件
* @param ftp
* @param pathname
* @return
*/
public static boolean removeAll(FTPClient ftp, String pathname) {
try {
ftp.removeDirectory(pathname);
FTPFile[] files = ftp.listFiles(pathname);
for (FTPFile f : files) {
if (f.isDirectory()) {
removeAll(ftp,pathname + "/" + f.getName());
boolean isDelDir = ftp.removeDirectory(pathname);
log.info("FTP目录是否已删除>>"+isDelDir);
}
if (f.isFile()) {
boolean isDelFile = ftp.deleteFile(pathname + "/" + f.getName());
ftp.removeDirectory(pathname);
log.info("FTP文件是否已删除>>"+isDelFile);
}
}
} catch (IOException e) {
e.printStackTrace();
return false;
}
return true;
}
5、上传文件,并重命名
/**
* 上传文件,并重命名.
* @param filePathName 上传的文件,包含目录的文件名
* @param newName 新的文件名
* @return 上传结果,是否成功.
* @throws IOException
*/
public static boolean uploadFile(FTPClient ftp,String filePathName, String newName)
throws IOException {
boolean flag = false;
InputStream iStream = null;
try {
log.info("ftp new file name : "+newName);
ftp.setControlEncoding("GBK");
iStream = new FileInputStream(filePathName);
ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
//将当前数据连接模式设置为PASSIVE_LOCAL_DATA_CONNECTION_MODE，即：被动模式
ftp.enterLocalPassiveMode();
//将流写到服务器
ftp.storeFile(new String(filePathName.getBytes("GBK"),"iso-8859-1"),iStream);
flag = ftp.storeFile(newName, iStream);
} catch (IOException e) {
flag = false;
return flag;
} finally {
if (iStream != null) {
iStream.close();
}
}
return flag;
}
6、从ftp上下载文件到本地
/**
* 从ftp上下载文件到本地
* @param ftpClient:ftp连接
* @param remoteFilepath：ftp服务器端路径
* @param localFilePath：本地路径
* @return 是否下载成功
*/
public static boolean downloadFileFromFtp(FTPClient ftpClient,String remoteFilepath,String localFilePath){
boolean flag = false;
try {
//判断本地文件是否已经存在，如果已经存在，则无需下载
//FTPClient ftpClient = FtpUtil.connectServer(ftp);
File localFile = new File(localFilePath);
if (!localFile.exists()) {
InputStream inputStream = FtpUtil.downFile(ftpClient,remoteFilepath);
if (inputStream != null) flag = SystemUtil.inputStreamToFile(inputStream, localFilePath);
}else {
if (localFile.length() == 0) {
log.info("文件大小为0，即将为您重新下载！");
localFile.delete();
InputStream inputStream = FtpUtil.downFile(ftpClient,remoteFilepath);
if (inputStream != null) flag = SystemUtil.inputStreamToFile(inputStream, localFilePath); // 将文件流转化为本地文件
}else{
log.info("本地文件已存在.......");
flag = true;
}
}
FtpUtil.closeServer(ftpClient);
return flag;
} catch (Exception e) {
flag = false;
log.error("从FTP下载文件到本地失败...");
log.error(e);
e.printStackTrace();
return flag;
}
}
/**
* 将文件流转化为本地文件
* @param inputStream
* @param localFilePath
* @return boolean
* @throws IOException
*/
public static boolean inputStreamToFile(InputStream inputStream,String localFilePath) throws IOException {
File newDir = new File(localFilePath.replace("\\", "/").substring(0, localFilePath.lastIndexOf("\\")));
if (!newDir.exists()) newDir.mkdirs();
FileOutputStream fs= new FileOutputStream(localFilePath);
try {
/*FileChannel fc= ((FileInputStream) inputStream).getChannel();
log.info("文件大小:"+fc.size());*/
int bytesum = 0;
int byteread = 0;
byte[] buffer = new byte[1024];
long startTime = System.currentTimeMillis();
while ((byteread = inputStream.read(buffer)) != -1) {
bytesum += byteread; // 字节数 文件大小
fs.write(buffer, 0, byteread);
}
fs.flush();
long endTime = System.currentTimeMillis();
log.info("将文件流转化为本地文件耗时/毫秒:"+(endTime-startTime));
return true;
} catch (Exception e) {
log.error("将文件流转化为本地文件失败",e);
return false;
}finally{
fs.close();
}
}
7、获取下一级目录列表 文件+文件夹（返回list<PathVo>）
/**
* 获取下一级目录列表 文件+文件夹（返回list<PathVo>）
* @param ftp
* @param pathName
* @return
* @throws IOException
*/
public static List<PathVo> getNextDirectory(FTPClient ftp,String pathName) throws IOException {
log.info("Ftp中pathName："+pathName);
List<PathVo> filePathList = new ArrayList<PathVo>();
if(null == pathName) pathName = "/";
else pathName = pathName.replace("\\", "/");
if(!pathName.startsWith("/")) pathName ="/"+pathName;
if(!pathName.endsWith("/")) pathName = pathName + "/";
boolean flag = ftp.changeWorkingDirectory(pathName);
if (!flag) {
log.info("重定位失败。");
return filePathList;
}
log.info("目录切换"+ftp.printWorkingDirectory());
//ftp.enterLocalActiveMode();//主动模式，默认
ftp.enterLocalPassiveMode();//被动模式
//ftp.configure(new FTPClientConfig("dist.dgp.util.fileZillaPlugin.UnixFTPEntryParser"));//FileZilla安装FTP时使用
String[] list = ftp.listNames();
System.out.println(list.length);
FTPFile[] files = ftp.listFiles();
if (files == null || files.length == 0) {
ftp.changeToParentDirectory();
return filePathList;
}
log.info("文件长度："+files.length);
for (int i = 0; i < files.length; i++) {
PathVo vo = new PathVo();
if (files[i].isFile()) {
vo.setType("file");
vo.setFullPath(pathName+files[i].getName());
vo.setSize(formatSize(files[i].getSize()));
vo.setLastModified(getFileLastModified(files[i].getTimestamp().getTimeInMillis()));
vo.setLabel(files[i].getName());
vo.setExtension(files[i].getName().substring(files[i].getName().lastIndexOf(".")+1));
vo.setChildren(null);
filePathList.add(vo);
} else if (files[i].isDirectory()) {
vo.setType("folder");
vo.setFullPath(pathName+files[i].getName());
vo.setLabel(files[i].getName());
vo.setLastModified(getFileLastModified(files[i].getTimestamp().getTimeInMillis()));
vo.setChildren(getNextDirectory(ftp,pathName + files[i].getName() + "/"));
filePathList.add(vo);
}
}
log.info("filePathList.size():"+filePathList.size());
return filePathList;
}
8、获取文件最后编辑时间
/**
* 获取文件最后编辑时间
* @param filename
* @return
*/
public static String getFileLastModified(long timeInMillis) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm");
Calendar cal = Calendar.getInstance();
cal.setTimeInMillis(timeInMillis);
return sdf.format(cal.getTime());
}
9、其他
FTPClient ftp = new FTPClient();
ftp.logout(); // 关闭ftp连接
ftp.setFileType(fileType); // 设置ftp的文件传输类型
ftp.changeWorkingDirectory(path); // 改变ftp的工作目录
ftp.removeDirectory(path); // 删除一个FTP服务器上的目录（如果为空）
ftp.deleteFile(pathName); // 删除文件
