FTP관련 유틸 추가
parent
b8e3d219b4
commit
c631bb09e8
@ -0,0 +1,160 @@
|
||||
package cokr.xit.fims.cmmn.ftp;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.regex.Matcher;
|
||||
|
||||
import org.apache.commons.net.ftp.FTPClient;
|
||||
import org.apache.commons.net.ftp.FTPFile;
|
||||
import org.apache.commons.net.ftp.FTPReply;
|
||||
|
||||
public class FTPUtil {
|
||||
public static boolean fileDown(remoteSystemInfo rs, String remoteWorkPath, String downloadRoot) {
|
||||
|
||||
FTPClient client = null;
|
||||
try {
|
||||
|
||||
String thisSystemFileSeperator = File.separator;
|
||||
|
||||
String remoteSystemFileSeparator = rs.getOsType().equals("linux") ? "/" : "\\";
|
||||
|
||||
if(!thisSystemFileSeperator.equals(remoteSystemFileSeparator)) {
|
||||
remoteWorkPath = remoteWorkPath.replaceAll(
|
||||
Matcher.quoteReplacement(thisSystemFileSeperator),
|
||||
Matcher.quoteReplacement(remoteSystemFileSeparator)
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
client = new FTPClient();
|
||||
client.setControlEncoding("UTF-8");
|
||||
client.connect(rs.getIp(), 21);
|
||||
|
||||
// 접속을 확인.
|
||||
int resultCode = client.getReplyCode();
|
||||
if (!FTPReply.isPositiveCompletion(resultCode)) {
|
||||
System.out.println("FTP server refused connection.!");
|
||||
throw new RuntimeException("접속 오류");
|
||||
}
|
||||
|
||||
client.setSoTimeout(1000);
|
||||
// 로그인을 한다.
|
||||
if (!client.login(rs.getId(), rs.getPw())) {
|
||||
System.out.println("Login Error!");
|
||||
throw new RuntimeException("로그인 오류");
|
||||
}
|
||||
|
||||
|
||||
List<String> remoteFiles = new ArrayList<>();
|
||||
List<String> remoteDirectories = new ArrayList<>();
|
||||
|
||||
// FTP에서 파일 리스트와 디렉토리 정보를 취득한다.
|
||||
if (!FTPUtil.getFileList(client, remoteSystemFileSeparator, remoteWorkPath, remoteFiles, remoteDirectories)) {
|
||||
// 리스트 취득 실패시 프로그램을 종료한다.
|
||||
System.out.println("File search Error!");
|
||||
throw new RuntimeException("오류 발생");
|
||||
}
|
||||
|
||||
for (String remoteDirectory : remoteDirectories) {
|
||||
System.out.println("디렉토리-"+remoteDirectory);
|
||||
|
||||
String newFolderPath = "";
|
||||
if(thisSystemFileSeperator.equals(remoteSystemFileSeparator)) {
|
||||
newFolderPath = downloadRoot + remoteDirectory;
|
||||
} else {
|
||||
newFolderPath = downloadRoot + remoteDirectory.replaceAll(
|
||||
Matcher.quoteReplacement(remoteSystemFileSeparator),
|
||||
Matcher.quoteReplacement(thisSystemFileSeperator)
|
||||
);
|
||||
}
|
||||
|
||||
File folder = new File(newFolderPath);
|
||||
folder.mkdirs();
|
||||
}
|
||||
|
||||
|
||||
for (String remoteFile : remoteFiles) {
|
||||
System.out.println("파일-"+remoteFile);
|
||||
|
||||
String tempFileOutputPath = "";
|
||||
|
||||
if(thisSystemFileSeperator.equals(remoteSystemFileSeparator)) {
|
||||
tempFileOutputPath = downloadRoot + remoteFile;
|
||||
} else {
|
||||
tempFileOutputPath = downloadRoot + remoteFile.replaceAll(
|
||||
Matcher.quoteReplacement(remoteSystemFileSeparator),
|
||||
Matcher.quoteReplacement(thisSystemFileSeperator)
|
||||
);
|
||||
}
|
||||
|
||||
try (FileOutputStream fo = new FileOutputStream(tempFileOutputPath)){
|
||||
//FTPClient의 retrieveFile함수로 보내면 다운로드가 이루어 진다.
|
||||
if (client.retrieveFile(remoteFile, fo)) {
|
||||
System.out.println("Download - " + remoteFile);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
throw new RuntimeException("오류 발생");
|
||||
} finally {
|
||||
// ftp 커넥션이 연결되어 있으면 종료한다.
|
||||
try {
|
||||
if (client.isConnected()) {
|
||||
client.disconnect();
|
||||
}
|
||||
} catch (Throwable e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
// FTP의 파일 리스트와 디렉토리 정보를 취득하는 함수.
|
||||
public static boolean getFileList(FTPClient client, String fileSeparator, String work, List<String> files, List<String> directories) {
|
||||
System.out.println("work is "+work);
|
||||
|
||||
// FTP의 디렉토리 커서를 이동한다.
|
||||
try {
|
||||
if (client.changeWorkingDirectory(work)) {
|
||||
System.out.println("커서이동 성공");
|
||||
// 해당 디렉토리의 파일 리스트를 취득한다.
|
||||
for (FTPFile file : client.listFiles()) {
|
||||
|
||||
if (!file.isFile()) {
|
||||
// 디렉토리리면 함수의 재귀적 방식으로 하위 탐색을 시작한다.
|
||||
if (!getFileList(client, fileSeparator, work + file.getName() + fileSeparator, files, directories)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// directories 리스트에 디렉토리 경로를 추가한다.
|
||||
directories.add(work + file.getName() + fileSeparator);
|
||||
} else {
|
||||
// files 리스트에 경로를 추가한다.
|
||||
files.add(work + file.getName());
|
||||
}
|
||||
|
||||
}
|
||||
// FTP의 디렉토리 커서를 상위로 이동하는 함수
|
||||
// client.changeToParentDirectory();
|
||||
|
||||
// FTP의 디렉토리 커서를 이동한다.
|
||||
return client.changeWorkingDirectory(fileSeparator);
|
||||
|
||||
} else {
|
||||
System.out.println("커서이동 실패");
|
||||
}
|
||||
} catch (IOException e) {
|
||||
System.out.println("유틸 에러");
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
// 커서 이동에 실패하면 false를 리턴한다.
|
||||
return false;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,13 @@
|
||||
package cokr.xit.fims.cmmn.ftp;
|
||||
|
||||
import lombok.Getter;
|
||||
import lombok.Setter;
|
||||
|
||||
@Getter
|
||||
@Setter
|
||||
public class remoteSystemInfo {
|
||||
String ip;
|
||||
String id;
|
||||
String pw;
|
||||
String osType;
|
||||
}
|
||||
Loading…
Reference in New Issue