[JAVA]SFTP 파일 업로드 하기

SFTP를 이용한 파일전송에 대해서 알아보도록 하겠습니다.  간단한 전송 소스 예제를 소개 해드립니다.

 
 
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
 
/**
 * 서버와 연결하여 파일을 업로드하고, 다운로드한다.
 *
 */
 public class SFTPClient{
     private Session session = null;
 
    private Channel channel = null;
 
    private ChannelSftp channelSftp = null;
 
    /**
     * 서버와 연결에 필요한 값들을 가져와 초기화 시킴
     *
     * @param host
     *            서버 주소
     * @param userName
     *            접속에 사용될 아이디
     * @param password
     *            비밀번호
     * @param port
     *            포트번호
     */
     public void init(String host, String userName, String password, int port) throws JSchException,Exception  {
         JSch jsch = new JSch();
         try {
             session = jsch.getSession(userName, host, port);
             session.setPassword(password);
 
            java.util.Properties config = new java.util.Properties();
             config.put("StrictHostKeyChecking", "no");
             session.setConfig(config);
             session.connect();
 
            channel = session.openChannel("sftp");
             channel.connect();
         } catch (JSchException e) {
             e.printStackTrace();
         }
 
        channelSftp = (ChannelSftp) channel;
 
    }
 
    /**
     * 하나의 파일을 업로드 한다.
     *
     * @param dir
     *            저장시킬 주소(서버)
     * @param file
     *            저장할 파일
     */
     public boolean upload(String dir, File file)  throws SftpException,FileNotFoundException,Exception{
 
        FileInputStream in = null;
         try {
             in = new FileInputStream(file);
             channelSftp.cd(dir);
             channelSftp.put(in, file.getName());
             return true;
         } catch (SftpException e) {
             e.printStackTrace();
             return false;
         } catch (FileNotFoundException e) {
             e.printStackTrace();
             return false;
         } catch (Exception e) {
            // TODO: handle exception
             return false;
        } 
         finally {
             if (channelSftp.isConnected()) {
                 channelSftp.disconnect();
             }             
             try {
                 in.close();
             } catch (IOException e) {
                 e.printStackTrace();
             }
         }
     }
 
    /**
     * 하나의 파일을 다운로드 한다.
     *
     * @param dir
     *            저장할 경로(서버)
     * @param downloadFileName
     *            다운로드할 파일
     * @param path
     *            저장될 공간
     */
     public void download(String dir, String downloadFileName, String path) {
         InputStream in = null;
         FileOutputStream out = null;
         try {
             channelSftp.cd(dir);
             in = channelSftp.get(downloadFileName);
         } catch (SftpException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
 
        try {
             out = new FileOutputStream(new File(path));
             int i;
 
            while ((i = in.read()) != -1) {
                 out.write(i);
             }
         } catch (IOException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } finally {
             try {
                 out.close();
                 in.close();
             } catch (IOException e) {
                 e.printStackTrace();
             }
 
        }
 
    }
 
    /**
     * 서버와의 연결을 끊는다.
     */
     public void disconnection() {
         channelSftp.quit();
 
    }
 }