1.FTP服務器上傳和下載功能 查看詳情

1）.首先在本地機器上創建一個用戶！這些用戶是用來登錄到FTP的！我的電腦右鍵->管理->本地用戶和組－>用戶->“右鍵”新建用戶－>輸入用戶名和密碼再點創建就行了！

2).其次是在C盤新建文件夾“FTP上傳”和“FTP下載”兩個文件夾！並在每個文件夾裏放不同的文件，以便區分！

3) 之後是安裝IIS組件！在開始菜單裏—>控制面板－〉添加或刪除程序->添加/刪除windows組件－>應用程序服務器->Internet 信息服務->

－〉FTP服務器-〉確定－〉完成！這樣就把FTP安裝在服務器上了！

4) 最後就是配置FTP服務器，創建上傳和下載服務！創建上傳服務器：右鍵網站－>選擇添加FTP站點－>描述可以根據自己的需要填寫

－>地址一般都是自己的IP地址，端口默認使用21->物理路徑指向“C:\FTP上傳”->訪問權限要鉤上“讀取”和“寫入”－>點擊完成就把上傳的服務創建好了！

註意：如果服務和應用程序下面 沒有 internet信息服務（IIS）管理這一項 需要在打開和關閉windows功能添加 web管理工具全選 如圖：

上傳服務器圖解：

5) 創建下載服務器：因為21號端口已經被占用所以我們就用2121端口！它的物理路徑指向“C：\FTP下載”！只有讀取權限！！具體的步驟和FTP上傳一樣，區別只是讀取。

6）最後就可以測試剛才建立的ftp服務器是否建立成功了。在IE瀏覽器上輸入以下地址ftp://192.168.8.100即可打開具有上傳功能的FTP頁面，

輸入ftp：//192.168.9.3：2121即可打開只有下載功能的頁面了！當然，登錄之 前還需要你輸入開始建立的那個賬號及密碼

2.FTP 實現上傳下載功能

所需要的jar包 commons.net.jar log4j.jar

package com.zhouwuji.list;

public class Ftp {
       private String ipAddr;//ip地址
        
        private Integer port;//端口號
        
        private String userName;//用戶名
        
        private String pwd;//密碼
        
        private String path;//aaa路徑
    
        public String getIpAddr() {
            return ipAddr;
        }
    
        public void setIpAddr(String ipAddr) {
            this.ipAddr = ipAddr;
        }
    
        public Integer getPort() {
            return port;
        }
    
        public void setPort(Integer port) {
            this.port = port;
        }
    
        public String getUserName() {
            return userName;
        }
    
        public void setUserName(String userName) {
            this.userName = userName;
        }
    
        public String getPwd() {
            return pwd;
        }
    
        public void setPwd(String pwd) {
            this.pwd = pwd;
        }
    
        public String getPath() {
            return path;
        }
    
        public void setPath(String path) {
            this.path = path;
        }
        
}

package com.zhouwuji.list;


