Java ftpClient 사용한 ftp 전송 구현
org.apache.commons.net.ftp.FTPClient
파일업로드 ftp 구현은
1. web -> server MultipartRequest 방식으로 올리고
2. server에서 받아온 file을 서버에 저장
3. 저장한 파일을 ftp 전송(파일서버에 전송)
4. server에 저장된 tmp 파일 제거
디렉토리는 1step 씩 생성되며
디렉토리가 없으면 ftp 전송이 안됨 ( 없는 디렉토리 생성 x )
디렉토리 있는지 검사 하는 함수가 없어 ,
디렉토리 이동을 해서 성공하면 디렉토리가 있는것이고
실패 하면 디렉토리 생성해야됨
existed = fm.changeWorkingDirectory(singleDir);
if (!existed) {
디렉토리 생성후 디렉토리 안으로 이동해 줘야
다음 step 부터 생성됨
FileUpload
import java.io.File; import java.io.IOException; import java.net.UnknownHostException; import org.springframework.web.multipart.MultipartFile; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPClientConfig; import org.apache.commons.net.ftp.FTPReply; public class FileUpload {
private static final String _svr = "1.201.137.64"; //ftp 서버 private static final int _port = 21; //ftp 포트
private static final String _svr_user = "audien"; private static final String _svr_pass = "comsta10454$";
private static FTPManager instance = new FTPManager();
//private static final String[] _war_dst = {"/storage/tomcat-8/instance1/webapps/audien-b2c.war", "/storage/tomcat-8/instance2/webapps/audien-b2c.war", "/storage/tomcat-8/instance3/webapps/audien-b2c.war", "/storage/tomcat-8/instance4/webapps/audien-b2c.war"}; //private static final String _war_src = "C:\\_HUI\\01.dev\\workspace\\gm2\\audien-b2c\\target\\audien-b2c.war";
/* type = banner, category, coupon, event war_dst = /storage/tomcat-8/instance1/webapps/audien-b2c.war //서버에 생성될 파일 경로 war_src = C:\\_HUI\\01.dev\\workspace\\gm2\\audien-b2c\\target\\audien-b2c.war //복사될 파일 경로
*/
private static FTPManager getInstance() { return instance; }
public boolean putFile(String file_src, String file_dst, String file_nm) { boolean ret=false;
FTPManager fm = instance;
try {
fm.open(_svr, 21, _svr_user, _svr_pass);
System.out.println("replay=" + fm.getReplyString()); fm.setFileType(FTPManager.BINARY_FILE_TYPE); System.out.println("replay=" + fm.getReplyString());
fm.changeWorkingDirectory("/"); System.out.println("Current Directory = "+ fm.printWorkingDirectory());
String[] pathElements = file_dst.split("/"); if (pathElements != null && pathElements.length > 0) { boolean existed; for (String singleDir : pathElements) { existed = fm.changeWorkingDirectory(singleDir); if (!existed) { boolean created = fm.makeDirectory(singleDir); if (created) { System.out.println("CREATED directory: " + singleDir); fm.changeWorkingDirectory(fm.printWorkingDirectory()+"/"+singleDir); } else { System.out.println("COULD NOT create directory: " + singleDir); } } } }
System.out.println("upload ["+file_src+" to "+_svr + fm.printWorkingDirectory()+file_nm+"]"); if (fm.putFile(file_src, fm.printWorkingDirectory()+"/"+file_nm)) { System.out.println("successfully"); ret = true; } else { System.out.println("File Upload Failure"); ret = false; }
fm.close();
} catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); }
//System.exit(0);
return ret; }
public String getFilePath() { String filePath = this.getClass().getResource("").getPath(); filePath = filePath.substring(1,filePath.indexOf(".metadata"))+"audien-b2c-mgmt/";
return filePath+"src/main/webapp/resources/files/tmp/";
}
public String getFtpPath(String type, String path) { String filePath= "/storage/common/images/"+type+"/"; filePath= filePath+path.substring(0,1)+"/" +path.substring(1,3)+"/" +path.substring(3,5)+"/" +path.substring(5,7)+"/"; //+path.substring(7,9)+"/";
return filePath; }
public void removeFile(String file_src){ File file = new File(file_src);
if(file.exists()){ file.delete(); }
} public String getExtension(String fName){ String extension = ""; if( fName != null ) { String strSplit[] = fName.split("[.]"); if( strSplit.length >= 2 ) { extension = "." + strSplit[strSplit.length-1]; } }
return extension; }
}
|
FTPManager
import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.net.SocketException; import java.net.UnknownHostException; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPClientConfig; import org.apache.commons.net.ftp.FTPReply; public class FTPManager extends FTPClient { private static String UNIX_FILE_SEP = StringUtil.UNIX_FILE_SEP; private static char EXTENSION_SEP = StringUtil.EXTENSION_SEP; private static String FILE_SEP = StringUtil.FILE_SEP; private static String REFUSE_CONNECTION = "FTP server refused connection."; private static String FAIL_LOGIN = "Unknown username and password."; private static String FAIL_LOGOUT = "Unknown error caused by FTP server."; private static String UNKNOWN_FILE = "Unknown file name and extension."; private static String NOT_FOUND_FILE = "Given file does not exist.";
private static String UNKNOWN_ABS_FILE = "No absolute path file."; private static String UNKNOWN_DIR = "Given directory does not exist."; private static String ALREADY_FILE = "Already exists file name."; public FTPManager() { }
public void open(String server, int port, String user, String password) throws SocketException, IOException { try { int reply; FTPClientConfig conf = null; conf = new FTPClientConfig(FTPClientConfig.SYST_UNIX); configure(conf); connect(server, port); //System.out.println("Connected to " + server + "."); //System.out.print(getReplyString()); // After connection attempt, you should check the reply code to // verify success. reply = getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { disconnect(); throw new SocketException(REFUSE_CONNECTION); } if (!login(user, password)) throw new SocketException(FAIL_LOGIN); } catch (SocketException e) { throw e; } catch (IOException e) { throw e; } }
public void close() throws IOException, SocketException { try { if (isConnected()) { if (!logout()) { throw new SocketException(FAIL_LOGOUT); } disconnect(); } } catch (IOException e) { throw e; } }
public boolean getFile(String localfile) throws IOException, FileNotFoundException { DataOutputStream dos = null; try { File f = new File(localfile); if (f.exists()) { throw new FileNotFoundException(ALREADY_FILE); }
dos = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(f))); return retrieveFile(new StringBuffer().append( printWorkingDirectory()).append(UNIX_FILE_SEP).append( f.getName()).toString(), dos); } catch (FileNotFoundException e) { throw e; } catch (IOException e) { throw e; } finally { try { if (dos != null) dos.close(); } catch (IOException e) { throw e; } } }
public boolean getFile(String localfile, String remotefile) throws IOException, FileNotFoundException, IllegalArgumentException { if (remotefile == null || remotefile.length() == 0 || remotefile.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } int n = remotefile.lastIndexOf(UNIX_FILE_SEP); if (n == -1) { throw new IOException(UNKNOWN_ABS_FILE); } // check whether remotefile exists String cur_dir = remotefile.substring(0, n); String[] files = listNames(cur_dir); if (files == null) { throw new IllegalArgumentException(UNKNOWN_DIR); } int len = files.length; boolean b = false; for (int i = 0; i < len; i++) { // System.out.println("file name=" + files[i]); if (files[i].equals(remotefile)) { b = true; break; } } // not found remote file if (!b) { throw new FileNotFoundException(NOT_FOUND_FILE); } DataOutputStream dos = null; try { File f = new File(localfile); if (f.exists()) { throw new FileNotFoundException(ALREADY_FILE); }
dos = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(f))); return retrieveFile(remotefile, dos); } catch (FileNotFoundException e) { throw e; } catch (IOException e) { throw e; } finally { try { if (dos != null) dos.close(); } catch (IOException e) { throw e; } } }
public boolean putFile(String localfile) throws IOException, FileNotFoundException { try { return putFile(localfile, localfile.substring(localfile.lastIndexOf(FILE_SEP) + 1)); } catch (FileNotFoundException e) { throw e; } catch (IOException e) { throw e; } }
public boolean putFile(String localfile, String remotefile) throws IOException, FileNotFoundException { if (remotefile == null || remotefile.length() == 0 || remotefile.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } DataInputStream dis = null; String cur_dir; try { // check whether only file if (remotefile.indexOf(UNIX_FILE_SEP) == -1) { cur_dir = printWorkingDirectory(); remotefile = new StringBuffer().append(cur_dir).append( UNIX_FILE_SEP).append(remotefile).toString(); } else { // check with listNames function cur_dir = remotefile.substring(0, remotefile.lastIndexOf(UNIX_FILE_SEP)); } // not supported. ==> "list" command // FTPFile[] files = listFiles(cur_dir); // int len = files.length; // System.out.println("file length="+ len); // // for (int i=0; i< len;i++ ) { // System.out.println("file name="+ files[i].getName()); // //System.out.println("Already exists file name."); // } String[] files = listNames(cur_dir); if (files != null) { int len = files.length; for (int i = 0; i < len; i++) { // System.out.println("file name=" + files[i]); if (files[i].equals(remotefile)) { throw new IOException(ALREADY_FILE); } } } dis = new DataInputStream(new BufferedInputStream(new FileInputStream(localfile))); return appendFile(remotefile, dis); } catch (FileNotFoundException e) { throw e; } catch (IOException e) { throw e; } finally { try { if (dis != null) dis.close(); } catch (IOException e) { throw e; } } }
public boolean renameFile(String oldname, String newname) throws IOException, IllegalArgumentException, FileNotFoundException { if (oldname == null || oldname.length() == 0 || oldname.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } if (newname == null || newname.length() == 0 || newname.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } try { // check whether only file if (oldname.indexOf(UNIX_FILE_SEP) == -1) { String cur_dir = printWorkingDirectory(); // change to absolute path file. oldname = new StringBuffer().append(cur_dir).append( UNIX_FILE_SEP).append(oldname).toString(); // check whether file exists with listNames function String[] files = listNames(cur_dir); // don't need to check because of using printWorkingDirectory // function. // if (files == null) { // throw new IllegalArgumentException(UNKNOWN_DIR); // } boolean b = false; int len = files.length; for (int i = 0; i < len; i++) { // System.out.println("file name=" + files[i]); if (files[i].equals(oldname)) { b = true; break; } } // not found original file if (!b) { throw new IllegalArgumentException(NOT_FOUND_FILE); } return rename(oldname, newname); } else { // file contains directory // check with listNames function String cur_dir = oldname.substring(0, oldname .lastIndexOf(UNIX_FILE_SEP)); String[] files = listNames(cur_dir); if (files == null) { throw new IllegalArgumentException(UNKNOWN_DIR); } int len = files.length; boolean b = false; for (int i = 0; i < len; i++) { // System.out.println("file name=" + files[i]); if (files[i].equals(oldname)) { b = true; break; } } // not found original file if (!b) { throw new FileNotFoundException(NOT_FOUND_FILE); } return rename(oldname, newname); } } catch (IOException e) { throw e; } }
public boolean uploadFile(String localfile, String remotefile) throws IOException, FileNotFoundException { if (remotefile == null || remotefile.length() == 0 || remotefile.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } FileInputStream fis = null; String cur_dir; try { // if (FTP.STREAM_TRANSFER_MODE) { // check whether only file if (remotefile.indexOf(UNIX_FILE_SEP) == -1) { cur_dir = printWorkingDirectory(); remotefile = new StringBuffer().append(cur_dir).append( UNIX_FILE_SEP).append(remotefile).toString(); } else { cur_dir = remotefile.substring(0, remotefile .lastIndexOf(UNIX_FILE_SEP)); } // compare file size between localfile and remotefile long remotesize = getRemoteFileSize(remotefile); // long localsize = getLocalFileSize(localfile); if (remotesize == 0) { fis = new FileInputStream(localfile); } else { fis = new FileInputStream(localfile); fis.skip(remotesize); } return appendFile(remotefile, fis); // } } catch (FileNotFoundException e) { throw e; } catch (IOException e) { throw e; } finally { try { if (fis != null) fis.close(); } catch (IOException e) { throw e; } } }
public long getRemoteFileSize(String remotefile) throws IOException { try { int ret = sendCommand("SIZE", remotefile); String reply = getReplyString().trim(); if (ret != 213) { return 0L; } return Long.parseLong(reply.substring(4)); } catch (IOException e) { throw e; } }
public String getFileTimeStamp(String remotefile) throws FileNotFoundException, IOException { if (remotefile == null || remotefile.length() == 0 || remotefile.indexOf(EXTENSION_SEP) == -1) { throw new FileNotFoundException(UNKNOWN_FILE); } try { int ret = sendCommand("MDTM", remotefile); String reply = getReplyString().trim(); if (ret != 213) { throw new IOException(reply); } return reply.substring(4); } catch (IOException e) { throw e; } }
public long getLocalFileSize(String localfile) throws FileNotFoundException { File f = new File(localfile); if (!f.exists()) { throw new FileNotFoundException(NOT_FOUND_FILE); } if (!f.isFile()) { throw new FileNotFoundException(NOT_FOUND_FILE); } return f.length(); } public static void main(String args[]) { FTPManager fm = new FTPManager(); try { // --------------------------------------------- // Test for upload file // --------------------------------------------- fm.open("192.168.0.34", 21, "srbt", "Nam7728"); System.out.println("replay=" + fm.getReplyString()); fm.setFileType(FTPManager.BINARY_FILE_TYPE); System.out.println("replay=" + fm.getReplyString()); // streaming file is ok // fm.uploadFile("C:\\Temp\\aaa.mpg","/app1/srbt/tmp/aaa.mpg"); // fm.uploadFile("C:\\Temp\\bbb.pdf","/app1/srbt/tmp/bbb.pdf"); // long size = fm.getRemoteFileSize("/app1/srbt/tmp/aaa.mpg"); // System.out.println("size=" + size); // // String date = fm.getFileTimeStamp("/app1/srbt/tmp/aaa.mpg"); // System.out.println("replay=" + fm.getReplyString()); // System.out.println(date); // // size = fm.getLocalFileSize("C:\\Temp\\aaa.mpg"); // System.out.println(size); // -------------------------------------------- // Test for unix server // -------------------------------------------- // String localfile = "C:\\Temp\\alaw.wav"; // String remotefile = "test.wav"; // fm.open("192.168.0.34", 21, "srbt", "Nam7728"); // fm.setFileType(FTPManager.BINARY_FILE_TYPE); // // System.out.println("Current Directory = " // + fm.printWorkingDirectory()); // // if (fm.changeWorkingDirectory("tmp")) { // System.out.println("ChangeDir Success = " // + fm.printWorkingDirectory()); // } else { // System.out.println("ChangeDir Failure"); // } // // if (fm.putFile(localfile, remotefile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // remotefile = "/app1/srbt/tmp/test1.wav"; // if (fm.putFile(localfile, remotefile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // if (fm.putFile(localfile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // if (fm.renameFile(remotefile, "aaa.wav")) { // System.out.println("File Rename Success"); // } else { // System.out.println("File Rename Failure"); // } // // if (fm.renameFile(remotefile, "aaa.wav")) { // test for existing // System.out.println("File Rename Success"); // } else { // System.out.println("File Rename Failure"); // } // // if (fm.getFile("c:\\aaa.wav")) { // System.out.println("File Download Success"); // } else { // System.out.println("File Download Failure"); // } // // if (fm.getFile("c:\\aaa1.wav", "/app1/srbt/tmp/test.wav")) { // System.out.println("File Download Success"); // } else { // System.out.println("File Download Failure"); // } // -------------------------------------------- // Test for NT server // -------------------------------------------- // String localfile = "C:\\Temp\\alaw.wav"; // String remotefile = "test.wav"; // // fm.open("192.168.6.97", 21, "srbt", "Nam7728"); // System.out.println(fm.getSystemName()); // fm.setFileType(FTPManager.BINARY_FILE_TYPE); // fm.type(FTPManager.BINARY_FILE_TYPE); // // System.out.println("Current Directory = " // + fm.printWorkingDirectory()); // // if (fm.changeWorkingDirectory("tmp")) { // System.out.println("ChangeDir Success = " // + fm.printWorkingDirectory()); // } else { // System.out.println("ChangeDir Failure"); // } // // if (fm.putFile(localfile, remotefile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // remotefile = "/tmp/test1.wav"; // if (fm.putFile(localfile, remotefile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // if (fm.putFile(localfile)) { // System.out.println("File Upload Success"); // } else { // System.out.println("File Upload Failure"); // } // // if (fm.renameFile(remotefile, "aaa.wav")) { // System.out.println("File Rename Success"); // } else { // System.out.println("File Rename Failure"); // } // // if (fm.getFile("C:\\aaa.wav")) { // System.out.println("File Download Success"); // } else { // System.out.println("File Download Failure"); // } // // if (fm.getFile("C:\\aaa1.wav", "/tmp/test.wav")) { // System.out.println("File Download Success"); // } else { // System.out.println("File Download Failure"); // } fm.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } } }
|