java实现ftp文件的上传与下载

 1 /**
 2  * ftp链接常量
 3  *
 4  */
 5 public class Ftp {
 6 
 7     private String ipAddr;//ip地址
 8     
 9     private Integer port;//端口号
10     
11     private String userName;//用户名
12     
13     private String pwd;//密码
14     
15     private String path;//aaa路径
16 
17     public String getIpAddr() {
18         return ipAddr;
19     }
20 
21     public void setIpAddr(String ipAddr) {
22         this.ipAddr = ipAddr;
23     }
24 
25     public Integer getPort() {
26         return port;
27     }
28 
29     public void setPort(Integer port) {
30         this.port = port;
31     }
32 
33     public String getUserName() {
34         return userName;
35     }
36 
37     public void setUserName(String userName) {
38         this.userName = userName;
39     }
40 
41     public String getPwd() {
42         return pwd;
43     }
44 
45     public void setPwd(String pwd) {
46         this.pwd = pwd;
47     }
48 
49     public String getPath() {
50         return path;
51     }
52 
53     public void setPath(String path) {
54         this.path = path;
55     }
56     
57     
58 }

  1 import java.io.File;
  2 import java.io.FileInputStream;
  3 import java.io.FileOutputStream;
  4 import java.io.IOException;
  5 import java.io.OutputStream;
  6 
  7 
  8 import org.apache.commons.net.ftp.FTPClient;
  9 import org.apache.commons.net.ftp.FTPFile;
 10 import org.apache.commons.net.ftp.FTPReply;
 11 import org.apache.log4j.Logger;
 12 
 13 public class FtpUtil {
 14     
 15     private static Logger logger=Logger.getLogger(FtpUtil.class);
 16     
 17     private static FTPClient ftp;
 18     
 19     /**
 20      * 获取ftp连接
 21      * @param f
 22      * @return
 23      * @throws Exception
 24      */
 25     public static boolean connectFtp(Ftp f) throws Exception{
 26         ftp=new FTPClient();
 27         boolean flag=false;
 28         int reply;
 29         if (f.getPort()==null) {
 30             ftp.connect(f.getIpAddr(),21);
 31         }else{
 32             ftp.connect(f.getIpAddr(),f.getPort());
 33         }
 34         ftp.login(f.getUserName(), f.getPwd());
 35         ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
 36         reply = ftp.getReplyCode();      
 37         if (!FTPReply.isPositiveCompletion(reply)) {      
 38               ftp.disconnect();      
 39               return flag;      
 40         }      
 41         ftp.changeWorkingDirectory(f.getPath());      
 42         flag = true;      
 43         return flag;
 44     }
 45     
 46     /**
 47      * 关闭ftp连接
 48      */
 49     public static void closeFtp(){
 50         if (ftp!=null && ftp.isConnected()) {
 51             try {
 52                 ftp.logout();
 53                 ftp.disconnect();
 54             } catch (IOException e) {
 55                 e.printStackTrace();
 56             }
 57         }
 58     }
 59     
 60     /**
 61      * ftp上传文件
 62      * @param f
 63      * @throws Exception
 64      */
 65     public static void upload(File f) throws Exception{
 66         if (f.isDirectory()) {
 67             ftp.makeDirectory(f.getName());
 68             ftp.changeWorkingDirectory(f.getName());
 69             String[] files=f.list();
 70             for(String fstr : files){
 71                 File file1=new File(f.getPath()+"/"+fstr);
 72                 if (file1.isDirectory()) {
 73                     upload(file1);
 74                     ftp.changeToParentDirectory();
 75                 }else{
 76                     File file2=new File(f.getPath()+"/"+fstr);
 77                     FileInputStream input=new FileInputStream(file2);
 78                     ftp.storeFile(file2.getName(),input);
 79                     input.close();
 80                 }
 81             }
 82         }else{
 83             File file2=new File(f.getPath());
 84             FileInputStream input=new FileInputStream(file2);
 85             ftp.storeFile(file2.getName(),input);
 86             input.close();
 87         }
 88     }
 89     
 90     /**
 91      * 下载链接配置
 92      * @param f
 93      * @param localBaseDir 本地目录
 94      * @param remoteBaseDir 远程目录
 95      * @throws Exception
 96      */
 97     public static void startDown(Ftp f,String localBaseDir,String remoteBaseDir ) throws Exception{
 98         if (FtpUtil.connectFtp(f)) {
 99             
100             try { 
101                 FTPFile[] files = null; 
102                 boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir); 
103                 if (changedir) { 
104                     ftp.setControlEncoding("GBK"); 
105                     files = ftp.listFiles(); 
106                     for (int i = 0; i < files.length; i++) { 
107                         try{ 
108                             downloadFile(files[i], localBaseDir, remoteBaseDir); 
109                         }catch(Exception e){ 
110                             logger.error(e); 
111                             logger.error("<"+files[i].getName()+">下载失败"); 
112                         } 
113                     } 
114                 } 
115             } catch (Exception e) { 
116                 logger.error(e); 
117                 logger.error("下载过程中出现异常"); 
118             } 
119         }else{
120             logger.error("链接失败！");
121         }
122         
123     }
124     
125     
126     /** 
127      * 
128      * 下载FTP文件 
129      * 当你需要下载FTP文件的时候，调用此方法 
130      * 根据<b>获取的文件名，本地地址，远程地址</b>进行下载 
131      * 
132      * @param ftpFile 
133      * @param relativeLocalPath 
134      * @param relativeRemotePath 
135      */ 
136     private  static void downloadFile(FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath) { 
137         if (ftpFile.isFile()) {
138             if (ftpFile.getName().indexOf("?") == -1) { 
139                 OutputStream outputStream = null; 
140                 try { 
141                     File locaFile= new File(relativeLocalPath+ ftpFile.getName()); 
142                     //判断文件是否存在，存在则返回 
143                     if(locaFile.exists()){ 
144                         return; 
145                     }else{ 
146                         outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName()); 
147                         ftp.retrieveFile(ftpFile.getName(), outputStream); 
148                         outputStream.flush(); 
149                         outputStream.close(); 
150                     } 
151                 } catch (Exception e) { 
152                     logger.error(e);
153                 } finally { 
154                     try { 
155                         if (outputStream != null){ 
156                             outputStream.close(); 
157                         }
158                     } catch (IOException e) { 
159                        logger.error("输出文件流异常"); 
160                     } 
161                 } 
162             } 
163         } else { 
164             String newlocalRelatePath = relativeLocalPath + ftpFile.getName(); 
165             String newRemote = new String(relativeRemotePath+ ftpFile.getName().toString()); 
166             File fl = new File(newlocalRelatePath); 
167             if (!fl.exists()) { 
168                 fl.mkdirs(); 
169             } 
170             try { 
171                 newlocalRelatePath = newlocalRelatePath + ‘/‘; 
172                 newRemote = newRemote + "/"; 
173                 String currentWorkDir = ftpFile.getName().toString(); 
174                 boolean changedir = ftp.changeWorkingDirectory(currentWorkDir); 
175                 if (changedir) { 
176                     FTPFile[] files = null; 
177                     files = ftp.listFiles(); 
178                     for (int i = 0; i < files.length; i++) { 
179                         downloadFile(files[i], newlocalRelatePath, newRemote); 
180                     } 
181                 } 
182                 if (changedir){
183                     ftp.changeToParentDirectory(); 
184                 } 
185             } catch (Exception e) { 
186                 logger.error(e);
187             } 
188         } 
189     } 
190 
191     
192     public static void main(String[] args) throws Exception{  
193             Ftp f=new Ftp();
194             f.setIpAddr("1111");
195             f.setUserName("root");
196             f.setPwd("111111");
197             FtpUtil.connectFtp(f);
198             File file = new File("F:/test/com/test/Testng.java");  
199             FtpUtil.upload(file);//把文件上传在ftp上
200             FtpUtil.startDown(f, "e:/",  "/xxtest");//下载ftp文件测试
201             System.out.println("ok");
202           
203        }  
204     
205 }