From 6729c925673fcf41cf12f6f1b59d1489a6031731 Mon Sep 17 00:00:00 2001
From: admin <liwen611>
Date: 星期一, 25 三月 2024 13:32:18 +0800
Subject: [PATCH] 连接ftp代码调整
---
ruoyi-admin/src/main/java/com/ruoyi/utils/FtpUtils.java | 39 ++++++++++++++++++++++-----------------
1 files changed, 22 insertions(+), 17 deletions(-)
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/utils/FtpUtils.java b/ruoyi-admin/src/main/java/com/ruoyi/utils/FtpUtils.java
index 1408a59..6e1becc 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/utils/FtpUtils.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/utils/FtpUtils.java
@@ -24,7 +24,7 @@
private static Logger logger = LoggerFactory.getLogger(FtpUtils.class);
private static final String DEFAULT_CHARSET = "UTF-8";
- private static final int DEFAULT_TIMEOUT = 60 * 1000;
+ private static final int DEFAULT_TIMEOUT = 6000 * 1000;
private static final String DAILY_FILE_PATH = "get";
static FTPClient ftpClient;
private volatile String ftpBasePath;
@@ -130,26 +130,31 @@
logger.info("username---"+username+"--host---"+host+"---port---"+port+"-----password-----"+password);
boolean flag = false;
try {
- ftpClient = new FTPClient();
- // 杩炴帴FTP鏈嶅姟鍣�
- ftpClient.connect(host, port);
- // 鐧婚檰FTP鏈嶅姟鍣�
- boolean login = ftpClient.login(username, password);
- // 涓枃鏀寔
- ftpClient.setControlEncoding(DEFAULT_CHARSET);
- // 璁剧疆鏂囦欢绫诲瀷涓轰簩杩涘埗锛堝鏋滀粠FTP涓嬭浇鎴栦笂浼犵殑鏂囦欢鏄帇缂╂枃浠剁殑鏃跺�欙紝涓嶈繘琛岃璁剧疆鍙兘浼氬鑷磋幏鍙栫殑鍘嬬缉鏂囦欢瑙ｅ帇澶辫触锛�
- ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
- ftpClient.enterLocalPassiveMode();
+ if (ftpClient!=null && !FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
+ ftpClient = new FTPClient();
+ // 杩炴帴FTP鏈嶅姟鍣�
+ ftpClient.connect(host, port);
+ // 鐧婚檰FTP鏈嶅姟鍣�
+ boolean login = ftpClient.login(username, password);
+ // 涓枃鏀寔
+ ftpClient.setControlEncoding(DEFAULT_CHARSET);
+ // 璁剧疆鏂囦欢绫诲瀷涓轰簩杩涘埗锛堝鏋滀粠FTP涓嬭浇鎴栦笂浼犵殑鏂囦欢鏄帇缂╂枃浠剁殑鏃跺�欙紝涓嶈繘琛岃璁剧疆鍙兘浼氬鑷磋幏鍙栫殑鍘嬬缉鏂囦欢瑙ｅ帇澶辫触锛�
+ ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
+ ftpClient.enterLocalPassiveMode();
// if (!ftpClient.login(username, password)) {
// disconnect();
// throw new IOException("涓嶈兘杩炴帴鍒拌鏈嶅姟 :" + host);
// }
- if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
- logger.error("杩炴帴FTP澶辫触锛岀敤鎴峰悕鎴栧瘑鐮侀敊璇��");
- disconnect();
+ if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
+ logger.error("杩炴帴FTP澶辫触锛岀敤鎴峰悕鎴栧瘑鐮侀敊璇��");
+ disconnect();
+ } else {
+ logger.info("FTP杩炴帴鎴愬姛!");
+ flag = true;
+ }
} else {
- logger.info("FTP杩炴帴鎴愬姛!");
+ logger.info("褰撳墠FTP澶勪簬杩炴帴鐘舵��,鏃犵嚎閲嶅杩炴帴!");
flag = true;
}
} catch (Exception e) {
@@ -665,14 +670,14 @@
logger.info("FTP鏂囦欢鍚嶄慨鏀瑰け璐�---------->>>>>鏂囦欢鍚嶏細"+split2[0]);
}
input.close();
- disconnect();
+ //disconnect();
return storeFlag;
}
} catch (Exception e) {
logger.error("FTP鏂囦欢涓婁紶澶辫触锛�", e);
} finally {
- disconnect();
+ //disconnect();
}
return false;
}
--
Gitblit v1.8.0