[java] 자바(java)로 만든 FTP와 SFTP Client 통합 프로그램 [펌]

[java] 자바(java)로 만든 FTP와 SFTP Client 통합 프로그램 [펌]

 

아래에는 FTP, SFTP 따로 동작하는 프로그램인데

클래스를 크게 3개로 나누어서 통합프로그램을 만들었습니다.

 

서버로 설정한 CentOS

Virtual Box를 사용하여 CentOS를 임의의 서버로 설정하였습니다.

 

프로젝트 구조

프로젝트 구조는 위 사진과 같습니다.

 

FTP와 SFTP를 사용하기 위해선 commons.net과 JSch라이브러리가 필요한데 이와 관련된 내용은 아래글에 있고,

 

여기선 통합프로그램을 어떻게 구현했는지에 대한 코드만 올리겠습니다.

 

ProgramStart.java

1. package program;
3. import java.io.BufferedReader;
4. import java.io.IOException;
5. import java.io.InputStreamReader;
7. public class ProgramStart {
8. public static void main(String[] args) {// 메인 메소드
9. String command = "";
10. BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
11. MyFTPClient myFTPClient = new MyFTPClient();
12. MySFTPClient mySFTPClinet = new MySFTPClient();
13. System.out.print("프로토콜 유형: ");
14. try {
15. command = br.readLine();
16. if (command.equals("ftp") || command.equals("FTP")) {
17. myFTPClient.start();
18. } else if (command.equals("sftp") || command.equals("SFTP")) {
19. mySFTPClinet.start();
20. } else {
21. System.out.println("어떤 프로토콜을 쓸건지 다시 입력해주세요.");
22. System.exit(0);
23. }
24. } catch (IOException e) {
25. e.printStackTrace();
26. }
27. }
28. }

 

MyFTPClient.java

