|
@@ -27,19 +27,24 @@ public class FtpUtil {
|
|
|
* @throws Exception
|
|
|
*/
|
|
|
public static boolean connectFtp(Ftp f) throws Exception {
|
|
|
- ftp = new FTPClient();
|
|
|
boolean flag = false;
|
|
|
- int reply;
|
|
|
- ftp.connect(f.getIpAddr(), f.getPort());
|
|
|
- ftp.login(f.getUserName(), f.getPwd());
|
|
|
- ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
|
|
|
- reply = ftp.getReplyCode();
|
|
|
- if (!FTPReply.isPositiveCompletion(reply)) {
|
|
|
- ftp.disconnect();
|
|
|
- return flag;
|
|
|
+ try {
|
|
|
+ ftp = new FTPClient();
|
|
|
+ ftp.connect(f.getIpAddr(), f.getPort());
|
|
|
+ ftp.login(f.getUserName(), f.getPwd());
|
|
|
+ ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
|
|
|
+ int reply = ftp.getReplyCode();
|
|
|
+ if (!FTPReply.isPositiveCompletion(reply)) {
|
|
|
+ ftp.disconnect();
|
|
|
+ return flag;
|
|
|
+ }
|
|
|
+ ftp.changeWorkingDirectory(f.getPath());
|
|
|
+ flag = true;
|
|
|
+ } catch (Exception e) {
|
|
|
+ flag = false;
|
|
|
+ logger.error(e);
|
|
|
+ logger.error("FTP链接失败");
|
|
|
}
|
|
|
- ftp.changeWorkingDirectory(f.getPath());
|
|
|
- flag = true;
|
|
|
return flag;
|
|
|
}
|
|
|
|
|
@@ -111,8 +116,9 @@ public class FtpUtil {
|
|
|
*/
|
|
|
public static boolean startDown(Ftp f, String localBaseDir, String remoteBaseDir, String filename) throws Exception {
|
|
|
boolean flag = false;
|
|
|
- if (FtpUtil.connectFtp(f)) {
|
|
|
- try {
|
|
|
+ try {
|
|
|
+ if (FtpUtil.connectFtp(f)) {
|
|
|
+
|
|
|
FTPFile[] files = null;
|
|
|
boolean changedir = ftp.changeWorkingDirectory(remoteBaseDir);
|
|
|
if (changedir) {
|
|
@@ -129,15 +135,17 @@ public class FtpUtil {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- } catch (Exception e) {
|
|
|
- logger.error(e);
|
|
|
- logger.error("下载过程中出现异常");
|
|
|
- } finally {
|
|
|
- closeFtp();
|
|
|
+
|
|
|
+ } else {
|
|
|
+ logger.error("链接失败!");
|
|
|
+ flag = false;
|
|
|
}
|
|
|
- } else {
|
|
|
- logger.error("链接失败!");
|
|
|
+ } catch (Exception e) {
|
|
|
flag = false;
|
|
|
+ logger.error(e);
|
|
|
+ logger.error("FTP下载过程中链接失败");
|
|
|
+ } finally {
|
|
|
+ closeFtp();
|
|
|
}
|
|
|
return flag;
|
|
|
}
|
|
@@ -217,9 +225,10 @@ public class FtpUtil {
|
|
|
f.setPath(GlobalData.FTP_VIEW_PATH);
|
|
|
FtpUtil.connectFtp(f);
|
|
|
String path = "D:\\upload\\xkzsq";
|
|
|
- File file = new File(path);
|
|
|
- FtpUtil.upload(file);// 把文件上传在ftp上
|
|
|
- //FtpUtil.startDown(f, "E:\\upload\\jdtx\\", "/jdtx/", "20160718164041.txt");// 下载ftp文件测试
|
|
|
+ File file = new File(path);
|
|
|
+ FtpUtil.upload(file);// 把文件上传在ftp上
|
|
|
+ // FtpUtil.startDown(f, "E:\\upload\\jdtx\\", "/jdtx/",
|
|
|
+ // "20160718164041.txt");// 下载ftp文件测试
|
|
|
System.out.println("ok");
|
|
|
|
|
|
}
|