[Java] java ftp 서버 파일 업로드하기

출처 : http://blog.naver.com/PostView.nhn?blogId=korn123&logNo=30131283804

원격지 ftp서버에 접속하여 파일을 업로드하는 예제입니다.


관련 API

http://commons.apache.org/net/apidocs/org/apache/commons/net/ftp/


패키지 다운(압축해제 후 commons-net-x.x.x.jar 파일 import)

http://commons.apache.org/net/download_net.cgi

1. 원격지 ftp서버의 폴더상태

2. ftp서버에 업로드할 로컬폴더 상태

3. main method 실행후

4. 업로드 후 ftp서버의 폴더상태

    - 익스플로러 접속시 한글명이 깨져보이나 탐색기로 확인하면 정상적으로 보입니다.

//========================  FTPUpLoader.java  ==================================

package com.appspot.hihanjoong.util.ftp;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.ArrayList;

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;

/**
 * ftp서버 접속하여 파일을 업로드/다운로드 함
 * @author 조한중(hanjoongcho@gmail.com)
 *
 */
public class FTPUpLoader {
    /**
     * 
     * @param ip         ftp서버ip
     * @param port       ftp서버port
     * @param id         사용자id
     * @param password   사용자password 
     * @param folder     ftp서버에생성할폴더
     * @param files      업로드list
     * @return
     */
    public boolean sendFtpServer(String ip, int port, String id, String password,

                          String folder,String localPath, ArrayList<String> files) {
        boolean isSuccess = false;
        FTPClient ftp = null;
        int reply;
        try {
            ftp = new FTPClient();
            ftp.connect(ip, port);
            System.out.println("Connected to " + ip + " on "+ftp.getRemotePort());
            
            // After connection attempt, you should check the reply code to verify
            // success.
            reply = ftp.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                ftp.disconnect();
                System.err.println("FTP server refused connection.");
                System.exit(1);
            }
            
            if(!ftp.login(id, password)) {
                ftp.logout();
                throw new Exception("ftp 서버에 로그인하지 못했습니다.");
            }
            
            ftp.setFileType(FTP.BINARY_FILE_TYPE);
            ftp.enterLocalPassiveMode();
            

            System.out.println(ftp.printWorkingDirectory());
            try{
                ftp.makeDirectory(folder);
            }catch(Exception e){
                e.printStackTrace();
            }
            ftp.changeWorkingDirectory(folder);
            System.out.println(ftp.printWorkingDirectory());
            
            
            for(int i = 0; i < files.size(); i++) {
                //ftp서버에 한글파일을 쓸때 한글깨짐 방지
                String tempFileName = new String(files.get(i).getBytes("utf-8"),"iso_8859_1");
                String sourceFile = localPath + files.get(i);        
                File uploadFile = new File(sourceFile);
                FileInputStream fis = null;
                try {
                    fis = new FileInputStream(uploadFile);
                    System.out.println(sourceFile + " : 전송시작 = >");

                   

                     //tempFileName 업로드 될 타겟의 풀 경로가 들어가야 함.  ex) /A/A01/A001/aa.zip   파일명만 들어갈경우 unix에서 전송 실패하는 경우가 생김.
                    isSuccess = ftp.storeFile(tempFileName, fis);  
                    System.out.println(sourceFile + " : 전송결과 = >" + isSuccess);
                } catch(IOException e) {
                    e.printStackTrace();
                    isSuccess = false;
                } finally {
                    if (fis != null) {
                        try {fis.close(); } catch(IOException e) {}
                    }
                }//end try
            }//end for
            
            ftp.logout();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (ftp != null && ftp.isConnected()) {
                try { ftp.disconnect(); } catch (IOException e) {}
            }
        }
        return isSuccess;
    }

}

//========================  FTPUpLoaderMain.java  ================================== 

package com.appspot.hihanjoong.util.ftp;

import java.util.ArrayList;

public class FTPUpLoaderMain {
    
    public static void main(String[] args) {
        
        FTPUpLoader upLoader = new FTPUpLoader();
        ArrayList<String> list = new ArrayList<String>();
        
        list.add("한글이미지.PNG");
        list.add("토렌져.exe");
        list.add("Livepot.Searcher.install.exe");
        list.add("utorrent.exe");
        
        boolean re = upLoader.sendFtpServer("192.168.2.7", 21, "guest",

                                                               "guest", "test2","C:\\test\\", list);
        
        if(re){
            System.out.println("FTPUpLoaderMain.java :: 업로드 성공");
        }else{
            System.out.println("FTPUpLoaderMain.java :: 업로드 실패");
        }
    }
    

}

---

FTP UpLoad 수정 버전

FTPUpLoader.Java

FTPUpLoader.Java

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.util.ArrayList;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.net.ftp.FTP;

import org.apache.commons.net.ftp.FTPClient;

import org.apache.commons.net.ftp.FTPReply;

/**

 * ftp서버 접속하여 파일을 업로드/다운로드.

 *

 */

public class FTPUpLoader {

    

    private FTPClient ftp = null;

    

    public FTPUpLoader() {

    }

    

    //FTP connect

    public void connectFTPUpLoader() {

        

        int port = 21;                                          //upload 목적지 port.

        String ip = FileUtil.getProperty("framework.ftp.ip");                     //upload 목적지 ip.

        String id = FileUtil.getProperty("framework.ftp.id");                      //upload 목적지 계정.

        String password = FileUtil.getProperty("framework.ftp.pw");          //upload 목적지 비밀번호.

        int reply;

        

        try {

            

            this.ftp = new FTPClient();

            this.ftp.connect( ip, port );

            

            System.out.println("Connected to " + ip + " on "+ftp.getRemotePort());   //log

            

            // After connection attempt, you should check the reply code to verify

            // success.

            reply = ftp.getReplyCode();

            if ( !FTPReply.isPositiveCompletion(reply) ) {

                ftp.disconnect();

                System.err.println("FTP server refused connection.");   //log

                System.exit(1);

            }

            

            if( !ftp.login(id, password) ) {

                ftp.logout();

                throw new Exception("ftp 서버에 로그인하지 못했습니다.");

            }

            

            ftp.setFileType(FTP.BINARY_FILE_TYPE);

            ftp.enterLocalPassiveMode();

            

            System.out.println(ftp.printWorkingDirectory());   //log

            

        }catch(Exception e) {

            e.printStackTrace();

        }

    }

    

