ftp 上传下载

1. package lemote.test.mid.util;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.FileInputStream;
   
6. import java.io.FileOutputStream;
   
7. 
   
8. import lemote.test.mid.properties.DefaultValue;
   
9. 
   
10. import org.apache.commons.net.ftp.FTP;
    
11. import org.apache.commons.net.ftp.FTPClient;
    
12. import org.apache.commons.net.ftp.FTPClientConfig;
    
13. import org.apache.commons.net.ftp.FTPReply;
    
14. 
    
15. import android.os.Environment;
    
16. 
    
17. public class FtpUnit {
    
18.         private FTPClient ftpClient = null;
    
19.         private String SDPATH;
    
20.         public FtpUnit(){
    
21.                 SDPATH =Environment.getExternalStorageDirectory()+"/";
    
22.         }
    
23.         
    
24.         /**
    
25.          * 链接Ftp服务器
    
26.          */
    
27.         public  void connectServer(){
    
28.                 if(ftpClient == null){
    
29.                         int reply;
    
30.                         try{
    
31.                                 ftpClient = new FTPClient();
    
32.                                 ftpClient.setDefaultPort(21);
    
33.                                 ftpClient.configure(getFtpConfig());
    
34.                                 ftpClient.connect("172.16.18.175");
    
35.                                 ftpClient.login("anonymous","");
    
36.                                 ftpClient.setDefaultPort(21);                                
    
37.                                 reply = ftpClient.getReplyCode();
    
38.                                 System.out.println(reply+"----");
    
39.                 if (!FTPReply.isPositiveCompletion(reply)) {
    
40.                      ftpClient.disconnect();
    
41.                      System.err.println("FTP server refused connection.");
    
42.                  }
    
43.                 ftpClient.enterLocalPassiveMode();
    
44.                 ftpClient.setControlEncoding("gbk");
    
45.                         }catch(Exception e){
    
46.                                 e.printStackTrace();
    
47.                         }
    
48.                 }
    
49.         }
    
50.         
    
51.         /**
    
52.      * 上传文件
    
53.      * @param localFilePath--本地文件路径
    
54.      * @param newFileName--新的文件名
    
55.     */
    
56.    public void uploadFile(String localFilePath,String newFileName){
    
57.         connectServer();
    
58.        //上传文件
    
59.         BufferedInputStream buffIn=null;
    
60.        try{
    
61.             buffIn=new BufferedInputStream(new FileInputStream(SDPATH+"/"+localFilePath));
    
62.             System.out.println(SDPATH+"/"+localFilePath);
    
63.             System.out.println("start="+System.currentTimeMillis());
    
64.             ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
    
65.             ftpClient.storeFile("a1.mp3", buffIn);
    
66.             System.out.println("end="+System.currentTimeMillis());
    
67.         }catch(Exception e){
    
68.             e.printStackTrace();
    
69.         }finally{
    
70.            try{
    
71.                if(buffIn!=null)
    
72.                     buffIn.close();
    
73.             }catch(Exception e){
    
74.                 e.printStackTrace();
    
75.             }
    
76.         }
    
77.     }
    
78.    
    
79.    /**
    
80.     * 下载文件
    
81.     * @param remoteFileName --服务器上的文件名
    
82.     * @param localFileName--本地文件名
    
83.    */
    
84.   public  void loadFile(String remoteFileName,String localFileName){
    
85.        connectServer();
    
86.        System.out.println("==============="+localFileName);
    
87.       //下载文件
    
88.        BufferedOutputStream buffOut=null;
    
89.       try{
    
90.            buffOut=new BufferedOutputStream(new FileOutputStream(SDPATH+localFileName));
    
91.            long start = System.currentTimeMillis();
    
92.            ftpClient.retrieveFile(remoteFileName, buffOut);
    
93.            long end = System.currentTimeMillis();
    
94.            System.out.println(end-start);
    
95.        }catch(Exception e){
    
96.            e.printStackTrace();
    
97.        }finally{
    
98.           try{
    
99.               if(buffOut!=null)
    
100.                    buffOut.close();
     
101.            }catch(Exception e){
     
102.                e.printStackTrace();
     
103.            }
     
104.        }
     
105.    }
     
106.   
     
107.         /**
     
108.      * 设置FTP客服端的配置--通常能够不设置
     
109.      * @return
     
110.      */
     
111.    private static FTPClientConfig getFtpConfig(){
     
112.         FTPClientConfig ftpConfig=new FTPClientConfig(FTPClientConfig.SYST_UNIX);
     
113.         ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING);
     
114.        return ftpConfig;
     
115.     }
     
116.    
     
117.    /**
     
118.     * 关闭链接
     
119.    */
     
120.   public  void closeConnect(){
     
121.       try{
     
122.           if(ftpClient!=null){
     
123.                ftpClient.logout();
     
124.                ftpClient.disconnect();
     
125.            }
     
126.        }catch(Exception e){
     
127.            e.printStackTrace();
     
128.        }
     
129.    }
     
130.   
     
131. }