1. package program;
3. import java.io.File;
4. import java.io.FileInputStream;
5. import java.io.FileNotFoundException;
6. import java.io.FileOutputStream;
7. import java.io.IOException;
8. import java.io.InputStream;
9. import java.io.OutputStream;
10. import java.util.Scanner;
12. import org.apache.commons.net.ftp.FTP;
13. import org.apache.commons.net.ftp.FTPClient;
14. import org.apache.commons.net.ftp.FTPFile;
15. import org.apache.commons.net.ftp.FTPReply;
17. public class MyFTPClient {
19. public void start() {
20. FTPClient ftpClient = new FTPClient();
21. // 서버접속
22. Scanner scanner = new Scanner(System.in);
23. System.out.print("호스트 주소 입력: ");
24. String server = scanner.nextLine();
25. try {
27. ftpClient.connect(server, 21);
28. if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
29. System.out.println(server + "에 연결됐습니다.");
30. System.out.println(ftpClient.getReplyCode() + " SUCCESS CONNECTION.");
31. }
32. } catch (Exception e) {
33. System.out.println("서버 연결 실패");
34. System.exit(0);
35. }
36. // 계정입력
37. System.out.print("계정 입력: ");
38. String user = scanner.nextLine();
39. System.out.print("비밀번호 입력: ");
40. String password = scanner.nextLine();
41. try {
42. ftpClient.login(user, password);
43. System.out.println(ftpClient.getReplyCode() + " Login successful.");
44. } catch (IOException e) {
45. System.out.println(ftpClient.getReplyCode() + " Login incorrect.");
46. System.exit(0);
47. }
49. // 명령어시작
50. while (true) {
51. System.out.print("ftp> ");
52. String str = "";
53. str = scanner.nextLine();
54. String[] params = str.split(" ");
55. String command = params[0];
56. // 명령어 시작
57. if (command.equals("cd")) {
58. String path = params[1];
59. try {
60. ftpClient.changeWorkingDirectory(path);
61. } catch (IOException e) {
62. e.printStackTrace();
63. }
64. } // end cd
65. else if (command.equals("mkdir")) {
66. String directory = params[1];
67. try {
68. ftpClient.makeDirectory(directory);
69. } catch (IOException e) {
70. e.printStackTrace();
71. }
72. } // end mkdir
73. else if (command.equals("rmdir")) {
74. String directory = params[1];
75. try {
76. ftpClient.removeDirectory(directory);
77. } catch (IOException e) {
78. e.printStackTrace();
79. }
80. } // end rmdir
81. else if (command.equals("binary")) {
82. try {
83. ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
84. System.out.println(ftpClient.getReplyCode() + " Switching to Binary mode.");
85. } catch (IOException e) {
86. e.printStackTrace();
87. }
88. } // end binary
89. else if (command.equals("ascii")) {
90. try {
91. ftpClient.setFileType(FTP.ASCII_FILE_TYPE);
92. System.out.println(ftpClient.getReplyCode() + " Switching to ASCII mode.");
93. } catch (IOException e) {
94. e.printStackTrace();
95. }
96. } // end ascii
97. else if (command.equals("pwd")) {
98. try {
99. System.out.println(ftpClient.printWorkingDirectory());
100. } catch (IOException e) {
101. e.printStackTrace();
102. }
103. } // end pwd
104. else if (command.equals("quit")) {
105. try {
106. ftpClient.logout();
107. System.out.println(ftpClient.getReplyCode() + " Goodbye.");
108. break;
109. } catch (IOException e) {
110. e.printStackTrace();
111. }
112. } // end quit
113. else if (command.equals("put")) {
114. String p1 = str.split(" ")[1];
115. String p2 = str.split(" ")[2];
117. File putFile = new File(p2);
118. InputStream inputStream = null;
120. try {
121. inputStream = new FileInputStream(putFile);
122. boolean result = ftpClient.storeFile(p1, inputStream);
123. if (result == true) {
124. System.out.println("업로드 성공");
125. } else {
126. System.out.println("업로드 실패");
127. }
128. } catch (IOException e) {
129. e.printStackTrace();
130. } finally {
131. if (inputStream != null) {
132. try {
133. inputStream.close();
134. } catch (IOException e) {
135. e.printStackTrace();
136. }
137. }
138. }
139. } // end put
140. else if (command.equals("get")) {
141. String p1 = str.split(" ")[1];
142. String p2 = str.split(" ")[2];
144. File getFile = new File(p2);
145. OutputStream outputStream = null;
147. try {
148. outputStream = new FileOutputStream(getFile);
149. boolean result = ftpClient.retrieveFile(p1, outputStream);
150. if (result == true) {
151. System.out.println("다운로드 성공");
152. } else {
153. System.out.println("다운로드 실패");
154. }
155. } catch (FileNotFoundException e1) {
156. e1.printStackTrace();
157. } catch (IOException e) {
158. e.printStackTrace();
159. } finally {
160. if (outputStream != null) {
161. try {
162. outputStream.close();
163. } catch (IOException e) {
164. e.printStackTrace();
165. }
166. }
167. }
168. } // end get
169. else if (command.equals("delete")) {
170. String file = str.split(" ")[1];
171. try {
172. ftpClient.deleteFile(file);
173. } catch (IOException e) {
174. e.printStackTrace();
175. }
176. } // end rm
177. else if (command.equals("ls")) {
178. String[] files = null;
179. try {
180. files = ftpClient.listNames();
181. for (int i = 0; i < files.length; i++) {
182. System.out.println(files[i]);
183. }
184. } catch (IOException e) {
185. e.printStackTrace();
186. }
187. } // end ls
188. else if (command.equals("dir")) {
189. FTPFile[] files = null;
190. try {
191. files = ftpClient.listFiles();
192. for (int i = 0; i < files.length; i++) {
193. System.out.println(files[i]);
194. }
195. } catch (IOException e) {
196. e.printStackTrace();
197. }
198. } // end dir
199. } // end while
200. try {
201. ftpClient.disconnect();
202. } catch (IOException e) {
203. e.printStackTrace();
204. } finally {
205. scanner.close();
206. }
207. System.exit(0);
208. }
209. }

 

MySFTPClient.java