    //FTP disconnect

    public void disconnectFTPUpLoader() {

        try {

            this.ftp.logout();

        }catch(Exception e) {

            e.printStackTrace();

        }finally {

            if( ftp != null && ftp.isConnected() ) {

                try { ftp.disconnect(); }catch (IOException e) {}

            }

        }

    }

    

    /**

     * @param ip             ftp서버ip

     * @param port          ftp서버port

     * @param id             사용자id

     * @param password   사용자password 

     * @param folder        ftp서버에생성할폴더

     * @param files          업로드filelist

     * @return

     */

    public boolean sendFtpServer( String folder, String localPath, ArrayList<String> files ) {

        boolean isSuccess = false;

        

        try {

            // A\A01\A01002

            String[] folders = folder.split("\\\\");

            String folder_str = "";

            

            try {

                

                for(int i=0; i<folders.length; i++) {

                    folder_str += folders[i] + "\\";

                    ftp.makeDirectory( folder_str );

                }

            }catch( Exception e ) {

                e.printStackTrace();

            }

            

            ftp.changeWorkingDirectory( folder_str );

            

            System.out.println(ftp.printWorkingDirectory());   //log

            

            File uploadFile =  null;

            FileInputStream fis = null;

            

            String tempFileName = "";

            String sourceFile = "";

            for( int i = 0; i < files.size(); i++ ) {

                //ftp서버에 한글파일을 쓸때 한글깨짐 방지

                tempFileName = new String(files.get(i).getBytes("utf-8"),"iso_8859_1");

                sourceFile = localPath + files.get(i);        

                uploadFile = new File(sourceFile);

                fis = null;

                

                try {

                    

                    fis = new FileInputStream(uploadFile);

                    System.out.println(sourceFile + " : 전송시작 = >");   //log

                    

                     //tempFileName 업로드 될 타겟의 풀 경로가 들어가야 함.  ex) /A/A01/A001/aa.zip   파일명만 들어갈경우 unix에서 전송 실패하는 경우가 생김.

                    isSuccess = ftp.storeFile(tempFileName, fis); 

                    System.out.println(sourceFile + " : 전송결과 = >" + isSuccess);   //log

                }catch(IOException e) {

                    e.printStackTrace();

                    isSuccess = false;

                }finally {

                    if( fis != null ) {

                        try { fis.close(); } catch(IOException e) {}

                    }

                }//end try

            }//end for

            

        }catch (Exception e) {

            e.printStackTrace();

        }

        

        return isSuccess;

    }

    

    /*FTP 다운로드*/

    public int downloadFtpFile(String filePath, String fileName, HttpServletRequest request) throws Exception {

        

        BufferedOutputStream bos = null;

        File fPath  = null;

        File fDir = null;

        File f   = null; 

        

        String downloadPath = FileUtil.getProperty("framework.ftp.download_path"); //다운로드 경로

        

        int result = -1;

        

        try {

            

             // download 경로에 해당하는 디렉토리 생성  

             downloadPath = downloadPath + "\\" + filePath;  

             fPath = new File(downloadPath);

             fDir = fPath;

             fDir.mkdirs();

             

             f = new File(downloadPath, fileName);

             

             ftp.changeWorkingDirectory(filePath);

          

             bos = new BufferedOutputStream(new FileOutputStream(f));

             boolean isSuccess = ftp.retrieveFile(fileName, bos);

              

             if (isSuccess) {

                 result = 1; // 성공     

             }

          

        }catch (Exception e) {

            e.printStackTrace(); 

        }finally{  

            if(bos != null) try {bos.close();} catch (Exception e) {}

        } // try ~ catch ~ finally

        

        return result;

    } // downloadFtpFile

}

/*

    import java.util.ArrayList;

    

    public class FTPUpLoaderMain {

        

        public static void main(String[] args) {

            

            FTPUpLoader upLoader = new FTPUpLoader();

            ArrayList<String> list = new ArrayList<String>();

            

            list.add("한글이미지.PNG");

            list.add("토렌져.exe");

            list.add("Livepot.Searcher.install.exe");

            list.add("utorrent.exe");

            

            //boolean re = upLoader.sendFtpServer("127.0.0.1", 21, "guest",

            //                                                       "guest", "test2","C:\\test\\", list);

                                                                   

            upLoader.connectFTPUpLoader();

            boolean re = upLoader.sendFtpServer( "AA", "C:\\test\\", list );  //(원격지 생설될 폴더, 업로드할 파일 위치, 업로드 파일 리스트)

            upLoader.disconnectFTPUpLoader();

            

            if(re){

                System.out.println("FTPUpLoaderMain.java :: 업로드 성공");

            }else{

                System.out.println("FTPUpLoaderMain.java :: 업로드 실패");

            }

        }

    }

*/

/*

 upLoader.connectFTPUpLoader();     

 int up_rtv = upLoader.downloadFtpFile( "ftp:dns\\test\\", "aa.wmv", request); //(다운로드경로, 파일명, requesy)

 upLoader.disconnectFTPUpLoader();

*/

[출처] java ftp 서버 파일 업로드하기 |작성자 Hanjoong