基于FTP4J组件的FTP操作客户端，ftp4j组件ftp,基于FTP4J组件的FT
分享于 点击 2375 次 点评：229
基于FTP4J组件的FTP操作客户端，ftp4j组件ftp,基于FTP4J组件的FT
基于FTP4J组件的FTP操作客户端，支持上传、下载，两台FTP服务器文件流同步。```javapackage com.matol.utils
import it.sauronsoftware.ftp4j.FTPClient;import it.sauronsoftware.ftp4j.FTPDataTransferListener;import it.sauronsoftware.ftp4j.FTPFile;
import java.io.File;import java.io.FileInputStream;import java.io.InputStream;import java.util.ArrayList;import java.util.List;
/ 基于FTP4J组件的FTP操作客户端 ww*/ public final class FTPToolkit { //单例模型 private FTPToolkit() { }
/** * 创建FTP连接 * @param host 主机名或IP * @param port ftp端口 * @param username ftp用户名 * @param password ftp密码 * @return 一个单例客户端 */ public static FTPClient ftpConn(String host, int port, String username, String password) { FTPClient client = new FTPClient(); try { client.connect(host, port); client.login(username, password); client.setCharset("GBK"); client.setType(FTPClient.TYPE_BINARY); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.ftpConn() "+e.getMessage()); } return client; }/** * 取得目录下所有文件列表 * @param path * @return */public static List<FTPFile> getlistFiles(FTPClient client,String path) { List<FTPFile> filesList = new ArrayList<FTPFile>(); try { client.changeDirectory(path); FTPFile[] fileNames = client.list(); //.listNames(); if (null != fileNames) { for (FTPFile file : fileNames) { if(file.getType() == FTPFile.TYPE_FILE){ filesList.add(file); //System.out.println(file.getName()+" | "+file.getSize()+" | "+DateUtil.converDateToString(file.getModifiedDate(),DateUtil.defaultDatePattern)); } } } } catch (Exception e) { System.out.println("###[Error] FTPToolkit.getlistFiles()"+ e.getMessage()); } return filesList;}/** * 取得目录下所有文件列表 * @param path * @return */public static List<String> getlistFileNames(FTPClient client,String path) { List<String> filesList = new ArrayList<String>(); try { client.changeDirectory(path); String[] fileNames = client.listNames(); if (null != fileNames) { for (String file : fileNames) { filesList.add(path+"/"+file); //System.out.println(path+"/"+file); } } } catch (Exception e) { System.out.println("###[Error] FTPToolkit.getlistFileNames()"+ e.getMessage()); } return filesList;}/** * 根据文件路径获取文件流 * @param path * @return*/public static InputStream fetchInputStream(FTPClient client,String ftpFilePath,String ftpPath) { InputStream is = null; try { String localFilePath = getFileName("ftptmp/"+ftpFilePath) + "_ftp.tmp"; File tempLocalFile = new File(localFilePath); if (!tempLocalFile.exists()) { tempLocalFile.createNewFile(); } client.download(ftpPath, tempLocalFile); is = new FileInputStream(tempLocalFile); //删除临时文件(由于不能关闭文件流，删除临时文件无效,所以最好使用deleteOnExit，外层程序使用文件流结束后，关闭流，自动删除) //tempLocalFile.deleteOnExit(); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.fetchInputStream()"+e.getMessage()); } return is;}/*** 上传文件到FTP* @param ftpFilePath 要上传到FTP的路径* @param source 源数据*/public static void uploadInputStream(FTPClient client,String ftpFilePath, InputStream ftpFile) { try { mkDirs(client,ftpFilePath.substring(0, ftpFilePath.lastIndexOf("/")));
client.upload(ftpFilePath, ftpFile, 0l, 0l, null); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.uploadInputStream()"+e.getMessage()); }finally{ try { //关闭文件流 ftpFile.close(); } catch (Exception e) {} }}
/** * FTP下载文件到本地一个文件夹,如果本地文件夹不存在，则创建必要的目录结构 * @param client FTP客户端 * @param remoteFileName FTP文件 * @param localFolderPath 存的本地目录 */ public static void download(FTPClient client, String remoteFileName, String localFolderPath) { try { int x = isExist(client, remoteFileName); MyFtpListener listener = MyFtpListener.instance("download"); File localFolder = new File(localFolderPath); if (!localFolder.exists()) { localFolder.mkdirs(); } if (x == FTPFile.TYPE_FILE) { String localfilepath = formatPath4File(localFolderPath+File.separator+new File(remoteFileName).getName()); if (listener != null) { client.download(remoteFileName, new File(localfilepath), listener); }else{ client.download(remoteFileName, new File(localfilepath)); } } } catch (Exception e) { System.out.println("###[Error] FTPToolkit.download()"+e.getMessage()); } }//递归创建层级目录（坑爹的问题，原本想着递归处理，后来才发现如此的简单）private static void mkDirs(FTPClient client,String p) throws Exception { if (null == p) { return;} if(p != null && !"".equals(p) && !"/".equals(p)){ String ps = ""; for(int i=0;i<p.split("/").length;i++){ ps += p.split("/")[i]+"/"; if (!isDirExist(client,ps)) { client.createDirectory(ps);// 创建目录 client.changeDirectory(ps);// 进入创建的目录 System.out.println(">>>>> create directory:["+i+"]["+ps+"]"); }else{ //System.out.println("select directory:["+i+"]["+ps+"]"); } } }}//检查目录是否存在private static boolean isDirExist(FTPClient client,String dir) { try { client.changeDirectory(dir); } catch (Exception e) { return false; } return true;}/** * FTP上传本地文件到FTP的一个目录下 * @param client FTP客户端 * @param localfilepath 本地文件路径 * @param remoteFolderPath FTP上传目录 */ public static void upload(FTPClient client, String localfilepath, String remoteFolderPath) { try { mkDirs(client,remoteFolderPath); File localfile = new File(localfilepath); upload(client, localfile, remoteFolderPath); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.upload()"+e.getMessage()); } } /** * FTP上传本地文件到FTP的一个目录下 * @param client FTP客户端 * @param localfile 本地文件 * @param remoteFolderPath FTP上传目录 */ public static void upload(FTPClient client, File localfile, String remoteFolderPath) { remoteFolderPath = formatPath4FTP(remoteFolderPath); MyFtpListener listener = MyFtpListener.instance("upload"); try { client.changeDirectory(remoteFolderPath); if (listener != null) { client.upload(localfile, listener); }else{ client.upload(localfile); } client.changeDirectory("/"); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.upload()"+e.getMessage()); } }/** * 批量上传本地文件到FTP指定目录上 * @param client FTP客户端 * @param localFilePaths 本地文件路径列表 * @param remoteFolderPath FTP上传目录 */ public static void uploadListPath(FTPClient client, List<String> localFilePaths, String remoteFolderPath) { try { remoteFolderPath = formatPath4FTP(remoteFolderPath); client.changeDirectory(remoteFolderPath); MyFtpListener listener = MyFtpListener.instance("uploadListPath"); for (String path : localFilePaths) { File file = new File(path); if (listener != null) { client.upload(file, listener); }else { client.upload(file); } } client.changeDirectory("/"); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.uploadListPath()"+e.getMessage()); } } /** * 批量上传本地文件到FTP指定目录上 * @param client FTP客户端 * @param localFiles 本地文件列表 * @param remoteFolderPath FTP上传目录 */ public static void uploadListFile(FTPClient client, List<File> localFiles, String remoteFolderPath) { try { client.changeDirectory(remoteFolderPath); remoteFolderPath = formatPath4FTP(remoteFolderPath); MyFtpListener listener = MyFtpListener.instance("uploadListFile"); for (File file : localFiles) { if (listener != null){ client.upload(file, listener); }else{ client.upload(file); } } client.changeDirectory("/"); } catch (Exception e) { System.out.println("###[Error] FTPToolkit.uploadListFile() "+e.getMessage()); } }/** * 判断一个FTP路径是否存在，如果存在返回类型(FTPFile.TYPE_DIRECTORY=1、FTPFile.TYPE_FILE=0、FTPFile.TYPE_LINK=2) * @param client FTP客户端 * @param remotePath FTP文件或文件夹路径 * @return 存在时候返回类型值(文件0，文件夹1，连接2)，不存在则返回-1 */ public static int isExist(FTPClient client, String remotePath) { int x = -1; try { remotePath = formatPath4FTP(remotePath); FTPFile[] list = client.list(remotePath); if (list.length > 1){ x = 1; }else if (list.length == 1) { FTPFile f = list[0]; if (f.getType() == FTPFile.TYPE_DIRECTORY) { x = 1; } //假设推理判断 String _path = remotePath + "/" + f.getName(); if(client.list(_path).length == 1){ x = 1; }else{ x = 0; } } else { client.changeDirectory(remotePath); x = 1; } } catch (Exception e) { x = -1; System.out.println("###[Error] FTPToolkit.isExist() "+e.getMessage()); } return x;}/** * 关闭FTP连接，关闭时候像服务器发送一条关闭命令 * @param client FTP客户端 * @return 关闭成功，或者链接已断开，或者链接为null时候返回true，通过两次关闭都失败时候返回false */ public static boolean closeConn(FTPClient client) { if (client == null) return true; if (client.isConnected()) { try { client.disconnect(true); return true; } catch (Exception e) { try { client.disconnect(false); } catch (Exception e1) {} } } return true; }//###---------------------------------------------------------------------/** * 格式化文件路径，将其中不规范的分隔转换为标准的分隔符,并且去掉末尾的文件路径分隔符。 * 本方法操作系统自适应 * @param path 文件路径 * @return 格式化后的文件路径 */ public static String formatPath4File(String path) { String reg0 = "\\\\+"; String reg = "\\\\+|/+"; String temp = path.trim().replaceAll(reg0, "/"); temp = temp.replaceAll(reg, "/"); if (temp.length() > 1 && temp.endsWith("/")) { temp = temp.substring(0, temp.length() - 1); } temp = temp.replace('/', File.separatorChar); return temp; } /** * 格式化文件路径，将其中不规范的分隔转换为标准的分隔符 * 并且去掉末尾的"/"符号(适用于FTP远程文件路径或者Web资源的相对路径)。 * @param path 文件路径 * @return 格式化后的文件路径 */ public static String formatPath4FTP(String path) { String reg0 = "\\\\+"; String reg = "\\\\+|/+"; String temp = path.trim().replaceAll(reg0, "/"); temp = temp.replaceAll(reg, "/"); if (temp.length() > 1 && temp.endsWith("/")) { temp = temp.substring(0, temp.length() - 1); } return temp; } /** * 获取FTP路径的父路径，但不对路径有效性做检查 * @param path FTP路径 * @return 父路径，如果没有父路径，则返回null */ public static String genParentPath4FTP(String path) { String f = new File(path).getParent(); if (f == null) { return null; }else { return formatPath4FTP(f); }}//###---------------------------------------------------------------------//获取指定目录下的文件public static File[] getPathFiles(String path){ File file = new File(path); if (file.isDirectory()) { File[] files = file.listFiles(); return files; } return null;}//删除指定目录下的临时文件public static void deleteFiles(String path){ File file = new File(path); if (file.isDirectory()) { File[] files = file.listFiles(); for (int i = 0; i < files.length; i++) { //String name = files[i].getName(); //if(name.trim().toLowerCase().endsWith("_ftp.tmp")) { //System.out.println(name + "\t"); //} //清空临时文件 _ftp.tmp files[i].delete(); } } }//截取文件名称public static String getFileName(String fileName){ String fs = "F"+System.currentTimeMillis(); try { if(fileName != null && !"".equals(fileName)){ if(fileName.lastIndexOf("/") > 0 && fileName.lastIndexOf(".") > 0){ fs = fileName.substring(fileName.lastIndexOf("/")+1); }else{ fs = fileName; } if(fs.length() >50){ fs = fs.substring(0,50); } return fs; }else{ return fs; } } catch (Exception e) { System.out.println("###[Error] FtpTools.getFileName()"+e.getMessage()); } return fs;}public static void main(String args[]) throws Exception { FTPClient f41 = FTPToolkit.ftpConn("129.2.8.31", 21, "root", "root31"); FTPClient f42 = FTPToolkit.ftpConn("129.2.8.32", 21, "root", "root32"); //InputStream in = FTPToolkit.fetchInputStream(f41,"/home/photofile/wenzi-003.jpg"); //FTPToolkit.uploadInputStream(f41,"/home/photofile/aa.jpg",in); //FTPToolkit.upload(f41, "E:\\demo\\av1.jpg", "/home/photofile/10/20"); //FTPToolkit.download(f41, "/home/photofile/wenzi-100.jpg", "E:\\"); //FTPToolkit.getlistFiles(f41,"/home/photofile"); //文件流对流读取操作 List<String> ls = null;//FTPToolkit.getlistFileNames(f41,"/home/photofile"); if(ls != null && ls.size() >0){ InputStream in=null; for(int i =0;i<ls.size();i++){ //in = FTPToolkit.fetchInputStream(f41,ls.get(i)); if(in != null && in.available() > 0){ FTPToolkit.uploadInputStream(f42,"/home/wasadmin/photoSysTempFTP/"+getFileName(ls.get(i)),in); f41.deleteFile(ls.get(i)); } } //清空项目下的临时文件 FTPToolkit.deleteFiles("ftptmp"); } FTPToolkit.closeConn(f41); FTPToolkit.closeConn(f42); }}
/ FTP监听器/ class MyFtpListener implements FTPDataTransferListener { private String tag; private MyFtpListener(String tags) { this.tag = tags; }
public static MyFtpListener instance(String tags) { return new MyFtpListener(tags); }public void started() { //System.out.println(tag+ "：FTP启动。。。。。。"); } public void transferred(int length) { //System.out.println(tag+ "：FTP传输["+length+"]。。。。。。"); } public void completed() { //System.out.println(tag+ "：FTP完成。。。。。。"); } public void aborted() { //System.out.println(tag+ "：FTP中止。。。。。。"); } public void failed() { //System.out.println(tag+ "：FTP挂掉。。。。。。"); }}```
用户点评