apache-commons-net Ftp 进行文件、文件夹的上传下载及日志的输出
用到了apache 的 commons-net-3.0.1.jar 和 log4j-1.2.15.jar 这连个jar包
JAVA 代码如下：
1 package com.bjut.edu.cn.ftp;
2
3 import java.io.BufferedInputStream;
4 import java.io.BufferedOutputStream;
5 import java.io.File;
6 import java.io.FileInputStream;
7 import java.io.FileNotFoundException;
8 import java.io.FileOutputStream;
9 import java.io.IOException;
10 import java.util.TimeZone;
11 import org.apache.commons.net.ftp.FTPClient;
12 import org.apache.commons.net.ftp.FTPClientConfig;
13 import org.apache.commons.net.ftp.FTPFile;
14 import org.apache.commons.net.ftp.FTPReply;
15
16 import org.apache.log4j.Logger;
17
18 public class Ftp {
19 private FTPClient ftpClient;
20 private String strIp;
21 private int intPort;
22 private String user;
23 private String password;
24
25 private static Logger logger = Logger.getLogger(Ftp.class.getName());
26
27 /* *
28 * Ftp构造函数
29 */
30 public Ftp(String strIp, int intPort, String user, String Password) {
31 this.strIp = strIp;
32 this.intPort = intPort;
33 this.user = user;
34 this.password = Password;
35 this.ftpClient = new FTPClient();
36 }
37 /**
38 * @return 判断是否登入成功
39 * */
40 public boolean ftpLogin() {
41 boolean isLogin = false;
42 FTPClientConfig ftpClientConfig = new FTPClientConfig();
43 ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());
44 this.ftpClient.setControlEncoding("GBK");
45 this.ftpClient.configure(ftpClientConfig);
46 try {
47 if (this.intPort > 0) {
48 this.ftpClient.connect(this.strIp, this.intPort);
49 } else {
50 this.ftpClient.connect(this.strIp);
51 }
52 // FTP服务器连接回答
53 int reply = this.ftpClient.getReplyCode();
54 if (!FTPReply.isPositiveCompletion(reply)) {
55 this.ftpClient.disconnect();
56 logger.error("登录FTP服务失败！");
57 return isLogin;
58 }
59 this.ftpClient.login(this.user, this.password);
60 // 设置传输协议
61 this.ftpClient.enterLocalPassiveMode();
62 this.ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
63 logger.info("恭喜" + this.user + "成功登陆FTP服务器");
64 isLogin = true;
65 } catch (Exception e) {
66 e.printStackTrace();
67 logger.error(this.user + "登录FTP服务失败！" + e.getMessage());
68 }
69 this.ftpClient.setBufferSize(1024 * 2);
70 this.ftpClient.setDataTimeout(30 * 1000);
71 return isLogin;
72 }
73
74 /**
75 * @退出关闭服务器链接
76 * */
77 public void ftpLogOut() {
78 if (null != this.ftpClient && this.ftpClient.isConnected()) {
79 try {
80 boolean reuslt = this.ftpClient.logout();// 退出FTP服务器
81 if (reuslt) {
82 logger.info("成功退出服务器");
83 }
84 } catch (IOException e) {
85 e.printStackTrace();
86 logger.warn("退出FTP服务器异常！" + e.getMessage());
87 } finally {
88 try {
89 this.ftpClient.disconnect();// 关闭FTP服务器的连接
90 } catch (IOException e) {
91 e.printStackTrace();
92 logger.warn("关闭FTP服务器的连接异常！");
93 }
94 }
95 }
96 }
97
98 /***
99 * 上传Ftp文件
100 * @param localFile 当地文件
101 * @param romotUpLoadePath上传服务器路径 - 应该以/结束
102 * */
103 public boolean uploadFile(File localFile, String romotUpLoadePath) {
104 BufferedInputStream inStream = null;
105 boolean success = false;
106 try {
107 this.ftpClient.changeWorkingDirectory(romotUpLoadePath);// 改变工作路径
108 inStream = new BufferedInputStream(new FileInputStream(localFile));
109 logger.info(localFile.getName() + "开始上传.....");
110 success = this.ftpClient.storeFile(localFile.getName(), inStream);
111 if (success == true) {
112 logger.info(localFile.getName() + "上传成功");
113 return success;
114 }
115 } catch (FileNotFoundException e) {
116 e.printStackTrace();
117 logger.error(localFile + "未找到");
118 } catch (IOException e) {
119 e.printStackTrace();
120 } finally {
121 if (inStream != null) {
122 try {
123 inStream.close();
124 } catch (IOException e) {
125 e.printStackTrace();
126 }
127 }
128 }
129 return success;
130 }
131
132 /***
133 * 下载文件
134 * @param remoteFileName 待下载文件名称
135 * @param localDires 下载到当地那个路径下
136 * @param remoteDownLoadPath remoteFileName所在的路径
137 * */
138
139 public boolean downloadFile(String remoteFileName, String localDires,
140 String remoteDownLoadPath) {
141 String strFilePath = localDires + remoteFileName;
142 BufferedOutputStream outStream = null;
143 boolean success = false;
144 try {
145 this.ftpClient.changeWorkingDirectory(remoteDownLoadPath);
146 outStream = new BufferedOutputStream(new FileOutputStream(
147 strFilePath));
148 logger.info(remoteFileName + "开始下载....");
149 success = this.ftpClient.retrieveFile(remoteFileName, outStream);
150 if (success == true) {
151 logger.info(remoteFileName + "成功下载到" + strFilePath);
152 return success;
153 }
154 } catch (Exception e) {
155 e.printStackTrace();
156 logger.error(remoteFileName + "下载失败");
157 } finally {
158 if (null != outStream) {
159 try {
160 outStream.flush();
161 outStream.close();
162 } catch (IOException e) {
163 e.printStackTrace();
164 }
165 }
166 }
167 if (success == false) {
168 logger.error(remoteFileName + "下载失败!!!");
169 }
170 return success;
171 }
172
173 /***
174 * @上传文件夹
175 * @param localDirectory
176 * 当地文件夹
177 * @param remoteDirectoryPath
178 * Ftp 服务器路径 以目录"/"结束
179 * */
180 public boolean uploadDirectory(String localDirectory,
181 String remoteDirectoryPath) {
182 File src = new File(localDirectory);
183 try {
184 remoteDirectoryPath = remoteDirectoryPath + src.getName() + "/";
185 this.ftpClient.makeDirectory(remoteDirectoryPath);
186 // ftpClient.listDirectories();
187 } catch (IOException e) {
188 e.printStackTrace();
189 logger.info(remoteDirectoryPath + "目录创建失败");
190 }
191 File[] allFile = src.listFiles();
192 for (int currentFile = 0; currentFile < allFile.length; currentFile++) {
193 if (!allFile[currentFile].isDirectory()) {
194 String srcName = allFile[currentFile].getPath().toString();
195 uploadFile(new File(srcName), remoteDirectoryPath);
196 }
197 }
198 for (int currentFile = 0; currentFile < allFile.length; currentFile++) {
199 if (allFile[currentFile].isDirectory()) {
200 // 递归
201 uploadDirectory(allFile[currentFile].getPath().toString(),
202 remoteDirectoryPath);
203 }
204 }
205 return true;
206 }
207
208 /***
209 * @下载文件夹
210 * @param localDirectoryPath本地地址
211 * @param remoteDirectory 远程文件夹
212 * */
213 public boolean downLoadDirectory(String localDirectoryPath,String remoteDirectory) {
214 try {
215 String fileName = new File(remoteDirectory).getName();
216 localDirectoryPath = localDirectoryPath + fileName + "//";
217 new File(localDirectoryPath).mkdirs();
218 FTPFile[] allFile = this.ftpClient.listFiles(remoteDirectory);
219 for (int currentFile = 0; currentFile < allFile.length; currentFile++) {
220 if (!allFile[currentFile].isDirectory()) {
221 downloadFile(allFile[currentFile].getName(),localDirectoryPath, remoteDirectory);
222 }
223 }
224 for (int currentFile = 0; currentFile < allFile.length; currentFile++) {
225 if (allFile[currentFile].isDirectory()) {
226 String strremoteDirectoryPath = remoteDirectory + "/"+ allFile[currentFile].getName();
227 downLoadDirectory(localDirectoryPath,strremoteDirectoryPath);
228 }
229 }
230 } catch (IOException e) {
231 e.printStackTrace();
232 logger.info("下载文件夹失败");
233 return false;
234 }
235 return true;
236 }
237 // FtpClient的Set 和 Get 函数
238 public FTPClient getFtpClient() {
239 return ftpClient;
240 }
241 public void setFtpClient(FTPClient ftpClient) {
242 this.ftpClient = ftpClient;
243 }
244
245 public static void main(String[] args) throws IOException {
246 Ftp ftp=new Ftp("10.3.15.1",21,"ghips","ghipsteam");
247 ftp.ftpLogin();
248 //上传文件夹
249 ftp.uploadDirectory("d://DataProtemp", "/home/data/");
250 //下载文件夹
251 ftp.downLoadDirectory("d://tmp//", "/home/data/DataProtemp");
252 ftp.ftpLogOut();
253 }
254 }