[JAVA]Apache FTPClient操作“卡死”問題的分析和解決
1 import org.apache.commons.net.ftp.FTP; 2 import org.apache.commons.net.ftp.FTPClient; 3 import org.apache.commons.net.ftp.FTPFile; 4 import org.apache.commons.net.ftp.FTPReply; 5 6 import java.io.BufferedInputStream; 7 import java.io.BufferedOutputStream; 8 import java.io.File; 9import java.io.FileInputStream; 10 import java.io.FileNotFoundException; 11 import java.io.FileOutputStream; 12 import java.io.IOException; 13 import java.io.InputStream; 14 import java.io.OutputStream; 15 import java.net.UnknownHostException; 16 import java.util.ArrayList; 17 import java.util.List;18 19 public class FtpUtil { 20 public static final String ANONYMOUS_LOGIN = "anonymous"; 21 private FTPClient ftp; 22 private boolean is_connected; 23 24 public FtpUtil() { 25 ftp = new FTPClient(); 26 is_connected = false; 27 } 28 29 publicFtpUtil(int defaultTimeoutSecond, int connectTimeoutSecond, int dataTimeoutSecond){ 30 ftp = new FTPClient(); 31 is_connected = false; 32 33 ftp.setDefaultTimeout(defaultTimeoutSecond * 1000); 34 ftp.setConnectTimeout(connectTimeoutSecond * 1000); 35 ftp.setDataTimeout(dataTimeoutSecond * 1000); 36 } 37 38 /** 39 * Connects to FTP server. 40 * 41 * @param host 42 * FTP server address or name 43 * @param port 44 * FTP server port 45 * @param user 46 * user name 47 * @param password 48 * user password 49 * @param isTextMode 50 * text / binary mode switch 51 * @throws IOException 52 * on I/O errors 53 */ 54 public void connect(String host, int port, String user, String password, boolean isTextMode) throws IOException { 55 // Connect to server. 56 try { 57 ftp.connect(host, port); 58 } catch (UnknownHostException ex) { 59 throw new IOException("Can't find FTP server '" + host + "'"); 60 } 61 62 // Check rsponse after connection attempt. 63 int reply = ftp.getReplyCode(); 64 if (!FTPReply.isPositiveCompletion(reply)) { 65 disconnect(); 66 throw new IOException("Can't connect to server '" + host + "'"); 67 } 68 69 if (user == "") { 70 user = ANONYMOUS_LOGIN; 71 } 72 73 // Login. 74 if (!ftp.login(user, password)) { 75 is_connected = false; 76 disconnect(); 77 throw new IOException("Can't login to server '" + host + "'"); 78 } else { 79 is_connected = true; 80 } 81 82 // Set data transfer mode. 83 if (isTextMode) { 84 ftp.setFileType(FTP.ASCII_FILE_TYPE); 85 } else { 86 ftp.setFileType(FTP.BINARY_FILE_TYPE); 87 } 88 } 89 90 /** 91 * Uploads the file to the FTP server. 92 * 93 * @param ftpFileName 94 * server file name (with absolute path) 95 * @param localFile 96 * local file to upload 97 * @throws IOException 98 * on I/O errors 99 */ 100 public void upload(String ftpFileName, File localFile) throws IOException { 101 // File check. 102 if (!localFile.exists()) { 103 throw new IOException("Can't upload '" + localFile.getAbsolutePath() + "'. This file doesn't exist."); 104 } 105 106 // Upload. 107 InputStream in = null; 108 try { 109 110 // Use passive mode to pass firewalls. 111 ftp.enterLocalPassiveMode(); 112 113 in = new BufferedInputStream(new FileInputStream(localFile)); 114 if (!ftp.storeFile(ftpFileName, in)) { 115 throw new IOException("Can't upload file '" + ftpFileName + "' to FTP server. Check FTP permissions and path."); 116 } 117 118 } finally { 119 try { 120 in.close(); 121 } catch (IOException ex) { 122 } 123 } 124 } 125 126 /** 127 * Downloads the file from the FTP server. 128 * 129 * @param ftpFileName 130 * server file name (with absolute path) 131 * @param localFile 132 * local file to download into 133 * @throws IOException 134 * on I/O errors 135 */ 136 public void download(String ftpFileName, File localFile) throws IOException { 137 // Download. 138 OutputStream out = null; 139 try { 140 // Use passive mode to pass firewalls. 141 ftp.enterLocalPassiveMode(); 142 143 // Get file info. 144 FTPFile[] fileInfoArray = ftp.listFiles(ftpFileName); 145 if (fileInfoArray == null) { 146 throw new FileNotFoundException("File " + ftpFileName + " was not found on FTP server."); 147 } 148 149 // Check file size. 150 FTPFile fileInfo = fileInfoArray[0]; 151 long size = fileInfo.getSize(); 152 if (size > Integer.MAX_VALUE) { 153 throw new IOException("File " + ftpFileName + " is too large."); 154 } 155 156 // Download file. 157 out = new BufferedOutputStream(new FileOutputStream(localFile)); 158 if (!ftp.retrieveFile(ftpFileName, out)) { 159 throw new IOException("Error loading file " + ftpFileName + " from FTP server. Check FTP permissions and path."); 160 } 161 162 out.flush(); 163 } finally { 164 if (out != null) { 165 try { 166 out.close(); 167 } catch (IOException ex) { 168 } 169 } 170 } 171 } 172 173 /** 174 * Removes the file from the FTP server. 175 * 176 * @param ftpFileName 177 * server file name (with absolute path) 178 * @throws IOException 179 * on I/O errors 180 */ 181 public void remove(String ftpFileName) throws IOException { 182 if (!ftp.deleteFile(ftpFileName)) { 183 throw new IOException("Can't remove file '" + ftpFileName + "' from FTP server."); 184 } 185 } 186 187 /** 188 * Lists the files in the given FTP directory. 189 * 190 * @param filePath 191 * absolute path on the server 192 * @return files relative names list 193 * @throws IOException 194 * on I/O errors 195 */ 196 public List<String> list(String filePath) throws IOException { 197 List<String> fileList = new ArrayList<String>(); 198 199 // Use passive mode to pass firewalls. 200 ftp.enterLocalPassiveMode(); 201 202 FTPFile[] ftpFiles = ftp.listFiles(filePath); 203 int size = (ftpFiles == null) ? 0 : ftpFiles.length; 204 for (int i = 0; i < size; i++) { 205 FTPFile ftpFile = ftpFiles[i]; 206 if (ftpFile.isFile()) { 207 fileList.add(ftpFile.getName()); 208 } 209 } 210 211 return fileList; 212 } 213 214 /** 215 * Sends an FTP Server site specific command 216 * 217 * @param args 218 * site command arguments 219 * @throws IOException 220 * on I/O errors 221 */ 222 public void sendSiteCommand(String args) throws IOException { 223 if (ftp.isConnected()) { 224 try { 225 ftp.sendSiteCommand(args); 226 } catch (IOException ex) { 227 } 228 } 229 } 230 231 /** 232 * Disconnects from the FTP server 233 * 234 * @throws IOException 235 * on I/O errors 236 */ 237 public void disconnect() throws IOException { 238 239 if (ftp.isConnected()) { 240 try { 241 ftp.logout(); 242 ftp.disconnect(); 243 is_connected = false; 244 } catch (IOException ex) { 245 } 246 } 247 } 248 249 /** 250 * Makes the full name of the file on the FTP server by joining its path and 251 * the local file name. 252 * 253 * @param ftpPath 254 * file path on the server 255 * @param localFile 256 * local file 257 * @return full name of the file on the FTP server 258 */ 259 public String makeFTPFileName(String ftpPath, File localFile) { 260 if (ftpPath == "") { 261 return localFile.getName(); 262 } else { 263 String path = ftpPath.trim(); 264 if (path.charAt(path.length() - 1) != '/') { 265 path = path + "/"; 266 } 267 268 return path + localFile.getName(); 269 } 270 } 271 272 /** 273 * Test coonection to ftp server 274 * 275 * @return true, if connected 276 */ 277 public boolean isConnected() { 278 return is_connected; 279 } 280 281 /** 282 * Get current directory on ftp server 283 * 284 * @return current directory 285 */ 286 public String getWorkingDirectory() { 287 if (!is_connected) { 288 return ""; 289 } 290 291 try { 292 return ftp.printWorkingDirectory(); 293 } catch (IOException e) { 294 } 295 296 return ""; 297 } 298 299 /** 300 * Set working directory on ftp server 301 * 302 * @param dir 303 * new working directory 304 * @return true, if working directory changed 305 */ 306 public boolean setWorkingDirectory(String dir) { 307 if (!is_connected) { 308 return false; 309 } 310 311 try { 312 return ftp.changeWorkingDirectory(dir); 313 } catch (IOException e) { 314 } 315 316 return false; 317 } 318 319 /** 320 * Change working directory on ftp server to parent directory 321 * 322 * @return true, if working directory changed 323 */ 324 public boolean setParentDirectory() { 325 if (!is_connected) { 326 return false; 327 } 328 329 try { 330 return ftp.changeToParentDirectory(); 331 } catch (IOException e) { 332 } 333 334 return false; 335 } 336 337 /** 338 * Get parent directory name on ftp server 339 * 340 * @return parent directory 341 */ 342 public String getParentDirectory() { 343 if (!is_connected) { 344 return ""; 345 } 346 347 String w = getWorkingDirectory(); 348 setParentDirectory(); 349 String p = getWorkingDirectory(); 350 setWorkingDirectory(w); 351 352 return p; 353 } 354 355 /** 356 * Get directory contents on ftp server 357 * 358 * @param filePath 359 * directory 360 * @return list of FTPFileInfo structures 361 * @throws IOException 362 */ 363 public List<FfpFileInfo> listFiles(String filePath) throws IOException { 364 List<FfpFileInfo> fileList = new ArrayList<FfpFileInfo>(); 365 366 // Use passive mode to pass firewalls. 367 ftp.enterLocalPassiveMode(); 368 FTPFile[] ftpFiles = ftp.listFiles(filePath); 369 int size = (ftpFiles == null) ? 0 : ftpFiles.length; 370 for (int i = 0; i < size; i++) { 371 FTPFile ftpFile = ftpFiles[i]; 372 FfpFileInfo fi = new FfpFileInfo(); 373 fi.setName(ftpFile.getName()); 374 fi.setSize(ftpFile.getSize()); 375 fi.setTimestamp(ftpFile.getTimestamp()); 376 fi.setType(ftpFile.isDirectory()); 377 fileList.add(fi); 378 } 379 380 return fileList; 381 } 382 383 /** 384 * Get file from ftp server into given output stream 385 * 386 * @param相關推薦
[JAVA]Apache FTPClient操作“卡死”問題的分析和解決
1 import org.apache.commons.net.ftp.FTP; 2 import org.apache.commons.net.ftp.FTPClient; 3 import org.apache.commons.net.ftp.FTPFile; 4 import org.a
JAVA]Apache FTPClient操作“卡死”問題的分析和解決
最近在和一個第三方的合作中不得已需要使用FTP檔案介面。由於FTP Server由對方提供，而且雙方背後各自的網路環境環境都很不單純等等原因，造成測試環境無法模擬實際情況。測試環境中程式一切正常，但是在部署到生產環境之後發現FTP操作不規律性出現“卡死”現象：程式捕獲不到任何
JAVA下FTPClient操作卡死問題分析解決
最近在做一個FTP資料下載功能，FTP Server由公司另一個專案組提供，本人開發的時候全是基於內網的，FTP Server並非直接使用提供方的，而是本人自己本地搭建的FTP Server，因此無法完全模擬實際情況。測試環境中程式一切正常，但在部署到生產環境的時候
I2C從機掛死分析和解決方法
I2C幾乎是嵌入系統中最為通用序列匯流排，MCU周邊的各種器件只要對速度要求不高都可以使用。優點是相容性好（幾乎所有MCU都有I2C主機控制器，沒有也可以用IO模擬），管腳佔用少，晶片實現簡單。I2C協議雖然簡單，實際使用過程中小毛病還不少。今天先來看一個平日最為常見的問
位元組流與字元流，位元組流和字元流的使用哪個多？ java 讀寫操作大檔案 BufferedReader和RandomAccessFile
一 首先我們要知道 在程式中所有的資料都是以流的方式進行傳輸或儲存的 而流有兩種 位元組流用來處理位元組或二進位制物件 字元流主要用來處理字元或字串，一個字元佔兩個位元組 而上一篇的java 讀寫操作大檔案 BufferedReader和RandomAccessFile Buf
一個JAVA單例模式的典型錯誤應用的分析和解決方法
問題來自論壇，其程式碼如下：[java] view plain copy print?import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; imp
Eclipse中JSP和JavaScript進行Copy卡死，問題解決
在Eclipse中編輯JSP檔案時，對文字字元進行復制和貼上時，很卡，主要原因是Eclipse中增加了一些JSP和Javascript的校驗，將這些校驗去掉基本上就可以了，具體的如下所示： Window -> Preference -> General -&g
對java與.net平臺進行的分析和看法
現在，我們能看到到還只是一個很混亂的局面。而在未來，我們將看到.NET的成熟，以及它和JAVA的融合。JAVA將繼續保持它的特點：跨平臺的伺服器端應用，如WAP伺服器，或者是電信領域的如JAIN(Java API for Intelligent Networks，同時它在嵌入式系統中將繼續保持它的優勢，象智慧
分析和解決JAVA 記憶體洩露的實戰例子
這幾天，一直在為Java的“記憶體洩露”問題糾結。Java應用程式佔用的記憶體在不斷的、有規律的上漲，最終超過了監控閾值。福爾摩 斯不得不出手了！ 分析記憶體洩露的一般步驟 如果發現Java應用程式佔用的記憶體出現了洩露的跡象，那麼我們一般採用下面的步驟分
java查詢資料庫表卡死，解決方法
五一回來上班，像往常一樣開啟電腦啟動eclipse執行專案，一切都很正常…… 言歸正傳，先說說發生的現象，專案啟動一直卡死，設定的tomcat啟動超時時間120，不會是因為這個啟動失敗，環境用了好幾個月一直正常； 後來檢視日誌發
HBase中正則過濾表示式與JAVA正則表示式不一致問題的分析和解決
HBase提供了豐富的查詢過濾功能。 比如說它提供了RegexStringComparator這樣的函式，可以實現按照正則表示式進行過濾。它可以有效地彌補向前綴查詢這樣的機制，從而可以使hbase也
JAVA記憶體洩露分析和解決方案及WINDOWS自帶檢視工具
Java記憶體洩漏是每個Java程式設計師都會遇到的問題,程式在本地執行一切正常,可是佈署到遠端就會出現記憶體無限制的增長,最後系統癱瘓,那麼如何最快最好的檢測程式的穩定性,防止系統崩盤,作者用自已的親身經歷與各位分享解決這些問題的辦法.作為Internet最流行的程式語言之一,Java現正非常流行.我們的網
Handler記憶體洩露的分析和解決辦法以及實現延時執行操作的幾種方法
一.Handler記憶體洩露的分析和解決辦法在進行非同步操作時，我們經常會使用到Handler類。最常見的寫法如下。public class MainActivity extends Activity
Java--Big Number操作（BigInteger類和BigDecimal類）
BigInteger類 java.math.BigInteger 類的使用場景是大整數操作。它提供類似
Java IO流操作彙總： inputStream 和 outputStream
我們在進行Android java 開發的時候，經常會遇到各種IO流操作。IO流操作一般分為兩類：字元流和位元組流。以“Reader”結尾都是字元流，操作的都是字元型的資料；以“Stream”結尾的都是位元組流，操作的都是byte資料。現將各種常見IO流總結如下： 一、位元
MySQL資料庫操作卡死問題
在MySQL資料庫操作的時候難免會遇到卡死的問題， 下面給出一個常用的小技巧： 1、show full processlist; 列出當前的操作process，一般會看到很多waiting的process，說明已經有卡住的proces了，我們要殺死這些proces
Java資料結構----棧(Stack)原始碼分析和個人簡單實現
一、Stack原始碼分析 1.繼承結構 棧是資料結構中一種很重要的資料結構型別，因為棧的後進先出功能是實際的開發中有很多的應用場景。Java API中提供了棧（Stacck)的實現。 Stack類繼承了Vector類，而Vector類繼承了AbstractList抽象
關於android雙屏異顯的一些總結和卡死的一些解決方法
做android專案，接觸到一些雙屏異顯的知識，在這裡做個總結： 1.雙屏異顯 我們知道，這個是雙屏異顯的大概程式碼，基本類似，建立一個MyPresentation類，繼承Presentation，然後利用下面程式碼： mDisplayManager=(DisplayMan
挖礦程序minerd，wnTKYg入侵分析和解決
linux wntkyg minerd 挖礦程序minerd，wnTKYg入侵分析和解決 作者:CYH一．起因：最近登陸一臺redis服務器 發現登陸的時間非常長，而且各種命令敲大顯示出的內容延遲
記錄一次apache服務器啟動報錯和解決方法
受限 png www img oot 端口 使用 rwx 環境 問題描述：在liunx系統上安裝軟件時需要較大的權限，一般用戶是不能隨便安裝的。為了省事，在安裝lamp環境時，整個過程都是以root身份安裝各種軟件的。最後整個環境是安裝成功，但是像apache這樣的服務器如