FtpFileUtil 备忘

package ...;import java.io.File;import java.io.InputStream;import java.io.OutputStream;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import org.apache.commons.net.ftp.FTPClient;import org.apache.commons.net.ftp.FTPFile;import org.apache.commons.net.ftp.FTPReply;import org.apache.log4j.Logger;public class FtpFileUtil {?? ?private static Logger Log = Logger.getLogger(FtpFileUtil.class);?? ?private static String ENCODING = "GBK";?? ??? ?private static String ftphostaddr = "...";?? ?private static int port = 21;?? ?private static String ftpname = "...";?? ?private static String ftppwd = "...";?? ?private static String ftppath = "...";?? ?private static String localpath = "...";?? ?private static String filename = "test.txt";?? ??? ?public static void main(String[] args) {//?? ??? ?// 上传文件//?? ??? ?FtpUtil.uploadFile(ftphostaddr,port,ftpname,ftppwd//?? ??? ??? ??? ?,ftppath,localpath,filename);//?? ??? ?// 下载文件//?? ??? ?FtpUtil.downFile(ftphostaddr,filename);?? ??? ?//?? ??? ?// 删除文件//?? ??? ?FtpUtil.deleteFile(ftphostaddr,filename);?? ??? ?//?? ??? ?// 获取目录全部文件名称//?? ??? ?for (String string : FtpUtil.getFileNames(ftphostaddr,ftppath)) {//?? ??? ??? ?System.out.println(string);//?? ??? ?}?? ??? ??? ??? ??? ?}?? ??? ?/**?? ? * 从本地上传文件到文件服务器上?? ? * 文件已存在追加写入?? ? */?? ?public static void uploadFile(String ftphostaddr,int port,String ftpname,?? ??? ??? ?String ftppwd,String ftppath,String localpath,String filename){?? ??? ?// FTP连接?? ??? ?FTPClient ftp = initFtp(ftphostaddr,ftppwd);?? ??? ?try {?? ??? ??? ?String fileAllName = ftppath + filename;?? ??? ??? ?Log.info("上传目录 :" + ftphostaddr+fileAllName);?? ??? ??? ?// 判断FTP目录是否存在?? ??? ??? ?boolean catalog = false;?? ??? ??? ?FTPFile[] ftpFileArr = ftp.listFiles(ftppath);?? ??? ??? ?if (ftpFileArr.length > 0) {?? ??? ??? ??? ?catalog = true;?? ??? ??? ?}?? ??? ??? ??? ??? ??? ?// 创建目录?? ??? ??? ?if (!catalog) {?? ??? ??? ??? ?Log.info("目录不存在，请查看后重新尝试。");//?? ??? ??? ??? ?boolean flag = true;//?? ??? ??? ??? ?String newdir = new String(ftppath.getBytes(ENCODING),"ISO-8859-1");//?? ??? ??? ??? ?flag = ftp.makeDirectory(newdir);//?? ??? ??? ??? ?if (flag) {//?? ??? ??? ??? ??? ?Log.info("make directory " + newdir + " successfully ！");//?? ??? ??? ??? ?} else {//?? ??? ??? ??? ??? ?Log.info("make directory " + newdir + " failed ！");//?? ??? ??? ??? ?}?? ??? ??? ?}?? ??? ??? ??? ??? ??? ?// 上传文件?? ??? ??? ?boolean flag = false;?? ??? ??? ?File file = new File( localpath+filename );?? ??? ??? ?InputStream input? = new FileInputStream( file );?? ??? ??? ?String remote = new String(fileAllName.getBytes(ENCODING),"ISO-8859-1");?? ??? ??? ?if (ftp.appendFile(remote,input)) {?? ??? ??? ??? ?flag = true;?? ??? ??? ?}?? ??? ??? ?input.close();?? ??? ??? ?Log.info("push file (" + file.getCanonicalPath() + ") => " + (flag ? "SUCCESS" : "FAILED"));?? ??? ??? ?ftp.logout();?? ??? ??? ?ftp.disconnect();?? ??? ?} catch (IOException e) {?? ??? ??? ?// TODO Auto-generated catch block?? ??? ??? ?e.printStackTrace();?? ??? ??? ?new Exception("从本地上传文件到服务器失败");?? ??? ?}?? ?}?? ??? ?/**?? ? * 从文件服务器上下载文件到本地?? ? * 不删除服务器文件?? ? * 文件追加写入?? ? */?? ?public static void downFile(String ftphostaddr,String filename) {?? ??? ?FTPClient ftp = initFtp(ftphostaddr,ftppwd);?? ??? ?try {?? ??? ??? ?// 4.指定要下载的目录?? ??? ??? ?ftp.changeWorkingDirectory(ftppath);// 转移到FTP服务器目录?? ??? ??? ?// 5.遍历下载的目录?? ??? ??? ?// 解决中文乱码问题，两次解码?? ??? ??? ?byte[] bytes = filename.getBytes("iso-8859-1");?? ??? ??? ?String fn = new String(bytes,"utf8");?? ??? ??? ?if (fn.equals(filename)) {?? ??? ??? ??? ?// 6.写操作，将其写入到本地文件中?? ??? ??? ??? ?Log.info("下载文件：? " + filename + "? 开始:? "?? ??? ??? ??? ??? ??? ?+ System.currentTimeMillis());?? ??? ??? ??? ?File localFile = new File(localpath + filename);?? ??? ??? ??? ?OutputStream is = new FileOutputStream(localFile);?? ??? ??? ??? ?ftp.retrieveFile(filename,is);//?? ??? ??? ??? ?// 7.判断本地文件是否正确写入，如果正确写入，将文件服务器上的文件删除//?? ??? ??? ??? ?if (localFile.exists()) {//?? ??? ??? ??? ??? ?Log.info("删除服务器上文件：" + filename);//?? ??? ??? ??? ??? ?ftp.deleteFile(filename);//?? ??? ??? ??? ?}?? ??? ??? ??? ??? ??? ??? ??? ?Log.info("下载文件：? " + filename + "? 结束:? "?? ??? ??? ??? ??? ??? ?+ System.currentTimeMillis());?? ??? ??? ??? ?is.close();?? ??? ??? ?}?? ??? ??? ?// 8.关闭?? ??? ??? ?ftp.logout();?? ??? ??? ?ftp.disconnect();?? ??? ?} catch (Exception e) {?? ??? ??? ?e.printStackTrace();?? ??? ??? ?new Exception("从服务器下载文件过程中发生错误");?? ??? ?} finally {?? ??? ??? ?if (ftp.isConnected()) {?? ??? ??? ??? ?try {?? ??? ??? ??? ??? ?ftp.disconnect();?? ??? ??? ??? ?} catch (IOException ioe) {?? ??? ??? ??? ??? ?ioe.printStackTrace();?? ??? ??? ??? ?}?? ??? ??? ?}?? ??? ?}?? ?}?? ??? ?/**?? ? * 将服务器上的文件删除?? ? */?? ?public static void deleteFile(String ftphostaddr,String ftppwd?? ??? ??? ?,String filename){?? ??? ?FTPClient ftp = initFtp(ftphostaddr,ftppwd);?? ??? ??? ??? ?Log.info("删除服务器上文件：" + filename);?? ??? ?try {?? ??? ??? ?ftp.cwd(ftppath);?? ??? ??? ?ftp.deleteFile(filename);?? ??? ??? ?ftp.logout();?? ??? ??? ?ftp.disconnect();?? ??? ?} catch (IOException e) {?? ??? ??? ?// TODO Auto-generated catch block?? ??? ??? ?e.printStackTrace();?? ??? ??? ?new Exception("将服务器上的文件删除失败");?? ??? ?}?? ?}?? ??? ?/**?? ? * 获取服务器上文件夹下全部文件的名称?? ? */?? ?public static String[] getFileNames(String ftphostaddr,String ftppath) {?? ??? ?FTPClient ftp = initFtp(ftphostaddr,ftppwd);?? ??? ?try {?? ??? ??? ?ftp.cwd(ftppath);?? ??? ??? ?ftp.enterLocalPassiveMode();// 开通一个端口来传输数据?? ??? ??? ?String[] subfile = ftp.listNames();?? ??? ??? ?return subfile;?? ??? ?} catch (IOException e) {?? ??? ??? ?// TODO Auto-generated catch block?? ??? ??? ?e.printStackTrace();?? ??? ??? ?new Exception("获取文件夹下全部文件的名称失败");?? ??? ?}?? ??? ?return null;?? ?}?? ??? ?/**?? ? * 建立FTP连接?? ? */?? ?public static FTPClient initFtp(String ftphostaddr,?? ??? ??? ?String ftpname,String ftppwd) {?? ??? ?int reply;?? ??? ?FTPClient ftp = new FTPClient();?? ??? ?try {?? ??? ??? ?// 1.连接服务器?? ??? ??? ?// ftp.connect(ftphostaddr);?? ??? ??? ?ftp.connect(ftphostaddr,port);?? ??? ??? ?// 2.登录服务器 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器?? ??? ??? ?ftp.login(ftpname,ftppwd);?? ??? ??? ?// 3.判断登陆是否成功?? ??? ??? ?reply = ftp.getReplyCode();?? ??? ??? ?if (!FTPReply.isPositiveCompletion(reply)) {?? ??? ??? ??? ?ftp.disconnect();?? ??? ??? ?}?? ??? ?} catch (Exception e) {?? ??? ??? ?e.printStackTrace();?? ??? ??? ?new Exception("服务器连接失败");?? ??? ?}?? ??? ?return ftp;?? ?}?? ??? ?/**?? ? * 关闭连接?? ? */?? ?public static void closeConnect(FTPClient ftp) {?? ??? ?try {?? ??? ??? ?if (ftp != null) {?? ??? ??? ??? ?// 8.关闭?? ??? ??? ??? ?ftp.logout();?? ??? ??? ??? ?ftp.disconnect();?? ??? ??? ?}?? ??? ??? ?Log.info("close Connect");?? ??? ?} catch (Exception e) {?? ??? ??? ?e.printStackTrace();?? ??? ?}?? ?}?? ??? ?}