import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.List;

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 FtpUtil {
        
    private static Logger logger=Logger.getLogger(FtpUtil.class);
     
    private static FTPClient ftp;
           
           /**
            * 獲取ftp連接
            * @param f
            * @return
            * @throws Exception
            */
           public static boolean connectFtp(Ftp f) throws Exception{
               ftp=new FTPClient();
               boolean flag=false;
               int reply;
               if (f.getPort()==null) {
                   ftp.connect(f.getIpAddr(),21);
               }else{
                   ftp.connect(f.getIpAddr(),f.getPort());
               }
               ftp.login(f.getUserName(), f.getPwd());
               ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
               reply = ftp.getReplyCode();      
               if (!FTPReply.isPositiveCompletion(reply)) {      
                     ftp.disconnect();      
                     return flag;      
               }      
               ftp.changeWorkingDirectory(f.getPath());      
               flag = true;      
               return flag;
           }
           
           /**
            * 關閉ftp連接
            */
           public static void closeFtp(){
               if (ftp!=null && ftp.isConnected()) {
                   try {
                       ftp.logout();
                       ftp.disconnect();
                   } catch (IOException e) {
                       e.printStackTrace();
                   }
               }
           }
           
           /**
            * ftp上傳文件
            * @param f
            * @throws Exception
            */
           public static void upload(File f) throws Exception{
               if (f.isDirectory()) {
                   ftp.makeDirectory(f.getName());
                   ftp.changeWorkingDirectory(f.getName());
                   String[] files=f.list();
                   for(String fstr : files){
                       File file1=new File(f.getPath()+"/"+fstr);
                       if (file1.isDirectory()) {
                           upload(file1);
                           ftp.changeToParentDirectory();
                       }else{
                           File file2=new File(f.getPath()+"/"+fstr);
                           FileInputStream input=new FileInputStream(file2);
                           ftp.storeFile(file2.getName(),input);
                           input.close();
                       }
                   }
               }else{
                   File file2=new File(f.getPath());
                   FileInputStream input=new FileInputStream(file2);
                   ftp.storeFile(file2.getName(),input);
                   input.close();
               }
           }
           
           /**
            * 下載鏈接配置
            * @param f
            * @param localBaseDir 本地目錄
            * @param remoteBaseDir 遠程目錄
            * @throws Exception
            */
           public static void startDown(Ftp f,String localBaseDir,String remoteBaseDir ) throws Exception{
               if (FtpUtil.connectFtp(f)) {
                   
                 try { 
                     FTPFile[] files = null; 
                     boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir); 
                     if (changedir) { 
                         ftp.setControlEncoding("GBK"); 
                         files = ftp.listFiles(); 
                         for (int i = 0; i < files.length; i++) { 
                             try{ 
                                 downloadFile(files[i], localBaseDir, remoteBaseDir); 
                             }catch(Exception e){ 
                                 logger.error(e); 
                                 logger.error("<"+files[i].getName()+">下載失敗"); 
                             } 
                         } 
                     } 
                 } catch (Exception e) { 
                     logger.error(e); 
                     logger.error("下載過程中出現異常"); 
                 } 
             }else{
                 logger.error("鏈接失敗！");
             }
             
         }
         
         
         /** 
          * 
          * 下載FTP文件 
          * 當你需要下載FTP文件的時候，調用此方法 
          * 根據<b>獲取的文件名，本地地址，遠程地址</b>進行下載 
          * 
          * @param ftpFile 
          * @param relativeLocalPath 
          * @param relativeRemotePath 
          */ 
         private  static void downloadFile(FTPFile ftpFile, String relativeLocalPath,String relativeRemotePath) { 
             if (ftpFile.isFile()) {
                 if (ftpFile.getName().indexOf("?") == -1) { 
                     OutputStream outputStream = null; 
                     try { 
                         File locaFile= new File(relativeLocalPath+ ftpFile.getName()); 
                         //判斷文件是否存在，存在則返回 
                         if(locaFile.exists()){ 
                             return; 
                         }else{ 
                             outputStream = new FileOutputStream(relativeLocalPath+ ftpFile.getName()); 
                             ftp.retrieveFile(ftpFile.getName(), outputStream); 
                             outputStream.flush(); 
                             outputStream.close(); 
                         } 
                     } catch (Exception e) { 
                         logger.error(e);
                     } finally { 
                         try { 
                             if (outputStream != null){ 
                                 outputStream.close(); 
                             }
                         } catch (IOException e) { 
                            logger.error("輸出文件流異常"); 
                         } 
                     } 
                 } 
             } else { 
                 String newlocalRelatePath = relativeLocalPath + ftpFile.getName(); 
                 String newRemote = new String(relativeRemotePath+ ftpFile.getName().toString()); 
                 File fl = new File(newlocalRelatePath); 
                 if (!fl.exists()) { 
                     fl.mkdirs(); 
                 } 
                 try { 
                     newlocalRelatePath = newlocalRelatePath + ‘/‘; 
                     newRemote = newRemote + "/"; 
                     String currentWorkDir = ftpFile.getName().toString(); 
                     boolean changedir = ftp.changeWorkingDirectory(currentWorkDir); 
                     if (changedir) { 
                         FTPFile[] files = null; 
                         files = ftp.listFiles(); 
                         for (int i = 0; i < files.length; i++) { 
                             downloadFile(files[i], newlocalRelatePath, newRemote); 
                         } 
                     } 
                     if (changedir){
                         ftp.changeToParentDirectory(); 
                     } 
                 } catch (Exception e) { 
                     logger.error(e);
                 } 
             } 
         } 
     
         public boolean removeFile(String ftpFileName) {  
             boolean flag = false;  
         
             try {  
                 ftpFileName = new String(ftpFileName.getBytes("GBK"),"iso-8859-1");  
                 flag = ftp.deleteFile(ftpFileName);  
                 return flag;  
             } catch (IOException e) {  
                 e.printStackTrace();  
                 return false;  
             }  
         }
         
          public static void test() throws IOException{
            /*   //新建文件夾
              int  s=ftp.mkd("/bak");
                // 查詢目錄
              FTPFile[] file= ftp.listDirectories();
             for (FTPFile ftpFile : file) {
                System.out.println(ftpFile);
            }*/
             //讀取文件內容
        /*InputStream inputStream= ftp.retrieveFileStream("sendLogDetail_201801.txt");    
        BufferedReader br =new BufferedReader(
                new InputStreamReader(
                    new BufferedInputStream(inputStream)));
        String info =null;
        while(null!=(info=br.readLine())){
            System.out.println(info);
        
        }*/
         OutputStream outputStream2=ftp.appendFileStream("sendLogDetail_201801.txt");
         //OutputStream outputStream=ftp.storeFileStream("/sendLogDetail_201801.txt");
         String str="ZHOUWU";
         byte[] bsw=str.getBytes();
         outputStream2.write(bsw);
         outputStream2.close();
          }
          
          
         public static void main(String[] args) throws Exception{  
                 Ftp f=new Ftp();
                 f.setIpAddr("192.168.8.100");
                 f.setUserName("OU");
                 f.setPwd("OU7758521");
                 FtpUtil.connectFtp(f);
                 FtpUtil.test();
                 
                 
                 // File file = new File("D:/xp/test/sendLogDetail_201801.txt");  
                 //把文件上傳在ftp上
                 // FtpUtil.upload(file);
                 //下載ftp文件測試
                /*  FtpUtil.startDown(f, "D:/xp/",  "/");
                  System.out.println("ok");*/
               
            }  
         
     }

文件上傳下載和FTP--FTP服務器創建和上下傳文件