1. package program;
3. import java.security.KeyPairGenerator;
4. import java.security.NoSuchAlgorithmException;
5. import java.security.Security;
6. import java.util.Scanner;
7. import java.util.Vector;
9. import javax.crypto.KeyAgreement;
11. import org.bouncycastle.jce.provider.BouncyCastleProvider;
13. import com.jcraft.jsch.Channel;
14. import com.jcraft.jsch.ChannelSftp;
15. import com.jcraft.jsch.JSch;
16. import com.jcraft.jsch.JSchException;
17. import com.jcraft.jsch.Session;
18. import com.jcraft.jsch.SftpException;
20. public class MySFTPClient {
21. public void start() {
22. // https://lahuman.jabsiri.co.kr/152
23. // DH알고리즘을 쓰기위한 코드
24. Security.addProvider(new BouncyCastleProvider());
25. try {
26. KeyPairGenerator.getInstance("DH");
27. } catch (NoSuchAlgorithmException e1) {
28. e1.printStackTrace();
29. }
30. try {
31. KeyAgreement.getInstance("DH");
32. } catch (NoSuchAlgorithmException e1) {
33. e1.printStackTrace();
34. }
36. Session session = null;
37. Channel channel = null;
38. JSch jsch = new JSch();
40. Scanner scanner = new Scanner(System.in);
41. System.out.print("계정 입력: ");
42. String username = scanner.nextLine();
43. System.out.print("호스트 주소 입력: ");
44. String host = scanner.nextLine();
45. System.out.print("비밀번호 입력: ");
46. String password = scanner.nextLine();
48. try {
49. // 세션 객체 생성
50. session = jsch.getSession(username, host, 22);
51. // 비밀번호설정
52. session.setPassword(password);
53. // 호스트 정보를 검사하지 않음
54. session.setConfig("StrictHostKeyChecking", "no");
55. // 세션접속
56. session.connect();
57. // sftp채널열기
58. channel = session.openChannel("sftp");
59. // 채널접속
60. channel.connect();
61. System.out.println("Connected to user@" + host);
62. } catch (JSchException e) {
63. e.printStackTrace();
64. System.out.println("접속에 실패했습니다.");
65. // 실패시 시스템 종료
66. System.exit(0);
67. }
68. ChannelSftp channelSftp = (ChannelSftp) channel;
69. while (true) {
70. System.out.print("sftp> ");
71. String str = "";
72. str = scanner.nextLine();
74. String[] params = str.split(" ");
75. String command = params[0];
77. if (command.equals("cd")) {
78. String p1 = params[1];// 스플릿의 과부하를 줄인다..왜? 변수명으로 바꼈자나
79. try {
80. channelSftp.cd(p1);
81. } catch (SftpException e) {
82. System.out.println("Couldn't stat remote file: No such file or directory");
83. }
84. } // end cd
85. else if (command.equals("lcd")) {
86. // lcd C:\Users\solulink
87. String p1 = params[1];
88. try {
89. channelSftp.lcd(p1);
90. } catch (SftpException e) {
92. System.out.println("Couldn't change local directory to " + p1 + ": No such file or directory");
93. }
94. } // end lcd
95. else if (command.equals("pwd")) {
96. try {
97. System.out.println("Remote working directory: " + channelSftp.pwd());
98. } catch (SftpException e) {
99. e.printStackTrace();
100. }
101. } // end pwd
102. else if (command.equals("lpwd")) {
103. // lpwd
104. System.out.println("Local working directory: " + channelSftp.lpwd());
105. } // end lpwd
106. else if (command.equals("get")) {
107. try {
108. if (params.length == 2) {
109. channelSftp.get(params[1]);
110. } else {
111. channelSftp.get(params[1], params[2]);
112. }
113. } catch (SftpException e) {
114. System.out.println("Ex)get centos.txt C:\\Users\\solulink");
115. }
116. } // end get
117. else if (command.equals("put")) {
118. String p1 = str.split(" ")[1];
119. try {
120. channelSftp.put(p1);
122. } catch (SftpException e) {
123. System.out.println("Ex)put window.txt");
124. }
125. } // end put
126. else if (command.equals("ls") || command.equals("dir")) {
127. String path = ".";
128. try {
129. // 가변길이의 배열
130. Vector vector = channelSftp.ls(path);
131. if (vector != null) {
132. for (int i = 0; i < vector.size(); i++) {
133. Object obj = vector.elementAt(i);
134. if (obj instanceof ChannelSftp.LsEntry) {
135. System.out.println(((ChannelSftp.LsEntry) obj).getLongname());
136. }
137. }
138. }
139. } catch (SftpException e) {
140. System.out.println(e.toString());
141. }
142. } // end ls
143. else if (command.equals("rm")) {
144. try {
145. String p1 = str.split(" ")[1];
146. channelSftp.rm(p1);
147. } catch (SftpException e) {
148. System.out.println("Couldn't delete file: No such file or directory");
149. }
150. } // end rm
151. else if (command.equals("mkdir")) {
152. String p1 = str.split(" ")[1];
153. try {
154. channelSftp.mkdir(p1);
155. } catch (SftpException e) {
156. e.printStackTrace();
157. }
158. } // end mkdir
159. else if (command.equals("rmdir")) {
160. String p1 = str.split(" ")[1];
161. try {
162. channelSftp.rmdir(p1);
163. } catch (SftpException e) {
164. System.out.println("Couldn't remove diretory: No such file or directory");
165. }
166. } // end rmdir
167. else if (command.equals("chmod")) {
168. // 접근권한 설정
169. // chmod 777 window.txt(rwx:7 x:1 wx:3 r-x:5)
170. String p1 = str.split(" ")[1];
171. String p2 = str.split(" ")[2];
172. try {
173. channelSftp.chmod(Integer.parseInt(p1), p2);
174. } catch (NumberFormatException e) {
175. e.printStackTrace();
176. } catch (SftpException e) {
177. e.printStackTrace();
178. }
179. } // end chmod
180. else if (command.equals("chown")) {
181. // 파일소유권변경->일반계정에 root권한 부여(vi /etc/passwd->UID와GID변경)
182. // 리눅스에서 cat /etc/passwd
183. // jinpyolee : 1000 sftpuser : 1004
184. // chown 1000 window.txt
185. String p1 = str.split(" ")[1];
186. String p2 = str.split(" ")[2];
187. try {
188. channelSftp.chown(Integer.parseInt(p1), p2);
189. } catch (NumberFormatException e) {
190. e.printStackTrace();
191. } catch (SftpException e) {
192. e.printStackTrace();
193. }
194. } // end chown
195. else if (command.equals("ln") || (command.equals("symlink"))) {
196. // 링크파일 생성(rwxrwxrwx, 리눅스에서 하늘색으로 나옴)
197. // ln window.txt win.txt
198. String p1 = str.split(" ")[1];
199. String p2 = str.split(" ")[2];
200. try {
201. channelSftp.symlink(p1, p2);
202. } catch (SftpException e) {
203. e.printStackTrace();
204. }
205. } // end ln
206. else if (command.equals("quit")) {
207. channelSftp.quit();
208. // 반복문 나가서 종료
209. break;
210. } // end quit
211. else {
212. System.out.println("Invalid command.");
213. }
214. } // end while
215. // 연결해제
216. channelSftp.disconnect();
217. // 스캐너자원반납
218. scanner.close();
219. // 시스템종료
220. System.exit(0);
221. }
222. }// end class

 

메인은 ProgramStart.java에 있습니다.

 

FTP로 서버에 접속한 모습

FTP를 이용해 서버(CentOS)에 접속한 모습입니다.

구현된 명령어 사용은 생략하겠습니다.

 

SFTP로 서버에 접속한 모습

SFTP를 이용해 서버에 접속한 모습입니다.

 

연결 순서가 조금 다르긴하나 큰 차이는 없습니다.

 

연결후 CMD창에서와 같이 명령어를 사용하면 됩니다.

출처: https://thefif19wlsvy.tistory.com/5 [FIF's 코딩팩토리]